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

  • 相关阅读:
    nyoj 115------城市平乱( dijkstra // bellman )
    nyoj-----284坦克大战(带权值的图搜索)
    nyoj-----42一笔画问题
    hdu-------1081To The Max
    nyoj------170网络的可靠性
    HDUOJ-------1052Tian Ji -- The Horse Racing(田忌赛马)
    初学Java之Pattern与Matcher类
    初学java之StringBuffer类的常用方法
    初学java之大数处理
    hdu---1024Max Sum Plus Plus(动态规划)
  • 原文地址:https://www.cnblogs.com/Peter2014/p/11066178.html
Copyright © 2011-2022 走看看