rabbitmq相关内容

Sidekiq VS RabbitMQ

我们的Ruby on rails 4Web应用程序中需要一个排队系统 有什么不同,您为什么会/不会选择 Sidekiq胜过RabbitMQ? 推荐答案 不同的用法是完全不同的事情。Sidekiq是用于作业排队和处理的功能齐全的解决方案,而RabbitMQ只是一个消息代理,您可以在它的基础上构建您自己的东西。 ..
发布时间:2022-07-24 18:10:02 其他开发

如何根据标准限制并发消息消耗

场景(我已经简化了): 许多最终用户可以从前端Web应用程序(生产者)开始作业(繁重的作业,例如渲染大型PDF)。 作业被发送到单个持久RabbitMQ队列。 许多工作应用程序(使用者)处理这些作业并将结果写回数据存储中。 此相当标准的模式运行良好。 问题:如果用户在同一分钟内启动了10个作业,而在同一时间只有10个工作应用程序处于运行状态,则该最终用户实际上会占用自己的所有 ..
发布时间:2022-07-24 17:59:29 其他开发

单元测试骆驼/RabbitMQ路由问题

我在单元测试使用Rabbitmq作为代理的骆驼路由时遇到问题。 我已经研究了几个星期了,但还没有找到有效的方法来做到这一点。 首先,我在测试中没有调用rabbitmq时遇到了问题,并且将其保留为单元测试而不是集成测试。这是通过使用visicewith并将队列切换为模拟队列来实现的。 但是,使用以下代码时,消息不会到达结果队列或结束队列(MOBILE_QUEUE)。 java ..
发布时间:2022-06-25 17:36:53 其他开发

如何监听动态创建的队列?

我有一个rabbitListener,它可以持续地异步监听队列“user-Messages”的用户消息。除非队列中加载了批量消息,否则一切正常。当消息批量发布到队列时,同一用户的消息会先处理,其他用户的消息则会等待处理。 我无法使用优先级队列,因为所有用户的优先级都相等。因此,我希望创建新队列并在运行时监听它们。一旦消息被使用,所有队列都将是短暂的。(该队列将被删除) 浏览时,我发现可 ..
发布时间:2022-06-24 16:07:39 Java开发

RabbitMQ发布/订阅与轮询

我在应用程序中使用RabbitMQ来实现客户端和服务器之间的通信。 大多数情况下,客户端将信息发送到服务器。但有时客户端需要了解服务器中的一些更新。 目前,我使用轮询每隔1分钟询问服务器是否有一些更新。 我的问题是,使用发布/订阅机制将更新推送到客户端会不会更好? 我有大量的客户(大约10000个)。那么,是否可以打开10000个队列,每个客户端一个队列? 推荐答案 ..
发布时间:2022-06-16 21:43:11 其他开发

我们可以将芹菜作为消息消费者(而不是生产者)和分发者吗?

使用celery,是否可以使用RabbitMQ侦听新邮件并计划工作进程来处理它? celerydocumentation的很多内容都是关于将其用作代理(比方说RabbitMQ)的任务生产者,在该代理中执行任务并通过代理交付。 我希望使用来自代理的消息(由其他服务生成),并使用celery处理这些消息。 推荐答案 是。您所要做的就是配置放入rabbitMQ中的消息,使芹菜将其 ..
发布时间:2022-04-15 14:10:11 其他开发

更改RabbitMQ队列中的参数

我有一个RabbitMQ队列,最初声明如下: var result = _channel.QueueDeclare("NewQueue", true, false, false, null); 我尝试添加一个死信交换,所以我将代码更改为: _channel.ExchangeDeclare("dl.exchange", "direct"); Dictionary ..
发布时间:2022-04-15 14:09:03 C#/.NET

RabbitMQ/AMQP中的消息版本控制?

处理消息版本控制的推荐方法是什么?主要的思想流派似乎是: 始终在邮件结构更改时创建新的邮件类 永远不要将(纯)序列化对象用作消息。始终使用某种版本头字段和字节流主体字段。这样,接收方始终可以在尝试读取邮件正文之前接受邮件并检查版本号。 切勿将二进制序列化对象用作消息。相反,可以使用文本形式,如JSON。这样,接收方始终可以接受消息,检查版本号,然后(如果可能)理解消息正文。 由于我 ..
发布时间:2022-04-15 14:06:30 其他开发

我的服务堆栈服务中的异常不会将消息移动到死信队列

我有一个带有标准服务栈RabbitMQ抽象的服务栈服务。 消息队列是为我的MyRequest型自动创建的,并且我已经设置了一个服务方法来处理来自MyRequest.In Queue的请求 我预计如果我在此方法中抛出异常,消息将被放入死信队列。但是,它们只是从入站队列中删除,不会进入死信队列 public class MyOtherService : AsmServiceBase { ..
发布时间:2022-04-01 09:55:38 C#/.NET

MQTT over Secure WebSockets套接字在一分钟后关闭-RabbitMQ

我通过安全WebSockets(使用此模块的角度为6,import { Paho } from 'ng2-mqtt/mqttws31')连接到MQTT RabbitMQ实例。它连接成功,但插座连接似乎在一分钟后关闭。KeepAliveInterval设置为什么并不重要,它似乎总是在一分钟后关闭套接字连接。 这是我的客户端连接: this.client.connect({ userNam ..
发布时间:2022-03-28 17:13:52 其他开发

JMS和AMQP-RabbitMQ

我想了解什么是JMS,以及它是如何与AMQP术语联系在一起的。 我知道JMS是一个API,而AMQP是一个协议。 以下是我的假设(以及问题) RabbitMQ使用AMQP协议(而不是实现AMQP协议) Java客户端需要使用AMQP协议客户端库来连接/使用RabbitMQ JMS API在这里发挥什么作用?JMS API应使用AMQP客户端库连接RabbitMQ? 我们通常使用J ..
发布时间:2022-02-23 19:30:13 Java开发

Docker - 具有多个图像的容器

我想制作一个包含多个镜像的 Dockerfile,以便在一个容器中运行. 解决此问题的最佳方法是什么?下面是我想在单个容器中运行的列表.我在制作包含所有这些内容的 Dockerfile 时运气不佳. MySQL 服务器 RabbitMQ Java8 Node.js Xvfb 火狐 铬 这就是我目前所拥有的,我可以得到一些提示 来自 stackbrew/ubuntu: ..
发布时间:2022-01-24 21:22:02 其他开发

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

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