diff --git a/disruptor_nmc/src/main/java/com/rehome/disruptor_nmc/service/ScheduledService.java b/disruptor_nmc/src/main/java/com/rehome/disruptor_nmc/service/ScheduledService.java index fb73885..7bed31d 100644 --- a/disruptor_nmc/src/main/java/com/rehome/disruptor_nmc/service/ScheduledService.java +++ b/disruptor_nmc/src/main/java/com/rehome/disruptor_nmc/service/ScheduledService.java @@ -192,12 +192,12 @@ public class ScheduledService { nowWeather.setCreateDate(now); //用 Disruptor 消息队列 实现特快高并发处理,支撑每秒 600 万订单无压力! - DisruptorMqService disruptorMqService = SpringUtil.getBean(DisruptorMqService.class); - disruptorMqService.pushMessageToMq(nowWeather); +// DisruptorMqService disruptorMqService = SpringUtil.getBean(DisruptorMqService.class); +// disruptorMqService.pushMessageToMq(nowWeather); //直接jpa存储数据到表 -// NmcWeatherService nmcWeatherServiceTemp = SpringUtil.getBean(NmcWeatherService.class); -// nmcWeatherServiceTemp.saveNowWeather(nowWeather); + NmcWeatherService nmcWeatherServiceTemp = SpringUtil.getBean(NmcWeatherService.class); + nmcWeatherServiceTemp.saveNowWeather(nowWeather); log.info("消息队列已发送完毕"); } } catch (Exception e) { diff --git a/disruptor_nmc/src/main/resources/application.yml b/disruptor_nmc/src/main/resources/application.yml index b57e071..0b7ac3f 100644 --- a/disruptor_nmc/src/main/resources/application.yml +++ b/disruptor_nmc/src/main/resources/application.yml @@ -9,7 +9,8 @@ spring: # url: jdbc:mysql://127.0.0.1:3306/head_office_data_center?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true&allowMultiQueries=true # url: jdbc:mysql://localhost:3306/head_office_data_center?useUnicode=true&characterEncoding=utf-8&useSSL=true&nullCatalogMeansCurrent=true&serverTimezone=UTC # url: jdbc:mysql://192.168.2.18:3306/disruptor_nmc?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true - url: jdbc:mysql://192.168.3.7:3306/disruptor_nmc?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true + #url: jdbc:mysql://192.168.3.7:3306/disruptor_nmc?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true + url: jdbc:mysql://127.0.0.1:3306/disruptor_nmc?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true username: root password: Skyinno251, # driverClassName: oracle.jdbc.driver.OracleDriver