rabbitmq相关内容

在不禁用心跳的情况下保持 pika BlockingConnection 存活

我正在开发一个带有 pika 0.10.0 和 python 2.7 版本的 RabbitMQ 消费者.在我的消费者客户端中,我有一个根据输入消息运行一段时间的进程.它可以从 3 到 40 分钟不等.我不想禁用心跳.相反,我正在寻找一些可以使连接保持活动状态的回滚机制,直到将 delivery_tag 发回.这可能吗? 我得到的链接很少,都建议禁用心跳作为解决方法.但我不想禁用它. 参 ..
发布时间:2022-01-11 18:07:06 其他开发

AMQP 如何克服直接使用 TCP 的困难?

AMQP如何克服发送消息时直接使用TCP的困难?或者更具体地说是在发布/订阅场景中? 解决方案 在 AMQP 中有一个代理,该代理接收消息,然后完成将它们路由到交换和队列的困难部分.您还可以设置持久队列,即使客户端断开连接,也可以为客户端保存消息. 您当然可以自己完成所有这些工作,但要正确完成这些工作量很大.尤其是 RabbitMQ,已经在许多部署中进行了实战测试. 你还在使用 ..
发布时间:2022-01-11 18:06:45 其他开发

从 RabbitMQ 队列中检索消息

我希望在我的 PHP 应用程序中实现 RabbitMQ,并且正在使用 php-amqp 扩展.我唯一的问题是,如何轻松查询以返回 PHP 中的队列内容? php-amqp 似乎无法让我这样做.如果我错了,请在这里帮助我:) 解决方案 James,你能在rabbitmq-discuss上问这个问题吗?您的问题涉及“查询"队列以获取消息的含义.在 RabbitMQ 中,您使用来自队列的消 ..
发布时间:2022-01-11 18:06:24 PHP

如何使用 Java 在 RabbitMQ 中实现 Headers Exchange?

我是一个新手,试图在 java 客户端中实现 Headers 交换.我知道这就是“x-match"绑定参数的用途.当“x-match"参数设置为“any"时,只需一个匹配的标头值就足够了.或者,将“x-match"设置为“all"要求所有值必须匹配.但是任何人都可以为我提供一个框架代码以便更好地理解. 解决方案 对于使用 headers 交换,您只需将您的交换声明为 headers 类型: ..
发布时间:2022-01-11 18:06:07 Java开发

使用 RabbitMQ 发送对象

我知道这个问题与问题重复使用rabbitmq发送消息不是字符串而是结构 如果使用第一种方法来做到这一点 第一种方式 我有以下痕迹: java.io.EOFException在 java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2304)在 java.io.ObjectInputS ..
发布时间:2022-01-11 18:05:53 Java开发

更改 cookie 文件后 RabbitMQ 节点身份验证失败

我有多个 RabbitMQ 节点在不同的机器上运行.安装每个节点后,我未能为每个节点指定一个通用 cookie,因此我不得不返回并手动更改文件 .erlang.cookie .我的问题是,这样做之后,我收到了相互矛盾的错误消息.如果我做 rabbitmqctl status我收到以下错误: 诊断 尝试联系:['rabbit@nc-mso-test01'] rabbit@nc-ms ..
发布时间:2022-01-11 18:05:36 其他开发

删除 celery 中的 Task/PeriodicTask

如何删除 celery 中的常规 Task 或 PeriodicTask? 解决方案 您撤销任务:参见文档: Control.revoke(task_id, destination=None, terminate=False, signal='SIGTERM', **kwargs)告诉所有(或特定的)工作人员通过 id 撤销任务.如果一个任务被撤销,worker 将忽略该任务并且根本不执 ..
发布时间:2022-01-11 18:05:28 Python

Rabbitmq 消息到达时间戳

