diff --git a/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/Job/ManyJob.java b/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/Job/ManyJob.java index 30a8438..4bd816c 100644 --- a/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/Job/ManyJob.java +++ b/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/Job/ManyJob.java @@ -28,6 +28,7 @@ public class ManyJob { @Autowired private EntinfoServiceImpl entinfoService; + // @Scheduled(cron = "*/10 * * * * *") // 每10分钟执行一次 public void manyJob(){ redisService.deleteObject("entinfo"); diff --git a/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/service/impl/BusinessServiceImpl.java b/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/service/impl/BusinessServiceImpl.java index 552de94..efd1ae3 100644 --- a/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/service/impl/BusinessServiceImpl.java +++ b/zhiLian-business/zhiLian-data-service/src/main/java/com/zhiLian/business/service/impl/BusinessServiceImpl.java @@ -160,6 +160,7 @@ public class BusinessServiceImpl extends ServiceImpl @Autowired private RabbitTemplate rabbitTemplate; + /** * http URL 链接 * @param business @@ -196,12 +197,12 @@ public class BusinessServiceImpl extends ServiceImpl new InputStreamReader(httpConn.getInputStream())); String resultData = br.readLine(); System.out.println("从服务端返回结果: " + resultData); - // 7.关闭HttpURLConnection连接 httpConn.disconnect(); } catch (Exception e) { throw new RuntimeException(e); } + Entinfo build = Entinfo.builder() .entCode("test_" + business.getId()) .ip("192.168.120.128") diff --git a/zhiLian-modules/zhiLian-modules-gen/src/main/java/com/zhiLian/gen/controller/GenController.java b/zhiLian-modules/zhiLian-modules-gen/src/main/java/com/zhiLian/gen/controller/GenController.java index f92c1d5..01f8423 100644 --- a/zhiLian-modules/zhiLian-modules-gen/src/main/java/com/zhiLian/gen/controller/GenController.java +++ b/zhiLian-modules/zhiLian-modules-gen/src/main/java/com/zhiLian/gen/controller/GenController.java @@ -73,7 +73,6 @@ public class GenController extends BaseController { List list = genTableService.selectDbTableList(genTable); return getDataTable(list); } - /** * 查询数据表字段列表 */ diff --git a/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/ManyDataSource.java b/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/ManyDataSource.java index d5e72eb..b2b9a8e 100644 --- a/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/ManyDataSource.java +++ b/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/ManyDataSource.java @@ -67,13 +67,6 @@ public class ManyDataSource { @RabbitListener(queuesToDeclare = {@Queue(name = "zhiLian-vehicle-exchange")}) public void smsConfig(String msg, Message message, Channel channel){ //获取消息的ID -// new Thread(() -> { -// try { -// Thread.sleep(10000); -// } catch (InterruptedException e) { -// throw new RuntimeException(e); -// } -// }).start(); String messageId = message.getMessageProperties().getMessageId(); try { //添加消息id到redis set集合中 添加成功返回1 表示未消费 添加失败返回0 表示已消费 @@ -103,7 +96,6 @@ public class ManyDataSource { private void druidData(String msg) { Entinfo entinfo1 = JSON.parseObject(msg, Entinfo.class); log.info("消息为:{}",entinfo1); - DruidDataSourceFactory druidDataSourceFactory = SpringUtils.getBean(DruidDataSourceFactory.class); DynamicDataSource dynamicDataSource = SpringUtils.getBean(DynamicDataSource.class); DataSourceInfo dataSourceInfo = DataSourceInfo.hostAndPortBuild(entinfo1.getEntCode(), entinfo1.getIp(), entinfo1.getPort()); @@ -123,7 +115,6 @@ public class ManyDataSource { // List entinfos = remoteFileService.listAll(); // databaseNameList.a(entinfos) List entinfo = redisTemplate.opsForList().range("entinfo", 0, -1); - entinfo.forEach(string -> { Entinfo entInfo = JSON.parseObject(string, Entinfo.class); databaseNameList.add(entInfo); diff --git a/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/config/role/DynamicDataSource.java b/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/config/role/DynamicDataSource.java index fc0bce3..f3db0a2 100644 --- a/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/config/role/DynamicDataSource.java +++ b/zhiLian-vehicle/zhiLian-vehicle-service/src/main/java/com/zhiLian/vehicle/datasource/config/role/DynamicDataSource.java @@ -27,6 +27,7 @@ public class DynamicDataSource extends AbstractRoutingDataSource { */ private Map defineTargetDataSources; + /** * 决定当前线程使用哪个数据源 */ @@ -35,6 +36,7 @@ public class DynamicDataSource extends AbstractRoutingDataSource { return DynamicDataSourceHolder.getDynamicDataSourceKey(); } + /** * 添加数据库 * @param key 键