springboot rabbitmq推送数据

在使用Spring Boot推送数据到RabbitMQ，你需要进行以下几个步骤：

1. 配置RabbitMQ连接信息：在`application.properties`或`application.yml`文件中添加以下配置信息：

spring.rabbitmq.host=<RabbitMQ服务器地址>
spring.rabbitmq.port=<RabbitMQ服务器端口>
spring.rabbitmq.username=<RabbitMQ用户名>
spring.rabbitmq.password=<RabbitMQ密码>

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

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

3. 创建消息发送者：创建一个发送消息的类，例如`MessageSender`，并在类中注入`AmqpTemplate`对象。

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

@Component
public class MessageSender {

    private final AmqpTemplate rabbitTemplate;

    @Autowired
    public MessageSender(AmqpTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

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

4. 发送消息：在需要发送消息的地方，使用`MessageSender`类发送消息。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    private final MessageSender messageSender;

    @Autowired
    public MyController(MessageSender messageSender) {
        this.messageSender = messageSender;
    }

    @GetMapping("/send")
    public String sendMessage() {
        // 发送消息到名为"exchangeName"的交换机，使用"routingKey"作为路由键
        messageSender.sendMessage("exchangeName", "routingKey", "Hello, RabbitMQ!");
        return "Message sent";
    }
}

以上步骤中，你需要根据实际情况配置RabbitMQ连接信息、替换交换机名称和路由键等。通过调用`sendMessage`方法发送消息，即可将数据推送到RabbitMQ队列中。