连接过多：Hibernate BoneCP
Posted
技术标签:
【中文标题】连接过多：Hibernate BoneCP【英文标题】：Too many connections: Hibernate BoneCP 【发布时间】：2015-01-29 03:37:31 【问题描述】：背景： 我在我的模型层中使用休眠和我的 sql 来公开 REST 服务。我有一个在后端使用其余服务的移动客户端。该代码当前部署在 AWS 微实例上。
问题： 一旦并发用户数超过 30-40，我就会开始收到“com.mysql.jdbc.exceptions.MySQLNonTransientConnectionException：连接太多”。我了解微型实例上的 mysql 数据库配置为最多具有 30-35 个连接，但是在负载很高的情况下，我希望调用等待而不是出错。变慢一点是可以接受的，但不应该出错。
代码： 这是hibernate cfg文件：
com.jolbox.bonecp.provider.BoneCPConnectionProvider org.hibernate.dialect.MySQL方言 com.mysql.jdbc.Driver
<property name="bonecp.driverClass">com.mysql.jdbc.Driver</property>
<property name="bonecp.jdbcUrl">jdbc:mysql://***.rds.amazonaws.com:3306/jooky</property>
<property name="bonecp.username">**</property>
<property name="bonecp.password">**</property>
<property name="bonecp.maxConnectionAgeInSeconds">30</property>
<property name="bonecp.idleConnectionTestPeriodInMinutes">60</property>
<property name="bonecp.maxConnectionsPerPartition">25</property>
<property name="bonecp.minConnectionsPerPartition">10</property>
<property name="bonecp.partitionCount">1</property>
<property name="bonecp.acquireIncrement">5</property>
<property name="bonecp.statementsCacheSize">50</property>
<property name="acquireRetryDelayInMs">500</property>
<property name="acquireRetryAttempts">200</property>
<mapping class="jooky.model.entity.Party" />
<mapping class="jooky.model.entity.LocationRequest" />
<mapping class="jooky.model.entity.Location" />
<mapping class="jooky.model.entity.UserCheckinHistory" />
<mapping class="jooky.model.entity.Person" />
<mapping class="jooky.model.entity.UserLocSearchHistory"/>
</session-factory>
我必须公开 REST 服务的代码是：
@RequestMapping(value = "/getLocations", method = RequestMethod.POST)
public @ResponseBody
String getLocations(@RequestBody String input)
Gson gson = new GsonBuilder().create();
NearbyLocationsRequest request = gson.fromJson(input,
NearbyLocationsRequest.class);
SessionFactory sessionFactory = new Configuration().configure().buildSessionFactory();
//SessionFactory sessionFactory = ControllerUtil.getSessionFactory();
Session session = sessionFactory.openSession();
session.beginTransaction();
String ret="Error:UNKNOWN_EXCEPTION: Server error.";
List results = null;
try
// NearbyLocationQueryInput inputGson = gson.fromJson(input,
// NearbyLocationQueryInput.class);
if(request.getPersonId()== null )
ret="Error:CANNOT_CONNECT_PER_ID_NULL: Person Id cannot be null";
session.getTransaction().rollback();
session.close();
sessionFactory.close();
return ret;
List users = session
.createCriteria(Person.class)
.add(Restrictions.eq("personId", request.getPersonId()))
.list();
Person person = null;
if (users != null && users.size() > 0)
person = (Person) users.get(0);
if(person.getPoints()==null)
person.setPoints(0);
else
ret="Error:CANNOT_CONNECT_PER_NOT_FOUND: No person found with id:"+request.getPersonId();
session.getTransaction().rollback();
session.close();
sessionFactory.close();
return ret;
double latitude = request.getLatitude();
double longitude = request.getLongitude();
// To search by kilometers instead of miles, replace 3959 with 6371
int distConstant = 6371;
if ("MILES".equals(request.getDistanceUnit()))
distConstant = 3959;
int queryRadius = 100;
if (request.getQueryRadius() != null)
queryRadius = request.getQueryRadius();
int maxResults = 100;
if (request.getMaxResults() != null)
maxResults = request.getMaxResults();
// latitude = input.getLatitude();
// longitude = input.getLongitude();
// Closest within radius of 25 Miles
Query query = session
.createSQLQuery(
" SELECT LOCATION_ID, LOCATION_NAME, LOC_FB_ID, LOC_GOOGLE_ID, LOCATION_EMAIL, FB_PAGE, IMAGE_LOCATION, "
+ " ADDRESS1, ADDRESS2, ADDRESS3, CITY, STATE, COUNTRY, ZIP, PHONE1, PHONE2, "
+ " PLAYLIST_NAME, PLAYER_STATUS, LOCATION_TYPE, CUSINE, LATITUDE, LONGITUDE, OPENING_TIME, CLOSING_TIME, HEARTBEAT_TIME, PLAYLIST_VERSION, "
+ " LOCATION_MESSAGE, WEBSITE, HIGHLIGHTS , "
+ " ( "
+ distConstant
+ " * acos( cos( radians(:bind_lat) ) * cos( radians( latitude ) ) * cos( radians( longitude ) - radians(:bind_long) ) + sin( radians(:bind_lat) ) * sin( radians( latitude ) ) ) ) AS DISTANCE "
+ " FROM location HAVING distance < "
+ queryRadius
+ " "
+ " ORDER BY distance LIMIT " + maxResults)
.addEntity(Location.class);
query.setParameter("bind_long", longitude);
query.setParameter("bind_lat", latitude);
results = query.list();
UserLocSearchHistory history = new UserLocSearchHistory();
history.setId(new UserLocSearchHistoryId(request.getPersonId(), new Date()));
history.setAppVersion(request.getAppVersion());
history.setLatitude(new BigDecimal(latitude));
history.setLongitude(new BigDecimal(longitude));
session.save(history);
NearbyLocationsResponse response = new NearbyLocationsResponse();
response.setUserPoints(person.getPoints());
response.setLocations(results);
session.getTransaction().commit();
session.flush();
session.close();
sessionFactory.close();
ret=gson.toJson(response);
catch (Exception e)
session.getTransaction().rollback();
session.flush();
session.close();
sessionFactory.close();
e.printStackTrace();
return ret;
错误堆栈： HTTP 状态 500 - 请求处理失败；嵌套异常是 org.hibernate.HibernateException：org.hibernate.HibernateException：java.sql.SQLException：无法打开到给定数据库的测试连接。 JDBC url = jdbc:mysql://***.rds.amazonaws.com:3306/jooky，用户名 = jooky。终止连接池。原始异常：------类型异常报告
消息请求处理失败；嵌套异常是 org.hibernate.HibernateException：org.hibernate.HibernateException：java.sql.SQLException：无法打开到给定数据库的测试连接。 JDBC url = jdbc:mysql://****.amazonaws.com:3306/jooky，用户名 = ****。终止连接池。原始异常：------
描述服务器遇到了一个内部错误，导致它无法完成这个请求。
异常
org.springframework.web.util.NestedServletException：请求处理失败；嵌套异常是 org.hibernate.HibernateException：org.hibernate.HibernateException：java.sql.SQLException：无法打开到给定数据库的测试连接。 JDBC url = jdbc:mysql://*****.com:3306/jooky，用户名 = jooky。终止连接池。原始例外： ------
com.mysql.jdbc.exceptions.MySQLNonTransientConnectionException：连接太多
在 com.mysql.jdbc.SQLError.createSQLException(SQLError.java:921)
在 com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:2985)
在 com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:885)
在 com.mysql.jdbc.MysqlIO.secureAuth411(MysqlIO.java:3421)
在 com.mysql.jdbc.MysqlIO.doHandshake(MysqlIO.java:1247)
在 com.mysql.jdbc.Connection.createNewIO(Connection.java:2775)
在 com.mysql.jdbc.Connection.(Connection.java:1555)
在 com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:285)
在 java.sql.DriverManager.getConnection(DriverManager.java:571)
在 java.sql.DriverManager.getConnection(DriverManager.java:215)
在 com.jolbox.bonecp.BoneCP.obtainRawInternalConnection(BoneCP.java:309)
在 com.jolbox.bonecp.BoneCP.(BoneCP.java:346)
在 com.jolbox.bonecp.provider.BoneCPConnectionProvider.createPool(BoneCPConnectionProvider.java:167)
在 com.jolbox.bonecp.provider.BoneCPConnectionProvider.configure(BoneCPConnectionProvider.java:141)
在 com.jolbox.bonecp.provider.BoneCPConnectionProvider.configure(BoneCPConnectionProvider.java:271)
在 org.hibernate.boot.registry.internal.StandardServiceRegistryImpl.configureService(StandardServiceRegistryImpl.java:89)
在 org.hibernate.service.internal.AbstractServiceRegistryImpl.initializeService(AbstractServiceRegistryImpl.java:206)
org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:973)
org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:863)
javax.servlet.http.HttpServlet.service(HttpServlet.java:647)
org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:837)
javax.servlet.http.HttpServlet.service(HttpServlet.java:728)
根本原因 org.hibernate.HibernateException：org.hibernate.HibernateException：java.sql.SQLException：无法打开到给定数据库的测试连接。 JDBC url = jdbc:mysql://aa1hw2wctsxa60n.ckmpnrdgeoee.ap-southeast-1.rds.amazonaws.com:3306/jooky，用户名 = jooky。终止连接池。原始例外： ------
com.mysql.jdbc.exceptions.MySQLNonTransientConnectionException：连接太多
在 com.mysql.jdbc.SQLError.createSQLException(SQLError.java:921)
在 com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:2985)
在 com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:885)
在 com.mysql.jdbc.MysqlIO.secureAuth411(MysqlIO.java:3421)
在 com.mysql.jdbc.MysqlIO.doHandshake(MysqlIO.java:1247)
在 com.mysql.jdbc.Connection.createNewIO(Connection.java:2775)
在 com.mysql.jdbc.Connection.
【问题讨论】：
【参考方案1】：这是由于 mysql 连接限制。要删除此类错误/异常，您需要在 mysql 中增加 max_connection 变量。
【讨论】：
我做不到，我可以拥有的最大连接数限制为 30-35 你有完整的mysql访问权限来修改全局变量吗？ BoneCP 有时会在配置的最大值之上瞬时波动。连接。如果您在使用 HikariCP 时遇到这些问题，我会很好奇。以上是关于连接过多：Hibernate BoneCP的主要内容，如果未能解决你的问题，请参考以下文章
Hibernate - org.hibernate.exception.GenericJDBCException：无法打开连接