JMS由下面三部分组成:消息头、属性、消息体。其中消息体定义了五种消息体格式，也可以称为消息类型。

　　JMS规范中的消息类型包括TextMessage、MapMessage、ObjectMessage、BytesMessage、和StreamMessage等五种。ActiveMQ也有对应的实现，下面我们结合Spring JMS分别来看一下五种消息类型的收发代码。类结构如下图:

　　下面结合spring研究常见的几种消息类型:

applicationContext.xml如下：

 

1.最常见的  TextMessage

public void sendMessage(final String message) {        jmsTemplate.send(destination, new MessageCreator() {            public Message createMessage(Session session) throws JMSException {                TextMessage textMessage = session.createTextMessage(message);                return textMessage;            }        });        logger.info("send textMesage:{}",message);    }

 查看后台:

 

2.MapMessage发送Map消息

public void sendMessage(final String message) {        jmsTemplate.send(destination, new MessageCreator() {            public Message createMessage(Session session) throws JMSException {                MapMessage mapMessage = session.createMapMessage();                mapMessage.setString("str",message);                mapMessage.setBoolean("boolean",false);                return mapMessage;            }        });    }

查看后台消息:

 

3.ObjectMessage发送序列化对象消息，Object必须实现Serializable接口

public void sendMessage() {        jmsTemplate.send(destination, new MessageCreator() {            public Message createMessage(Session session) throws JMSException {                ObjectMessage objectMessage = session.createObjectMessage();                ArrayList
     
       obj = new ArrayList();                obj.add("123");                obj.add("456");                objectMessage.setObject(obj);                return objectMessage;            }        });    }
     

 查看后台消息:

 

 

4.  bytesMessage 发送字节消息

public void sendMessage() {        jmsTemplate.send(destination, new MessageCreator() {            public Message createMessage(Session session) throws JMSException {                BytesMessage bytesMessage = session.createBytesMessage();                bytesMessage.writeBytes("str".getBytes());                bytesMessage.writeBoolean(false);                return bytesMessage;            }        });    }

后台:

5.StreamMessage　　发送Stream消息

public void sendMessage() {        jmsTemplate.send(destination, new MessageCreator() {            public Message createMessage(Session session) throws JMSException {                StreamMessage streamMessage = session.createStreamMessage();                streamMessage.writeString("str");                streamMessage.writeInt(100);                streamMessage.writeObject("obj");                return streamMessage;            }        });    }

 

消息的接受者:

public void onMessage(Message message) {        try{            System.out.println(message.getClass());            // TextMessage            if (message instanceof TextMessage) {                TextMessage textMessage1 = (TextMessage) message;                System.out.println(textMessage1.getText());            }            // MapMessage            if (message instanceof MapMessage) {                MapMessage mapMessage = (MapMessage) message;                System.out.println(mapMessage.toString());            }            // ObjectMessage            if (message instanceof ObjectMessage) {                ObjectMessage objectMessage = (ObjectMessage) message;                System.out.println(objectMessage.toString());            }            // BytesMessage            if (message instanceof BytesMessage) {                byte[] b = new byte[1024];                int len = -1;                BytesMessage bm = (BytesMessage) message;                while ((len = bm.readBytes(b)) != -1) {                    System.out.println(new String(b, 0, len));                }            }            // StreamMessage            if (message instanceof StreamMessage) {                StreamMessage sm = (StreamMessage) message;                System.out.println(sm.readString());                System.out.println(sm.readInt());            }        }catch (Exception e){        }    }