是否可以使用Spring WebSocket在WebSocket上通过STOMP发送二进制数据？

Question

在spring文档之后，我能够通过WebSockets通过STOMP发送和接收JSON。然而，在高速率下性能很差，因此我希望分析二进制消息的使用。

• Spring腹板套筒4.0

我使用带有必要代理中继的SimpMessageTemplate发送消息-请参阅Spring留档

@Controller
public class DemoBinaryController {
   @Autowired
   private SimpMessagingtemplate template

   @Scheduled(fixedDelay = 5000)
   public void demo() throws Exception {
      GenericMessage<byte[]> message = new GenericMessage<byte[]>(new byte[]{65,66,67});
      template.send("/app/binarydemo", message);
   }
}

JavaScript客户端使用stomp接收数据。js使用标准机制。

var subscription = client.subscribe("/app/binarydemo", new function(message) {
   console.log("RX message", typeof message.body, message.body.length);
});

消息以字符串形式接收，控制台输出如下。我在期待一些原始类型，比如ArrayBuffer

RX message string  3
RX message string  3

我意识到STOMP中的T代表文本，然而Spring文档暗示二进制消息至少在普通websocket中是可能的，STOMP规范也指出了这一点

STOMP是基于文本的，但也允许传输二进制消息。

• 调试发送代码，据我所知，它似乎保持为字节[]

更新：我在服务器端做了更多的调试。似乎org.springframework.web.socket.TextMessage总是在org.springframework.web.socket.messaging.StompSubPro colHandler中使用，而不是org.springframework.web.socket.BinaryMessage。我已经为这个SPR-12301提出了一个功能请求

message = MessageBuilder.withPayload(message.getPayload()).setHeaders(headers).build();
byte[] bytes = this.stompEncoder.encode((Message<byte[]>) message);

synchronized(session) {
    session.sendMessage(new TextMessage(new String(bytes, UTF8_CHARSET)));
}

• 这种技术组合是否可能实现这种方法？
• 我错过了关键的一步吗？
• 有谁能给我举一个有效的例子

Answer 1

尝试仅使用ByteArrayMessageConverter配置您的服务器：

@Configuration
@EnableWebSocketMessageBroker
public class MyWebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
   
   @Override
    public boolean configureMessageConverters(List<MessageConverter> messageConverters) {
        messageConverters.add(new ByteArrayMessageConverter());
        return false;
    }

}

更新

啊！我明白了。谢谢：

public TextMessage(byte[] payload) {
    super(new String(payload, UTF_8));
    this.bytes = payload;
}

从STOMP规范的另一侧：

STOMP消息的正文必须是字符串。如果要发送和接收JSON对象。。。

根据ArrayBuffer：

从存量数据获取数组缓冲区

• 从Base64字符串

所以，我认为你没有一个方法，而不是为你提供一些自定义的MessageConverter，它将你的byte[]转换为Base64 String并发送它。

在JavaScript方面，您应该以某种方式将该字符串解码为ArrayBuffer。

Answer 2

似乎是组织。springframework。网状物插座TextMessage始终在组织内使用。springframework。网状物插座消息传递。stompsubtocolhandler而不是org。springframework。网状物插座二进制消息。我已经为SPR-12301提出了一个功能请求，该请求已被接受。

message = MessageBuilder.withPayload(message.getPayload()).setHeaders(headers).build();
byte[] bytes = this.stompEncoder.encode((Message<byte[]>) message);

synchronized(session) {
    session.sendMessage(new TextMessage(new String(bytes, UTF8_CHARSET)));
}

使现代化

• SPR-12301在4.1.2中交付，但只增加了对接收二进制消息的支持
• 提出SPR-12475用于发送二进制消息