>>分享流行的Java框架以及开源软件,对孙卫琴的《精通Spring:Java Web开发技术详解》提供技术支持 书籍支持  卫琴直播  品书摘要  在线测试  资源下载  联系我们
发表一个新主题 开启一个新投票 回复文章 您是本文章第 14819 个阅读者 刷新本主题
 * 贴子主题:  Marshalling在Netty中的使用 回复文章 点赞(0)  收藏  
作者:mary    发表时间:2021-06-24 03:45:15     消息  查看  搜索  好友  邮件  复制  引用

1. 引入jar包

  <dependency>

<groupId>org.jboss.marshalling</groupId>

<artifactId>jboss-marshalling</artifactId>

<version>1.4.10.Final</version>

</dependency>

<dependency>

<groupId>org.jboss.marshalling</groupId>

<artifactId>jboss-marshalling-serial</artifactId>

<version>1.4.10.Final</version>

</dependency>

2.编写编码解码程序

public final class MarshallingCodeCFactory {

    /**
     * 创建Jboss Marshalling解码器MarshallingDecoder
     * @return MarshallingDecoder
     */

    public static MarshallingDecoder buildMarshallingDecoder() {
        //首先通过Marshalling工具类的精通方法获取Marshalling实例对象 参数serial标识创建的是java序列化工厂对象。
        final MarshallerFactory marshallerFactory = Marshalling.getProvidedMarshallerFactory("serial");
        //创建了MarshallingConfiguration对象,配置了版本号为5
        final MarshallingConfiguration configuration = new MarshallingConfiguration();
        configuration.setVersion(5);
        //根据marshallerFactory和configuration创建provider
        UnmarshallerProvider provider = new DefaultUnmarshallerProvider(marshallerFactory, configuration);
        //构建Netty的MarshallingDecoder对象,俩个参数分别为provider和单个消息序列化后的最大长度
        MarshallingDecoder decoder = new MarshallingDecoder(provider, 1024 * 1024 * 1);
        return decoder;
    }

    /**
     * 创建Jboss Marshalling编码器MarshallingEncoder
     * @return MarshallingEncoder
     */

    public static MarshallingEncoder buildMarshallingEncoder() {
        final MarshallerFactory marshallerFactory = Marshalling.getProvidedMarshallerFactory("serial");
        final MarshallingConfiguration configuration = new MarshallingConfiguration();
        configuration.setVersion(5);
        MarshallerProvider provider = new DefaultMarshallerProvider(marshallerFactory, configuration);
        //构建Netty的MarshallingEncoder对象,MarshallingEncoder用于实现序列化接口的POJO对象序列化为二进制数组
        MarshallingEncoder encoder = new MarshallingEncoder(provider);
        return encoder;
    }

}

3.使用

socketChannel.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingDecoder());

socketChannel.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingEncoder());

4.注意事项

  要传输的对象必须实现原生的序列化
public class RpcRequest  implements Serializable { }

  ----------------------------
原文链接:https://www.jianshu.com/p/ab9fb15800a5

程序猿的技术大观园:www.javathinker.net



[这个贴子最后由 flybird 在 2021-06-24 11:08:27 重新编辑]
  Java面向对象编程-->集合(上)
  JavaWeb开发-->Web运作原理(Ⅰ)
  JSP与Hibernate开发-->数据库事务的概念和声明
  Java网络编程-->对象的序列化与反序列化
  精通Spring-->Vue组件开发高级技术
  Vue3开发-->Vue简介
  MessagePack反序列化使用示例
  Redis为什么单线程能够支持高并发
  SpringCloud服务间内部调用原理
  SpringCloud Feign的分析
  9种设计模式在Spring中的运用,一定要非常熟练!
  Spring MVC的拦截器的详细用法
  Nginx安装及配置
  Spring Cloud 技术栈及架构一览
  3分钟让你明白JSON是什么
  微服务中的Kafka与Micronaut
  nginx详解反向代理、负载均衡、LNMP架构上线动态网站
  深入理解Mybatis一级缓存
  mybatis-plus 注解实现多表关联查询的最佳实践
  Axis、Axis2和CXF比较
  MyBatis解析和运行原理
  更多...
 IPIP: 已设置保密
楼主      
1页 0条记录 当前第1
发表一个新主题 开启一个新投票 回复文章


中文版权所有: JavaThinker技术网站 Copyright 2016-2026 沪ICP备16029593号-2
荟萃Java程序员智慧的结晶,分享交流Java前沿技术。  联系我们
如有技术文章涉及侵权,请与本站管理员联系。