STOMP：调用用@MessageMapping注释的方法不向订阅用户发送消息

发布于 2025-01-10 19:16:02 字数 798 浏览 0 评论 0原文

遵循有关 websockets 的本教程 (https://www.baeldung.com/websockets-spring)这在我的计算机本地工作。

我的问题是，仅当 stompclient 直接与 @MessageMapping 对话时，直接使用端点（/send）调用该方法不会向所有订阅用户发送消息。

    @MessageMapping("/liveoffers")
    @SendTo("/topic/messages")
    public OutputMessage send(final Message message) throws Exception {
        final String time = new SimpleDateFormat("HH:mm").format(new Date());
        return new OutputMessage(message.getFrom(), message.getText(), time);
    }

    @GetMapping(value = "/send")
    @ResponseStatus(HttpStatus.OK)
    public void invokeSend() throws Exception {
        send(new Message("from", "text"));
    }

无论如何，我可以用下面类似的方式调用@MessageMapping，但实际上它可以正常工作吗？

原文

Followed this tutorial regarding websockets (https://www.baeldung.com/websockets-spring) and this works locally on my computer.

My issue is that calling the method directly with an endpoint (/send) does not send a message to all subscribed users, only when stompclient talks to the @MessageMapping directly.

    @MessageMapping("/liveoffers")
    @SendTo("/topic/messages")
    public OutputMessage send(final Message message) throws Exception {
        final String time = new SimpleDateFormat("HH:mm").format(new Date());
        return new OutputMessage(message.getFrom(), message.getText(), time);
    }

    @GetMapping(value = "/send")
    @ResponseStatus(HttpStatus.OK)
    public void invokeSend() throws Exception {
        send(new Message("from", "text"));
    }

Is there anyway I can call the @MessageMapping in a similar way below but actually have it functioning?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

埋葬我深情 2025-01-17 19:16:02

您是否考虑过使用 SimpMessagingTemplate 来发送消息而不是调用映射方法？

@Autowired
SimpMessagingTemplate template;

@GetMapping(value = "/send")
@ResponseStatus(HttpStatus.OK)
public void invokeSend() throws Exception {
    template.convertAndSend("/topic/messages", new Message("from", "text"));
}

Have you considered using SimpMessagingTemplate to send a message instead of calling a mapped method?

@Autowired
SimpMessagingTemplate template;

@GetMapping(value = "/send")
@ResponseStatus(HttpStatus.OK)
public void invokeSend() throws Exception {
    template.convertAndSend("/topic/messages", new Message("from", "text"));
}

回复收藏 0 原文

~没有更多了~