我能够在 spring documentation 之后通过 WebSockets 使用 STOMP 发送和接收 JSON .然而，在高速率下性能很差，所以我想分析一下二进制消息的使用。
- Spring-WebSockets 4.0
- 在 Chrome 35 中运行的 JavaScript 客户端
- stomp.js 1.7.1
发送
我使用带有必要代理中继的 SimpMessageTemplate 发送消息 - 请参阅 spring documentation
@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 文档暗示二进制消息至少可以使用普通 WebSockets，也是 stomp specification州
STOMP is text based but also allows for the transmission of binary messages.
- 正在调试发送代码，据我所知，它似乎仍然是 byte []
- 在接收时调试 stomp.js 库。当底层 ws.onmessage 回调(stomp-1.7.1.js 中的第 243 行)接收到该消息时，该消息似乎是一个字符串
- 大量搜索 - 这似乎是一个信息很少的罕见话题
- 查看 stomp.js 源代码。对二进制文件的唯一引用是 ws.binaryType = "arraybuffer"。
更新:我在服务器端做了更多调试。似乎 org.springframework.web.socket.TextMessage 总是在 org.springframework.web.socket.messaging.StompSubProtocolHandler 中使用而不是 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)));
}
我的问题
- 这种技术组合能否实现这种方法？
- 我是否遗漏了一些关键步骤？
- 谁能给我指出一个工作示例
请您参考如下方法:
似乎 org.springframework.web.socket.TextMessage 总是在 org.springframework.web.socket.messaging.StompSubProtocolHandler 中使用，而不是 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)));
}
更新
