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那么所有相关的注册记录即消费者数量就会恢复,只有重启实例才可重置。

  • 相关阅读:
    2019牛客多校第二场H题(悬线法)
    hdu6212 Zuma(区间dp)
    uva1428树状数组
    UVA1395 (最苗条的最小生成树)
    牛客练习赛53 C题bitset
    Love Live!
    Princess principal
    New Game!- 牛客
    P3311 [SDOI2014]数数
    [HNOI2008]GT考试
  • 原文地址:https://www.cnblogs.com/Peter2014/p/11066178.html
Copyright © 2011-2022 走看看