Spring Cloud 集成 RabbitMQ 进行消息处理 - 详细步骤 - 常规

要在 Spring Cloud 中使用 RabbitMQ 进行消息处理，需要进行以下步骤：

添加 RabbitMQ 依赖

在 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

配置 RabbitMQ 连接

在 application.yml 文件中添加以下配置：

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

创建消息发送者

创建一个消息发送者类，使用 @EnableBinding(Source.class) 注解将其绑定到 RabbitMQ 的 Source 接口上：

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.support.MessageBuilder;

@EnableBinding(Source.class)
public class MessageSender {

    private final Source source;

    public MessageSender(Source source) {
        this.source = source;
    }

    public void sendMessage(String message) {
        source.output().send(MessageBuilder.withPayload(message).build());
    }
}

创建消息接收者

创建一个消息接收者类，使用 @EnableBinding(Sink.class) 注解将其绑定到 RabbitMQ 的 Sink 接口上，并使用 @StreamListener(Sink.INPUT) 注解监听消息：

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;

@EnableBinding(Sink.class)
public class MessageReceiver {

    @StreamListener(Sink.INPUT)
    public void receiveMessage(String message) {
        System.out.println('Received message: ' + message);
    }
}

发送和接收消息

在需要发送消息的地方，注入 MessageSender 类并调用 sendMessage 方法：

@Autowired
private MessageSender messageSender;

public void sendMessage() {
    messageSender.sendMessage('Hello, RabbitMQ!');
}

在需要接收消息的地方，注入 MessageReceiver 类即可。当有消息到达时，receiveMessage 方法会被自动调用。

以上就是在 Spring Cloud 中使用 RabbitMQ 进行消息处理的基本步骤。需要注意的是，RabbitMQ 的配置和使用方式可能因版本和环境而异，具体实现时需要根据实际情况进行调整。