centos上安裝rabbitmq並且python測試

来源:http://www.cnblogs.com/yueerwanwan0204/archive/2016/03/25/5319474.html
-Advertisement-
Play Games

把我的阿裡雲重置了一下,重新安裝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,還是蠻有意思的。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • activemq官網給出了3種master/slave的HA方案,詳見:http://activemq.apache.org/masterslave.html ,基於共用文件目錄,db,zookeeper。 下麵演示瞭如何在本機搭建基於zookeeper的activemq集群: 一、在目錄activ ...
  • 1、定義頭和根元素 部署描述符文件就像所有XML文件一樣,必須以一個XML頭開始。這個頭聲明可以使用的XML版本並給出文 件的字元編碼。 DOCYTPE聲明必須立即出現在此頭之後。這個聲明告訴伺服器適用的servlet規範的版本(如2.2或2.3)並 指定管理此文件其餘部分內容的語法的DTD(Doc... ...
  • CArchive允許以一個二進位的形式保存一個對象的複雜網路,也可以再次裝載它們,在記憶體中重新構造,這一過程叫作串列化/序列化(Serialization),簡單的說,CArchive與CFile配合使用可以以二進位讀取/保存數據到文件。 創建一個CArchive對象之前,你必須創建併成功打開一個C ...
  • 1.Question Description: sometimes, POJO bean contains another bean or collection as property, it's suitable for select data from more than one table. ...
  • Tomcat啟動報錯: 25-Mar-2016 10:40:43.478 SEVERE [main] org.apache.catalina.startup.Catalina.stopServer Could not contact localhost:8015. Tomcat may not be ...
  • 問題:使用 Canvas.DrawPath 繪製時,最後一點無法畫到終點位置。(這個問題要在粗線才能察覺) 適用:Delphi 10 Seattle (或更早的版本) for Android & iOS 修複方法: 請將源碼 FMX.StrokeBuilder.pas 複製到自己的工程目錄里,再進行 ...
  • 1、類型標註 之前不知道為啥別人寫的Swift語言的時候,定義常量或者變數的格式是 常量: let 常量名: 常量類型 = 常量值 或者 變數: var 變數名: 變數類型 = 初始值 原來書上有記載swift2.0上(如果要添加類型標註,需要在常量或者變數名後面加上一個冒號和空格,然後加上類型名稱 ...
  • 有錯誤的地方望各位好友幫忙修改,謝謝! ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...