1、創(chuàng)建連接工廠：
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost"); // 設(shè)置 RabbitMQ 服務(wù)器的主機(jī)地址
Connection connection = factory.newConnection(); // 創(chuàng)建連接
Channel channel = connection.createChannel(); // 創(chuàng)建通道
2、創(chuàng)建交換器和隊列：
String exchangeName = "my-exchange"; // 交換器名稱
String queueName = "my-queue"; // 隊列名稱
channel.exchangeDeclare(exchangeName, "direct", true, false, null); // 聲明直連型交換器
channel.queueDeclare(queueName, true, false, false, null); // 聲明隊列
綁定交換器和隊列：
java
channel.queueBind(queueName, exchangeName, "key"); // 將隊列綁定到交換器，使用指定的路由鍵
3、發(fā)送消息：
String message = "Hello, RabbitMQ!"; // 要發(fā)送的消息內(nèi)容
AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()
.contentType("text/plain") // 設(shè)置消息內(nèi)容類型
.build();
channel.basicPublish(exchangeName, "key", properties, message.getBytes("UTF-8")); // 發(fā)送消息到交換器
4、接收消息：
DefaultConsumer consumer = new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
String message = new String(body, "UTF-8");
System.out.println("Received message: " + message); // 處理接收到的消息
}
};
channel.basicConsume(queueName, true, consumer); // 啟動消費(fèi)者，監(jiān)聽隊列
在上述示例中，我們創(chuàng)建了一個連接工廠，并通過它建立與 RabbitMQ 服務(wù)器的連接和通道。然后，我們聲明了一個直連型交換器和一個隊列，并將它們綁定在一起。接下來，我們使用basicPublish方法發(fā)送消息到交換器，并使用basicConsume方法啟動消費(fèi)者來接收消息。文章來源：http://www.zghlxwxcb.cn/news/detail-855387.html
RabbitMQ 詳細(xì)操作步驟介紹
請注意，這只是一個簡單的示例，實(shí)際應(yīng)用中可能需要根據(jù)具體需求進(jìn)行更多的配置和處理，例如處理消息確認(rèn)、錯誤處理等。此外，還可以使用 RabbitMQ 的其他特性和功能，如主題交換器、Fanout 交換器、消息路由等。
希望這個示例對你有所幫助。如果你有任何進(jìn)一步的問題，請隨時提問。文章來源地址http://www.zghlxwxcb.cn/news/detail-855387.html
到了這里，關(guān)于如何使用 RabbitMQ 進(jìn)行消息的發(fā)送和接收的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
