我们之前将的是，直接使用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 使用注解进行监听队列 ，并且将队列里面的消息输出

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