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，仍是蛮有意思的。