对于客户端的启动来说,和服务端的启动类似,依然需要:
- 线程模型
- IO 模型
- 业务处理逻辑
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<SocketChannel>() {
@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);
}
});
}
}