标签: rabbitmq

如果我的理解是正确的,你实际上无法查看兔子队列中的消息而不将它们取出并将它们放回去.没有办法使用rabbitmqctl来检查队列.

在某些调试上下文中,了解队列中当前的内容非常有用.有没有办法得到消息？另外,Rabbit的设计是什么让这个过程变得麻烦？

Given ReadOnlyMemory Struct I want to convert the stream into a string

I have the following code:

var body = ea.Body; //ea.Body is of Type ReadOnlyMemory<byte>
var message = Encoding.UTF8.GetString(body);
Console.WriteLine(" [x] Received {0}", message);

And it gives the following error. I am using the latest C# with .NET CORE 3.1

Which is funny because I am literally copy pasting the Hello World example of a major product called RabbitMQ and it doesn't compile.

使用Python,Pika和RabbitMQ创建延迟(或停放)队列的最简单方法是什么？我见过类似的问题,但Python没有.

在设计应用程序时,我发现这是一个有用的想法,因为它允许我们限制需要重新排队的消息.

总是有可能你会收到比你能处理的更多的消息,可能是HTTP服务器很慢,或者数据库压力太大.

我还发现,在对丢失消息零容忍的情况下出现问题时非常有用,而重新排队无法处理的消息可能会解决这个问题.它也可能导致消息一次又一次排队的问题.可能导致性能问题,并记录垃圾邮件.

第19页的"RabbitMQ in Action"一书给出了独占和自动删除的描述:

exclusive - 设置为true时,您的队列将变为私有,并且只能由您的应用程序使用.当您需要将队列限制为仅一个使用者时,这非常有用.

自动删除 - 当最后一个使用者取消订阅时,将自动删除该队列.如果您需要仅由一个使用者使用的临时队列,请将auto-delete与exclusive结合使用.当消费者断​​开连接时,队列将被删除.

但据我所知,使用独占时,自动删除是多余的.只需要独家.RabbitMQ 教程似乎就是这样说的

...一旦我们断开消费者,就应该删除队列.有一个独家标志:

result = channel.queue_declare(exclusive=True)

在该教程中没有提及自动删除,并且sudo rabbitmqctl list_bindings似乎表明在接收器消失后队列实际上被删除了.

在RabbitMQ/AMQP Java客户端中,您可以创建一个AMQP.BasicProperties.Builder,并将其用于build()实例AMQP.BasicProperties.然后,可以将此构建的属性实例用于各种重要事项.此构建器类上有许多"构建器"样式方法:

BasicProperties.Builder propsBuilder = new BasicProperties.Builder();
propsBuilder
    .appId(???)
    .clusterId(???)
    .contentEncoding(???)
    .contentType(???)
    .correlationId(???)
    .deliveryMode(2)
    .expiration(???)
    .headers(???)
    .messageId(???)
    .priority(???)
    .replyTo(???)
    .timestamp(???)
    .type(???)
    .userId(???);

我正在寻找这些builer方法帮助"建立"的字段,最重要的是,每个字段存在哪些有效值.例如,什么是a clusterId,它的有效值是什么？什么是type有效值？等等.

我整个上午都在淘洗:

• Java客户端文档 ; 和
• Javadocs ; 和
• RabbitMQ完整参考指南 ; 和
• AMQP规范

在所有这些文档,我无法找到明确的定义(除了一些含糊的解释是什么priority,contentEncoding以及deliveryMode是)什么的每个领域都,以及他们的有效值.有人知道吗？更重要的是,有人知道这些甚至记录在哪里吗？提前致谢!

我正在尝试设置我的第一个RabbitMQ死信交换,这是我通过Web管理界面使用的步骤:

1. 创建名为"dead.letter.test"的新DIRECT交换
2. 创建新队列"dead.letter.queue"
3. 将"dead.letter.queue"绑定到"dead.letter.test"
4. 创建新队列"test1",将死信交换设置为"dead.letter.test"
5. 发送消息到"test1"
6. Nack(带有requeue = false)"test1"中的消息

我期待这些步骤应该通过"dead.letter.test"交换记录到"dead.letter.queue".这不会发生.

我可以手动将消息放入"dead.letter.test"交换中,它显示在"dead.letter.queue"中,所以我知道这很好.

当我查看管理UI时,它显示在队列"test1"上设置了DLX参数.

我哪里错了？

有谁知道是否有办法从客户端应用程序检查RabbitMQ队列中的消息数量？

我正在使用.NET客户端库.

RabbitMQ如何与Mule相比,我将使用面向消息的架构构建一个应用程序,而AMQP(RabbitMQ)提供了我想要的一切,但我对如此多的相关技术选择和ESB等类似概念感到困惑.如果我在不考虑其他选择的情况下做出选择,我有一个疑问.

我很清楚RabbitMQ是一个消息代理,它帮助我调解生产者和消费者之间的消息(所有形式或发布订阅,我可以理解它如何从真实的例子中使用,如twitter,或Facebook更新等)

什么是骡子,如果我能用骡子实现我在RabbitMQ中做的事情,我应该考虑类似于RabbitMQ的骡子吗？

mule的目标是否与消息代理的目标不同？

mule是否假设底层有一个消息代理将消息传递给适当的mule监听器(我可以在RabbitMQ中轻松编写监听器)

mule是一个完整的Java基础系统(我用RabbitMQ做的当前实验花了我不到30分钟编写一个简单的RPC客户端服务器,客户端作为C#和服务器作为Java,这样的事情很容易在Mule中完成).

我已经安装了rabbitmq ubuntu并尝试使用它启动它rabbitmq-server start,但是,我收到此错误:

Activating RabbitMQ plugins ...

0 plugins activated:

node with name "rabbit" already running on "mybox"

diagnostics:

- nodes and their ports on mybox: [{rabbit,38618},
                                       {rabbitmqprelaunch13346,41776}]
- current node: rabbitmqprelaunch13346@mybox
- current node home dir: /var/lib/rabbitmq
- current node cookie hash: 8QRKGluOJOcZ4AAkEdFwQg==

所以我尝试停止它或重新启动它service rabbitmq-server restart但我得到以下错误:Restarting rabbitmq-server: RabbitMQ is not running

服务器的主机名hostname -s是mybox.

如何停止当前运行的实例,或者至少如何管理它？我无法访问它,但我无法正常运行rabbitmq.

谢谢.

我在OS X上安装了RabbitMQ服务器,并在命令行启动它.现在,我不应该如何阻止它运行？我做了之后:

sudo rabbitmq-server -detached

我明白了:

Activating RabbitMQ plugins ...
0 plugins activated:

就是这样.我该如何正确关闭它？在文档中,它提到了使用rabbitmqctl(1),但我不清楚这意味着什么.谢谢.

编辑:根据下面的评论,这是我运行的sudo rabbitmqctl stop:

(project_env)mlstr-1:Package mlstr$ sudo rabbitmqctl stop
Password:
Stopping and halting node rabbit@h002 ...
Error: unable to connect to node rabbit@h002: nodedown

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

nodes in question: [rabbit@h002]

hosts, their running nodes and ports:
- h002: [{rabbit,62428},{rabbitmqctl7069,64735}]

current node details:
- node name: rabbitmqctl7069@h002
- home dir: /opt/local/var/lib/rabbitmq
- cookie hash: q7VU0JjCd0VG7jOEF9Hf/g==

为什么还有"当前节点"？我没有运行任何客户端程序,只有RabbitMQ服务器,这是否意味着服务器仍在运行？