使用 Redis 作为全功能消息代理的 Stomp 代理

Question

有没有办法将 redis 连接为全功能的 stompbroker？

根据 redis 文档，我们可以使用 redis 作为消息代理。我们计划使用 redis 作为我们聊天产品的消息代理。 我正在尝试连接到 redis，但它失败了。有没有办法为 stomp 连接 reids 消息代理？

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

  @Override
  public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/chat");
  }

  @Override
  public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.setApplicationDestinationPrefixes("/app");
//    registry.enableSimpleBroker("/topic");
    registry.enableStompBrokerRelay("/topic").setRelayHost("localhost").setRelayPort(6379).setClientLogin("guest").setClientPasscode("guest");
  }
}

当我尝试时，我得到了这个例外。 io.netty.handler.codec.DecoderException: java.lang.IllegalArgumentException: 没有枚举常量 org.springframework.messaging.simp.stomp.StompCommand.-ERR 未知命令CONNECT，参数以：

Answer 1

您需要兼容 STOMP 的消息代理。例如RabbitMQ with stomp pluginSpring 直接将每个 STOMP 命令传递给代理。无法将STOMP command 转换为Redis Pub/Sub 命令。