diff options
| author | fangshunjian <[email protected]> | 2018-11-08 15:38:33 +0800 |
|---|---|---|
| committer | fangshunjian <[email protected]> | 2018-11-08 15:38:33 +0800 |
| commit | ba43f4203d134edc387365c33ac6ba738112e8ad (patch) | |
| tree | 21373514f241b5fb223a0912966e85e3202ff0fa /src | |
| parent | 74c3c0b30356da744a592a332757bea2300d8b6f (diff) | |
1、druid连接池增加 maxwait 配置，默认10s
Diffstat (limited to 'src')
| -rw-r--r-- | src/com/nms/server/common/Constants.java | 9 | ||||
| -rw-r--r-- | src/com/nms/server/thread/file/upload/FileUploadManagerThread.java | 2 | ||||
| -rw-r--r-- | src/com/nms/server/util/DruidPool.java | 1 |
3 files changed, 10 insertions, 2 deletions
diff --git a/src/com/nms/server/common/Constants.java b/src/com/nms/server/common/Constants.java index f084217..d79cf0a 100644 --- a/src/com/nms/server/common/Constants.java +++ b/src/com/nms/server/common/Constants.java @@ -475,6 +475,10 @@ public class Constants { */ public static final boolean FILE_DOWNLOAD_FROM_COMMUNICATE_WEB; + /** + * druid 连接池 获取连接最大等待时间 + */ + public static final Long DRUID_MAXWAIT_MILLIS; static { // InetAddress inetAddress = null; @@ -839,7 +843,10 @@ public class Constants { * 任务 文件 下载 ip 获取方式，true：配置文件中的 web.socket.ip;false:system_table表中的 server_ip */ FILE_DOWNLOAD_FROM_COMMUNICATE_WEB = Config.getBoolan("file.download.from.communicate.web", true); - + /* + * 默认值：10s + */ + DRUID_MAXWAIT_MILLIS = Long.valueOf(Config.getString("druid.maxwait.millis", "10000")); } //文件传输 临时文件命名后缀 diff --git a/src/com/nms/server/thread/file/upload/FileUploadManagerThread.java b/src/com/nms/server/thread/file/upload/FileUploadManagerThread.java index 5d3ffdf..61b494d 100644 --- a/src/com/nms/server/thread/file/upload/FileUploadManagerThread.java +++ b/src/com/nms/server/thread/file/upload/FileUploadManagerThread.java @@ -57,7 +57,7 @@ public class FileUploadManagerThread implements Runnable{ dao = new CommonDao(); service = new UpgradeService(dao); } - hostIp = service.getHostIpByMissionId(mid); + hostIp = Constants.FILE_DOWNLOAD_FROM_COMMUNICATE_WEB ? Constants.WEB_SOCKET_IP : service.getHostIpByMissionId(mid); Common.addMissionIdWebIPMap(mid,hostIp); } }catch (NumberFormatException e) { diff --git a/src/com/nms/server/util/DruidPool.java b/src/com/nms/server/util/DruidPool.java index 5336ff5..416158b 100644 --- a/src/com/nms/server/util/DruidPool.java +++ b/src/com/nms/server/util/DruidPool.java @@ -39,6 +39,7 @@ public class DruidPool { ds.setPassword(Constants.DB_PASSWORD); ds.configFromPropety(properties); ds.setName("Druid连接池"); + ds.setMaxWait(Constants.DRUID_MAXWAIT_MILLIS);//最大等待时间 ds.init(); logger.debug("Druid初始化连接池成功,"+ds.toString()); } |