exchange-source -> exchange-destination-3 -> queue-3。
spring.cloud.stream.bindings.output_channel.destination=exchange-3 spring.cloud.stream.bindings.output_channel.group=queue spring.cloud.stream.bindings.input_channel.destination=exchange-3 spring.cloud.stream.bindings.input_channel.group=queue
spring.cloud.stream.bindings.output_channel.destination=exchange-3 11 # 队列名称 12 spring.cloud.stream.bindings.output_channel.group=queue spring.cloud.stream.bindings.input_channel.destination=exchange-3 10 # 队列名称 11 spring.cloud.stream.bindings.input_channel.group=queue
Queue的分配结果如下: [图片] (表2.1 消息费者的Queue分配结果表) 因为clientB没有订阅TOPIC_A,clientA也没有订阅TOPIC_B,所以TOPIA_A中的Queue-2、Queue
"queue-1").start(); new Thread(runnable, "queue-2").start(); new Thread(runnable, "queue "queue-1").start(); new Thread(runnable, "queue-2").start(); new Thread(runnable, "queue com.course.order";//都可以收到 queue-1 queue-2 String routingKey2 = "com.order.user";//都可以收到 queue-1 queue "queue-1").start(); new Thread(runnable, "queue-2").start(); new Thread(runnable, "queue