…1.Netty服务端

服务端代码参考【基于Netty实现安全认证的WebSocketwss服务端-CSDN博客】

2.Netty客户端

客户端代码参考【基于Netty实现WebSocket客户端-CSDN博客】中两种都可以这里用的是第一种。

SslContext

SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build();

...

pipeline.addLast(sslCtx.newHandler(sc.alloc(),

final

URI(wss://127.0.0.1:7070/helloWs);

import

io.netty.channel.ChannelFuture;

import

io.netty.channel.ChannelFutureListener;

import

io.netty.channel.ChannelHandlerContext;

import

io.netty.channel.ChannelInitializer;

import

io.netty.channel.ChannelOption;

import

io.netty.channel.ChannelPipeline;

import

io.netty.channel.EventLoopGroup;

import

io.netty.channel.SimpleChannelInboundHandler;

import

io.netty.channel.nio.NioEventLoopGroup;

import

io.netty.channel.socket.SocketChannel;

import

io.netty.channel.socket.nio.NioSocketChannel;

import

io.netty.handler.codec.http.DefaultHttpHeaders;

import

io.netty.handler.codec.http.HttpClientCodec;

import

io.netty.handler.codec.http.HttpObjectAggregator;

import

io.netty.handler.codec.http.websocketx.TextWebSocketFrame;

import

io.netty.handler.codec.http.websocketx.WebSocketClientHandshakerFactory;

import

io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler;

import

io.netty.handler.codec.http.websocketx.WebSocketVersion;

import

io.netty.handler.logging.LogLevel;

import

io.netty.handler.logging.LoggingHandler;

import

io.netty.handler.ssl.SslContext;

import

io.netty.handler.ssl.SslContextBuilder;

import

io.netty.handler.ssl.util.InsecureTrustManagerFactory;

import

io.netty.handler.stream.ChunkedWriteHandler;

import

lombok.extern.slf4j.Slf4j;import

java.net.URI;

java.util.concurrent.CountDownLatch;/***

https://blog.csdn.net/a1053765496/article/details/130701218*

基于Netty快速实现WebSocket客户端不手动处理握手*/

Slf4j

SimpleWssClient();client.test();}public

void

dest();latch.await();dest.writeAndFlush(new

TextWebSocketFrame(CountDownLatch完成后发送的消息));}public

Channel

URI(wss://127.0.0.1:7070/helloWs);EventLoopGroup

group

SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build();Bootstrap

boot

Bootstrap();boot.option(ChannelOption.SO_KEEPALIVE,

true).option(ChannelOption.TCP_NODELAY,

LoggingHandler(LogLevel.INFO)).channel(NioSocketChannel.class).handler(new

ChannelInitializerSocketChannel()

{Overrideprotected

sc.pipeline();pipeline.addLast(sslCtx.newHandler(sc.alloc(),

webSocketURL.getPort()));pipeline.addLast(new

HttpClientCodec());pipeline.addLast(new

ChunkedWriteHandler());pipeline.addLast(new

WebSocketClientProtocolHandler(WebSocketClientHandshakerFactory.newHandshaker(webSocketURL,

null,

DefaultHttpHeaders())));pipeline.addLast(new

SimpleChannelInboundHandlerTextWebSocketFrame()

{Overrideprotected

channelRead0(ChannelHandlerContext

ctx,

userEventTriggered(ChannelHandlerContext

ctx,

(WebSocketClientProtocolHandler.ClientHandshakeStateEvent.HANDSHAKE_COMPLETE.equals(evt))

{log.info(ctx.channel().id().asShortText()

握手完成);latch.countDown();send(ctx.channel());}super.userEventTriggered(ctx,

boot.connect(webSocketURL.getHost(),

webSocketURL.getPort()).sync();return

cf.channel();}public

TextWebSocketFrame(textMsg);channel.writeAndFlush(frame).addListener((ChannelFutureListener)

channelFuture

{channelFuture.channel().close();log.info(

发送失败.

channelFuture.cause());channelFuture.cause().printStackTrace();}});}

else

参考利用netty开发webScoketClient支持wss协议客户端、服务端心跳实现_websocketclient-CSDN博客