我正在使用以下 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 客户端实现库。
我使用 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 客户端实现处理任何消息大小。我在这里缺少什么?