From 4582be2ee7fa4e523bbe32bcd369271f8078011b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AF=86=E7=A0=81=E6=BC=8F=E6=B4=9E?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=AE=8C=E6=88=90?= <> Date: Tue, 5 Nov 2024 11:39:01 +0800 Subject: [PATCH] remove disruptor dao --- .../rehome/disruptor_nmc/service/ScheduledService.java | 8 ++++---- disruptor_nmc/src/main/resources/application.yml | 3 ++- 2 files changed, 6 insertions(+), 5 deletions(-) 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