有没有办法从消费者那里获取消息放入队列时的时间戳.不是发布的时间,而是实际进入队列的时间. 解决方案 不,没有办法解决这个问题,除非你声明自己为此编写了一个插件.AMQP 规范中没有任何内容表明消息必须知道它何时到达队列. 从 AMQP 的角度来看,没有必要知道这一点.还有很多情况下,消息可能会经过几个队列,那么哪个队列应该代表相关的时间戳? ..
发布时间:2022-01-11 18:05:13 C#/.NET

鼠兔,停止消费不起作用

我是 rabbitmq 和 pika 的新手,并且无法停止消费. 频道和队列设置: connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))通道 = 连接.通道()channel.queue_declare(queue=new_task_id,durable=True,auto_delete=T ..
发布时间:2022-01-11 18:05:06 Python

.NET 中带有 Unity IOC 容器的 RabbitMQ

我正在使用 Unity App Block 作为我的 IOC 容器,用于 WCF 项目的服务层.使用 Unity.WCF 库将其插入每个 WCF 服务时效果很好. 我最近将 RabbitMQ 引入了我的服务层,我目前正在使用“使用"块来连接并添加到队列中.我不喜欢这样,我希望使用 HierachicalLifetimeManager 来创建和销毁我与 RabbitMQ 的连接,因为我需要它们 ..
发布时间:2022-01-11 18:04:57 C#/.NET

过期的消息不会从 RabbitMQ 中删除

我通过生产者向 RabbitMQ 发送一条普通消息,然后我发送第二条消息,其中 expiration 属性分配了一个值.然后使用 rabbitmqctl list_queues 命令监控消息的状态. 我发现,如果我先发送一条普通消息,然后发送一条带有 expiration 的消息,rabbitmqctl list_queues 总是向我显示队列中的 2 条待处理消息.当我食用它们时,我只会得 ..
发布时间:2022-01-11 18:04:51 其他开发

RabbitMQ/Celery/Django 内存泄漏?

我最近接手了我公司正在进行的项目的另一部分,并发现我们的 RabbitMQ/Celery 设置中似乎存在内存泄漏. 我们的系统有 2Gb 的内存,在任何给定时间大约有 1.8Gb 可用.我们有多个任务处理大量数据并将它们添加到我们的数据库中. 当这些任务运行时,它们会消耗相当多的内存,很快我们的可用内存就会下降到 16Mb 到 300Mb 之间的任何地方.问题是,这些任务完成后,内存并 ..
发布时间:2022-01-11 18:04:34 其他开发

从 Docker 容器到本地主机的 Rabbitmq 连接被拒绝

我有一个运行 java 进程的 docker 容器,我试图连接到在我的本地主机上运行的 rabbitmq. 到目前为止,我已经完成了以下步骤: 在我的本地机器上(运行 Docker 版本 1.13.0-rc3 的 macbook,构建 4d92237 并关闭防火墙) 我已经更新了我的 rabbitmq_env.conf 文件以删除 RABBITMQ_NODE_IP_ADDRESS ..
发布时间:2022-01-11 18:04:26 其他开发

Erlang 机器立即停止(分发名称冲突?).服务未重新启动,因为 OnFail 设置为忽略

我正在使用 RabbitMQ.由于某种原因,rabbitMQ 服务在您启动后立即停止.我在事件日志中看到以下错误: RabbitMQ:Erlang 机器立即停止(分发名称冲突?).由于 OnFail 设置为忽略,服务不会重新启动. 有人告诉我运行这个命令:erl -sname rabbit 此命令生成以下输出: {(no error logger present")i neirtr o ..
发布时间:2022-01-11 18:04:18 其他开发

使用 RabbitMQ 的 MassTransit:消息何时移至错误队列

我正在使用 RabbitMQ 版本 3.0.2 &我在错误队列中看到近 1000 条消息.我想知道 消息何时移至错误队列? 有没有办法知道为什么某条消息被移动到错误队列中? 有没有办法将消息从错误队列移动到正常队列? 谢谢 解决方案 a) 他们未能反序列化或 b) 消费者抛出异常处理该消息五次 不是...如果您查看队列中的消息,有效负载标头可能包含注释,但我认为我们没有这 ..
发布时间:2022-01-11 18:04:10 其他开发