SpringCloud项目整合RabbitMQ

整合RabbitMQ到Spring Cloud项目中，通常涉及以下步骤：

1. 添加依赖：确保在项目的pom.xml中添加了RabbitMQ和Spring Cloud Stream的依赖。

<dependencies>
    <!-- Spring Cloud Stream RabbitMQ Binder -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    </dependency>
</dependencies>

2. 配置RabbitMQ连接：在application.yml或application.properties中配置RabbitMQ连接信息。

spring:
  rabbitmq:
    host: your-rabbitmq-host
    port: 5672
    username: your-username
    password: your-password

3. 创建消息接收者（Sink）和发送者（Source）：使用@EnableBinding注解标记配置类，并使用@StreamListener注解来监听消息。

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.handler.annotation.Payload;
 
@EnableBinding(Sink.class)
public class RabbitMQReceiver {
 
    @StreamListener(Sink.INPUT)
    public void receive(@Payload String message) {
        // 处理接收到的消息
    }
}

发送消息：

import org.springframework.beans.factory.annotation.Autowired;
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 RabbitMQSender {
 
    @Autowired
    private Source source;
 
    public void send(String message) {
        source.output().send(MessageBuilder.withPayload(message).build());
    }
}

这样就可以在Spring Cloud项目中使用RabbitMQ进行消息的发送和接收了。