perf: 调整发消息测试

dev
huangfeng 8 months ago
parent a4c0d7be24
commit 020fde5202

@ -33,7 +33,7 @@ public class TestController extends BasicController {
@GetMapping("sendMsg") @GetMapping("sendMsg")
@ApiOperation("发送消息") @ApiOperation("发送消息")
public void sendMsg(String msg) { public void sendMsg(String msg, Integer warningId) {
webSocketServer.sendMessage(msg , null); webSocketServer.sendMessage(msg, warningId);
} }
} }

@ -29,7 +29,7 @@ public class WebSocketServer {
log.info("剩余socket连接数" + sessionPools.size()); log.info("剩余socket连接数" + sessionPools.size());
} }
public void sendMessage(String message , Integer warningId) { public void sendMessage(String message, Integer warningId) {
MessageModel msg = new MessageModel(); MessageModel msg = new MessageModel();
msg.setType(1); msg.setType(1);
msg.setContent(message); msg.setContent(message);

Loading…
Cancel
Save