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() 方法来声明队列，该方法在队列不存在时创建队列。