修改：会话事件推送处理使用异步

liusuyi

2024-07-30 1b31589e39045e25a89148ae58d7dfd34fe53847

修改：会话事件推送处理使用异步

 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;

 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();
        // 构建正则表达式模式