refactor: 完善websocket测试用例

This commit is contained in:
hxr
2023-09-16 09:24:40 +08:00
parent c6953fd26d
commit 44570d3163
2 changed files with 20 additions and 3 deletions

View File

@@ -1,5 +1,6 @@
package com.youlai.system.controller.demo;
package com.youlai.system.websocket;
import com.youlai.system.websocket.dto.MessageDTO;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.messaging.handler.annotation.DestinationVariable;
@@ -49,8 +50,8 @@ public class WebsocketController {
@MessageMapping("/sendToUser/{username}")
//@SendToUser(value = "/queue/greeting")
public void sendToUser(Principal principal, @DestinationVariable String username, String message) {
log.info("sender:{};receiver:{}", username, principal.getName());
messagingTemplate.convertAndSendToUser(username, "/queue/greeting", "服务端点对点:" + message);
log.info("sender:{};receiver:{}", principal.getName(), username);
messagingTemplate.convertAndSendToUser(username, "/queue/greeting", new MessageDTO(principal.getName(), message));
/// return "Hello, " + message;
}

View File

@@ -0,0 +1,16 @@
package com.youlai.system.websocket.dto;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class MessageDTO {
private String sender;
private String content;
}