springboot整合rabbitmq 实现消息发送和消费

Spring Boot提供了RabbitMQ的自动化配置，使得整合RabbitMQ变得非常容易。

首先，需要在pom.xml文件中引入amqp-client和spring-boot-starter-amqp依赖：

dependency>
    groupId>com.rabbitmqgroupId>
    artifactId>amqp-clientartifactId>
    version>5.5.1version>
dependency>

dependency>
    groupId>org.springframework.bootgroupId>
    artifactId>spring-boot-starter-amqpartifactId>
dependency>

接下来需要在application.properties文件中配置RabbitMQ连接信息：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
sp服务器托管网ring.rabbitmq.virtual-host=/

然后编写消息发送者：

@Component
public class RabbitMQSender {
    private final RabbitTemplate rabbitTemplate;

    public RabbitMQSender(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    public void send(String message) {
        rabbitTemplate.convertAndSend("my-exchange", "my-rou服务器托管网ting-key", message);
    }
}

其中，my-exchange和my-routing-key是需要自己定义的交换机和路由键。

最后编写消息消费者：

@Component
public class RabbitMQReceiver {
    @RabbitListener(queues = "my-queue")
    public void receive(String message) {
        System.out.println("Received message: " + message);
    }
}

其中，my-queue也是需要自己定义的队列。

在以上步骤完成后，即可实现消息的发送和消费。

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net

相关推荐: #yyds干货盘点# LeetCode程序员面试金典：替换后的最长重复字符

1.简述： 给你一个字符串s和一个整数k。你可以选择字符串中的任一字符，并将其更改为任何其他大写英文字符。该操作最多可执行k次。 在执行上述操作后，返回包含相同字母的最长子字符串的长度。 示例 1： 输入：s = “ABAB”, k = 2 输出：4 解释：用…