我们之前将的是，直接使用java代码操作rabbitmq，相当于就是原生的代码操作rabbitmq，但是之后我们在项目里面，不会使用原生的java代码操作rabbitmq的，所以现在我们要将springboot项目是如何整合rabbitmq的。项目里面是如何使用rabbitmq的。

以下将会分别的讲解springboot项目是如何操作5种模型的。

直接使用简单的springboot项目来说5种模型

创建springboot项目

1 创建springboot项目

这个项目是用脚手架直接生成的，那么就直接导入了web 依赖和rabbit的依赖

<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build>

2 配置文件里面写rabbitmq的用户名和密码

之前我们用java代码的源码操作的时候，用户名和密码是直接写在工具类里面的，但是现在我们是整合了springboot，所以只需要在yml里面写配置就可以了。

以后就可以直接使用rabbitTemplates 进行操作rabbitmq

3 在测试类里面直接操作rabbitmq

之前只用java原生代码操作rabbitmq的时候，有5种模型

第一个模型

直接发送消息到队列里面

在项目里面监听队列，我们就创建一个类，用来监听队列，这个使用注解的方式进行开发 在rabbitmq软件里面之前是没有队列的，我们只用提供者提供的时候，不会直接创建队列的，我们只能在消费者里面监听的时候创建队列，就是消费者在消费的时候，没有队列就创建队列。

消费者

@Component 将这个类配置到spring容器里面 @RabbitListener(queuesToDeclare = @Queue("hello")) 一直在监听这个队列 public class HelloCustomer { @RabbitHandler 这个注解的意思是 只要监听到这个队列里面有消息，那么就执行下面的方法 public void receivel(String message){ message 就是这个队列里面的消息 System.out.println("message="+message); } }

只要写上面的类，这个就一直在监听，现在就等 提供者发消息了。

提供者

@SpringBootTest class SpringbootRabbitmqApplicationTests { @Autowired private RabbitTemplate rabbitTemplate; @Test void contextLoads() { //使用rabbitmq直接往队列里面放数据 // convertAndSend（）第一个参数 是 rabbitTemplate.convertAndSend("hello","hello world"); } }

意思就是使用rabbitTemplate直接发送消息

但是这个默认的是 直接创建的队列是持久化的，那么如何利用代码进行操作，可以利用代码进行配置是不是持久化呢？

以上的这个方法里面还可以写其他的参数，其他的参数就可以进行限制

@Component @RabbitListener(queuesToDeclare = @Queue(value = "hello",durable = "false",autoDelete = "true")) public class HelloCustomer { @RabbitHandler public void receivel(String message){ System.out.println("message="+message); } }

durable属性就是设置是不是要持久化 autoDelete属性是设置是不是要自动删除

总结

1 创建一个springboot项目 2 导入rabbitmq的依赖 3 配置用户名和密码 4 使用rabbittemplate 进行往 rabbitmq里面发数据 5 使用注解进行监听队列 ，并且将队列里面的消息输出

以上只是单纯的使用了队列，没有使用交换机，也是我们之前讲的第一个模型