RocketMQ实战与原理

Producer: 生产者，负责生产消息并发送到消息引擎。测评开始时，测评程序会启动10~20个Producer，每个Producer在一条线程中，然后每个Producer随机生产某个Topic或者附属于Queue的消息并发送到消息引擎； Topic: 消息主题。 Queue: 队列。抽象的概念，消息可以发送到特定的队列，或者属于某个特定的Topic Consumer：消费者。每个消费者必须attach到某个特定的Queue上，而且Consumer和Queue是一一对应关系。同时，Consumer可以订阅多个Topic。测评程序开始消费时，会启动10~20个Consumer，每个Consumer属于一条线程，而且attach到一个queue上，并订阅多个Topic。对于被多个Consumer订阅的某个Topic，这些Consumer直接的消费应该是独立的，也就是每个Consumer都应该全量消费这个Topic的消息。