使用netty客户端连接websocket服务

1. 引入netty-websocket-client依赖

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-websocket-client</artifactId>
    <version>版本号</version>
</dependency>

2. 创建WebSocketClient

WebSocketClient client = new WebSocketClient();

3. 设置WebSocketClient的参数

client.setUri("ws://localhost:8080/websocket");
client.setHandshake(new ClientHandshakeBuilder()
        .addHeader("Origin", "http://localhost:8080")
        .build());
client.setListener(new WebSocketListener() {
    @Override
    public void onOpen(ServerHandshake handshake) {
        System.out.println("连接成功");
    }

    @Override
    public void onClose(int code, String reason, boolean remote) {
        System.out.println("连接关闭");
    }

    @Override
    public void onMessage(String message) {
        System.out.println("接收到消息：" + message);
    }

    @Override
    public void onError(Exception ex) {
        System.out.println("连接出错：" + ex.getMessage());
    }
});

4. 启动WebSocketClient

client.connect();

5. 发送消息

String message = "Hello, WebSocket!";
client.sendMessage(message);

6. 关闭WebSocketClient

client.close();

完整示例代码：

public class WebSocketClientDemo {
    public static void main(String[] args) {
        WebSocketClient client = new WebSocketClient();
        client.setUri("ws://localhost:8080/websocket");
        client.setHandshake(new ClientHandshakeBuilder()
                .addHeader("Origin", "http://localhost:8080")
                .build());
        client.setListener(new WebSocketListener() {
            @Override
            public void onOpen(ServerHandshake handshake) {
                System.out.println("连接成功");
            }

            @Override
            public void onClose(int code, String reason, boolean remote) {
                System.out.println("连接关闭");
            }

            @Override
            public void onMessage(String message) {
                System.out.println("接收到消息：" + message);
            }

            @Override
            public void onError(Exception ex) {
                System.out.println("连接出错：" + ex.getMessage());
            }
        });
        client.connect();

        String message = "Hello, WebSocket!";
        client.sendMessage(message);

        client.close();
    }
}