springboot集成RabbitMQ非常简单，如果只是简单的使用配置非常少，springboot提供了spring-boot-starter-amqp项目对消息各种支持。在pom.xml中引入如下依赖内容，其中spring-boot-starter-amqp用于支持RabbitMQ。在该生产者，我们会产生一个字符串，并发送到名为hello的队列中。通过@RabbitListener注解定义该类对hello队列的监听，并用@RabbitHandler注解来指定对消息的处理方法。同时，我们通过RabbitMQ的控制面板，可以看到Connection和Channels中包含当前连接的条目。通过上面的示例，我们在Spring Boot应用中引入spring-boot-starter-amqp模块，进行简单配置就完成了对RabbitMQ的消息生产和消费的开发内容。实际上RabbitMQ还可以支持发送对象:当然由于涉及到序列化和反序列化,该对象要实现Serilizable接口.HelloSender做出如下改写:
暂无评论