接上一篇《RabbitMQ-安裝篇（阿里云主機）-CSDN博客》

安裝好RabbitMQ后，我們將開始RabbitMQ的使用，根據(jù)官網(wǎng)文檔RabbitMQ Tutorials | RabbitMQ，我們一步一步的學習。

1. "Hello World!"

這里先說明幾個概念：

生產(chǎn)者：指消息的發(fā)送方，用圖例表示。

消費者：指消息的接收放，用圖例表示。

隊列(queue)：生產(chǎn)者發(fā)送的消息將被傳遞到隊列里，消費這從隊列中消費消息

下面以 生產(chǎn)者 發(fā)送消息到隊列，消費者從隊列里消費消息為例，演示如何調用（Java代碼）。

RabbitMQ支持多種協(xié)議。本教程使用AMQP0-9-1，它是一個開放的、通用的消息傳遞協(xié)議。

1.1 下載依賴項

下載客戶端庫客戶端連接庫及其依賴項（SLF4J API和SLF4J Simple）。將這些文件復制到您的工作目錄中，連同教程Java文件。

1.2 生產(chǎn)者代碼-Send.java

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.nio.charset.StandardCharsets;//生產(chǎn)者
public class Send {public static void main(String[] argv) throws Exception {// 創(chuàng)建連接ConnectionFactory factory = new ConnectionFactory();factory.setHost("【服務器地址】");factory.setPort(【端口：默認5672】);factory.setUsername("【賬號】");factory.setPassword("【密碼】");factory.setVirtualHost("【虛擬主機】");// 創(chuàng)建信道,發(fā)送消息String queueName = "rc.queue";try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) {channel.queueDeclare(queueName, true, false, false, null);String message = "Hello World!";channel.basicPublish("", queueName, null, message.getBytes(StandardCharsets.UTF_8));System.out.println(" [x] Sent '" + message + "'");}}
}

請將代碼中相關配置項設置為您自己的配置。

運行代碼，即可向RabbitMQ中的rc.queue隊列發(fā)送一條Hello World消息。（rc.queue為我自己創(chuàng)建的，請根據(jù)實際情況調整）

在RabbitMQ后臺可以查看到該隊列里的消息。

1.3 消費者代碼-Recv.java

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;
import java.nio.charset.StandardCharsets;//消費者
public class Recv {public static void main(String[] argv) throws Exception {// 創(chuàng)建連接ConnectionFactory factory = new ConnectionFactory();factory.setHost("【服務器地址】");factory.setPort(【端口：默認5672】);factory.setUsername("【賬號】");factory.setPassword("【密碼】");factory.setVirtualHost("【虛擬主機】");// 創(chuàng)建連接通道Connection connection = factory.newConnection();Channel channel = connection.createChannel();String queueName = "rc.queue";channel.queueDeclare(queueName, true, false, false, null);System.out.println(" [*] Waiting for messages. To exit press CTRL+C");DeliverCallback deliverCallback = (consumerTag, delivery) -> {String message = new String(delivery.getBody(), StandardCharsets.UTF_8);System.out.println(" [x] Received '" + message + "'");};channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {});}
}

運行結果

2.其他模式

調通了1種模式，其他模式類似的方式調試即可。RabbitMQ Tutorials | RabbitMQ

3.在Springboot中使用RabbitMQ??

3.1?添加依賴

在pom.xml中添加Spring Boot的RabbitMQ依賴。

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

?3.2 配置RabbitMQ

在application.properties或application.yml中配置RabbitMQ連接信息。

# application.properties
spring.rabbitmq.host=【服務器地址】
spring.rabbitmq.port=【端口：默認5672】
spring.rabbitmq.username=【用戶名】
spring.rabbitmq.password=【密碼】

spring:rabbitmq:host: 【服務器地址】port: 【端口：默認5672】username: 【用戶名】password: 【密碼】

?配置Queue、Exchange和Binding：

通過Java配置類定義消息隊列、交換器和它們之間的綁定關系。

（如果在RabbitMQ控制臺設置好了Queue、Exchange和Binding，無需下面的配置）

@Configuration
public class RabbitMQConfig {@BeanQueue myQueue() {return new Queue("your-queue-name", true);}@BeanDirectExchange myExchange() {return new DirectExchange("your-exchange");}@BeanBinding binding(Queue myQueue, DirectExchange myExchange) {return BindingBuilder.bind(myQueue).to(myExchange).with("your-routingKey");}
}

3.3 創(chuàng)建消息生產(chǎn)者

定義一個簡單的消息生產(chǎn)者類，使用@RabbitTemplate注解來發(fā)送消息到隊列：

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class MessageProducer {private final RabbitTemplate rabbitTemplate;@Autowiredpublic MessageProducer(RabbitTemplate rabbitTemplate) {this.rabbitTemplate = rabbitTemplate;}public void sendMessage(String message) {rabbitTemplate.convertAndSend("your-queue-name", message);}
}

3.4.創(chuàng)建消息消費者

定義一個消息消費者類，使用@RabbitListener注解來監(jiān)聽特定的隊列：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class MessageConsumer {@RabbitListener(queues = "your-queue-name")public void receiveMessage(String message) {System.out.println("Received message: " + message);}
}

3.5.啟動和測試

確保你的應用啟動類上有@EnableRabbit注解啟用RabbitMQ。確保你的RabbitMQ服務正在運行，并嘗試從你的應用中發(fā)送和接收消息。你可以通過調用MessageProducer中的sendMessage方法來測試發(fā)送功能，而接收功能應該自動觸發(fā)MessageConsumer中的receiveMessage方法。