test: 尝试使用 @SendToUser 来回复消息

basic-websocket/src/main/java/com/yiring/websocket/web/StompReceiver.java

@@ -17,6 +17,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.messaging.handler.annotation.MessageMapping;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.messaging.simp.annotation.SendToUser;
 import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
 import org.springframework.messaging.simp.user.SimpUser;
 import org.springframework.messaging.simp.user.SimpUserRegistry;
@@ -84,7 +85,8 @@ public class StompReceiver {
     }
 
     @MessageMapping("/ping")
-    public void test(StompHeaderAccessor accessor, String message) {
+    @SendToUser("/topic/reply")
+    public Result<JSONObject> test(String message) {
         log.info("收到来自 STOMP Client `/app/ping` 消息：{}", message);
 
         Set<SimpUser> simpUsers = simpUserRegistry.getUsers();
@@ -97,10 +99,6 @@ public class StompReceiver {
         body.put("message", "pong");
         body.put("time", DateFormatter.DATE_TIME.format(LocalDateTime.now()));
 
-        simpMessagingTemplate.convertAndSendToUser(
-            Objects.requireNonNull(accessor.getSessionId()),
-            "/topic/reply",
-            Result.ok(body)
-        );
+        return Result.ok(body);
     }
 }