java websocket 发送字节数组案例

以下是使用 Java WebSocket API 发送字节数组的示例代码：

首先，需要创建一个 WebSocket 客户端类，如下所示：

import java.io.IOException;
import java.net.URI;
import java.nio.ByteBuffer;
import java.util.concurrent.CountDownLatch;
import javax.websocket.ClientEndpoint;
import javax.websocket.CloseReason;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;

@ClientEndpoint
public class MyWebSocketClient {

    private final CountDownLatch latch;
    private Session session;

    public MyWebSocketClient(URI endpointURI) {
        this.latch = new CountDownLatch(1);
        WebSocketContainer container = javax.websocket.ContainerProvider.getWebSocketContainer();
        try {
            container.connectToServer(this, endpointURI);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        latch.countDown();
    }

    @OnMessage
    public void onMessage(String message) {
        // Handle text message
    }

    @OnMessage
    public void onMessage(ByteBuffer message) {
        // Handle binary message
    }

    @OnError
    public void onError(Throwable t) {
        // Handle error
    }

    @OnClose
    public void onClose(CloseReason reason) {
        // Handle close
    }

    public void sendMessage(byte[] data) {
        if (session != null && session.isOpen()) {
            ByteBuffer buffer = ByteBuffer.wrap(data);
            session.getAsyncRemote().sendBinary(buffer);
        }
    }

    public void await() {
        try {
            latch.await();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

然后，可以通过以下代码使用 MyWebSocketClient 类发送字节数组：

MyWebSocketClient client = new MyWebSocketClient(new URI("ws://localhost:8080/websocket"));
client.await();
byte[] data = // byte array to send
client.sendMessage(data);

在 MyWebSocketClient 中，我们实现了 `@OnMessage` 方法来处理二进制消息。我们使用 ByteBuffer 将字节数组包装起来，并使用 `Session.getAsyncRemote().sendBinary()` 方法将其发送到 WebSocket 服务器。

需要注意的是，如果 WebSocket 服务器无法处理二进制消息，将会抛出 `javax.websocket.EncodeException` 异常。在这种情况下，可以尝试使用自定义消息编码器来解决问题。