ActiveMQBytesMessage内容修改

ゝ一纸荒年。 2023-02-13 08:10 33阅读 0赞

### ActiveMQBytesMessage内容修改 ###

*   *  读写分离分析
     *  获得旧内容
     *  写入新内容
     *  结束输入

## 读写分离分析 ##

ActiveMQBytesMessage是activeMQ进行字节传输使用的消息类型，内部维护一个DataInputStream和一个ByteArrayInputStream，使用一个ByteSequence对象保存数据，保存时关闭写操作，根据参数进行压缩，涉及到读写分离，因此编写本篇博客记录。  
1.新创建或者调用clearBody方法后的对象，处于只写模式  
2.处于只写模式下的对象无法读取数据，必须关闭只写模式，进入只读模式才能获取已写内容信息  
3.只有处于只读模式下的对象才能调用getBodyLength方法获得数据长度，在写结束前长度为0  
4.只能对只读对象调用clearBody，会将保存的内容清空，并进入只写模式  
5.只能对只写对象调用reset方法，会将字节流数据flush到字节缓存流，通过字节缓存流获得ByteSequence对象保存数据，并关闭所有的输入流，计算长度信息，之后可以通过getBodyLength方法获得字节数据长度

## 获得旧内容 ##

当一个BytesMessage完成字节流的编写后进入只读模式，先获得旧数据

byte[] bytes = new byte[(int) bytesMessage.getBodyLength()];
    	 bytesMessage.readBytes(bytes);

## 写入新内容 ##

获得旧数据后，既可以进行业务操作计算新的数据，然后需要调用clearBody清空旧内容进入可写模式，再写入新数据

bytesMessage.clearBody();
    .....//业务计算
    bytesMessage.writeBytes(newBytes)

## 结束输入 ##

写入后一定要调用reset关闭输入，进入只读模式，然后才会flush掉io管道中的所有数据并保存进入ByteSequence对象，如果没有调用关闭输入的消息直接生产到broker上，可能导致消费消息时出现下列bug：  
1.getBodyLength方法返回值为0  
2.ByteSequence内容丢失

bytesMessage.reset()

更多文章，请搜索公众号歪歪梯Club  
![更多资料，请搜索公众号歪歪梯Club][Club]

[Club]: https://img-blog.csdnimg.cn/20200521183346518.jpg

发表评论取消回复

表情：

评论列表（有 0 条评论，33人围观）

还没有评论，来说两句吧...

相关阅读

相关 JavaScript文档内容修改

插入子元素 <h1>这是标题1</h1> <h1>这是标题2</h1> <h1 class="biaoti3">这是标题3</h1> ...

末蓝、/ 2024年04月17日 19:58/ 0 赞/ 118 阅读

相关 ActiveMQBytesMessage内容修改

ActiveMQBytesMessage内容修改读写分离分析获得旧内容写入新内容结束输入读写分离分析

ゝ一纸荒年。/ 2023年02月13日 08:10/ 0 赞/ 34 阅读

相关 linux 修改文件内容命令

Posted on 2019-09-18 17:51 [zhouzhou10201][] 阅读(24860) 评论(0) [编辑][Link 1] 收藏 1、进入文

╰半橙微兮°/ 2022年11月27日 07:11/ 0 赞/ 262 阅读

相关修改删除内容

1. 点击添加弹出对话框点击确定按钮往ul中追加一个li 内容+修改+删除 2. 给ul添加点击事件实现事件委托获取触发源的内容

旧城等待，/ 2022年08月28日 08:57/ 0 赞/ 196 阅读

相关 jclasslib修改class文件内容

出于某些原因需要把别人jar包里面的class修改一下信息配置文件\.properties MANIFEST.MF 这些东西可以直接用记事本打开修改然后替换掉就OK.

骑猪看日落/ 2022年08月27日 03:25/ 0 赞/ 246 阅读

相关 git 创建、提交代码仓库，查看修改内容、撤销修改内容

上一节已经使用命令登陆了git，现在可以创建、提交代码仓库了。 1、创建代码仓库：使用cd进入到要创建代码仓库的目标文件夹，使用git init创建代码仓库； cd

朴灿烈づ我的快乐病毒、/ 2022年08月23日 04:59/ 0 赞/ 240 阅读

相关 JS函数修改html的元素内容，及修改属性内容

修改元素内容： <body> <p id="pid">Hello</p> <button οnclick="demo()">按钮</button>

「爱情、让人受尽委屈。」/ 2022年08月05日 10:27/ 0 赞/ 225 阅读

相关 python修改文件内容

1 替换文件中的一行 1.1 修改原文件 1 要把文件中的一行Server=192.168.22.22中的IP地址替换掉，因此把整行替换。 data =

超、凢脫俗/ 2022年07月14日 17:49/ 0 赞/ 248 阅读

相关 jclasslib修改class文件内容

出于某些原因需要把别人jar包里面的class修改一下信息配置文件\.properties MANIFEST.MF 这些东西可以直接用记事本打开修改然后替换掉就OK.

﹏ヽ暗。殇╰゛Y/ 2022年04月13日 10:12/ 0 赞/ 262 阅读

相关 Vue修改时，撤销修改内容

原文地址：[https://forum.vuejs.org/t/topic/37424][https_forum.vuejs.org_t_topic_37424] ![wa

￡神魔★判官ぃ/ 2021年09月17日 00:26/ 0 赞/ 752 阅读