我需要设置一个websocket服务器，该服务器可以接收客户端发送的音频数据。我为此使用码头。
我的处理程序代码:
{
@OnWebSocketClose
public void onClose(int statusCode, String reason) {
}
@OnWebSocketError
public void onError(Throwable t) {
}
@OnWebSocketConnect
public void onConnect(Session session) {
}
@OnWebSocketMessage
public void onMessage(String message) {
}
@OnWebSocketMessage
public void onMessage(bytes [] b) {
}
@OnWebSocketMessage
public void inputStream(InputStream is) {
}
}
由于音频文件很大，因此客户端正在分块发送音频文件。
现在，对于每个块，都将调用
onMessage(bytes [] b) {}方法。在服务器端，我需要添加这些块并处理音频。我怎样才能做到这一点。
onMessage(bytes [] b) {}和onMessage(InputStream is) {}方法之间还有什么区别。谢谢，
山塔努
最佳答案
根据onMessage javadoc，onMessage(byte[] b)和onMessage(InputStream is)都将收到整个消息:
如果该方法正在处理二进制消息:
因此，如果您使用这些方法之一，Jetty将自动重新组合这些块并将整个消息传递给您的方法(作为
byte[]数组或InputStream)。您可以通过这种方式接收的二进制消息的最大大小是使用setMaxBinaryMessageSize设置的
还要注意，您一次只能在Handler类中定义以下方法之一:
每个websocket端点对于每种本地websocket消息格式(文本，二进制和pong)只能具有一种消息处理方法。
如果要按时处理数据，则应改用以下方法签名:
@OnMessage
public void processUpload(byte[] b, boolean last, Session session) {
// process partial data here, which check on last to see if these is more on the way
}
并手动缓冲数据(在内存或磁盘文件等中)
反过来，客户端应使用sendPartialBytes方法之一来逐块发送数据。
如果您观察到的是客户端为每个数据块调用的“整个消息”方法(即
onMessage(byte[] b)(如客户端发送的那样)，则表明客户端未在使用协议capabilities发送分块消息，而是拆分了输入数据，然后将其部分作为独立的WS消息发送，从而有效地创建了它自己的应用程序级协议，用于以块的形式传输数据。在这种情况下，您必须更新客户端(如果可以的话)，
以使其使用常规WS协议功能，或实现客户端使用的相同“应用程序级协议”。
下面是一个超简单的端点示例，它将缓冲输入数据
直到WS套接字关闭为止(这意味着客户端一旦发送了所有块，便将关闭连接)。
@ServerEndpoint("/data")
public static class Handler {
private ByteArrayOutputStream buffer = new ByteArrayOutputStream();
@OnMessage
public void onMessage(byte[] message) throws IOException {
buffer.write(message);
}
@OnClose
public void onClose(Session session) throws IOException {
System.out.println(
buffer.toByteArray().length
);
}
}
此实现还意味着使用默认的ServerEndpointConfig.Configurator，以便每个连接恰好有一个Endpoint实例(如here所述)。
一个更复杂的实现可能希望重用套接字来发送多个文件，并指定一种机制来表示每次传输的开始和结束(例如，使用特殊格式的消息)，但这完全取决于客户端的实现方式。