rabbitmq相关内容
我正在开发一个带有 pika 0.10.0 和 python 2.7 版本的 RabbitMQ 消费者.在我的消费者客户端中,我有一个根据输入消息运行一段时间的进程.它可以从 3 到 40 分钟不等.我不想禁用心跳.相反,我正在寻找一些可以使连接保持活动状态的回滚机制,直到将 delivery_tag 发回.这可能吗? 我得到的链接很少,都建议禁用心跳作为解决方法.但我不想禁用它. 参
..
我有一个 iOS 应用程序,它使用 STOMP 客户端 与
..
有没有办法使用 .NET 使用单个同步调用来接收多条消息? 我看过 question 并且找到了 java 类com.rabbitmq.client.QueueingConsumer,但是我在.NET 命名空间(RabbitMQ.Client、RabbitMQ.Client.Events)中没有找到这样的客户端类 解决方案 您可以使用 BasicQoS.PrefetchCount 检索任
..
AMQP如何克服发送消息时直接使用TCP的困难?或者更具体地说是在发布/订阅场景中? 解决方案 在 AMQP 中有一个代理,该代理接收消息,然后完成将它们路由到交换和队列的困难部分.您还可以设置持久队列,即使客户端断开连接,也可以为客户端保存消息. 您当然可以自己完成所有这些工作,但要正确完成这些工作量很大.尤其是 RabbitMQ,已经在许多部署中进行了实战测试. 你还在使用
..
我正在尝试在 RabbitMQ 中实现一个 dlx 队列.场景很简单我有 2 个队列:1) 活着2) dead (x-dead-letter-exchange: "immediate", x-message-ttl: 5000) 以及绑定到 1) 活着的“立即"交换 我试图运行这个例子:http://blog.james-carr.org/2012/03/30/rabbitmq-sen
..
我希望在我的 PHP 应用程序中实现 RabbitMQ,并且正在使用 php-amqp 扩展.我唯一的问题是,如何轻松查询以返回 PHP 中的队列内容? php-amqp 似乎无法让我这样做.如果我错了,请在这里帮助我:) 解决方案 James,你能在rabbitmq-discuss上问这个问题吗?您的问题涉及“查询"队列以获取消息的含义.在 RabbitMQ 中,您使用来自队列的消
..
我正在尝试使用 rabbitmq 的 HTTP API 从队列中获取一些消息. 我正在关注这里我没有配置 vhost. 我尝试了以下 curl 命令: curl -i -u guest:guest -H "content-type:application/json" -X POST http://127.0.0.1:15672/api/queues/foo/get -d'{"coun
..
我是一个新手,试图在 java 客户端中实现 Headers 交换.我知道这就是“x-match"绑定参数的用途.当“x-match"参数设置为“any"时,只需一个匹配的标头值就足够了.或者,将“x-match"设置为“all"要求所有值必须匹配.但是任何人都可以为我提供一个框架代码以便更好地理解. 解决方案 对于使用 headers 交换,您只需将您的交换声明为 headers 类型:
..
我知道这个问题与问题重复使用rabbitmq发送消息不是字符串而是结构 如果使用第一种方法来做到这一点 第一种方式 我有以下痕迹: java.io.EOFException在 java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2304)在 java.io.ObjectInputS
..
我有多个 RabbitMQ 节点在不同的机器上运行.安装每个节点后,我未能为每个节点指定一个通用 cookie,因此我不得不返回并手动更改文件 .erlang.cookie .我的问题是,这样做之后,我收到了相互矛盾的错误消息.如果我做 rabbitmqctl status我收到以下错误: 诊断 尝试联系:['rabbit@nc-mso-test01'] rabbit@nc-ms
..
如何删除 celery 中的常规 Task 或 PeriodicTask? 解决方案 您撤销任务:参见文档: Control.revoke(task_id, destination=None, terminate=False, signal='SIGTERM', **kwargs)告诉所有(或特定的)工作人员通过 id 撤销任务.如果一个任务被撤销,worker 将忽略该任务并且根本不执
..
有没有办法从消费者那里获取消息放入队列时的时间戳.不是发布的时间,而是实际进入队列的时间. 解决方案 不,没有办法解决这个问题,除非你声明自己为此编写了一个插件.AMQP 规范中没有任何内容表明消息必须知道它何时到达队列. 从 AMQP 的角度来看,没有必要知道这一点.还有很多情况下,消息可能会经过几个队列,那么哪个队列应该代表相关的时间戳?
..
我是 rabbitmq 和 pika 的新手,并且无法停止消费. 频道和队列设置: connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))通道 = 连接.通道()channel.queue_declare(queue=new_task_id,durable=True,auto_delete=T
..
我正在使用 Unity App Block 作为我的 IOC 容器,用于 WCF 项目的服务层.使用 Unity.WCF 库将其插入每个 WCF 服务时效果很好. 我最近将 RabbitMQ 引入了我的服务层,我目前正在使用“使用"块来连接并添加到队列中.我不喜欢这样,我希望使用 HierachicalLifetimeManager 来创建和销毁我与 RabbitMQ 的连接,因为我需要它们
..
我通过生产者向 RabbitMQ 发送一条普通消息,然后我发送第二条消息,其中 expiration 属性分配了一个值.然后使用 rabbitmqctl list_queues 命令监控消息的状态. 我发现,如果我先发送一条普通消息,然后发送一条带有 expiration 的消息,rabbitmqctl list_queues 总是向我显示队列中的 2 条待处理消息.当我食用它们时,我只会得
..
我最近接手了我公司正在进行的项目的另一部分,并发现我们的 RabbitMQ/Celery 设置中似乎存在内存泄漏. 我们的系统有 2Gb 的内存,在任何给定时间大约有 1.8Gb 可用.我们有多个任务处理大量数据并将它们添加到我们的数据库中. 当这些任务运行时,它们会消耗相当多的内存,很快我们的可用内存就会下降到 16Mb 到 300Mb 之间的任何地方.问题是,这些任务完成后,内存并
..
我有一个运行 java 进程的 docker 容器,我试图连接到在我的本地主机上运行的 rabbitmq. 到目前为止,我已经完成了以下步骤: 在我的本地机器上(运行 Docker 版本 1.13.0-rc3 的 macbook,构建 4d92237 并关闭防火墙) 我已经更新了我的 rabbitmq_env.conf 文件以删除 RABBITMQ_NODE_IP_ADDRESS
..
我正在使用 RabbitMQ.由于某种原因,rabbitMQ 服务在您启动后立即停止.我在事件日志中看到以下错误: RabbitMQ:Erlang 机器立即停止(分发名称冲突?).由于 OnFail 设置为忽略,服务不会重新启动. 有人告诉我运行这个命令:erl -sname rabbit 此命令生成以下输出: {(no error logger present")i neirtr o
..
我正在使用 RabbitMQ 版本 3.0.2 &我在错误队列中看到近 1000 条消息.我想知道 消息何时移至错误队列? 有没有办法知道为什么某条消息被移动到错误队列中? 有没有办法将消息从错误队列移动到正常队列? 谢谢 解决方案 a) 他们未能反序列化或 b) 消费者抛出异常处理该消息五次 不是...如果您查看队列中的消息,有效负载标头可能包含注释,但我认为我们没有这
..
我在服务器和我的系统上安装了 rabbitmq 服务.我想使用 RPC 模式: var factory = new ConnectionFactory() {主机名 = "158.2.14.42",端口 = Protocols.DefaultProtocol.DefaultPort,UserName = "管理员",密码 = "@server@",虚拟主机 = "/"ContinuationTi
..