消息和主题(持久化-非持久化)分类--持久化订阅

1. 持久化 VS 非持久化, 持久化订阅

 

持久化消息 可以通过<broker> 的 persistent="true" 设置为true(默认值).

 

或者设置 producer.setDeliveryMode(DeliveryMode.PERSISTENT); //设置保存消息

然后再 connection.start();

 

 

 

2. 持久化订阅

 

默认情况下(使用ActiveMQ5.8.0版本默认配置启动代理) 使用publisher发送100个消息,如果发送消息时

消息发送完成之前,消费者没有启动,发送完成后再启动消息消费者,此时消费者不能接收消息.

因为消息已经发送过了.

 

使用持久化订阅可以让代理在消费者不在线时为消费者保存消息.当消费者上线了,可以再次接收并处理消息.

 

 

这时,消费者需要特殊处理,

首先在创建连接时要connection.setClientID("client-name"); 注册消费者.

然后MessageConsumer consumer = session.createDurableSubscriber(topic, "my-sub-name");

创建一个持久化订阅.

消费者创建好之后,要先运行一次,以便向消息代理注册消费者.

 

参考 :http://blog.chenlb.com/2010/01/jms-topic-durable-subscriber.html