From 1b31589e39045e25a89148ae58d7dfd34fe53847 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: 星期二, 30 七月 2024 09:38:36 +0800
Subject: [PATCH] 修改：会话事件推送处理使用异步
---
ard-work/src/main/java/com/ruoyi/alarm/config/AsyncConfiguration.java | 2 +-
ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java | 3 +++
2 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/alarm/config/AsyncConfiguration.java b/ard-work/src/main/java/com/ruoyi/alarm/config/AsyncConfiguration.java
index 9512bbb..bba963a 100644
--- a/ard-work/src/main/java/com/ruoyi/alarm/config/AsyncConfiguration.java
+++ b/ard-work/src/main/java/com/ruoyi/alarm/config/AsyncConfiguration.java
@@ -18,7 +18,7 @@
* @Version: 1.0
**/
@Configuration
-@EnableAsync(proxyTargetClass = true)
+@EnableAsync
public class AsyncConfiguration {
@Value("${ThreadPoolTask.corePoolSize}")
Integer corePoolSize;
diff --git a/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java b/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java
index 32c5f62..ac2d337 100644
--- a/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java
+++ b/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java
@@ -6,6 +6,7 @@
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import java.util.HashMap;
@@ -25,9 +26,11 @@
@Slf4j
public class MsgListener {
+ @Async
@EventListener(MessageEvent.class)
public void ArdCallHistoryEventListener(MessageEvent messageEvent) {
log.debug("鐩戝惉鍒颁細璇濇秷鎭簨浠�:"+messageEvent.getArdCallHistory().getContent());
+ log.debug("鍦ㄧ嚎鐢ㄦ埛鏁伴噺:"+ONLINE_USER_SESSIONS.size());
String targetId=messageEvent.getTargetId();
ArdCallHistory ardCallHistory = messageEvent.getArdCallHistory();
// 鏋勫缓姝ｅ垯琛ㄨ揪寮忔ā寮�
--
Gitblit v1.9.3