本文共 2279 字，大约阅读时间需要 7 分钟。

对于客户端的启动来说，和服务端的启动类似，依然需要：

1. 线程模型
2. IO 模型
3. 业务处理逻辑

package com.jd.netty.shandianxia.netty;import io.netty.bootstrap.Bootstrap;import io.netty.channel.Channel;import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelOption;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.SocketChannel;import io.netty.channel.socket.nio.NioSocketChannel;import io.netty.handler.codec.string.StringEncoder;import io.netty.util.AttributeKey;import java.util.Date;import java.util.concurrent.TimeUnit;/** * @author ：ChenHao86 * @date ：Created in 2022/2/7 16:33 * @description： * @modified By： * @version: $ */public class NettyClient {

   private static Integer MAX_RETRY = 6;
public static void main(String[] args) {

   NioEventLoopGroup workerGroup = new NioEventLoopGroup();
指定引导类
Bootstrap bootstrap = new Bootstrap();
bootstrap
// 1.指定线程模型
.group(workerGroup)
// 2.指定 IO 类型为 NIO
.channel(NioSocketChannel.class)
// 3.IO 处理逻辑
.handler(new ChannelInitializer
   
    () {

    
   @Override
    
public void initChannel(SocketChannel ch) {

    
   }
    
})
    
// attr() 方法可以给NioSocketChannel绑定自定义属性
    
// 可通过channel.attr()取出这个属性
    
// 说白了就是给NioSocketChannel维护一个 map 而已
    
.attr(AttributeKey.newInstance("clientName"), "nettyClient")
    
// 表示连接的超时时间，超过这个时间还是建立不上的话则代表连接失败
    
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000)
    
// 表示是否开启 TCP 底层心跳机制，true 为开启
    
.option(ChannelOption.SO_KEEPALIVE, true)
    
// 表示是否开始 Nagle 算法，true 表示关闭，false 表示开
    
// 如果要求高实时性，有数据发送时就马上发送，就设置为 true 关闭，如果需要减少发送次数减少网络交互，就设置为 false 开启
    
.option(ChannelOption.TCP_NODELAY, true);
    
// 4.建立连接
    
connect(bootstrap, "juejin.cn", 80, MAX_RETRY);
    
}
    
private static void connect(Bootstrap bootstrap, String host, int port, int retry) {

    
   bootstrap.connect(host, port).addListener(future -> {

    
   if (future.isSuccess()) {

    
   System.out.println("连接成功!");
    
} else if (retry == 0) {

    
   System.err.println("重试次数已用完，放弃连接！");
    
} else {

    
   // 第几次重连
    
int order = (MAX_RETRY - retry) + 1;
    
// 本次重连的间隔
    
int delay = 1 << order;
    
System.err.println(new Date() + ": 连接失败，第" + order + "次重连……");
    
bootstrap.config().group().schedule(() -> connect(bootstrap, host, port, retry - 1), delay, TimeUnit.SECONDS);
    
}
    
});
    
}}
   

转载地址：https://blog.csdn.net/weixin_40597409/article/details/122903882 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！