tongtong/youlai-boot
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: 完善websocket配置和测试用例

Browse Source
This commit is contained in:
haoxr
2023-09-07 18:42:18 +08:00
parent 09bfa1876d
commit a7a4175a57
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/youlai/system/controller/WebsocketController.java → src/main/java/com/youlai/system/controller/demo/WebsocketController.java
View File

@@ -1,4 +1,4 @@
package com.youlai.system.controller; package com.youlai.system.controller.demo;
import com.youlai.system.common.result.Result; import com.youlai.system.common.result.Result;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
@@ -30,7 +30,7 @@ public class WebsocketController {
*/ */
@PostMapping("/sendToAll") @PostMapping("/sendToAll")
// @SendTo("/topic/all") // 使用SimpMessagingTemplate发送消息给所有订阅了"/topic/all"目标的客户端 // @SendTo("/topic/all") // 使用SimpMessagingTemplate发送消息给所有订阅了"/topic/all"目标的客户端
public Result sendToAll(String message) { public void sendToAll(String message) {
log.info("【广播消息请求接收】消息：{}", message); log.info("【广播消息请求接收】消息：{}", message);
// 处理接收到的消息逻辑 // 处理接收到的消息逻辑
// ... // ...
@@ -41,7 +41,6 @@ public class WebsocketController {
// 使用SimpMessagingTemplate发送消息给所有订阅了"/topic/all"目标的客户端 // 使用SimpMessagingTemplate发送消息给所有订阅了"/topic/all"目标的客户端
messagingTemplate.convertAndSend("/topic/all", content); messagingTemplate.convertAndSend("/topic/all", content);
return Result.success("广播消息发送成功");
} }
/** /**