学习一对多的使用配置,也就是工作队列,简单的说就是消费者通过竞争来接收消息,获得一个消息,谁消费速度快谁能获得足够多的消息。
为了避免消费者服务在处理消息时挂掉,导致消息丢失,rabbitmq提供了可选消息确认机制,消费者发送一个ask确认,然后把该条消息从队列中移除,之后这个消费者再去执行下一个消息接收。这个消息确认默认开启。
创建两个消费者,加一条输出区分到底是哪个消费者来处理消息。
生产者循环发送10个消息,然后在RebbitmqController调用发送方法。
RebbitmqController的调用。
请求地址后看看输出,Comsumer1和Comsumer2均匀的瓜分了消息。
over!第二种模式就是这样子的,未完待续。