From 2101288d9ac96f3029c75ec71a810da5f5029819 Mon Sep 17 00:00:00 2001
From: fs-danaus <danaus314@qq.com>
Date: 星期四, 22 十二月 2022 10:35:28 +0800
Subject: [PATCH] 删除DataSourceMessageListener类,功能已移到RefreshDataSourceMessageImpl类
---
/dev/null | 54 ------------------------------------------------------
src/spring-redis.xml | 5 -----
src/com/yc/im/util/RedisSocket.java | 1 -
3 files changed, 0 insertions(+), 60 deletions(-)
diff --git a/src/com/yc/im/util/RedisSocket.java b/src/com/yc/im/util/RedisSocket.java
index 9f74d30..5a49562 100644
--- a/src/com/yc/im/util/RedisSocket.java
+++ b/src/com/yc/im/util/RedisSocket.java
@@ -9,7 +9,6 @@
public class RedisSocket {
public static RedisUtil redisUtil= (RedisUtil) FactoryBean.getBean("redisUtil");//瀛樺彇
protected static String CHANNEL_KEFU="Onbus_WSMQ";//瀹㈡湇娑堟伅棰戦亾鍚嶇О
- public static String CHANNEL_DATASOURCE = "Onbus_DataSource" ; //鏁版嵁婧愰閬撳悕绉�
public static String REDISTKEY_CLIENTLISTS="WS_clientlists";//鐢ㄦ埛闆嗗悎鐨刱ey
protected static String REDISTKEY_GROUPLISTS="WS_grouplists";//缇ょ粍闆嗗悎鐨刱ey
protected static String REDISTKEY_ONLINENUMBER="WS_onlines";//鍦ㄧ嚎浜烘暟key
diff --git a/src/com/yc/multiData/DataSourceMessageListener.java b/src/com/yc/multiData/DataSourceMessageListener.java
deleted file mode 100644
index 7f5a520..0000000
--- a/src/com/yc/multiData/DataSourceMessageListener.java
+++ /dev/null
@@ -1,54 +0,0 @@
-package com.yc.multiData;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.redis.connection.Message;
-import org.springframework.data.redis.connection.MessageListener;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.serializer.RedisSerializer;
-
-import com.google.gson.Gson;
-import com.yc.entity.DataSourceActionEntity;
-import com.yc.factory.FactoryBean;
-
-
-public class DataSourceMessageListener implements MessageListener {
- @Autowired
- private RedisTemplate<String, String> redisTemplate;
-
- @Override
- public void onMessage(Message message, byte[] pattern) {
- try {
- RedisSerializer<?> serializer = redisTemplate.getValueSerializer();
- Object body = serializer.deserialize(message.getBody());
- //String channel = new String(pattern); //鍙栬闃呴閬� 涓婚 channel
- if (body!=null&&!"".equals(body)) {
- Gson gson=new Gson();
- DataSourceActionEntity dataSourceActionEntity= gson.fromJson((String)body,new com.google.gson.reflect.TypeToken<DataSourceActionEntity>() {}.getType());
-
- if (dataSourceActionEntity!=null) {
- MultiDataSource multiDataSource = (MultiDataSource) FactoryBean.getBean("multiDataSource");
- if (DataSourceActionEntity.ActionEnum.REFRESH.getName().equals(dataSourceActionEntity.getAction())) {
- multiDataSource.refreshDataSource(dataSourceActionEntity.getDbId()); //鍒锋柊鏈湴鏁版嵁婧�
- }
- if (DataSourceActionEntity.ActionEnum.DELETE.getName().equals(dataSourceActionEntity.getAction())){
- multiDataSource.removeDataSource(dataSourceActionEntity.getDbId()) ; //鍒犻櫎鏁版嵁婧�
- }
- if (DataSourceActionEntity.ActionEnum.REFRESHEXPIREDDATE.getName().equals(dataSourceActionEntity.getAction())){
- multiDataSource.refreshExpiredDataSource(); //鏇存柊杩囨湡鐨勬暟鎹簮
- }
- }
- }
- }catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- public RedisTemplate<String, String> getRedisTemplate() {
- return redisTemplate;
- }
-
- public void setRedisTemplate(RedisTemplate<String, String> redisTemplate) {
- this.redisTemplate = redisTemplate;
- }
-}
-
diff --git a/src/spring-redis.xml b/src/spring-redis.xml
index 77f9099..dfb0c1b 100644
--- a/src/spring-redis.xml
+++ b/src/spring-redis.xml
@@ -79,9 +79,6 @@
<bean id="listenerForWebSocket" class="com.yc.im.api.messagelistener.WebSocketMessageListener">
<property name="redisTemplate" ref="redisTemplate"/>
</bean>
- <bean id="listenerForDataSource" class="com.yc.multiData.DataSourceMessageListener">
- <property name="redisTemplate" ref="redisTemplate"/>
- </bean>
<bean id="listenerForImageCache" class="com.yc.sdk.shopping.filter.ClearImageCacheMessageListener">
<property name="redisTemplate" ref="redisTemplate"/>
</bean>
@@ -108,11 +105,9 @@
<redis:listener-container >
<!-- the method attribute can be skipped as the default method name is "onMessage" -->
<redis:listener ref="listenerForWebSocket" serializer="jdkSerializer" topic="Onbus_WSMQ" />
- <redis:listener ref="listenerForDataSource" serializer="jdkSerializer" topic="Onbus_DataSource" />
<redis:listener ref="listenerForImageCache" serializer="jdkSerializer" topic="Onbus_ClearImageCache" />
<redis:listener ref="listenerForMessages" serializer="jdkSerializer" topic="Onbus_Messages" />
<redis:listener ref="listenerForQrCodeSession" serializer="jdkSerializer" topic="Onbus_Qrcode" />
-<!-- <redis:listener ref="listenerForQrCodeInvalid" serializer="jdkSerializer" topic="__keyevent@*__:expired"/>-->
<redis:listener ref="listenerForMaintainPay" serializer="jdkSerializer" topic="Onbus_Maintain"/>
</redis:listener-container>
--
Gitblit v1.8.0