把我的阿裡雲重置了一下,重新安裝rabbitmq,看看會出現什麼問題。 首先,把erlang環境安裝一下,直接 會找到上面這個庫,直接安裝就可以了。 安裝好erlang環境,再下載rabbitmq包。 為了方便,直接下載rpm包,rpm包地址是:http://www.rabbitmq.com/rel ...
把我的阿裡雲重置了一下,重新安裝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,還是蠻有意思的。