用Java rabbitmq 主动发起请求实现代码

以下是一个简单的 Java 代码示例，用于向 RabbitMQ 发送一条消息：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Sender {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        String message = "Hello World!";
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
        System.out.println(" [x] Sent '" + message + "'");

        channel.close();
        connection.close();
    }
}

在这个例子中，我们创建了一个名为 "hello" 的队列。我们使用 channel.basicPublish() 方法向该队列发送一条消息。然后我们关闭通道和连接。

注意，我们使用了 ConnectionFactory 类来创建一个连接，该类可以设置 RabbitMQ 服务器的主机名和其他参数。我们还使用了 channel.queueDeclare() 方法来声明队列，该方法在队列不存在时创建队列