本篇文章为大家展示了rabbitmq如何在SpringBoot中应用，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
大洼网站制作公司哪家好，找
成都创新互联！从网页设计、网站建设、微信开发、APP开发、
成都响应式网站建设公司等网站项目制作，到程序开发，运营维护。
成都创新互联成立与2013年到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选
成都创新互联。
org.springframework.boot
spring-boot-starter
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-starter-amqp
org.projectlombok
lombok
AMQP，即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制,spring-boot-starter-amqp引入的就是rabbitmq。有个前提，你的机子上要首先先安装rabbitmq的server,然后执行 rabbitmq-server server就启动了。启动后，我们就可以配置我们的客户端程序了。首先看下我们的配置文件
spring.application.name: spirng-boot-rabbitmq
spring.rabbitmq.host: 127.0.0.1
spring.rabbitmq.port: 5672
spring.rabbitmq.username: guest
spring.rabbitmq.password: guest
配置了服务器的IP，端口，用户名，密码等基础信息，保证我们能连上服务器。
增加一个Rabbitmq的配置类
package com.shuqi;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitConfig {
@Bean
public Queue Queue() {
return new Queue("hello");
}
}创建了一个名称叫做hello的队列，然后producer可以往hello的队列里放数据，consumer可以从hello的队列里消费数据。看下producer的处理程序
package com.shuqi.controller;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class HelloController {
@Autowired
private AmqpTemplate rabbitTemplate;
@RequestMapping("/hello")
public String hello(@RequestParam String name){
rabbitTemplate.convertAndSend("hello","hello "+name);
return "消息发送成功";
}
}通过controller生产消息，通过AmqpTemplate发送消息。有了生产者我们看下消费者
package com.shuqi.consumer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
@RabbitListener(queues = "hello")
@Slf4j
public class HelloConsumer {
@RabbitHandler
public void process(String hello) {
log.info("接收到的消息：message:{}",hello);
}
}@RabbitListener(queues = "hello") 表示是一个Rabbitmq的监听器，监听的队列名称是hello,说明数据可定会过来，数据过来了，通过 @RabbitHandler 修饰的方法来处理过来的数据。打印一下。下面我们启动项目看看效果。
在浏览器中输入 http://localhost:8080/hello?name=shuqi 看到下面的结果
看下控制台输出的日志
2018-03-25 16:24:32.752 INFO 4987 --- [cTaskExecutor-1] com.shuqi.consumer.HelloConsumer : 接收到的消息：message:hello shuqi
上述内容就是rabbitmq如何在SpringBoot中应用，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。
文章名称：rabbitmq如何在SpringBoot中应用-创新互联
文章源于：
http://cdkjz.cn/article/deeoej.html
