目录 C1和C2属于竞争关系，一个消息只有一个消费者可以取到。 代码部分只需要用两个消费者进程监听同一个队里即可。 两个消费者呈现竞争关系。 用一个生产者推送10条消息 for(int i=0;i<10;i++) { String body=i+"hello rabbitmq!!!"; channel.basicPublish("","work_queues",null,body.getBytes()); } 两个监听的消费者接收情况如下。 一个生产者发送消息后有两个消费者可以收到消息。 生产者把消息发给交换机，交换机再把消息通过Routes路由分发给不同的队列。 //发送消息 public class producer_PubSub { public static void main(String[] args) throws IOException, TimeoutException { //1.创建连接工厂 ConnectionFactory factory=new ConnectionFactory(); //2.设置参数 factory.setHost("");...
