在每个 http 请求上向客户端发送 stomp 消息答案

【问题标题】：Sending stomp message to client on every http request在每个 http 请求上向客户端发送 stomp 消息
【发布时间】：2019-06-27 04:02:45
【问题描述】：

我有一个 Spring Boot 服务器和一个客户端，它们使用 STOMP 通过 Websockets 连接。

我的用例是每次向特定端点发出 http 请求时，我都想向客户端发送数据。我发现的所有教程都只显示了客户端向“/hello”发送一些数据而服务器通过向“topic/greetings”发送数据来做出反应的情况：

@MessageMapping("/hello")
@SendTo("/topic/greetings")
public Greeting greeting(HelloMessage message) throws Exception {
    Thread.sleep(1000); // simulated delay
    return new Greeting("Hello, " + HtmlUtils.htmlEscape(message.getName()) + "!");
}

我需要的是一种无需消息映射即可发送数据的控制器方法。每次有人向端点执行获取请求时，它应该只向客户端发送数据。我尝试了以下方法，但没有成功：

@Autowired
private SimpMessagingTemplate msgTemplate;

@SendTo("topic/data-received")
@RequestMapping(value = "/send-data", method = RequestMethod.POST)
public String sendData(@RequestHeader(value = "id") String id,
                               @RequestHeader(value = "data") String data) {

    User user = new User();
    user.id = UUID.fromString(id);
    user.stringData = data;
    database.saveStringData(user);
    msgTemplate.convertAndSend("topic/data-received", "data sent!!");
    return "successful";
}

这是我的客户端代码：

function connect() {
var socket = new SockJS('/clipboard-websocket');
var stompClient = Stomp.over(socket);
stompClient.connect({}, function (frame) {
    console.log('Connected: ' + frame);
    stompClient.subscribe('topic/data-received/', function (message) {
        alert("Data received!!");
    });
}

这就是我的 WebSocket 配置：

@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
    config.enableSimpleBroker("/topic");
    config.setApplicationDestinationPrefixes("/app");
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/clipboard-websocket").withSockJS();
}

【问题讨论】：

标签： java spring spring-boot websocket stomp

【解决方案1】：

目标中缺少尾部斜杠

msgTemplate.convertAndSend("/topic/data-received", "data sent!!");

github-repo-issue-54498776

【讨论】：

非常感谢您的工作！不幸的是，这还没有解决问题。
我在项目的其他地方缺少斜线。现在工作;)