mq中通信对象的设计字段和批量发送时数据封装

  • Z时代
  • 2024-01-10
  • 分类：综合

编程

   MessageBatch
   Message
   MessageDecoder
   
如何设计一个通用的通信体
   private int code;
    private LanguageCode language = LanguageCode.JAVA;
    private int version = 0;
    private int opaque = requestId.getAndIncrement(); 客户请求序号
    private int flag = 0;
    private String remark;
    private HashMap<String, String> extFields; 扩展属性
    private transient CommandCustomHeader customHeader; 每个请求对应得请求头信息
    //序列化方式

    private SerializeType serializeTypeCurrentRPC = serializeTypeConfigInThisServer;

    private transient byte[] body;//消息体
    
    
    将多条消息放在body中，然后收到之后在进行解码 ，这样就保证了message能够兼容多列表消息发送
    
    这里使用了nio的byteBuffer,进行数据转换时字节的解密和加密过程；byteBuffer分为heapByteBuffer和DirectByteBuffer
    

以上是 mq中通信对象的设计字段和批量发送时数据封装 的全部内容， 来源链接： utcz.com/z/516758.html

回到顶部