描述：最近做一个预警的功能，使用到ActiveMQ消息订阅功能，但是问题来了，页面上有四个Topic订阅消息就接收不到消息，接收一个topic消息就没问题。排查问题后，程序是没问题的，问题应该出现在ActiveMQ配置文件设置那块。直接找到activemq.xml,如图： ​ 源代码 ...

待续 ...

新增topic是需要客户端直接通知broker完成的： 通过createAndUpdateTopicConfig方法 发送给broker以后，在AdminBrokerProcessor里面负责处理这个类型消息： private synchronized ...

一、问题答案 　　是不可以的 而且后注册的会替换前注册的，MqConsumer2会替换MqConsumer，并且只结束tag-2的消息 二、为什么呢？ 我们从源码的角度来分析下 1.订阅消息的方法 public void subscribe ...

最近做的项目的一个版本需求中，需要用到MQ,对数据记录进行异步落库，这样可以减轻数据库的压力,同时可以抗住大量的数据落库。这里需要说明一下本人用到的MQ是公司自己在阿里的RokectMQ的基础上进行封 ...

直观的结果：当生产者向 topic 发送消息， 1. 若不存在持久订阅者和在线的普通订阅者，这个消息不会保存，当普通订阅者上线后，它是收不到消息的。 2. 若存在离线的持久订阅者，broker 会为该持久订阅者保存消息，当该持久订阅者上线后，会收到消息。 本质：producer 发送消息 ...

MQ学习系列： 消息队列概念与认知 ActiveMQ Topic消息重发 ActiveMQ Topic 消息持久化订阅 zookeeper+ActiveMQ集群实现高可用 一、持久化到文件（默认） 第一步：在${activemq.base}/conf ...

　　项目中使用了RocketMQ，没有显式的创建和Topic和MessageQueue，在消息发送时，就创建了Topic和 4个 MessageQueue 　　此时想要修改MessageQueue的数量方式如下： 通过producer.createTopic方法创建； 通过控制台方式 ...