ActiveMQ消息類型

ActiveMQ在處理消息的時候，不能直接進行消息的傳遞，必須將消息封裝為對應的類型，才可以傳輸。

TextMessage文本消息(常用)

攜帶一個java.lang.String作為有效數據(負載)的消息，可用于字符串類型的信息交換。

ObjectMessage對象消息

攜帶一個可以序列化的Java對象作為有效負載的消息，可用于Java對象類型的信息交換。

注意：需要在接收方添加受信任的包

案例演示

1.在com.bjpowernode.activemq.model包下創建User類

2.修改QueueSender類中，添加發送對象的代碼

//對象消息類型
User user = new User();
user.setId(100);
user.setName("張三");
user.setAge(18);
Message message = session.createObjectMessage(user);

3.修改QueueReceiver類中，添加對對象消息接收處理的代碼

4.直接運行會報錯

說消息已經處理，但是沒有接收到，可以到指定的網站上查看如何配置

5.查看網站提供的解決方式，在消息消費者端將對象所在的包添加為受信任的

//1 .創建一個連接工廠
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
//添加受信任的包
List trustList = new ArrayList();
trustList.add("com.bjpowernode.activemq.model");
connectionFactory.setTrustedPackages(trustList);

6.接收效果

MapMessage映射消息

攜帶一組鍵值對的數據作為有效負載的消息，其中Key必須為字符串，有效數據值必須是Java原始數據類型(或者它們的包裝類)及String。

案例演示

1.修改QueueSender類中，添加發送映射消息的代碼

//映射消息
MapMessage message = session.createMapMessage();
message.setInt("age",10);
message.setString("school","北京動力節點");

2.修改QueueReceiver類中，添加對映射消息接收處理的代碼

3.運行查看效果

BytesMessage字節消息

攜帶一組原始數據類型的字節流(字節數組)作為有效負載的消息。

注意:發送和接收的順序必須一致。

案例演示

1.修改QueueSender類中，添加發送字節消息的代碼

//字節消息
BytesMessage message = session.createBytesMessage();
message.writeBoolean(true);
message.writeUTF("北京動力節點");//寫字符串方法

2.修改QueueReceiver類中，添加對字節消息接收處理的代碼

3.運行查看效果

StreamMessage流消息

攜帶一個原始數據類型流作為有效負載的消息，它保持了寫入流時的數據類型，寫入什么類型，則讀取也需要是相同的類型。

注意:發送和接收的順序必須一致。

案例演示

1.修改QueueSender類中，添加發送字節消息的代碼

StreamMessage message = session.createStreamMessage();
message.writeLong(1000L);
message.writeString("哈哈");

2.修改QueueReceiver類中，添加對字節消息接收處理的代碼

3.運行查看效果