ActiveMQ消息主体

- 日理万妓 2022-08-24 04:17 236阅读 0赞

## ActiveMQ消息主体 ##

消息主体

消息主体包含了消息的核心数据。

JMS 定义了5中消息类型： TextMessage、MapMessage、BytesMessage、

StreamMessage和ObjectMessage

选择最合适的消息类型可以使JMS最有效 的处理消息。

*  TextMessage（文本消息）

将数据作为简单字符串存放在主体中(XML就可以作为字符串发)

TextMessage msg = session.createTextMessage();

msg.setText(text);

有些厂商支持一种XML专用的消息格式，带来了便利，但是不是标准的JMS类型，影响

移植性。

只自己定义了两个方法setText(String s)、getText()

*  MapMessage（映射消息）

使用一张映射表来存放其主体内容（参照Jms API）

MapMessage msg = session.createMapMessage();

msg.setString(“CUSTOMER\_NAME”,”John”);

msg.setInt(“CUSTOMER\_AGE”,12);

String s = msg.getString(“CUSTOMER\_NAME”);

int age = msg.getInt(“CUSTOMER\_AGE”);

*  BytesMessage（字节消息）

将字节流存放在消息主体中。适合于下列情况：必须压缩发送的大量数据、需要与现有

消息格式保持一致等（参照Jms API）

byte\[\] data;

BytesMessage msg = session.createBytesMessage();

msg.wirte(data);

byte\[\] msgData = new byte\[256\];

int bytesRead = msg.readBytes(msgData);

*   StreamMessage（流消息）

用于处理原语类型。这里也支持属性字段和MapMessage所支持的数据类型。使用这种

消息格式时，收发双方事先协商好字段的顺序，以保证写读顺序相同（参照Jms API）

StringMessage msg = session.createStreamMessage();

msg.writeString(“John”);

msg.writeInt(12);

String s = msg.readString();

Int age = msg.readInt();

（PS：个人认为有点像socket的信息收发）

*   ObjectMessage（对象消息）

用于往消息中写入可序列化的对象。

消息中可以存放一个对象，如果要存放多个对象，需要建立一个对象集合，然后把这个

集合写入消息。

客户端接收到一个ObjectMessage时，是read-only模式。如果一个客户端试图写

message，将会抛出MessageNotWriteableException。如果调用了clearBody方法，message既可以读又可以写

自己只单独定义了两个方法：getObject()和setObject(Serializable s)

ObjectMessage包含的只是object的一个快照，set之后object的修改对ObjectMessage的body无效 （从两个方法可以看出，这种消息已经强制要你实现java.io. Serializable接口）

Message只读时被set抛出MessageNotWriteableException;

set和get时，如果对象序列化失败抛出MessageFormatException

发表评论取消回复

表情：

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

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

相关阅读

相关 ActiveMQ消息主体

ActiveMQ消息主体消息主体消息主体包含了消息的核心数据。 JMS 定义了5中消息类型： TextMessage、MapMessage、BytesMessag

- 日理万妓/ 2022年08月24日 04:17/ 0 赞/ 237 阅读

相关 ActiveMQ消息策略

ActiveMQ中提供了众多的“策略”(policy),它们可以在broker端为每个通道“定制”消息的管理方式。本文将简单描述主要的几种Policy。一. Dis

素颜马尾好姑娘i/ 2022年06月13日 08:25/ 0 赞/ 345 阅读

相关【ActiveMQ】activemq 三种消息监听器

在[spring][]整合JMS的应用中我们在定义消息监听器的时候一共可以定义三种类型的消息监听器，分别是MessageListener、SessionAwareMessage

墨蓝/ 2022年06月13日 00:14/ 0 赞/ 414 阅读

相关 ActiveMQ的消息过滤器

1、消息过滤器的简介消息选择器的用法 MessageConsumer是一个Session创建的对象，用来从Destination接收消息

电玩女神/ 2022年05月24日 05:37/ 0 赞/ 164 阅读

相关 ActiveMQ消息形式

消息形式有两种类型 Queue 点对点模式一个生产者，和一个消费者一一对应 ![这里写图片描述][70] Topic 发布/订阅者模式一个生产者

ゝ一世哀愁。/ 2022年05月16日 20:36/ 0 赞/ 292 阅读

相关 ActiveMQ 消息中间件

ActiveMQ简单介绍与使用 1 JMS 1.1 背景&JMS概述 1.2JMS术语 1.3JMS术语概念（一）

浅浅的花香味﹌/ 2022年03月18日 01:40/ 0 赞/ 388 阅读

相关 ActiveMQ顺序消费消息+消息分组

简介 Queue中的消息是按照顺序发送给Consumers的。然而，当你有多个Consumer同时从相同的Queue提取消息时，顺序将不能得到保证。因为这些消息时被多个线

淩亂°似流年/ 2022年02月22日 16:48/ 0 赞/ 550 阅读

相关消息响应主体 ResponseData 工具类

> 前言在系统开发的过程中，我们会尝尝遇到数据返回不统一、散、且乱的问题，尤其是前后端分离的情况下，这个问题就更明显了，怎么样来解决这个问题呢，这时就需

柔情只为你懂/ 2022年02月18日 14:51/ 0 赞/ 330 阅读

相关消息队列之ActiveMQ

ActiveMQ 特点 ActiveMQ 是由 Apache 出品的一款开源消息中间件，旨在为应用程序提供高效、可扩展、稳定、安全的企业级消息通信。它的设计目标是提供标

一时失言乱红尘/ 2022年01月31日 20:37/ 0 赞/ 416 阅读

相关消息中间件（ActiveMQ）

原文地址：[手把手教你如何玩转消息中间件（ActiveMQ）][ActiveMQ] 情景引入小白：起床起床起床起床。。。。快起床~ 我：怎么了又，大惊小怪，吓到我

冷不防/ 2022年01月06日 04:37/ 0 赞/ 447 阅读