JMS規(guī)范中五種消息類型

摘要: 本文講述了JMS規(guī)范中五種消息類型，包括TextMessage、BytesMessage、MapMessage、StreamMessage和ObjectMessage

1.前言

        ActiveMQ學(xué)習(xí)筆記(四)——通過ActiveMQ收發(fā)消息http://my.oschina.net/xiaoxishan/blog/380446 和ActiveMQ學(xué)習(xí)筆記(五)——使用Spring JMS收發(fā)消息http://my.oschina.net/xiaoxishan/blog/381209   中，發(fā)送和接受的消息類型都是TextMessage，即文本消息（如下面的代碼所示）。顯然消息類型只有文本類型是不能滿足要求的。

//發(fā)送文本消息

 session.createTextMessage(msg);

 //接受文本消息

 public void onMessage(Message msg) {

    TextMessage message = (TextMessage) msg;

      ……

 }

   根據(jù)Message接口的方法，可以獲取消息類型

String msgType = getJMSType()

    根據(jù) JSR 914: JavaTM Message Service (JMS) API ，JMS規(guī)范中的消息類型包括TextMessage、BytesMessage、MapMessage、StreamMessage和ObjectMessage等五種。ActiveMQ也有對(duì)應(yīng)的實(shí)現(xiàn)，下面我們結(jié)合Spring JMS分別來看一下五種消息類型的收發(fā)代碼。

2. 消息發(fā)送示例代碼

  /**

   * 向默認(rèn)隊(duì)列發(fā)送text消息

   */

  public void sendMessage(final String msg) {

    String destination = jmsTemplate.getDefaultDestination().toString();

    System.out.println("ProducerService向隊(duì)列" + destination + "發(fā)送了消息：\t" + msg);

    jmsTemplate.send(new MessageCreator() {

      public Message createMessage(Session session) throws JMSException {

        return session.createTextMessage(msg);

      }

    });

  }

  /**

   * 向默認(rèn)隊(duì)列發(fā)送map消息

   */

  public void sendMapMessage() {

    jmsTemplate.send(new MessageCreator() {

      public Message createMessage(Session session) throws JMSException {

        MapMessage message = session.createMapMessage();

        message.setString("name", "小西山");

        return message;

      }

    });

  }

  /**

   * 向默認(rèn)隊(duì)列發(fā)送Object消息

   */

  public void sendObjectMessage() {

    jmsTemplate.send(new MessageCreator() {

      public Message createMessage(Session session) throws JMSException {

        Staff staff = new Staff(1, "搬磚工"); // Staff必須實(shí)現(xiàn)序列化

        ObjectMessage message = session.createObjectMessage(staff);

        return message;

      }

    });

  }

  /**

   * 向默認(rèn)隊(duì)列發(fā)送Bytes消息

   */

  public void sendBytesMessage() {

    jmsTemplate.send(new MessageCreator() {

      public Message createMessage(Session session) throws JMSException {

        String str = "BytesMessage 字節(jié)消息";

        BytesMessage message = session.createBytesMessage();

        message.writeBytes(str.getBytes());

        return message;

      }

    });

  }

  /**

   * 向默認(rèn)隊(duì)列發(fā)送Stream消息

   */

  public void sendStreamMessage() {

    jmsTemplate.send(new MessageCreator() {

      public Message createMessage(Session session) throws JMSException {

        String str = "StreamMessage 流消息";

        StreamMessage message = session.createStreamMessage();

        message.writeString(str);

        message.writeInt(521);

        return message;

      }

    });

  }

3.消息接受示例代碼

 /**

   * 接受消息

   */

  public void receive(Destination destination) throws JMSException {

    Message message = jmsTemplate.receive(destination);

    // 如果是文本消息

    if (message instanceof TextMessage) {

      TextMessage tm = (TextMessage) message;

      System.out.println("ConsumerService從隊(duì)列" + destination.toString() + "收到了消息：\t" + tm.getText());

    }

    // 如果是Map消息

    if (message instanceof MapMessage) {

      MapMessage mm = (MapMessage) message;

      System.out.println("ConsumerService從隊(duì)列" + destination.toString() + "收到了消息：\t"

          + mm.getString("name"));

    }

    // 如果是Object消息

    if (message instanceof ObjectMessage) {

      ObjectMessage om = (ObjectMessage) message;

      Staff staff = (Staff) om.getObject();

      System.out.println("ConsumerService從隊(duì)列" + destination.toString() + "收到了消息：\t" + staff);

    }

    // 如果是bytes消息

    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));

      }

    }

    // 如果是Stream消息

    if (message instanceof StreamMessage) {

      StreamMessage sm = (StreamMessage) message;

      System.out.println(sm.readString());

      System.out.println(sm.readInt());

    }

  }