1. 程式人生 > >RabbitMQ(二):例項demo

RabbitMQ(二):例項demo

1、Windows下RabbitMQ的安裝

下載Erlang,地址:http://www.erlang.org/download/otp_win32_R15B.exe ,雙擊安裝即可(首先裝)

下載RabbitMQ,地址:http://www.rabbitmq.com/releases/rabbitmq-server/v3.3.4/rabbitmq-server-3.3.4.exe ,雙擊安裝即可

下載rabbit-client.jar ,Java程式碼時需要匯入。地址:http://www.rabbitmq.com/releases/rabbitmq-java-client/v3.3.4/rabbitmq-java-client-bin-3.3.4.zip

安裝完成後,在RabbitMQ的安裝目錄的sbin先會有:rabbitmq-server.bat

例如:


在cmd下:進入sbin目錄,執行rabbitmq-server start


2、介紹

RabbitMQ 是資訊傳輸的中間者。本質上,他從生產者(producers)接收訊息,轉發這些訊息給消費者(consumers).換句話說,他能夠按根據你指定的規則進行訊息轉發、緩衝、和持久化。

RabbitMQ 的一些常見的術語:
Producing意味著無非是傳送。一個傳送訊息的程式是一個producer(生產者)。一般用下圖表示Producer:


Queue(佇列)類似郵箱。依存於RabbitMQ內部。雖然訊息通過RabbitMQ在你的應用中傳遞,但是它們只能儲存在queue中。佇列不受任何限制,可以儲存任何數量的訊息—本質上是一個無限制的快取。很多producers可以通過同一個佇列傳送訊息,相同的很多consumers可以從同一個佇列上接收訊息。一般用下圖表示佇列:


Consuming(消費)類似於接收。consumer是基本屬於等待接收訊息的程式。一般使用下圖表示Consumer:


注意:producer(生產者),consumer(消費者),broker(RabbitMQ服務)並不需要部署在同一臺機器上,實際上在大多數實際的應用中,也不會部署在同一臺機器上。


2、Java入門例項
 一個producer傳送訊息,一個接收者接收訊息,並在控制檯打印出來。如下圖:

注:需要在官網下載rabbitmq-java-client-bin-*.zip將jar放入專案的classpath.

傳送端:Send.java 連線到RabbitMQ(此時服務需要啟動),傳送一條資料,然後退出。


  1. package com.zhy.rabbit._01;  
  2. import com.rabbitmq.client.Channel;  
  3. import com.rabbitmq.client.Connection;  
  4. import com.rabbitmq.client.ConnectionFactory;  
  5. publicclass Send  
  6. {  
  7.     //佇列名稱
  8.     privatefinalstatic String QUEUE_NAME = "hello";  
  9.     publicstaticvoid main(String[] argv) throws java.io.IOException  
  10.     {  
  11.         /** 
  12.          * 建立連線連線到MabbitMQ 
  13.          */
  14.         ConnectionFactory factory = new ConnectionFactory();  
  15.         //設定MabbitMQ所在主機ip或者主機名
  16.         factory.setHost("localhost");  
  17.         //建立一個連線
  18.         Connection connection = factory.newConnection();  
  19.         //建立一個頻道
  20.         Channel channel = connection.createChannel();  
  21.         //指定一個佇列
  22.         channel.queueDeclare(QUEUE_NAME, falsefalsefalsenull);  
  23.         //傳送的訊息
  24.         String message = "hello world!";  
  25.         //往佇列中發出一條訊息
  26.         channel.basicPublish("", QUEUE_NAME, null, message.getBytes());  
  27.         System.out.println(" [x] Sent '" + message + "'");  
  28.         //關閉頻道和連線
  29.         channel.close();  
  30.         connection.close();  
  31.      }  
  32. }  


值得注意的是佇列只會在它不存在的時候建立,多次宣告並不會重複建立。資訊的內容是位元組陣列,也就意味著你可以傳遞任何資料。

接收端:Recv.java 不斷等待伺服器推送訊息,然後在控制檯輸出。

  1. package com.zhy.rabbit._01;  
  2. import com.rabbitmq.client.Channel;  
  3. import com.rabbitmq.client.Connection;  
  4. import com.rabbitmq.client.ConnectionFactory;  
  5. import com.rabbitmq.client.QueueingConsumer;  
  6. publicclass Recv  
  7. {  
  8.     //佇列名稱
  9.     privatefinalstatic String QUEUE_NAME = "hello";  
  10.     publicstaticvoid main(String[] argv) throws java.io.IOException,  
  11.             java.lang.InterruptedException  
  12.     {  
  13.         //開啟連線和建立頻道,與傳送端一樣
  14.         ConnectionFactory factory = new ConnectionFactory();  
  15.         factory.setHost("localhost");  
  16.         Connection connection = factory.newConnection();  
  17.         Channel channel = connection.createChannel();  
  18.         //宣告佇列,主要為了防止訊息接收者先執行此程式,佇列還不存在時建立佇列。
  19.         channel.queueDeclare(QUEUE_NAME, falsefalsefalsenull);  
  20.         System.out.println(" [*] Waiting for messages. To exit press CTRL+C");  
  21.         //建立佇列消費者
  22.         QueueingConsumer consumer = new QueueingConsumer(channel);  
  23.         //指定消費佇列
  24.         channel.basicConsume(QUEUE_NAME, true, consumer);  
  25.         while (true)  
  26.         {  
  27.             //nextDelivery是一個阻塞方法(內部實現其實是阻塞佇列的take方法)
  28.             QueueingConsumer.Delivery delivery = consumer.nextDelivery();  
  29.             String message = new String(delivery.getBody());  
  30.             System.out.println(" [x] Received '" + message + "'");  
  31.         }  
  32.     }  
  33. }  

分別執行Send.java和Recv.java 順序無所謂。前提RabbitMQ服務開啟。

執行結果:

[x]Sent 'hello world!'

----------------------------------------

[*] Waiting for messages. To exitpress CTRL+C

[x] Received 'hello world!'