rabbitmq 相关问题

RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。

在 Dynamics CRM 插件中使用 RabbitMQ

我正试图创建一个概念验证应用程序,以了解我们是否可以在 Dynamics CRM 插件(未进行沙箱)中使用 RabbitMQ。Dynamics CRM (on premise) 是版本 1612 (8.2.5.4) RabbitMQ Server 是...

回答 1 投票 0

如何在python中使用RabbitMQ进行简单的单元测试?

在我的单元测试中,我想简单地开始消耗,发布一个消息,并收到一个响应回来,并断言如果响应是我所期望的。然而,我已经尝试做了几个小时......。

回答 1 投票 0

AMQP安全连接加密URI。

我想从我的 Java 客户端到 RabbitMQ AMQP 消息代理建立 AMQP 连接。实际上,它可以正常工作,如https:/www.rabbitmq.comapi-guide.html。我的做法是:...

回答 1 投票 4

如何在Google Cloud PubSub上实现请求-响应模式?

我有多个客户端A(主应用)和多个客户端B(支付服务)。如果我从客户端A发布一条消息,将在客户端B上处理和回复(在客户端A发布回复 ...

回答 1 投票 1

如何为Spring Integration中的Rabbit MQ消息监听器执行严格的排序?

我有一个Spring集成项目,我从RabbitMQ队列中发送和接收消息。系统发布消息的顺序是确定的,但之后接收消息的顺序......。

回答 1 投票 0

MassTransit和RabbitMQ,消息的历史。

我的问题更多的是架构上的,而不是程序上的,但我认为它将适合S.O.的T&C.我们有一个应用程序,它负责发送批量电子邮件。架构组成为...

回答 1 投票 0

如果RabbitMQ集群的客户机所连接的Node出现故障,他们能否重新连接到另一个Node?

我觉得我在这里错过了一些很基本的东西。我可以用三个节点(rabbit1、rabbit2和rabbit3)启动一个RabbitMQ集群,而不会出现任何问题。然后当我开始编写我的...

回答 1 投票 0

.NET Core 3.1 BackgroundService - 消耗 RabbitMQ 并使用 EntityFrameCore 插入。

我目前正在编写一个后台服务,它从队列中读取消息,并将这些值插入到mssql数据库中。我正在使用entityframecore将这些值插入到上下文中。现在我...

回答 1 投票 0

龙卷风上的皮卡消费者跑不动了

我想使用RabbitMQ和Tornado建立监控系统。我可以运行生产者,我的消费者可以消费队列中的数据,但数据不能显示在网站上。这只是我之前的实验...

回答 1 投票 0

JMS消息再传递

我想给自己补习一下JMS,对于下面的疑问,我很难找到答案:我有一个队列,有一个Producers和两个Consumer,两个Consumer共享连接......

回答 1 投票 0

使用绑定键的Symfony messenger队列 - 重试策略

我在我工作的公司里实现了Messenger。我发现路由键有问题。我想把一条消息发送到两个队列中,另外两个应用程序将处理这个队列。另外两个应用程序将处理这个队列。一切都很好,...

回答 1 投票 2

是否有任何设置,以返回到第一个集群CachingConnectionFactory setAddresses

我正在使用CachingConnectionFactory的setAddresses方法为多个集群。 connection = new CachingConnectionFactory(); connection.setAddresses("rabbit1:5672,rabbit2:5672"); 当我关闭...

回答 1 投票 0

改变RabbitMQ的消费者权重

就我在rabbitmq文档中看到的,被查询的消息是以循环的方式发送到连接的消费者。然而,我想让我的一个消费者只接受,比如说1%......

回答 1 投票 0

如何计算谁先接受订单?

有一些用户。他们可以执行订单。订单可以为所有用户发送。当用户收到订单时,他可以在1分钟内接受或拒绝订单。如果用户接受订单,我将信息存储在...

回答 1 投票 0

与RabbitMQ的Node.js连接

我有一个node.js应用程序 使用amqlib与RabbitMQ连接。我试图重现RabbitMQ的连接错误,通过重复相同的流程,我得到了两个不同的错误。...

回答 1 投票 0

可以查询pubsub系统中已经消耗的旧消息吗?

我正在建立一个打牌的系统,我决定使用SSE的pubsub系统来保持客户端的更新。我面临的一个问题是把消息保留下来,以便以后查询。一个用例是...

回答 2 投票 0

是让RabbitMQ的连接保持开放还是只在必要时才开放?

我有一个应用程序,它循环进行一系列的测试。在失败的测试中,它将消息发布到 RabbitMQ 队列中,其他应用程序将监视并从中获取。有数百个测试...

回答 1 投票 0

当队列有效载荷中添加的值出现错误时,我想重新排入RabbitMQ。

我有一个奇特类型的问题声明要解决。将RabbitMQ配置为消息代理,其工作正常,但当消耗过程中出现故障时,我现在用nack确认,但它 ...

回答 1 投票 0

我可以使用aws角色认证rabbitmq连接吗?

我在AWS EC2上托管了一个rabbitmq集群。我的远程应用程序是否可以使用AWS IAM角色或任何其他方式使用AWS服务来验证连接到rabbitmq服务器?...

回答 1 投票 0

消费者。无法连接到amqp:/user:**@rabbit1:5672/: 未能解析经纪人主机名。

我仔细阅读了非常类似的stackoverflow问题,并将我的代码改成了现在的样子。我仍然得到无法解析broker hostname的错误。如果我只是使用amqp:user:mypass@locahost:...。

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.