zoukankan      html  css  js  c++  java
  • 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,还是蛮有意思的。

  • 相关阅读:
    函数指针
    动态内存
    char*和char[]的区别
    C语言基本数据类型大小
    html5新特性localStorage和sessionStorage
    Swoole实现h5版聊天室笔记
    php使用mysql之sql注入(功)
    Http协议工作特点和工作原理笔记
    原生js使用ajax
    php常用的几个预定义变量
  • 原文地址:https://www.cnblogs.com/yueerwanwan0204/p/5319474.html
Copyright © 2011-2022 走看看