0
点赞
收藏
分享

微信扫一扫

SpringBoot-RabbitMQ任务模式

生产者

配置生产者

/**
* @author BNTang
*/
@Configuration
public class WorkConfig {

@Bean
public Queue work() {
return new Queue("work");
}

}

发送消息

@Test
public void testWork() {
for (int i = 0; i <= 10; i++) {
this.rabbitTemplate.convertAndSend("work", "hello Work → " + i);
}
System.out.println("消息发送成功");
}

消费者

/**
* @author BNTang
*/
@Component
public class WorkConsumer {

@RabbitListener(queuesToDeclare = {@Queue("work")})
public void receive1(String message) {
System.out.println("消费者【1】接收到消息:" + message);
}

@RabbitListener(queuesToDeclare = {@Queue("work")})
public void receive2(String message) {
System.out.println("消费者【2】接收到消息:" + message);
}
}

测试方式和前面章节中的一样自行测试即可。




举报

相关推荐

0 条评论