所谓的广播消息就是发送的一条消息会被多个消费者收到。
⼴播是向主题( topic )的所有订阅者发送消息。订阅同⼀个 topic 的多个消费者,能全量收到⽣产者发送的所有消息。
生产者发送了10个order,每个order里面有5个消息,那么就会有50条消息。这10个order会被两个消费者分割,某一条消息只会被某一个消费者进行消费。
现在能不能有一个消息发过去以后,消费者1能够收到,消费者2也能够收到。它们是在订阅同一个topic,这就需要广播消息了。
生产者:
创建一个生产者对象,启动之后就开始发送消息。这边会创建出100个msg对象,每次发的时候直接调用send方法就行了。
消费者这里比较明显的将自己的消费模式设置为了广播的模式。
消费者从一开始就从第一个offset位置进行消费,消费者设置消费模式为广播,剩下的都一样,消费者去订阅主题,在过滤消息的时候使用*号表示不过滤消息。
消费者只不过明确了消费模式为广播模式。
在广播消息里面消费者 广播消息模式的设定,设定之后,多个消费者都能够全量的收到生产者发送的所有的数据。