Ruoyi工程中添加RabbitMQ

在Ruoyi工程中添加RabbitMQ，可以按照以下步骤进行操作：

1. 首先，确保你的Ruoyi工程已经配置好了Maven依赖。在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2. 在Ruoyi工程的配置文件（application.yml或application.properties）中添加RabbitMQ的相关配置信息，包括主机名、端口号、用户名、密码等。例如：

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

3. 在Ruoyi工程中创建一个消息发送者（Producer）和一个消息接收者（Consumer）。

- 创建消息发送者：

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

@Component
public class RabbitMQSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send(String message) {
        rabbitTemplate.convertAndSend("exchangeName", "routingKey", message);
    }
}

- 创建消息接收者：

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

@Component
public class RabbitMQReceiver {

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

4. 在Ruoyi工程中使用消息发送者发送消息，以及使用消息接收者接收消息。

- 在需要发送消息的地方调用消息发送者的send方法：

@Autowired
private RabbitMQSender rabbitMQSender;

public void sendMessage() {
    rabbitMQSender.send("Hello RabbitMQ!");
}

- 在消息接收者中处理接收到的消息：

@Autowired
private RabbitMQReceiver rabbitMQReceiver;

@PostConstruct
public void init() {
    rabbitMQReceiver.receive();
}

这样，你就成功地在Ruoyi工程中添加了RabbitMQ。