Netty | 02 - 客户端启动流程以及常用api笔记
发布日期:2022-02-21 17:40:27 浏览次数:14 分类:技术文章

本文共 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 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:计网协议 | TCP(2-流量控制)
下一篇:时间戳工具类,获取今天0时刻和今天23分59分59时刻

发表评论

最新留言

初次前来,多多关照!
[***.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