关于openstack中队列池容量限制报错的解决
2013-12-13 00:00
239 查看
在server.log中报出如下错误:
显示为队列池容量问题,导致连接失败。
利用命令rabbitmqctl list_queues 查看队列信息,发现q_plugin队列中有150000条信息,别的队列都是空的,显然出问题了,应该是消息只进不出,原因在于消息队列堵塞,到底什么原因导致堵塞,不明确。
解决办法:写一个python脚本,把q_plugin队列中的所有消息取出,清空。
脚本代码:
import pika
connection=pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel=connection.channel()
channel.queue_declare(queue='q-plugin')
def callback(ch,method,properties,body):
print "Received %r" % (body,)
channel.basic_consume(callback,queue='q-plugin',no_ack=True)
channel.start_consuming()
说明:需要安装pika包
显示为队列池容量问题,导致连接失败。
利用命令rabbitmqctl list_queues 查看队列信息,发现q_plugin队列中有150000条信息,别的队列都是空的,显然出问题了,应该是消息只进不出,原因在于消息队列堵塞,到底什么原因导致堵塞,不明确。
解决办法:写一个python脚本,把q_plugin队列中的所有消息取出,清空。
脚本代码:
import pika
connection=pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel=connection.channel()
channel.queue_declare(queue='q-plugin')
def callback(ch,method,properties,body):
print "Received %r" % (body,)
channel.basic_consume(callback,queue='q-plugin',no_ack=True)
channel.start_consuming()
说明:需要安装pika包
相关文章推荐
- Linux 输入输出
- linux下实时查看tomcat运行日志
- java用url类实现的某个网站能不能被访问
- When PropertyChangedEventManager created/attached
- Shell 中数学计算总结
- CentOS 6.5 上使用Btrfs-安装集成工具包
- Eclipse配置Tomcat问题汇总
- Linux 常用命令——df, du, ln
- Linux内核的early_param原理追踪
- Linux加载驱动"invalid module format"错误的一种可能解决办法
- Hadoop全排序中的Sampler采样器
- 关于PHP写的投票网站之刷票终结版
- hadoop单线程实现server多socket连接读取数据原理分析
- Linux 常用指令
- SharePoint 2013 图文开发系列之InfoPath入门
- windows下git bash 乱码的问题解决
- 使用nginx sticky模块实现基于cookie的负载均衡
- 在Linux下编译WebkitGtk
- Linux 内存使用方法详细解析
- Linux 的启动流程