RabbitMQ day 1 (install)

RabbitMQ 安裝

這邊使用的是 CentOS-6.8 安裝 rabbitmq．安裝 rabbitmq 前要先安裝 erlang，安裝指令步驟 :

yum install epel-release (安裝epel擴充資源庫)
yum install erlang
確認 erlang 版本指令 : erl -version
yum install rabbitmq-server

預設開機要啟動 :

chkconfig rabbitmq-server on

啟動 rabbitmq server :

service rabbitmq-server start

查看 rabbitmq server 狀態 :

service rabbitmq-server status

停止 rabbitmq server :

service rabbitmq-server stop

安裝 web 管理介面

到 /usr/lib/rabbitmq/lib/rabbitmq_server-3.1.5/sbin 底下執行 :

./rabbitmq-plugins enable rabbitmq_management

重啟 rabbitmq server 後，輸入網址 http://localhost:15672，帳密都使用 guest 登入．

要連到 centos 先關閉防火牆，下 setup :

不要勾選，接著 OK 確認

Run Sample Code :

Maven project pom.xml :

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.simple</groupId>
  <artifactId>rabt</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>
  <name>rabt</name>
  <url>http://maven.apache.org</url>
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>
  <dependencies>
  <dependency>
      <groupId>com.rabbitmq</groupId>
      <artifactId>amqp-client</artifactId>
      <version>3.1.4</version>
  </dependency>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
  </dependencies>
</project>

Producer.java :

package com.simple.rabt;

import java.io.IOException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Producer {
  
  private final static String QUEUE_NAME = "hello";
  
  public static void main(String[] args) {
    try {
      ConnectionFactory factory = new ConnectionFactory();
          factory.setHost("192.168.56.102");
      Connection connection = factory.newConnection();
      Channel channel = connection.createChannel();
      channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
          String message = "Hello World!";  
          channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));  
          System.out.println("Produce [x] Send '" + message + "'");  
          channel.close();
          connection.close();
    } catch (IOException e) {
      e.printStackTrace();
    }   
  }
}

Consumer.java :

package com.simple.rabt;

import java.io.IOException;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;

public class Consumer {
  
  private final static String QUEUE_NAME = "hello";
  
  public static void main(String[] args) {
    
    try {
      ConnectionFactory factory = new ConnectionFactory();  
      factory.setHost("192.168.56.102");  
      Connection connection = factory.newConnection();
      Channel channel = connection.createChannel();  
          channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
          System.out.println("Consume [*] Waiting for messages. To exit press CTRL+C");  
          DefaultConsumer consumer = new DefaultConsumer(channel) {
              public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {  
                  String message = new String(body, "UTF-8");  
                  System.out.println("Consume [x] Received '" + message + "'");  
              }  
          };  
          channel.basicConsume(QUEUE_NAME, true, consumer);  
    } catch (IOException e) {
      e.printStackTrace();
    }  
  }
}

接著先執行 Consumer :

在 web 管理介面上，會看到有 Connections 在上面 :

上面看到的 IP 是 192.168.56.1 這 IP 是本機透過這個 Gateway 連到 Virtual Box 的 IP 192.168.56.102．附上我 Virtual Box 網卡的設定，設了兩張網卡(NAT是為了連外網、僅限主機介面卡是與本機溝通，在本機下 ifconfig 可看到192.168.56.1) :