前一篇寫了在Windows下的安裝使用,這次記錄下CentOS6.7下的安裝使用.

其實在CentOS下和Windows下過程是一樣的,都是 先安裝Erlang環境,再安裝RabbitMQ Server.

只不過CentOS下經常遇到各種問題,所以感覺上麻煩點.

主要分以下部分

1)安裝Erlang環境

2)安裝RabbitMQ Server

3)啟動server,並啟用管理臺外掛

4)新增使用者並設定許可權

5)外網登入管理臺

6)程式碼連線CentOS下的MQ

7)遇到的問題及解決辦法

1)安裝Erlang環境

官網提供了3種安裝方法,我這裡用第一種.

我最開始 選擇了centos,然後下載19.1.5這個版本, 然後進行安裝發現少一堆包.

最後還是安裝網頁下發的 說明進行線上安裝

首先

wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm
rpm -Uvh erlang-solutions-1.0-1.noarch.rpm

這2句一般不會遇到問題,然後

sudo yum install erlang

http://packages.erlang-solutions.com/rpm/centos/6/x86_64/repodata/primary.xml.gz: [Errno -1] Metadata file does not match checksum
Trying other mirror.
erlang-solutions/primary                                                                                                                                                   | 869 kB     00:00     
http://packages.erlang-solutions.com/rpm/centos/6/x86_64/repodata/primary.xml.gz: [Errno -1] Metadata file does not match checksum
Trying other mirror.
Error: failure: repodata/primary.xml.gz from erlang-solutions: [Errno 256] No more mirrors to try.
 

因為網速慢,遇到問題2

[Errno 12] Timeout on

Erlang安裝完成.

2)安裝RabbitMQ Server

需要先下載 rpm檔案 , (上面給的官網安裝地址 最上面就有下載的地方)

然後執行下面命令

rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc
yum install rabbitmq-server-3.6.5-1.noarch.rpm

遇到問題3

Error: Package: rabbitmq-server-3.6.5-1.noarch (/rabbitmq-server-3.6.5-1.noarch)
           Requires: socat

完成安裝

3)啟動server,並啟用管理臺外掛

執行	whereis rabbitmq
結果	rabbitmq: /etc/rabbitmq /usr/lib/rabbitmq
執行	cd /usr/lib/rabbitmq/bin
執行	rabbitmq-server start

              RabbitMQ 3.6.5. Copyright (C) 2007-2016 Pivotal Software, Inc.
  ##  ##      Licensed under the MPL.  See http://www.rabbitmq.com/
  ##  ##
  ##########  Logs: /var/log/rabbitmq/[email protected]
  ######  ##        /var/log/rabbitmq/[email protected]
  ##########
              Starting broker...
 completed with 0 plugins.

[[email protected] bin]# rabbitmq-plugins enable rabbitmq_management
The following plugins have been enabled:
  mochiweb
  webmachine
  rabbitmq_web_dispatch
  amqp_client
  rabbitmq_management_agent
  rabbitmq_management

Applying plugin configuration to [email protected] failed.
 * Could not contact node [email protected]
   Changes will take effect at broker restart.
 * Options: --online  - fail if broker cannot be contacted.
            --offline - do not try to contact broker.

這裡出現了 contact node [email protected] 的提示,但是當時沒注意,就繼續往下了

執行啟動命令. 啟動完成

整體如下圖

啟動完成.

4)新增使用者並設定許可權

因為假想中這是伺服器,我們平時訪問肯定都是在外網,所以預設的guest只能在本機使用肯定不行了.(官方推薦刪掉guest或者修改密碼)

所以我們需要新增一個可以外網訪問的使用者.

可以在頁面新增(更簡單一點),也可以用命令新增. 我們這裡用命令

rabbitmqctl  add_user  admin  123456

解決方法見7)中的問題4.解決後繼續

rabbitmqctl set_user_tags admin administrator
rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"

上面2句分別是設定角色(非官方說法),設定外網登入許可權

OK.新增使用者授權完成.

5)外網登入管理臺

在本地瀏覽器輸入CentOS的管理臺地址 http://192.168.1.100:15672/

這裡要注意下centos的防火牆狀態,我測試就直接把防火牆關了

關閉防火牆
/etc/init.d/iptables stop

如果登入失敗,返回狀態是401的話,就是許可權設定的有問題.

6)程式碼連線CentOS下的MQ

程式碼和上一篇Windows下的基本一樣,只是需要指定下IP,使用者名稱,密碼

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


public class Send {
  private final static String QUEUE_NAME = "hello";


  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("192.168.1.100");
    factory.setUsername("admin");
    factory.setPassword("123456");
    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(" [x] Sent '" + message + "'");


    channel.close();
    connection.close();
  }
}

接收的類也一樣

import com.rabbitmq.client.*;


import java.io.IOException;


public class Recv {

  private final static String QUEUE_NAME = "hello";

  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("192.168.1.100");
    factory.setUsername("admin");
    factory.setPassword("123456");
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();

    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

    Consumer consumer = new DefaultConsumer(channel) {
      @Override
      public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
          throws IOException {
    	  System.out.println("consumerTag"+consumerTag);
    	  System.out.println("properties"+properties.getMessageId());
        String message = new String(body, "UTF-8");
        System.out.println(" [x] Received '" + message + "'");
      }
    };
    channel.basicConsume(QUEUE_NAME, true, consumer);
  }
}

執行程式碼,成功執行.

7)遇到的問題及解決辦法

問題1

http://packages.erlang-solutions.com/rpm/centos/6/x86_64/repodata/primary.xml.gz: [Errno -1] Metadata file does not match checksum
Trying other mirror.

先安裝網上的  yum clean all 發現沒解決.

繼續深入

wget --no-cache http://packages.erlang-solutions.com/rpm/centos/6/x86_64/repodata/primary.xml.gz
sha1sum primary.xml.gz

得到下面的
1572f7949d751054a14e0b24ea3f2592633d06c4  primary.xml.gz

cd /var/cache/yum/x86_64/6/erlang-solutions
vim repomd.xml

發現裡面的數值和我們計算的不一致,則修改成上面計算的.(下面是我修改後的)

  <data type="primary">
    <location href="repodata/primary.xml.gz"/>
    <checksum type="sha">1572f7949d751054a14e0b24ea3f2592633d06c4</checksum>
    <timestamp>1478542719</timestamp>
    <open-checksum type="sha">61989f5a64efd4daecd0d719457a47a2290b7126</open-checksum>
  </data>

搞定!

問題2

[Errno 12] Timeout on

vim /etc/yum.conf	

問題3

Error: Package: rabbitmq-server-3.6.5-1.noarch (/rabbitmq-server-3.6.5-1.noarch)
           Requires: socat

yum install socat

	Loaded plugins: fastestmirror, refresh-packagekit, security
	Setting up Install Process
	Loading mirror speeds from cached hostfile
	 * base: mirrors.btte.net
	 * extras: mirrors.btte.net
	 * updates: mirror.bit.edu.cn
	No package socat available.
	Error: Nothing to do

wget --no-cache http://www.convirture.com/repos/definitions/rhel/6.x/convirt.repo -O /etc/yum.repos.d/convirt.repo
yum install socat
yum install rabbitmq-server-3.6.5-1.noarch.rpm

Error: unable to connect to node [email protected]: nodedown

service rabbitmq-server restart