2015年06月09日

1、首先学习Netty中几个重要的组建：

EventLoops： EventLoops 的目的是为Channel处理IO操作，一个EventLoop可以为多个Channel服务。

Bootstrap：Bootstrap是一个用于启动NIO（客户端）的辅助启动类。ServerBootstrap这是针对于服务端的，一个Netty应用通常由一个Bootstrap开始，负责配置整个Netty程序，串联起各个组件。

Handler：Handler组件是用来支持各种协议和处理数据的方式，比如连接、数据接收、异常、数据转换等。

Channel：Channel代表了一个Socket链路，或者其他和IO操作相关的组件，他和EventLoop一起用来IO处理。

Future：在Netty中所有的IO操作都是异步的，所以消息不能立刻被正确处理，可以等待这个执行完或者直接注册一个监听，具体通过Future和ChannelFutures注册监听，不管结果怎么样都会返回一个ChannelFuture。

ChannelPipeline：一个Netty应用基于ChannelPipeline机制，这种机制需要依赖于EventLoop和EventLoopGroup,因为他们三个都是和事件处理相关。

2、Netty处理连接请求和业务逻辑

a)、Netty是一个非阻塞的、事件驱动的、网络编程框架，很容易理解Netty会用线程来处理IO事件。

b)、一个Channl会对应一个EventLoop,而一个EventLoop会对应一个线程，就是说一个线程在负责一个Channel的IO操作。

3、如何配置一个Netty应用。

服务端：

// 配置服务端的NIO线程组

EventLoopGroup bossGroup = new NioEventLoopGroup(); // 用于与客户端进行连接

EventLoopGroup workerGroup = new NioEventLoopGroup(); // 用于对IO的读写操作

try {

ServerBootstrap b = new ServerBootstrap();

b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)

.option(ChannelOption.SO_BACKLOG, 1024).childHandler(new ChildChannelHandler());

// 绑定端口，同步等待客户端的连接

ChannelFuture f = b.bind(8080).sync();

// 等待服务端监听端口关闭

f.channel().closeFuture().sync();

} finally {

// 优雅退出，释放线程池资源

bossGroup.shutdownGracefully();

workerGroup.shutdownGracefully();

}

ChannelInitializer，当一个链接建立时，我们需要知道怎么来接收或者发送数据，当然，我们有各种各样的Handler实现来处理它，那么ChannelInitializer便是用来配置这些Handler，它会提供一个ChannelPipeline，并把Handler加入到ChannelPipeline

private class ChildChannelHandler extends ChannelInitializer<SocketChannel> {

@Override

protected void initChannel(SocketChannel sc) throws Exception {

// TimeServerHandler类继承ChannelHandlerAdapter类，用来对数据接收和发送。

sc.pipeline().addLast(new TimeServerHandler());

}

客户端：

// 配置客户端NIO线程组

EventLoopGroup group = new NioEventLoopGroup();

try {

Bootstrap b = new Bootstrap();

b.group(group).channel(NioSocketChannel.class)

.option(ChannelOption.TCP_NODELAY, true)

.handler(new ChannelInitializer<SocketChannel>() {

@Override

public void initChannel(SocketChannel ch)

throws Exception {

ch.pipeline().addLast(new TimeClientHandler());

// TimeClientHandler类继承ChannelHandlerAdapter类，用来对数据接收和发送。

}

});

// 发起异步连接操作

ChannelFuture f = b.connect(127.0.0.1, 8080).sync();

// 当代客户端链路关闭

f.channel().closeFuture().sync();

} finally {

// 优雅退出，释放NIO线程组

group.shutdownGracefully();

}

这是一个简单的实例，希望对你有帮助。

2015年06月09日相关推荐

开源社区Github在2022年06月09日公测了三个新的成就徽章
开源社区Github在2022年06月09日公测了三个新的成就Achievements 徽章今天登录GitHub突然惊喜的发现多了一个可爱的小鲨鱼徽章. 加上之前的三个徽章,现在一共有六个啦- 有两 ...
IntelliJ IDEA 14.0.2破解注册码文件（2015年06月08日）
Java文件代码: import java.math.BigInteger;import java.util.Date;import java.util.Random;import java.util ...
mysql 新建师徒_[深圳|内门弟子]JAVA-谢霆锋|2020年06月09日的日报-技能树.IT修真院...
今天完成的事情 1.mybatis的增删改查下面是实现步骤和测试结果项目目录 1.在pom.xml导入mybatis依赖和log4j 2.配置mybatis-config.xml<?xml ...
始于2015年11月23日，终于2018年08月08日
留念. 2015年11月23日:在一起 2016年01月17日-21日:北京机场,我们❤ 2016年04月16日:去他所在城市--成都 2016年06月04-06日:第一次小旅游--都江堰.青城山 2 ...
获香港证监会颁发牌照的弘量研究，正用智能投顾帮助金融机构降低成本，提升资产管理能力 By 藤子2017年10月09日 17:16 撰文 | 藤子 2015 年，雷春然和黄耀东都是在香港科技大学的
获香港证监会颁发牌照的弘量研究,正用智能投顾帮助金融机构降低成本,提升资产管理能力 By 藤子2017年10月09日 17:16 撰文 | 藤子 2015 年,雷春然和黄耀东都是在香港科技大学的图书馆 ...
WPF学习开发客户端软件-任务助手(下 2015年2月4日代码更新)
时光如梭,距离第一次写的 WPF学习开发客户端软件-任务助手(已上传源码) 已有三个多月,期间我断断续续地对该项目做了优化.完善等等工作,现在重新向大家介绍一下,希望各位可以使用,本软件以实用性为主 ...
空之轨迹手游服务器维护,《空之轨迹》手游06月15日更新公告
亲爱的游击士们: 我们将于06月15日7:00-9:00进行停服维护(开服时间视实际情况可能提前或延后),维护期间将无法登陆游戏,请玩家注意调整自己的游戏时间,给各位带来的不便敬请谅解. 精彩活动限 ...
【06月18日】A股滚动市净率PB历史新低排名
2010年01月01日到 2019年06月18日之间,滚动市净率历史新低排名. 上市三年以上的公司,2019年06月18日市净率在30以下的公司. 来源:A股滚动市净率(PB)历史新低排名. 1 ...
【06月05日】A股滚动市净率PB历史新低排名
2010年01月01日到 2019年06月05日之间,滚动市净率历史新低排名. 上市三年以上的公司,2019年06月05日市净率在30以下的公司. 来源:A股滚动市净率(PB)历史新低排名. 1 ...

2015年06月09日

2015年06月09日相关推荐

最新文章

热门文章