java Netty 之 Object对象传递
您应该也会想到,我们说过,Netty的消息传递都是基于流,通过ChannelBuffer传递的,那么自然,Object也需要转换成ChannelBuffer来传递。好在Netty本身已经给我们写好了这样的转换工具。ObjectEncoder和ObjectDecoder。
工具怎么用?再一次说说所谓的本质,我们之前也说过,Netty给我们处理自己业务的空间是在灵活的可子定义的Handler上的,也就是说,如果我们自己去做这个转换工作,那么也应该在Handler里去做。而Netty,提供给我们的ObjectEncoder和Decoder也恰恰是一组Handler。
修改Server和Client的启动代码:
// 设置一个处理客户端消息和各种消息事件的类(Handler) bootstrap.setPipelineFactory(new ChannelPipelineFactory() { @Override public ChannelPipeline getPipeline() throws Exception { return Channels.pipeline( new ObjectDecoder(ClassResolvers.cacheDisabled( this.getClass().getClassLoader())), new ObjectServerHandler()); } }); // 设置一个处理服务端消息和各种消息事件的类(Handler) bootstrap.setPipelineFactory(new ChannelPipelineFactory() { @Override public ChannelPipeline getPipeline() throws Exception { return Channels.pipeline( new ObjectEncoder(), new ObjectClientHandler()); } });
要传递对象,自然要有一个被传递模型,一个简单的Pojo,当然,实现序列化接口是必须的。
public class Command implements Serializable { private static final long serialVersionUID = 7590999461767050471L; private String actionName; public String getActionName() { return actionName; } public void setActionName(String actionName) { this.actionName = actionName; } }
服务端和客户端里,我们自定义的Handler实现如下:
public class ObjectServerHandler extends SimpleChannelHandler { @Override public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception { Command command = (Command) e.getMessage(); // 打印看看是不是我们刚才传过来的那个 System.out.println(command.getActionName()); } } /** * 对象传递,客户端代码 */ public class ObjectClientHandler extends SimpleChannelHandler { /** * 当绑定到服务端的时候触发,给服务端发消息。 */ @Override public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) { // 向服务端发送Object信息 sendObject(e.getChannel()); } /** * 发送Object */ private void sendObject(Channel channel) { Command command = new Command(); command.setActionName("Hello action."); channel.write(command); } }
启动后,服务端正常打印结果:Hello action.
简单梳理一下思路:
- 通过Netty传递,都需要基于流,以ChannelBuffer的形式传递。所以,Object -> ChannelBuffer.
- Netty提供了转换工具,需要我们配置到Handler。
- 样例从客户端 -> 服务端,单向发消息,所以在客户端配置了编码,服务端解码。如果双向收发,则需要全部配置Encoder和Decoder。
注意:
注册到Server的Handler是有顺序的,如果你颠倒一下注册顺序:
bootstrap.setPipelineFactory(new ChannelPipelineFactory() { @Override public ChannelPipeline getPipeline() throws Exception { return Channels.pipeline( new ObjectServerHandler(), new ObjectDecoder(ClassResolvers.cacheDisabled(this .getClass().getClassLoader()))); } });
结果就是,会先进入我们自己的业务,再进行解码。这自然是不行的,会强转失败。
如果想自己对Object进行编\解码,可以参考下面:
http://www.it165.net/pro/html/201207/3328.html
相关推荐
经过本人测试通过,少走弯路
java netty权威指南完整版带目录java netty权威指南完整版带目录java netty权威指南完整版带目录java netty权威指南完整版带目录java netty权威指南完整版带目录
通过Netty4 获取串口数据并且下发数据到串口,是一个封装不错的框架
基于 Java Netty实现的可用于内网穿透的代理工具.zip基于 Java Netty实现的可用于内网穿透的代理工具.zip基于 Java Netty实现的可用于内网穿透的代理工具.zip基于 Java Netty实现的可用于内网穿透的代理工具.zip基于...
SCANFISH-II 型声呐系统数据接口协议,对接tcp转发app,json封装
JAVA版基于netty的物联网高并发智能网关 JAVA版基于netty的物联网高并发智能网关 JAVA版基于netty的物联网高并发智能网关 JAVA版基于netty的物联网高并发智能网关 JAVA版基于netty的物联网高并发智能网关 JAVA...
基于tcp通讯,涉及java的netty服务器的推送功能和c++socket的封装以及protobuf在java和c++中的使用。
java netty需要的包。。。。。。。。。。。。java netty需要的包,netty-3.2.10.Final.jar一个就行
java实现基于netty 的utp字节数据接收服务,服务具体实现代码。样例java实现基于netty 的utp字节数据接收服务,服务具体实现代码。样例
JAVA netty完整示例代码。里面包括整个项目和所需的JAR包。示例以:TCP/IP自定义报文协议进行解析分析,基于帧头HEAD_DATA=0x76解析过程的示例代码,并对数据进行粘包分离的处理。粘包处理方式有两种:1.自定义报文...
做Java开发,现在很多场合需要分布式应用,很多通信框架的底层实现都包含Netty技术,为了更好了解,值得有兴趣的人研究一下
NettyDemo Netty使用实例,对象传递调用; LineBasedFrameDecoder + 消息中得换行符;解决TCP 粘包问题; Java序列化方案编解码对比;对象调用方案
实现Java服务端和C#客户端联通 Java使用Netty 开发环境为IDEA C#使用DotNetty 开发环境为VS2017 运行时先开启Java服务端 再开启客户端
java应用netty服务端和客户端示例,客户端和服务端的model对象目录必须一致
高性能的网络服务器,Java 开发学习进阶
在java中,netty通信业务。代码实现
JAVA采用Netty库实现基于以DTU传输的TCP服务器 ,可以支持多端口通讯 ,同时也支持 多协议解析
Java Netty版完全符合JT808部标文档的开发规范。直接可以下载使用,不信拉倒。
java Netty MMO 回合制网络游戏;基于 ioGame 网络编程框架开发的 MMO 类型的回合制网络游戏项目.zip java Netty MMO 回合制网络游戏;基于 ioGame 网络编程框架开发的 MMO 类型的回合制网络游戏项目.zip java Netty...
自开发的远程桌面控制应用,仅出于兴趣爱好,详情请见:https://github.com/Cool-Coding/remote-desktop-control 喜欢的话请点Star持续关注,也欢迎提issues。