| | |
|---|
| | | package org.dromara.common.websocket.listener; |
|---|
| | | |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.dromara.common.websocket.holder.WebSocketSessionHolder; |
|---|
| | | import org.dromara.common.websocket.utils.WebSocketUtils; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.boot.ApplicationArguments; |
|---|
| | | import org.springframework.boot.ApplicationRunner; |
|---|
| | | import org.springframework.core.Ordered; |
|---|
| | |
|---|
| | | @Slf4j |
|---|
| | | public class WebSocketTopicListener implements ApplicationRunner, Ordered { |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 在Spring Boot应用程序启动时初始化WebSocket主题订阅监听器 |
|---|
| | | * |
|---|
| | | * @param args 应用程序参数 |
|---|
| | | * @throws Exception 初始化过程中可能抛出的异常 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void run(ApplicationArguments args) throws Exception { |
|---|
| | | // 订阅WebSocket消息 |
|---|
| | | WebSocketUtils.subscribeMessage((message) -> { |
|---|
| | | log.info("WebSocket主题订阅收到消息session keys={} message={}", message.getSessionKeys(), message.getMessage()); |
|---|
| | | // 如果key不为空就按照key发消息 如果为空就群发 |
|---|
