如何用注解实现RabbitMQ生产者

在Java中，可以使用RabbitMQ的Java客户端库来实现RabbitMQ的生产者。使用注解可以更方便地配置和管理RabbitMQ生产者。

以下是使用注解实现RabbitMQ生产者的步骤：

1. 添加RabbitMQ客户端库的依赖

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.12.0</version>
</dependency>

2. 在Spring Boot应用程序的主类上添加@EnableRabbit注解

@SpringBootApplication
@EnableRabbit
public class MyApp {
    public static void main(String[] args) {
        SpringApplication.run(MyApp.class, args);
    }
}

3. 定义RabbitMQ连接工厂和RabbitMQ模板

@Configuration
public class RabbitMQConfig {
    @Value("${spring.rabbitmq.host}")
    private String host;

    @Value("${spring.rabbitmq.port}")
    private int port;

    @Value("${spring.rabbitmq.username}")
    private String username;

    @Value("${spring.rabbitmq.password}")
    private String password;

    @Value("${spring.rabbitmq.virtual-host}")
    private String virtualHost;

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(host);
        connectionFactory.setPort(port);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        connectionFactory.setVirtualHost(virtualHost);
        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate() {
        return new RabbitTemplate(connectionFactory());
    }
}

4. 定义RabbitMQ生产者

@Component
public class RabbitMQProducer {
    private static final String QUEUE_NAME = "my_queue";

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Bean
    public Queue queue() {
        return new Queue(QUEUE_NAME);
    }

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

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend(QUEUE_NAME, message);
        System.out.println("Sent message: " + message);
    }
}

在上面的代码中，我们定义了一个名为"my_queue"的队列，并使用@RabbitListener注解来监听该队列。在sendMessage方法中，我们使用RabbitTemplate将消息发送到队列中。

现在，我们可以在其他组件中注入RabbitMQProducer并调用它的sendMessage方法来发送消息到队列中。例如：

@RestController
public class MyController {
    @Autowired
    private RabbitMQProducer rabbitMQProducer;

    @GetMapping("/sendMessage")
    public void sendMessage() {
        rabbitMQProducer.sendMessage("Hello, RabbitMQ!");
    }
}

这样，当我们访问"/sendMessage"接口时，就会向"my_queue"队列发送一条消息。