前提：下載配置好mq和虛擬機
下面是我使用的方法
點擊=安裝與配置

先創建maven小項目
demo結構

第一步

導入jar包

<dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version></dependency><dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.11.0</version></dependency></dependencies>

第二步

創建生產消息

public class Send {//生產消息@Testpublic void testSendMessage() throws IOException, TimeoutException {//創建連接mq的連接對象ConnectionFactory connectionFactory = new ConnectionFactory();//設置連接mq主機connectionFactory.setHost("192.168.192.168");//設置端口號connectionFactory.setPort(5672);//設置哪個虛擬主機connectionFactory.setVirtualHost("/ems");//設置訪問虛擬主機的用戶名和密碼connectionFactory.setUsername("ems");connectionFactory.setPassword("123");//獲取連接對象Connection connection = connectionFactory.newConnection();//通過連接通道Channel channel = connection.createChannel();//通道綁定對應消息隊列//參數1：隊列名稱 --如果不存在,會自動創建//參數2：定義定義隊列特性是否要持久化 ---true持久化隊列 false不持久化//參數3：exclusive：是否獨占隊列 ---true獨占隊列 false不獨占//參數4：autoDelete：是否在消費完成后自動刪除隊列 ---ture自動刪除 false不自動刪除//參數5：額外附加參數channel.queueDeclare("hello.mq,hello.docker,helloworld",false,false,false,null);//發布消息//參數1：交換機名稱//參數2：隊列名稱//參數3：傳遞消息額外設置//參數4：消息的具體內容channel.basicPublish("","hello.mq,hello.docker,helloworld",null,"HelloRabbitMQ".getBytes());//關閉通道channel.close();//關閉主機connection.close();} }

運行之后到web界面查看有沒有消息隊列

總結

以上是生活随笔為你收集整理的rabbitmq连接java快速入门的全部內容，希望文章能夠幫你解決所遇到的問題。

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