springboot整合rabbitMQ系列(一)第一个模型,直接将消息发送给队列,消费端在队列里面直接拿出消息

2020-11-20 14:54:04 浏览数 (1)

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

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

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

创建springboot项目

1 创建springboot项目

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

代码语言:javascript复制
 <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软件里面之前是没有队列的,我们只用提供者提供的时候,不会直接创建队列的,我们只能在消费者里面监听的时候创建队列,就是消费者在消费的时候,没有队列就创建队列。

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

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

提供者
代码语言:javascript复制
@SpringBootTest
class SpringbootRabbitmqApplicationTests {

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

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

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

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

代码语言:javascript复制
@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 使用注解进行监听队列 ,并且将队列里面的消息输出

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

0 人点赞