`

Netty权威指南读书笔记(四)

 
阅读更多
netty服务端代码
public class MyServer {
public void bind(int port) {
EventLoopGroup ioGroup = new NioEventLoopGroup(); // 接收客户端发起的向服务端的连接
EventLoopGroup workerGroup = new NioEventLoopGroup();// 接收SocketChannel网络读写
try {
ServerBootStrap b = new ServerBootStrap();
b.group(ioGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.option(ChannelOption.SO_BACKLOG, 1024)
.childHandler(new ChannelInitializer<SocketChannel>() { //初始化的内部类实现
@Override
private void initChannel(SocketChannel sc) throws Exception {
         sc.pipeline().addLast(new LineBasedFrameDecoder(1024));
sc.pipeline().addLast(new StringDecoder());
sc.pipeline().addLast(new ChanelHandlerAdapter() { // 服务端core处理器内部类
@Override
public void channelRead(...){...} // 核心方法,处理读取到的信息
public void channelReadComplete(...){...} // 将通过write方法发送到缓冲数组中的消息写入SocketChannel中,channelRead中的write方法只把消息写入到缓冲数组中
public void exceptionCaught(...){...}
解释:LineBasedFrameDecoder一次遍历ByteBuf中的可读字节,判断是否有\n或者\r\n。如果有就以此位置为结束位置,从刻度索引都结束位置区间的字节就组成了一行。它是以换行符为结束标志的解码器。
它同时支持配置单行的最大长度。如果连续读取到最大长度仍然没有发现换行符,就会抛出TooLongFrameException异常,同时忽略掉之前读到的异常码流(防止由于异常码流缺失分隔符导致的内存溢出)
StringDecoder功能简单,只是将接收到的对象转换成字符串。

netty客户端代码

public class MyClientHandler {
public void connect(int port, String host) {
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
private void initChannel(SocketChannel sc) throws Exception {

sc.pipeline().addLast(new ChanelHandlerAdapter() { // 客户端core处理器内部类
@Override
public void channelRead(...){...} // 核心方法,处理读取到的信息
public void channelActive(...){...} // TCP链路建立成功后,Netty的NIO线程会调用该方法,该方法会调用flush方法,将请求消息发给服务端(和服务端不同,服务端在ChannelReadComplete中会调用flush,将通过write方法发送到缓冲数组中的消息写入SocketChannel中
public void exceptionCaught(...){...}
})

转自:http://blog.csdn.net/xxcupid/article/details/50492204
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics