SpringBoot结合Java实现消息传递

在Spring Boot中，我们可以使用RabbitMQ、Kafka等消息队列中间件来实现消息传递。这里我将向您展示如何使用RabbitMQ和Spring Boot实现消息传递。

1. 添加依赖

首先，在您的pom.xml文件中添加RabbitMQ和Spring Boot的依赖：

<dependencies>
    <!-- Spring Boot Starter AMQP -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>

2. 配置RabbitMQ

在application.properties或application.yml文件中配置RabbitMQ连接信息：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 创建消息生产者

创建一个名为MessageProducer的类，用于发送消息到RabbitMQ队列：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {

    @Autowired
    private AmqpTemplate amqpTemplate;

    public void sendMessage(String exchange, String routingKey, String message) {
        amqpTemplate.convertAndSend(exchange, routingKey, message);
    }
}

4. 创建消息消费者

创建一个名为MessageConsumer的类，用于从RabbitMQ队列接收消息：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {

    @RabbitListener(queues = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

5. 配置RabbitMQ监听器

在application.properties或application.yml文件中配置RabbitMQ监听器：

spring.rabbitmq.listener.simple.auto-startup=true
spring.rabbitmq.listener.simple.acknowledge-mode=manual

现在，当您调用MessageProducer类的sendMessage方法时，它将发送一条消息到名为myQueue的队列。MessageConsumer类的receiveMessage方法将接收到这条消息并打印出来。

这只是一个简单的示例，实际应用中可能需要根据需求进行更多的配置和优化。希望这对您有所帮助！