版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/YAOQINGGG/article/details/80101880
/**
* Created by brady on 17/4/8.
*/
public class TestProducer {
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
"tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(session.createTopic("testTopic1"));
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
// MessageProducer producer = session.createProducer(session.createQueue("testQueue1"));
Message message = session.createTextMessage("22223333333hello everybody!");
producer.send(message);
producer.close();
session.close();
connection.close();
}
}
其中有一项设置DeliveryMode,若设置为PERSISTENT,表示消息会持久化到磁盘上,比如kahadb,如果是NON_PERSISTENT,消息会放在内存里。也就是说当activemq服务关闭后。若是非持久化模式,消息若没有被消费,消息将丢失。
还有一点。若是queue,生产者发了一条消息m1,此时没有消费者。若启动消费者B,此时B仍然会消费m1。
如果是topic,生产者发了一条消息m1,此时没有消费者。若启动消费者B是非持久化订阅,此时B不会消费m1。若启动消费者B是持久化订阅,此时B才会消费m1。
代码如下
consumer = session.createDurableSubscriber(topic,"client_id"); // 持久化订阅
consumer = session.createConsumer(topic); // 非持久化订阅