
Netty | 02 - 客户端启动流程以及常用api笔记
发布日期:2022-02-21 17:40:27
浏览次数:14
分类:技术文章
本文共 2279 字,大约阅读时间需要 7 分钟。
对于客户端的启动来说,和服务端的启动类似,依然需要:
- 线程模型
- 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() {
@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 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
初次前来,多多关照!
[***.217.46.12]2023年03月11日 02时09分15秒
关于作者

喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
最新文章
三级目录怎么做html,三级目录.html
2019-12-19 12:50:15
html5随鼠标移动动画,使用JS实现气泡跟随鼠标移动的动画效果
2019-12-19 12:50:15
html+table+row+col,html – css位置:粘不使用display:table-row-group
2019-12-19 12:50:15
html文本域实例,Struts2 <s:textarea>文本域实例
2019-12-19 12:50:15
html5制作目录,创建或查看目录 - getDirectory《 HTML5:文件系统 》
2019-12-19 12:50:16
android activity 通信,Android应用开发教程:两个运行的Activity之间的通信
2019-12-19 12:50:13
android 8187驱动 win7,8187无线网卡驱动,教您Realtek瑞昱8187无线网卡驱动
2019-12-19 12:50:13
html背景图渐变自动切换,html – 在背景图像上使用CSS渐变
2019-12-19 12:50:14
android 适配器接口,RecyclerView在适配器里使用接口将实现交给界面或者用户来处理...
2019-12-19 12:50:14
html下拉列表初始状态,HTML选择:如何设置不会在下拉列表中显示的默认文本?...
2019-12-19 12:50:14
txt文档编辑html不显示图片,Layui富文本编辑器内容不显示,图片上传等问题
2019-12-19 12:50:14
html四张图片拼图,js实现html滑动图片拼图验证
2019-12-19 12:50:14
c语言二维数组的动态创建,王鹏-C++ 动态创建二维数组 (简单版)
2019-12-19 12:50:12
链表c语言 读指针,学习C语言指针和链表的体会
2019-12-19 12:50:12
Android 条件断点,Android DownloadManager 的使用及断点续传-Go语言中文社区
2019-12-19 12:50:12
荣耀电视鸿蒙系统安卓,刚刚!继发布或取代安卓的华为鸿蒙系统后,荣耀“电视”也来了...
2019-12-19 12:50:13
android 点击文本框 不调用键盘,Android点击EditText文本框之外任何地方隐藏键盘
2019-12-19 12:50:13
android 设置网络参数,Android网络请求-sign参数的设置方式
2019-12-19 12:50:13
android+最新手机,最新Android手机性能榜单:骁龙845+8G的它只排第三
2019-12-19 12:50:13
linux kafka 环境搭建,centos7搭建kafka集群
2019-12-19 12:50:10