解决重复连接的问题

src/main/java/com/zhiwei/manage/handle/Task.java

@@ -46,7 +46,6 @@ public class Task implements Runnable {
 
 	@Override
 	public void run() {
-		System.out.println("预警部分启动");
 		MessageService messageService = BeanFactory.getBean(MessageService.class);
 		NewsService newsService = BeanFactory.getBean(NewsService.class);
 		// 连通性测试

src/main/java/com/zhiwei/manage/service/TemplateServiceImpl.java

@@ -98,7 +98,6 @@ public class TemplateServiceImpl implements TemplateService {
 				page.setPageCount(count / pageSize);
 			} else
 				page.setPageCount(count / pageSize + 1);
-			System.out.println(page);
 			return page;
 		} catch (Exception e) {
 			log.info("模板查询出错，错误信息{}", e);

src/main/java/com/zhiwei/manage/util/ESUtil.java

@@ -77,8 +77,14 @@ public class ESUtil {
 		Calendar endTime = Calendar.getInstance();
 		endTime.setTime(end);
 		endTime.add(Calendar.HOUR, -8);
+		Client esClient=null;
 		try {
-			Client esClient = new ESClient(ser.getCollection(), ser.getDbHost(), ser.getDbPort()).getClient();
+			if (DbDepot.esClients.get(pt) == null) {
+				esClient = new ESClient(ser.getCollection(), ser.getDbHost(), ser.getDbPort()).getClient();
+				DbDepot.esClients.put(pt, esClient);
+			} else {
+				esClient = (Client) DbDepot.esClients.get(pt);
+			}
 			// 搜索数据
 			SearchRequestBuilder srb = esClient.prepareSearch(Config.getVal(MainThread.map.get(pt) + ".indexName"));
 			BoolQueryBuilder bb = new BoolQueryBuilder();
@@ -137,8 +143,14 @@ public class ESUtil {
 	public static List<Map<String, Object>> getDatasMap(String host, int port, String dbNamel, String collection, int count,
 			String id,String pt) {
 		List<Map<String,Object>> list=new ArrayList<>();
+		Client esClient=null;
 		try {
-			Client esClient = new ESClient(dbNamel, host, port).getClient();
+			if (DbDepot.esClients.get(pt) == null) {
+				esClient = new ESClient(dbNamel, host, port).getClient();
+				DbDepot.esClients.put(pt, esClient);
+			} else {
+				esClient = (Client) DbDepot.esClients.get(pt);
+			}
 			// 搜索数据
 			SearchRequestBuilder srb = esClient.prepareSearch(collection);
 			BoolQueryBuilder bb = new BoolQueryBuilder();