ActiveMq NON_PERSISTENT与PERSISTENT以及 durable subscription（持久订阅）的理解

http://quentinXXZ.iteye.com/blog/2113458

实验一：

public class Producer {
	public static void main(String[] args) {
	    String user = ActiveMQConnection.DEFAULT_USER;
	    String password = ActiveMQConnection.DEFAULT_PASSWORD;
	    String url = ActiveMQConnection.DEFAULT_BROKER_URL;
	    String subject = "TOOL.DEFAULT";
	    System.out.println(user +" "+ password+" "+url+" "+subject+" ");
	    
		ConnectionFactory contectionFactory = new ActiveMQConnectionFactory(user,password,url);
		try {
			Connection connection = contectionFactory.createConnection();
			connection.start();
			Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
			Destination destination = session.createQueue(subject);
			MessageProducer producer = session.createProducer(destination);
			for(int i = 0;i<=20;i++){
				MapMessage message = session.createMapMessage();
				message.setLong("date", new Date().getTime());
				Thread.sleep(5000);
				producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
				producer.send(message);
				
				System.out.println("—SendMessge："+new Date());
			}
			session.commit();
			session.close();
			connection.close();
		} catch (JMSException e) {
			e.printStackTrace();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

 注意：producer.setDeliveryMode(DeliveryMode. NON_PERSISTENT);

 此处显式指明DeliveryMode为NON_PERSISENT

public class Consumer {

	public static void main(String[] args) {
		String user = ActiveMQConnection.DEFAULT_USER;
	    String password = ActiveMQConnection.DEFAULT_PASSWORD;
	    String url = ActiveMQConnection.DEFAULT_BROKER_URL;
	    String subject = "TOOL.DEFAULT";
		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,password,url);
		Connection connection;
		try {
			connection = connectionFactory.createConnection();
			connection.start();
			final Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
			Destination destination = session.createQueue(subject);
			MessageConsumer message = session.createConsumer(destination);
			message.setMessageListener(new MessageListener(){

				public void onMessage(Message msg) {
					MapMessage message = (MapMessage)msg;
					try {
						System.out.println("--Receive："+new Date(message.getLong("date")));
						session.commit();
					} catch (JMSException e) {
						e.printStackTrace();
					}
				}
			});
			Thread.sleep(30000);
			session.close();
			connection.close();
		} catch (JMSException e) {
			e.printStackTrace();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}

}

 ActiveMq Broker的配置都为默认。

先启动Broker,再启动Producer，等待Producer的20条Message发送完毕，Prducer程序运行结束，之后再启动Consumer,20条Message正常接收。

可见PERSISTENT与NON_PERSISTENT,并不是指Broker会不会在Consumer未连接的情况为其存储Message

实验二：

先启动Broker,再启动Producer，等待Producer的20条Message发送完毕，Prducer程序运行结束。关闭ActiveMq  Broker服务，然后重启。之后再启动Consumer。

Consumer没有接收到任何消息。

实验三：

producer.setDeliveryMode(DeliveryMode. PERSISTENT);

在Producer中显式指明DeliveryMode为PERSISENT

实验步骤与实验二相同，但是此次Consumer收到了来自Producer的消息。

总结：

Persistent 用来指定JMS Provider对消息进行持久化操作，以免Provider fail的时候，丢失Message.

NON_Persistent 方式下的JMS Provider不会对消进宪持久化，但上述实验一可知，Consumer还是会收到Message,可见JMS Provider会将相应的消息存在内存中，当Consumer连接上时，再发送过去，但在Provider fail的时候，Message会丢失。

事实上ActiveMq提供了多种消息持久化方式，包括AMQ、KahaDB、JDBC、LevelDB。从5.4版本之后KahaDB做为默认的持久化方式。

以下网上摘的：

消息订阅分为非持久订阅(non-durable subscription)和持久订阅(durablesubscription)，非持久订阅只有当客户端处于激活状态，也就是和JMS Provider保持连接状态才能收到发送到某个主题的消息，而当客户端处于离线状态，这个时间段发到主题的消息将会丢失，永远不会收到。持久订阅时，客户端向JMS注册一个识别自己身份的ID，当这个客户端处于离线时，JMS Provider 会为这个ID 保存所有发送到主题的消息，当客户再次连接到JMS Provider时，会根据自己的ID得到所有当自己处于离线时发送到主题的消息。

Topic 主题由JMS Provider 管理，主题由主题名识别，客户端可以通过JNDI接口用主题名得到一个主题对象。