基于JMS规范的ActiveMQ

JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。

//消息生产者

package javax.jms;/*** @version $Rev: 467553 $ $Date: 2006-10-25 06:01:51 +0200 (Wed, 25 Oct 2006) $*/
public interface MessageProducer {void setDisableMessageID(boolean value) throws JMSException;boolean getDisableMessageID() throws JMSException;void setDisableMessageTimestamp(boolean value) throws JMSException;boolean getDisableMessageTimestamp() throws JMSException;void setDeliveryMode(int deliveryMode) throws JMSException;int getDeliveryMode() throws JMSException;void setPriority(int defaultPriority) throws JMSException;int getPriority() throws JMSException;void setTimeToLive(long timeToLive) throws JMSException;long getTimeToLive() throws JMSException;Destination getDestination() throws JMSException;void close() throws JMSException;void send(Message message) throws JMSException;void send(Message message, int deliveryMode, int priority, long timeToLive)throws JMSException;void send(Destination destination, Message message) throws JMSException;void send(Destination destination,Message message,int deliveryMode,int priority,long timeToLive)throws JMSException;
}

//消息消费者的定义

package javax.jms;/*** @version $Rev: 467553 $ $Date: 2006-10-25 06:01:51 +0200 (Wed, 25 Oct 2006) $*/
public interface MessageConsumer {String getMessageSelector() throws JMSException;MessageListener getMessageListener() throws JMSException;void setMessageListener(MessageListener listener) throws JMSException;Message receive() throws JMSException;Message receive(long timeout) throws JMSException;Message receiveNoWait() throws JMSException;void close() throws JMSException;
}

//消息监听

public interface MessageListener {void onMessage(Message message);
}

//消息的内部定义，所有属性的使用还是要看厂商支不支持

public interface Message {static final int DEFAULT_DELIVERY_MODE = DeliveryMode.PERSISTENT;static final int DEFAULT_PRIORITY = 4;static final long DEFAULT_TIME_TO_LIVE = 0;String getJMSMessageID() throws JMSException;void setJMSMessageID(String id) throws JMSException;long getJMSTimestamp() throws JMSException;void setJMSTimestamp(long timestamp) throws JMSException;byte[] getJMSCorrelationIDAsBytes() throws JMSException;void setJMSCorrelationIDAsBytes(byte[] correlationID) throws JMSException;void setJMSCorrelationID(String correlationID) throws JMSException;String getJMSCorrelationID() throws JMSException;Destination getJMSReplyTo() throws JMSException;void setJMSReplyTo(Destination replyTo) throws JMSException;Destination getJMSDestination() throws JMSException;void setJMSDestination(Destination destination) throws JMSException;int getJMSDeliveryMode() throws JMSException;void setJMSDeliveryMode(int deliveryMode) throws JMSException;boolean getJMSRedelivered() throws JMSException;void setJMSRedelivered(boolean redelivered) throws JMSException;String getJMSType() throws JMSException;void setJMSType(String type) throws JMSException;long getJMSExpiration() throws JMSException;void setJMSExpiration(long expiration) throws JMSException;int getJMSPriority() throws JMSException;void setJMSPriority(int priority) throws JMSException;void clearProperties() throws JMSException;boolean propertyExists(String name) throws JMSException;boolean getBooleanProperty(String name) throws JMSException;byte getByteProperty(String name) throws JMSException;short getShortProperty(String name) throws JMSException;int getIntProperty(String name) throws JMSException;long getLongProperty(String name) throws JMSException;float getFloatProperty(String name) throws JMSException;double getDoubleProperty(String name) throws JMSException;String getStringProperty(String name) throws JMSException;Object getObjectProperty(String name) throws JMSException;Enumeration getPropertyNames() throws JMSException;void setBooleanProperty(String name, boolean value) throws JMSException;void setByteProperty(String name, byte value) throws JMSException;void setShortProperty(String name, short value) throws JMSException;void setIntProperty(String name, int value) throws JMSException;void setLongProperty(String name, long value) throws JMSException;void setFloatProperty(String name, float value) throws JMSException;void setDoubleProperty(String name, double value) throws JMSException;void setStringProperty(String name, String value) throws JMSException;void setObjectProperty(String name, Object value) throws JMSException;void acknowledge() throws JMSException;void clearBody() throws JMSException;
}
比较重要的一些属性：jmsxappid标识发送消息的应用程序jmsxconsumertxid的事务标识符的交易内，此消息被消耗jmsxdeliverycount消息传递次数jmsxgroupid消息组，此消息的一部分JMSXGroupSeq组内此消息的序列号jmsxproducertxid标识符的交易在该消息所产生的交易jmsxrcvtimestamp的JMS提供者将信息传递给消费者的时间jmsxstate用来定义一个提供程序特定的状态jmsxuserid识别用户发送消息

Message selectors(消息筛选器)

//一个简单的用法
String selector = "SYMBOL= 'AAPL'";
MessageConsumer consumer=session.createConsumer(destination, selector);

MESSAGE BODY

JMS定义了六个java类型的消息体，也被称为有效载荷。通过使用这些对象，数据和信息可以通过消息有效载荷发送。

消息基消息类型（Message）。用于发送没有有效负载的消息，只有标题和属性。通常用于简单的事件通知。

文本消息（TextMessage）-消息的有效负载是一个字符串。通常用于发送简单的文本和数据。

映射/键值消息（mapmessage） -使用一组名称/值对其有效载荷。名称是字符串类型和值是一个java的原始类型。

字节消息（BytesMessage ）- 字节数组作为有效载荷。

流消息（StreamMessage）-  包含流原始java类型的填充顺序读取消息。

对象消息（ObjectMessage）- 将一个java序列化对象作为它的负载。通常用于复杂的java对象。还支持java集合。

JMS domains（两种消息模式）

THE POINT-TO-POINT DOMAIN（点对点模式）

THE PUBLISH/SUBSCRIBE DOMAIN （发布订阅模式）

演变出了 Request/reply messaging in JMS applications(请求回复模式)，事务确认的时候有很多的用处。