NettyClient 连接 WebSocket

最近在看webSocket netty socket服务
刚起步 在使用websocket时 思考 如果是 使用其他socketclient连接 非web端 是否能接收到socket的数据 经过搜索 找到了一个大佬的博客 (如果不允许请联系我) 拿来借鉴运行下，保存到自己的博客 方便以后的查看

websocket clien 代码
MockClientHandler
package nettyclientwebsocket;

  import io.netty.channel.Channel;
  import io.netty.channel.ChannelHandlerContext;
  import io.netty.channel.SimpleChannelInboundHandler;
  import io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
  import lombok.extern.slf4j.Slf4j;

  @Slf4j
  public class MockClientHandler extends SimpleChannelInboundHandler<String> {

 
       private final WebSocketClientHandshaker webSocketClientHandshaker;

       public MockClientHandler(WebSocketClientHandshaker webSocketClientHandshaker) {
          this.webSocketClientHandshaker = webSocketClientHandshaker;
  //      this.msgHandleService = SpringContextHolder.getBean(MsgHandleService.class);
      }

      /**
       * 当客户端主动链接服务端的链接后，调用此方法
       *
       * @param channelHandlerContext ChannelHandlerContext
       */
      @Override
      public void channelActive(ChannelHandlerContext channelHandlerContext) {
          log.info("
	⌜⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓
" +
                  "	├ [Mock 建立连接]
" +
                  "	⌞⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓");

          Channel channel = channelHandlerContext.channel();
          // 握手
          webSocketClientHandshaker.handshake(channel);
      }


      @Override
      protected void channelRead0(ChannelHandlerContext channelHandlerContext, String data) {
          log.info("接收到客户端的响应为:{}", data);
          //自定义处理消息
      }

      @Override
      public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
          log.info("
	⌜⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓
" +
                  "	├ [exception]: {}
" +
                  "	⌞⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓⎓", cause.getMessage());
          ctx.close();
      }

      @Override
      public void handlerRemoved(ChannelHandlerContext ctx) {
          System.out.println("与服务器端断开连接");
      }

      @Override
      public void channelReadComplete(ChannelHandlerContext channelHandlerContext) {
          channelHandlerContext.flush();
      }

  }

  
  import io.netty.channel.ChannelInitializer;
  import io.netty.channel.ChannelPipeline;
  import io.netty.channel.socket.SocketChannel;
  import io.netty.handler.codec.http.HttpClientCodec;
  import io.netty.handler.codec.string.StringDecoder;
  import io.netty.handler.codec.string.StringEncoder;
  import io.netty.handler.logging.LogLevel;
  import io.netty.handler.logging.LoggingHandler;

  public class MockClientInitializer extends ChannelInitializer<SocketChannel> {
      private MockClientHandler mockClientHandler;

      MockClientInitializer(MockClientHandler mockClientHandler) {
          this.mockClientHandler = mockClientHandler;
      }

      @Override
      protected void initChannel(SocketChannel channel)  {
          ChannelPipeline pipeline = channel.pipeline();
          // 将请求与应答消息编码或者解码为HTTP消息
          pipeline.addLast(new HttpClientCodec());
          pipeline.addLast(new LoggingHandler(LogLevel.INFO));
          pipeline.addLast("decoder", new StringDecoder());
          pipeline.addLast("encoder", new StringEncoder());
          // 客户端Handler
          pipeline.addLast("handler", mockClientHandler);
      }
  }




import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.http.DefaultHttpHeaders;
import io.netty.handler.codec.http.websocketx.WebSocketClientHandshakerFactory;
import io.netty.handler.codec.http.websocketx.WebSocketVersion;
import lombok.extern.slf4j.Slf4j;

import java.net.URI;
import java.net.URISyntaxException;

/**
 * @description:
 * @author: jcZhang
 * @date: 2020-05-20 16:19
 */
@Slf4j
public class TestNettyClientWebSocket {

    public static void main(String[] args) {
        EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
        try {
            URI uri = new URI("ws://*:*/*?*=*");
            Bootstrap bootstrap = new Bootstrap();
            MockClientHandler webSocketClientHandler = new MockClientHandler(
                    WebSocketClientHandshakerFactory.newHandshaker(uri
                            , WebSocketVersion.V13
                            , null
                            , false
                            , new DefaultHttpHeaders()));
            bootstrap.group(eventLoopGroup).channel(NioSocketChannel.class).
                    handler(new MockClientInitializer(webSocketClientHandler));
            Channel channel = bootstrap.connect(uri.getHost(), uri.getPort()).sync().channel();
            channel.closeFuture().sync();
        } catch (InterruptedException | URISyntaxException e) {
            log.error("socket连接异常:{}",e);
            e.printStackTrace();
        } finally {
            eventLoopGroup.shutdownGracefully();
        }
    }
}

  以上的代码跑过之后发现 与普通的socketclient代码 有很大的不同 websocket 多了一个握手服务  ，以上搜索就这些了。继续 下一步