Netty的深入浅出--3.基于socket编程实现服务端和客服端

一.服务端:

创建MyService:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 创建服务器管道初始化器MyServerInitialzer.java:

添加编码处理器LengthFieldBasedFrameDecoder(将二进制信息解码成实际携带的信息)

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 关于解码处理器暂时不进行讲解,后面再详细讲解:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 编码器

Netty的深入浅出--3.基于socket编程实现服务端和客服端

Netty的深入浅出--3.基于socket编程实现服务端和客服端

设置解码字符集:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

设置编码字符集:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

添加一个null作为占位符:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 创建自定义处理器MyServerHandler

之前项目里面泛型是HttpObejct,为什么这里是String,因为使用HttpObject收到的是整个传输请求,而String的话是因为我们之前已经通过那么多处理器处理好了,我们现在只需要处理客服端信息就ok了。

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 打印客服端发过来的信息:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

将数据返回给客服端:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

处理异常(打印异常信息以及关闭管道连接):

Netty的深入浅出--3.基于socket编程实现服务端和客服端

在main函数中将加入初始化管道MyServerInitializer (MyServerInitializer 不是单例对象,用的时候就会创建一个)

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 在管道初始化器MyServerInitializer加入自定义处理器

Netty的深入浅出--3.基于socket编程实现服务端和客服端

二. 客服端的:

创建主函数MyClient:

为什么只定义一个循环事件组(EvenLoopGroup):因为客服端这边只需要接收信息就可以了。

为什么使用的是.handler而不是和服务端那样使用.childHandler:因为使用handle默认使用第一个循环事件组(也就是使用eventLoopGroup),而.childHandler使用的是第二个组(workGroup)。在客服端这边只有一个循环事件组,所以使用.handler

Netty的深入浅出--3.基于socket编程实现服务端和客服端

连接服务器:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

关闭循环事件组:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

创建管道管理MyClientInitializer

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 里面的配置和服务端基本上一样

Netty的深入浅出--3.基于socket编程实现服务端和客服端

创建处理器MyClientHandler

Netty的深入浅出--3.基于socket编程实现服务端和客服端

channelRead0 :是服务端向客户端发送的消息

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 Netty的深入浅出--3.基于socket编程实现服务端和客服端

指定自己的处理器MyClientHandler

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 指定管道初始化器MyClientInitializer

Netty的深入浅出--3.基于socket编程实现服务端和客服端

 运行客服端和服务端

Netty的深入浅出--3.基于socket编程实现服务端和客服端

发现没有任何输出o(* ̄︶ ̄*)o 

原因很简单啊,客服端和服务端彼此都没有发送数据,怎么可能会有任何输出呢。

解决办法:

客服端向服务端发送数据:

Netty的深入浅出--3.基于socket编程实现服务端和客服端

再次启动服务端、客服端(顺序不能颠倒) 

Netty的深入浅出--3.基于socket编程实现服务端和客服端

Netty的深入浅出--3.基于socket编程实现服务端和客服端