代码拉取完成,页面将自动刷新
sudo apt-get install erlang-nox
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
添加admin用户,密码设置为admin。
sudo rabbitmqctl add_user admin admin
赋予权限
sudo rabbitmqctl set_user_tags admin administrator
赋予virtual host中所有资源的配置、写、读权限以便管理其中的资源
sudo rabbitmqctl set_permissions -p / admin '.*' '.*' '.*'
rabbitmqctl start_app
rabbitmq-plugins enable rabbitmq_management
rabbitmqctl stop
浏览器访问http://192.168.137.3:15672(我的ubuntu地址是192.168.137.3)
rabbitmqctl list_queues 查看队列
如何安全的吃包子
消费者端吃完包子返回包子标识符
ch.basic_ack(delivery_tag=method.delivery_tag)
# no_ack=True
队列持久化
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
)
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。