集群模式 在消费模式为集群的情况下,如果机器是集群的,消息只会给集群中的其中一台机器消费到 集群模式的演示(本身就默认) Rocketmq存储队列 在消息中间件每个topic是有4个写和读队列,主要是解决并发性能的问题的 如果只有一个队列,保证线程安全,必须得给队列进行写操作的时候上锁。 多几个队列,降低并发度,等待时间就短一些。 因为大多数服务器只有四核,意味着同时最多只能有CPU同时工作 广播模式 在消费模式为集群的情况下,如果机器是集群的,消费是会给集群中的所有机器所消费到 public class Consumer { public static void main(String[] args) throws Exception { DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("helloConsumerGroup"); consumer.setNamesrvAddr("43.143.161.59:9876"); consumer.subscribe("helloTopic","*");...