java - Stomp 拦截器不工作

标签 java stomp spring-websocket stomp-websocket

我正在使用 Spring WebSockets。它运行良好,但现在我需要在将消息发送到 Web 客户端之前对其进行修改。

因此我创建了以下拦截器:

@Component
public class StompMappingInterceptor extends ChannelInterceptorAdapter {

  @Override
  public Message<?> preSend(Message<?> message, MessageChannel channel) {
        message = MessageBuilder.withPayload(modifyMessage(message))
                .copyHeaders(message.getHeaders())
                .build();
        return message;
    ...
}

modifyMessage()应该使用MappingJackson2MessageConverter,但为了测试,我根本不修改消息:

private Message<?> modifyMessage(Message<?> message) {
    return message;
}

但是,Web 客户端从未收到该消息。

当我将 preSend() 方法更改为:

@Override
public Message<?> preSend(Message<?> message, MessageChannel channel) {
  return message;
}

然后它工作得很好,所以这似乎是我的 preSend() 方法和我创建新消息的方式的问题。我做错了什么?

最佳答案

新消息必须按如下方式创建:

@Override
public Message<?> preSend(Message<?> message, MessageChannel channel) {

    Message<?> newMessage = MessageBuilder.createMessage(modifyMessage(message),
    headerAccessor.getMessageHeaders());
    return message;
    ...
}

不同之处在于,这样,消息 header 不包含以下字段:

  • ID
  • 内容类型
  • 时间戳

由于某种我不知道的原因,这阻止了 Web 客户端接收消息。

关于java - Stomp 拦截器不工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42576096/

相关文章:

java - 如何获取多个选择值

java - 更改 Spring/Stomp/Websocket/Messaging 中的 session ID

rabbitmq - 将 Spring WS Stomp 服务器从 SimpleBroker 迁移到 RabbitMQ StompBrokerRelay

java - Spring Boot 在 WebSocket 上使用 Stomp : Handshake failed due to invalid Upgrade header: null

java - 具有重复的正则表达式排列

java - 解析嵌套在其他 XML 值中的 XML 标记

spring - 单个用户的 Websocket 过滤消息

Java Spring STOMP : Set broker IP

java - 具有相同性能的内循环(易碎)替代方案

activemq - 用于 ActiveMQ 上的 STOMP 的 JMS 队列浏览器的替代方案?