【发布时间】:2015-06-18 06:23:48
【问题描述】:
我正在使用以下 Arduino 函数通过 websocket 通信发送数据:
void WebSocketClient::sendEncodedData(String& str, uint8_t opcode) {
uint8_t mask[4];
int size = str.length()+1;
// Opcode; final fragment
socket_client->write(opcode | WS_FIN);
// NOTE: no support for > 16-bit sized messages
if (size > 125) {
socket_client->write(WS_SIZE16 | WS_MASK);
socket_client->write((uint8_t)(size >> 8));
socket_client->write((uint8_t)(size & 0xFF));
}
else {
socket_client->write((uint8_t)size | WS_MASK);
}
mask[0] = random(0, 256);
mask[1] = random(0, 256);
mask[2] = random(0, 256);
mask[3] = random(0, 256);
socket_client->write(mask[0]);
socket_client->write(mask[1]);
socket_client->write(mask[2]);
socket_client->write(mask[3]);
for (int i = 0; i<size; ++i) {
socket_client->write(str[i] ^ mask[i % 4]);
}
}
这个函数属于这个 Arduino websocket 客户端实现library。
我使用 Tyrus 项目的 java websocket 服务器代码如下:
public static void runServer() {
Server server = new Server("192.168.1.105", 8025, "/websockets", ArduinoEndPoint.class);
try {
server.start();
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
System.out.print("Please press a key to stop the server.");
reader.readLine();
} catch (Exception e) {
throw new RuntimeException(e);
} finally {
server.stop();
}
}
上述代码中的ArduinoEndPoint类代表了@onMessage、@onOpen和@onClose注解方法的简单实现。
我的问题是,当我从 Arduino 发送少于 25 个字符的消息时,它会在服务器上收到,但不会收到所有超过 25 个字符的消息。
Websocket 服务器使用 Tyrus java websocket 客户端实现处理任何消息大小。我在这里缺少什么?
【问题讨论】:
-
您使用的是哪个版本的 Tyrus? (1.10 是最新的稳定版)。这似乎是 grizzly 服务器的问题,因为 Tyrus 会在收到任何消息时触发 @On* 方法。无论如何,我们有很多发送相似消息大小的测试并且都通过了,所以它可能与一些 TCP 相关环境?就像在连接的任一侧缓冲..
标签: java c++ websocket arduino tyrus