标签: rabbitmqctl

我安装rabbitmqadmin并能够列出所有的交换和队列.我如何使用rabbitmqadmin或rabbitmqctl删除所有队列.

是否可以直接从命令行查看RabbitMQ消息内容？

sudo rabbitmqctl list_queues 列出队列.

有没有命令命令sudo rabbitmqctl list_queue_messages queue_name？

我正在使用rabbitmq来处理我工作的企业应用程序的数据库之间的消息.作为流程的一部分,我正在尝试帮助自动化服务器的设置(例如脚本).在此过程中,我尝试使用rabbitmqadmin从命令提示符声明交换.我有2个不同的服务器在运行CentOS 5.x,CentOS 6.x并且两个都有相同的问题.

到目前为止,我宣布了一个管理员用户并设置了密码,然后我将其标记设置为管理员标记,然后我确保它具有对vhost的权限.之后,我尝试声明交换,指定用户和密码,它失败.

rabbitmqctl add_user administrator password
rabbitmqctl set_user_tags administrator administrator
rabbitmqctl set_permissions -p / administrator ".*" ".*" ".*"
rabbitmqctl add_vhost vhostFoo
rabbitmqctl set_permissions -p vhostFoo administrator ".*" ".*" ".*"
rabbitmqadmin -u administrator -p password declare exchange --vhost=vhostFoo name=exchangeNew type=direct

对于CentOS 5.x盒子,我必须使用python26 rabbitmqadmin而不仅仅是rabbitmqadmin,但得到相同的结果.

最后一个命令导致:

*** Access refused: /api/exchanges/vhostFoo/exchangeNew

我的CentOS 5.x和Cent 6.x盒子都在运行rabbitmq 3.3.5.关于我缺少什么的想法或者我如何获得有关错误的更多信息的想法(例如错误日志文件或获得更详细输出的方式)？

我在Windows 2008 R2上运行带有Erlang OTP 17.1的RabbitMQ v3.3.5.我的Dev和QA环境是独立的.我的登台和生产环境是集群的.

我发现RabbitMQ服务正在运行时经常出现这个问题,RabbitMQ管理控制台正在查看所有内容,但是当我尝试从命令行运行rabbitmqctl时,它失败并显示节点已关闭的错误(在本地和在远程服务器).

如果我重新启动Windows服务,则会解决此问题.

我在RabbitMQ错误日志中看不到任何错误消息.最后一条消息表明节点已启动.

下面是我最近在登台窗口集群的节点2上遇到的问题的示例输出:

PS C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.3.5\sbin> .\rabbitmqctl.bat status
Status of node rabbit@MYSERVER2 ...
Error: unable to connect to node rabbit@MYSERVER2: nodedown

DIAGNOSTICS
===========

attempted to contact: [rabbit@MYSERVER2]

rabbit@MYSERVER2:
  * connected to epmd (port 4369) on MYSERVER2
  * epmd reports: node 'rabbit' not running at all
                  no other nodes on MYSERVER2
  * suggestion: start the node

current node details:
- node name: rabbitmqctl2199771@MYSERVER2
- home dir: C:\Users\RabbitMQ
- cookie hash: mn6OaTX9mS4DnZaiOzg8pA==

此时我重新启动RabbitMQ服务,然后再试一次 …

我想知道为什么我们需要routing key将消息路由exchange到队列.我们不能使用简单队列名来路由消息.此外,在发布到多个队列的情况下,我们可以使用多个队列名称.任何人都可以指出我们实际需要路由密钥的场景,队列名称是不够的.

我想默认为我的所有队列定义镜像.rabbitmqctl一旦节点启动,我目前必须使用:

rabbitmqctl set_policy ha-all "" '{"ha-mode":"all"}'

如果我的一个节点发生故障,我必须记得在重启时重新执行该代码.

有没有办法自动配置我的节点使用镜像队列？

我用docker来启动我的rabbitmqserver.如何使用rabbitmqctl连接到docker容器中的rabbitmqserver？

端口5672已暴露并映射到我的主机的5672端口.但我仍然收到以下错误:

Status of node rabbit@m2 ...
Error: unable to connect to node rabbit@m2: nodedown

我正在尝试安装rabbitmq.erlang即OTP 18.1文件的安装已成功完成,并且rabbitmq安装也成功完成.但是当我尝试连接rabbitmq时,我收到以下错误:

C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.5.6\sbin>rabbitmq-plugins.bat enable rabbitmq_management
Plugin configuration unchanged.
Applying plugin configuration to rabbit@INLN50899724A... failed.
 * Could not contact node rabbit@INLN50899724A.
   Changes will take effect at broker restart.
 * Options: --online  - fail if broker cannot be contacted.
            --offline - do not try to contact broker.
C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.5.6\sbin>rabbitmq-server restart
ERROR: epmd error for host INLN50899724A: address (cannot connect to host/port)

点击下面查看包含错误错误Empd Rabbitmq的图像

我在Windows操作系统上有一个RabbitMQ节点.我想在命令行中使用具有最少先决条件的脚本在该节点上创建vhost.

编辑:我试图使用rabbitmqctl add_vhost但我总是得到一个错误.

我安装了rabbitmq并正常工作,我知道如何接收日志,但不知道如何将其显示到带烧瓶的UI.

flask_app.py

from flask import Flask
from threading import Thread
app = Flask(__name__)
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.exchange_declare(exchange='logs',
                     type='fanout')

result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

channel.queue_bind(exchange='logs',
               queue=queue_name)

print('[*] Waiting for logs. To exit press CTRL+C')
def callback(ch, method, properties, body):
    print(body)

channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=True)

thread = Thread(channel.start_consuming())
thread.start()

@app.route('/')
def index():
    return 'hi'

我不知道如何使用多线程来运行flask应用程序并不断从队列接收日志.