一.在Linux中安裝RabbitMQ

　　通過Docker安裝：

　　　　獲取鏡像(選用management是帶有管理界面的)

docker pull rabbitmq:3.7.14-management

　　　　查看下載好的鏡像：docker images

　　　　運行鏡像：

docker run -d -p 5672:5672 -p 15672:15672 --name myrabbitmq 鏡像ID

　　　　打開端口號或關閉防火墻就可以遠程訪問其管理界面了，如下所示

　　　　

　　　　默認賬號密碼都是guest,登錄后頁面如圖所示：

　　　　　　

　　　　創建exchange：(exchange的作用是接收消息，并把消息放入隊列中)

　　　　　　

?

　　　　創建queue：

　　　　　　

?

　　　　exchange綁定queue：

　　　　　　

?

　　　　exchange給隊列發送消息案例

?　　　　　　

?

　　　　點擊發送后，刷新queue，發現queue中多了一條消息

　　　　　　

?

　　　　再點進去后可以查看具體內容

　　　　　　

?

二.SpringBoot整合RabbitMQ

　　1.引入RabbitMQ依賴

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

?

　　2.配置RabbitMQ

spring.rabbitmq.host=192.168.2.129 #這里設置的端口是5672而不是15672 spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest

　　3.使用RabbitMQ

　　　　發送消息：

@Autowired RabbitTemplate rabbitTemplate; @Test public void test1() {String str = "你好";rabbitTemplate.convertAndSend("amq.direct", "myqueue" , str);//第一個參數是交換器，第二參數是判斷發送到哪個隊列而制定的規則，第三個是發送消息的內容(注意，交換器需要綁定隊列) }

　　　　獲取消息：

@Test
public void test2() {
Object myqueue = rabbitTemplate.receiveAndConvert("myqueue");//這里放的是隊列的名字，一次獲取一條消息，獲取后，隊列中的消息將會刪除
System.out.println(myqueue);
}

?　　　　使用代碼創建exchange和queue：

@Autowired AmqpAdmin amqpAdmin; @Testpublic void test3(){//創建exchangeamqpAdmin.declareExchange(new DirectExchange("test.exchange" , false , true));//exchange名稱，是否持久化 ，是否自動刪除，還可以添加參數類型//創建queueamqpAdmin.declareQueue(new Queue("testqueue" , false));//queue名稱，是否持久化，還可以添加是否自動刪除，參數類型等//創建綁定以及設置通信規則amqpAdmin.declareBinding(new Binding("testqueue",Binding.DestinationType.QUEUE,"test.exchange","test",null));//綁定的名稱，綁定類型，綁定的exchange，給隊列發送消息的規則，參數}

　　　　使用代碼刪除exchange和queue：

　　　　

?

?

轉載于:https://www.cnblogs.com/ywb-articles/p/10665492.html

總結

以上是生活随笔為你收集整理的RabbitMQ从安装到使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。