RabbitMQ 入門 Helloworld

原文地址：https://blog.csdn.net/lmj623565791/article/details/37607165

轉載請標明出處：http://blog.csdn.net/lmj623565791/article/details/37607165

本系列教程主要來自於官網入門教程的翻譯，而後本身進行了部分的修改與實驗，內容僅供參考。

「Hello world」 of RabbitMQ

一、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

二、介紹

RabbitMQ 是信息傳輸的中間者。本質上，他從生產者（producers）接收消息，轉發這些消息給消費者（consumers）.換句話說，他可以按根據你指定的規則進行消息轉發、緩衝、和持久化。

RabbitMQ 的一些常見的術語：
Producing意味着無非是發送。一個發送消息的程序是一個producer(生產者)。通常用下圖表示Producer：

Queue（隊列）相似郵箱。依存於RabbitMQ內部。雖然消息經過RabbitMQ在你的應用中傳遞，可是它們只能存儲在queue中。隊列不受任何限制，能夠存儲任何數量的消息—本質上是一個無限制的緩存。不少producers能夠經過同一個隊列發送消息，相同的不少consumers能夠從同一個隊列上接收消息。通常用下圖表示隊列：

Consuming（消費）相似於接收。consumer是基本屬於等待接收消息的程序。通常使用下圖表示Consumer:

 

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

 

二、Java入門實例
 一個producer發送消息，一個接收者接收消息，並在控制檯打印出來。以下圖：

 

 

注：須要在官網下載rabbitmq-java-client-bin-*.zip將jar放入項目的classpath.

發送端：Send.java 鏈接到RabbitMQ（此時服務須要啓動），發送一條數據，而後退出。

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

值得注意的是隊列只會在它不存在的時候建立，屢次聲明並不會重複建立。信息的內容是字節數組，也就意味着你能夠傳遞任何數據。

 

接收端：Recv.java 不斷等待服務器推送消息，而後在控制檯輸出。

 

1.  
   package com.zhy.rabbit._01;
2.  
    
3.  
   import com.rabbitmq.client.Channel;
4.  
   import com.rabbitmq.client.Connection;
5.  
   import com.rabbitmq.client.ConnectionFactory;
6.  
   import com.rabbitmq.client.QueueingConsumer;
7.  
    
8.  
   public class Recv
9.  
   {
10.  
    //隊列名稱
11.  
    private final static String QUEUE_NAME = "hello";
12.  
     
13.  
    public static void main(String[] argv) throws java.io.IOException,
14.  
    java.lang.InterruptedException
15.  
    {
16.  
    //打開鏈接和建立頻道，與發送端同樣
17.  
    ConnectionFactory factory = new ConnectionFactory();
18.  
    factory.setHost( "localhost");
19.  
    Connection connection = factory.newConnection();
20.  
    Channel channel = connection.createChannel();
21.  
    //聲明隊列，主要爲了防止消息接收者先運行此程序，隊列還不存在時建立隊列。
22.  
    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
23.  
    System.out.println( " [*] Waiting for messages. To exit press CTRL+C");
24.  
     
25.  
    //建立隊列消費者
26.  
    QueueingConsumer consumer = new QueueingConsumer(channel);
27.  
    //指定消費隊列
28.  
    channel.basicConsume(QUEUE_NAME, true, consumer);
29.  
    while (true)
30.  
    {
31.  
    //nextDelivery是一個阻塞方法（內部實現實際上是阻塞隊列的take方法）
32.  
    QueueingConsumer.Delivery delivery = consumer.nextDelivery();
33.  
    String message = new String(delivery.getBody());
34.  
    System.out.println( " [x] Received '" + message + "'");
35.  
    }
36.  
     
37.  
    }
38.  
    }

 

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

運行結果：

[x]Sent 'hello world!'

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

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

[x] Received 'hello world!'