zoukankan      html  css  js  c++  java
  • ActiveMQ Topic持久化订阅的几点收获

    非持久化模式下,Topic不会落地任何消息,消息入队即出队, 消费者如果想要保留离线后的消息需要告诉MQ实例,即注册过程, 代码上大概是这样的:

    connectionFactory = new ActiveMQConnectionFactory(username, password, brokerUrl);
    connection = connectionFactory.createConnection();
    connection.setClientID(durableSubscribe.elementText("clientId"));
    connection.start();
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    destination = session.createTopic(destinationName);
    topicSubscriber = session.createDurableSubscriber(destination, durableSubscribe.elementText("consumerId"));
    topicSubscriber.setMessageListener(new DestinationListener());
    

    这里要补充几个实验收获:
    1.ActiveMQ的客户端无论是生产者还是消费者都有两个ID,以消费者举例,clientId代表一个连接connection, consumerId代表该连接产生的一个消费者,所以注册过程需要填入两个ID才能让MQ实例识别一个消费者
    2.Topic的机制是有副本,不论是在线的消费者或者离线的持久化消费者再次上线后都会收到相同的副本消息
    3.持久化订阅和非持久化订阅一样都可以同时连接同时获取消息副本,不存在所谓的同时只能发送给一个clientId的情况
    4.注册记录不会随着Topic的删除而删除,如果删除了Topic那么只要有一个consumer再度订阅了该Topic那么所有相关的注册记录即消费者数量就会恢复,只有重启实例才可重置。

  • 相关阅读:
    Linux imooc learning
    有用的生活有关的website
    ps -ef | grep java
    2.3. Configuring sudo Access-RedHat
    How to change java version in Linux
    文档记录工具
    Jmeter 学习imooc
    Linux 用户管理
    Builder模式(设计模式)
    Prototype模式(设计模式)
  • 原文地址:https://www.cnblogs.com/Peter2014/p/11066178.html
Copyright © 2011-2022 走看看