生产者
配置生产者
/**
* @author BNTang
*/
public class WorkConfig {
public Queue work() {
return new Queue("work");
}
}
发送消息
public void testWork() {
for (int i = 0; i <= 10; i++) {
this.rabbitTemplate.convertAndSend("work", "hello Work → " + i);
}
System.out.println("消息发送成功");
}
消费者
/**
* @author BNTang
*/
public class WorkConsumer {
(queuesToDeclare = { ("work")})
public void receive1(String message) {
System.out.println("消费者【1】接收到消息:" + message);
}
(queuesToDeclare = { ("work")})
public void receive2(String message) {
System.out.println("消费者【2】接收到消息:" + message);
}
}
测试方式和前面章节中的一样自行测试即可。