1 Star 0 Fork 1

张亚飞 / 消息队列rabbitmq

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

rabbitmq

消息中间件 -消息队列

  • 异步

开发语言erlang 爱立信公司

1、安装erlang:由于rabbitMq需要erlang语言的支持,在安装rabbitMq之前需要安装erlang

sudo apt-get install erlang-nox

2、安装、启动、停止、状态Rabbitmq

    sudo apt-get update                     
    sudo apt-get install rabbitmq-server  安装
    
    /etc/init.d/rabbitmq-server restart   启动
    sudo rabbitmq-server start          
    sudo rabbitmq-server stop
    sudo rabbitmq-server restart
    sudo rabbitmqctl status

3、添加用户,并赋予administrator权限

 添加admin用户密码设置为admin
        sudo rabbitmqctl add_user  admin  admin  
    赋予权限
        sudo rabbitmqctl set_user_tags admin administrator 
    赋予virtual host中所有资源的配置读权限以便管理其中的资源
        sudo rabbitmqctl  set_permissions -p / admin '.*' '.*' '.*'

4、Web管理器连接

    rabbitmqctl start_app
    rabbitmq-plugins enable rabbitmq_management
    rabbitmqctl stop
    浏览器访问http://192.168.137.3:15672我的ubuntu地址是192.168.137.3

    rabbitmqctl list_queues 查看队列

5、消息的安全接收

如何安全的吃包子

消费者端吃完包子返回包子标识符
ch.basic_ack(delivery_tag=method.delivery_tag)
# no_ack=True

6、持久化

队列持久化
channel.queue_declare(queue='task_queue',durable=True)
消息持久化  前提是队列持久化
channel.basic_publish(exchange='',
                      routing_key='task_queue',
                      body=message,
                      properties=pika.BasicProperties(
                          delivery_mode=2,  # make message persistent

)

  • RPC RPC
  • 启动web管理员界面 启动web管理员界面
  • 过滤消息 过滤消息
  • 更细致的过滤消息 更细致的过滤消息

空文件

简介

消息队列rabbitmq 展开 收起
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
1
https://gitee.com/zhangyafeii/rabbitmq.git
git@gitee.com:zhangyafeii/rabbitmq.git
zhangyafeii
rabbitmq
消息队列rabbitmq
master

搜索帮助