SpringBoot整合RabbitMQ
整合就直接使用单机版的了, 一直开着5个虚拟机, 我电脑不太行
新建SpringBoot工程
你已经是一个长大的IDEA了, 要学会自己新建工程, 然后IDEA...>
都是在创建工程的时候随便点的功能
启动类就不用我粘贴了吧
生产者代码实现
配置文件
spring:
application:
name: rabbitmq-producer...;
rabbitMQSender.sendMessage(msg,new HashMap());
}
}
消费者代码实现
配置文件
spring:
application...max-concurrency: 10 # 最大通道数量
prefetch: 1...5个通道, 这个就是我们在配置文件中设置的初始值
点进去可以看到消费的是哪个队列
启动生产者测试类
可以看到, 在confirm监听中, 得到了消息ID, ack为true, 没有异常, 消息发送成功