centos上安裝rabbitmq而且python測試

把個人阿里雲重置了一下，從新安裝rabbitmq，看看會出現什麼問題。

首先，把erlang環境安裝一下，直接

yum list | grep erlang
erlang.x86_64                           R16B-03.16.el7                 epel

會找到上面這個庫，直接安裝就能夠了。

yum install erlang.x86_64

安裝好erlang環境，再下載rabbitmq包。

爲了方便，直接下載rpm包，rpm包地址是:http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.1/rabbitmq-server-3.6.1-1.noarch.rpm

下載好之後，直接安裝、啓動

rpm -ivh rabbitmq-server-3.6.1-1.noarch.rpm
service rabbitmq-server start

啓動好之後，能夠看看當前有哪些用戶

[root@iZ94mr3pnsgZ download]# rabbitmqctl list_users
Listing users ...
guest    [administrator]

只有一個guest，要再也不加一個吧。

[root@iZ94mr3pnsgZ download]# rabbitmqctl add_user yueer01 password

好了，如今有第二個用戶 yueer01，密碼本身設置一個。可是這個yueer01沒有權限，

[root@iZ94mr3pnsgZ download]# rabbitmqctl list_users
Listing users ...
yueer01    []
guest    [administrator]

再給它加一個權限，目前rabbitmq提供4種權限。

none
不能訪問 management plugin

management
用戶能夠經過AMQP作的任何事外加：
列出本身能夠經過AMQP登入的virtual hosts  
查看本身的virtual hosts中的queues, exchanges 和 bindings
查看和關閉本身的channels 和 connections
查看有關本身的virtual hosts的「全局」的統計信息，包含其餘用戶在這些virtual hosts中的活動。

policymaker 
management能夠作的任何事外加：
查看、建立和刪除本身的virtual hosts所屬的policies和parameters

monitoring  
management能夠作的任何事外加：
列出全部virtual hosts，包括他們不能登陸的virtual hosts
查看其餘用戶的connections和channels
查看節點級別的數據如clustering和memory使用狀況
查看真正的關於全部virtual hosts的全局的統計信息

administrator   
policymaker和monitoring能夠作的任何事外加:
建立和刪除virtual hosts
查看、建立和刪除users
查看建立和刪除permissions
關閉其餘用戶的connections

 

爲了省事，咱們設置爲administrator吧。

[root@iZ94mr3pnsgZ download]# rabbitmqctl set_user_tags yueer01 administrator
Setting tags for user "yueer01" to [administrator] ...
[root@iZ94mr3pnsgZ download]# rabbitmqctl list_users
Listing users ...
yueer01    [administrator]
guest    [administrator]

都是管理員了，但總是命令行，仍是不夠清晰，rabbitmq爲咱們提供了一套很是容易的web管理，只要一條命令就能夠啓動了。

[root@iZ94mr3pnsgZ download]# rabbitmq-plugins enable rabbitmq_management
The following plugins have been enabled:
  mochiweb
  webmachine
  rabbitmq_web_dispatch
  amqp_client
  rabbitmq_management_agent
  rabbitmq_management

打開瀏覽器，輸入id地址和端口，看看究竟是什麼。。。

http://your_ip_address:15672/

輸入剛纔申請的用戶名密碼，yueer01 password

進入web頁面。看我下面的：

 

這就能夠了，至於詳細內容，能夠本身去研究。

 

好了，至此，整個安裝過程已經完畢，那咱們用python代碼在本地運行一下，看看會發生什麼狀況。

從rabbitmq官方找它的例子，修改一下，例子以下：

# coding:utf-8
import pika

username = 'yueer01'
password = 'password'
host = '10.10.10.10'

credentials = pika.PlainCredentials(username, password)
connection = pika.BlockingConnection(pika.ConnectionParameters(host=host, credentials=credentials, port=5672))
channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')

print "[x] Sent 'Hello World!'"
connection.close()

呀！竟然報錯了，看看錯誤緣由

pika.exceptions.ProbableAccessDeniedError

被拒絕了，通常任何網絡服務，對於權限都有設置的，好比mysql, redis，容許遠程訪問的時候，都須要本身配置的，因此咱們也要把rabbitmq設置遠程訪問功能。

原來咱們還少設置了permissions，直接打開網頁，切換到admin目錄下面，能夠看到下面的截圖

No access，你能夠直接點擊用戶名，設置一個默認的，也能夠用命令設置

命令設置權限方式爲：

[root@iZ94mr3pnsgZ rabbitmq]# rabbitmqctl set_permissions -p '/' yueer01 ".*" ".*" ".*"
Setting permissions for user "yueer01" in vhost "/" ...

再截圖，就能夠發現明顯變化了

 

再次運行腳本，結果完美

[x] Sent 'Hello World!'

Process finished with exit code 0

 

這時候，你能夠在網頁的圖表中，觀察各類數據，整個過程很是清晰。

下面再寫一個接受的腳本，仍是從官網找個例子，修改一下，代碼以下：

# coding:utf-8
import pika

username = 'yueer01'
password = 'password'
host = 'your_ip_address'

credentials = pika.PlainCredentials(username, password)
connection = pika.BlockingConnection(pika.ConnectionParameters(
    host=host, credentials=credentials, port=5672
))

channel = connection.channel()
channel.queue_declare(queue='Hello')


def callback(ch, method, properties, body):
    print "[x] Received %r" % body

channel.basic_consume(callback, queue='hello', no_ack=True)

print '[*] Waiting for messages. To exit press CTRL+C'
channel.start_consuming()

運行一下，就能夠看到結果了。。

[*] Waiting for messages. To exit press CTRL+C
[x] Received 'Hello World!'
[x] Received 'Hello World!'

我剛纔運行了2次publish，因此接受到2個數據包。

至此，rabbitmq的基本應用已經基本完成。之後咱們還會講到怎麼在twisted裏面接受和發送數據，異步執行rabbitmq，仍是蠻有意思的。