-
0 votesanswersviews
单元测试rabbitMQ c＃Moq
我正在尝试使用Moq nuget包对我的RabbitMQ交换和队列进行单元测试 . 但无论我如何尝试以及我使用谷歌有多少，我都无法理解我应该如何模仿rabbitMQ对象 . 任何指向一个非常新的单元测试，模型的指针??? 我尝试过使用nuget包RabbitMQ.Fakes如下： [TestMethod] public void testconnectionnotnull() { ... -
0 votesanswersviews
抽象RabbitMQ的Java类无法连接到队列服务器
我已经推出了以下Java类，它提供了一个发送 byte[] 并等待接收 byte[] 的方法： import com.rabbitmq.client.AMQP; import com.rabbitmq.client.BuiltinExchangeType; import com.rabbitmq.client.CancelCallback; import com.rabbitmq.client.C... -
0 votesanswersviews
将RabbitMQ使用者数据保存到数据库中
最近几天我一直在学习RabbitMQ和消息传递，我正在关注这个tutorial . 我已经设法让一切都像本教程一样工作 . 我在Laravel完成了这个项目，我创建了发布者和消费者脚本，它们按预期工作 . 到目前为止，我只使用 echo 命令显示消费者数据 . 我通过终端调用这个脚本 . 我的消费者脚本如下所示： $host = 'secret'; $port = 5672; $user = 's... -
0 votesanswersviews
Rabbit mq检测消费者代码中没有 生产环境 者
我有一个与 生产环境 者和许多消费者的rabbitmq设置 . 告诉消费者 生产环境 者由于崩溃或其他失败而无法发送的最佳做法是什么？ 如果制作人失败，我想通知并向所有消费者展示合适的信息 . -
0 votesanswersviews
如何确保只有一个消费者实际消费已发布的消息？
我使用Rabbitmq和微服务架构 . 我使用主题和直接交换我的许多用例，它工作正常 . 但是我有一个用例，我必须从数据库中删除一条记录 . 当我删除记录时，需要调用其他几个服务并维护/删除引用的记录 . 我可以通过直接交换简单地调用那些服务来实现这一点，但我读到它是编排首选而不是编排 . 这意味着我应该实现发布/订阅模式（rabbitmq中的扇出） . 我的问题是，如果我在分布式系统中使用发布/... -
1 votesanswersviews
由于缺少兔子工厂，Spring启动集成测试失败
我有一个使用rabbitmq的应用程序，并使用消息 . 我想编写一个集成测试来检查所有功能 . 我的配置如下： @SpringBootApplication(scanBasePackages = {"com.mysite.domaintools", "com.mysite.core", "com.mysite.database.re... -
173 votesanswersviews
为什么我们需要像PostMSQL这样的数据库上的RabbitMQ等消息代理？
我是RabbitMQ之类的消息代理的新手，我们可以使用它来为像Celery这样的调度系统创建任务/消息队列 . 现在，问题是： 我可以在PostgreSQL中创建一个表，它可以附加新任务并由消费者程序（如Celery）使用 . 为什么我想为RabbitMQ设置一个全新的技术？ 现在，我认为扩展不能成为答案，因为像PostgreSQL这样的数据库可以在分布式环境中工作 . 我搜索了数据库... -
0 votesanswersviews
单个线程可以使用多个队列吗？
我有一个Java线程调用 basicConsume(String queueName,...) 来从RabbitMQ服务器获取消息 . 单个线程是否可以同时阻止多个队列，例如 consume(List<String> queues,...) 它从哪个队列中返回第一个可用项目？ 我看了the API但没有找到任何办法这样做 . -
1 votesanswersviews
Spring AMQP：比较每个消费者的多个消费者与多个线程的性能
Spring AMQP：比较每个消费者的多个消费者与多个线程的性能 我正处于从Spring doc学习Spring AMQP的阶段 . 我不清楚增加消耗率异步消息的首选方法：根据Spring文档（http://docs.spring.io/spring-amqp/docs/1.2.1.RELEASE/reference/html/amqp.html#d4e329），以下两点注意到配置SimpleM... -
6 votesanswersviews
AMQP basic.get从队列中提取并发消费者
当使用RabbitMQ作为Message Broker时，我有一个场景，其中多个并发使用者使用basic.get AMQP方法从队列中提取消息，并使用显式确认来从队列中删除消息 . 假设以下设置 Q具有消息M1，M2，M3并且消费者C1，C2和C3（每个都具有其自己的连接和信道）连接到它 . 如何在basic.get方法中处理并发？对basic.get方法的调用是否同步处理每个使用自己的连接和... -
1 votesanswersviews
Spring AMQP具有预取的单一消费者并行性
我们有一个项目正在使用Spring-AMQP来使用来自RabbitMQ代理的消息 . 我们希望增加消费方面的并发性，以便多个工作线程可以并行处理消息 . 我首先阅读了本机RabbitMQ客户端的文档，这引导我使用单个使用者的设计，并且预取计数> 1来控制并行性 . 直接使用RabbitMQ客户端，这似乎很自然 . DefaultConsumer 的 handleDelivery 方法可以... -
0 votesanswersviews
Spring cloud stream - 由同一个消费者处理的消息
我有一个 生产环境 者向 Channels 发送消息 . 我有一个由三个消费者组成的消费者群体收到了 生产环境 者发送的消息 . 默认情况下，使用循环策略调度消息 . 消费者处理的第一条消息1消费者处理的第二条消息2 ... 我想配置Spring Cloud 流，因为所有消息都由同一个消费者（主消费者类型）消费 . 当然，如果这个消费者完成了另一个消费者将带头 . 只有一个主消费者的原因是消息将用... -
1 votesanswersviews
[Golang]客户端rabbitMQ意外关闭了TCP连接，如何捕获或修复它？
我正在使用rabbitMQ Golang客户端在两台服务器之间发布pub和sub消息，但我经常会遇到错误：“客户端意外关闭了TCP连接” . 我的rabbitMQ客户端正常运行，但经过一段时间后它停止了 . 谁可以帮我检查如何捕获此错误并重新连接/修复此错误 . 非常感谢 -
0 votesanswersviews
RabbitMQ.Fakes单元测试C＃，System.TypeLoadException
我正在使用消息代理RabbitMQ并设置了一个简单的交换和一个等待JSON字符串发送的队列 . 我希望对它进行单元测试，并为此安装了nuget软件包'RabbitMQ.Fakes'来创建模型以测试我的连接等等 . 到目前为止，我无法对此进行任何检查，因为当我点击“IConnection连接”行时，我收到此错误： System.TypeLoadException：'方法'CreateBasicPu... -
1 votesanswersviews
无法从kubernetes cron工作连接rabbitmq
我在远程（cloudamqp.com）上使用rabbitmq，我在Kubernetes上创建了一个cron作业 . 在我的本地计算机上，我的工作正常，Kubernetes cronJob计划完好，但Job重定向rabbitmq连接URL到 127.0.0.1:5672 ，我收到错误 . pika.exceptions.ConnectionClosed: Connection to 127.0.0.... -
2 votesanswersviews
使用Spring和外部Message Brokers进行消息传递
我的用例考虑了三个角色： A Message Producer （例如， Remote Backend ）; A Message Broker （例如， RabbitMQ ）; A Message Consumer （基于 Spring 的Web应用程序是自己的AS） . 沟通过程如下： Message Producer 创建一条消息（通过指定收件人），然后将其发送到 M... -
0 votesanswersviews
在celery.py中导入Django App函数
我正在开发一个应用程序，我必须定期从位于我的项目目录中的celery.py文件中调用myapp / task.py中的函数 . 但是当我从celery.py文件中执行import语句时 from myapp.tasks import test 我收到以下错误，我无法解决： django.core.exceptions.AppRegistryNotReady: Apps aren't loaded... -
1 votesanswersviews
使用RabbitMQ远程调用Java应用程序
我有一个基于java的仿真模型，建议部署在远程服务器上 . 仿真模型将通过来自Web应用程序的消息执行，我使用RabbitMQ作为Web应用程序和我的仿真模型之间的中介 . 我希望能够在Web应用程序向RabbitMQ发送“开始”消息时启动我的模拟 . 实现这一目标的好架构是什么？我正在考虑运行一个守护程序，该守护程序具有侦听特定队列的工作线程池 . 当一个新的'start'消息进入时，守护进程会... -
2 votesanswersviews
RabbitMQ真实场景
我使用RabbitMQ需要的是： 生产环境 者生成消息，接收者接收所有消息，这些消息在首次连接到队列之后发布 . 由于消费者想要消费所有发布的消息 . 因为，如果多个消费者连接到同一个队列，那么消费者将不会收到所有消息 . （另请参阅here） . 因此，消费者必须创建一个 'exclusive' 队列并连接到所需的交换 . 此外，它希望接收所有已发布的消息，即使它已关闭（将来） . 因此队列是 ... -
2 votesanswersviews
主题与RabbitMQ交换含糊不清
我有点困惑 . 我正在尝试实现主题交换，但我不确定需要什么 . 我想要几个路由键和1个主题交换（默认的amq.topic） . 我的钥匙就像： customer.appA.created customer.appB.created customer . * . created 我希望我的队列是持久的，但是我需要1个'customer'队列或2个队列用于appA和appB吗？我让我的... -
4 votesanswersviews
为什么在RabbitMQ中连接恢复后存在重复的消费者？
我在用： RabbitMQ 3.5.1 Java RabbitMQ客户端 具有两个RabbitMQ实例的集群 我的队列是： Durable = false Exclusive = false 自动删除= true 队列镜像不影响结果 在我的应用程序中，有一个异步消费者通过回调接收消息 . 当我尝试通过禁用与代理的网络通信来模拟连接失败时，会发生此问题 . 在重新... -
2 votesanswersviews
调用channel.close（）后关闭RabbitMQ连接
我正在使用Java RabbitMQ Client . 我发布了一条消息（basicPublish），然后我关闭了 Channels . 在Consumer中，channel.basicAck抛出异常： com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error;... -
0 votesanswersviews
Spring Integration RabbitMQ Consume来自amq.rabbitmq.event主题交换的内部事件
我想消耗发布到 amq.rabbitmq.event 的内部事件，例如 client.connected, client.disconnected . 下面是我的Spring配置： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springfram... -
2 votesanswersviews
RabbitMQ：没有消费者连接时丢弃消息
我正在尝试在一个模型中设置RabbitMQ，其中只有一个 生产环境 者和一个消费者，并且 生产环境 者发送的消息仅在消费者连接时才传递给消费者，但如果消费者不存在则丢弃 . 基本上我希望队列在没有消费者连接时删除它收到的所有消息 . 另一个约束是必须在RabbitMQ服务器端声明队列，并且不能由使用者或 生产环境 者显式创建 . 那可能吗？ 我看了几件事，但我似乎无法使其发挥作用： 持久与非持... -
2 votesanswersviews
Rabbitmq队列的多个使用者是否可能获得相同的消息？
我负责维护用Golang编写的 生产环境 软件，该软件使用RabbitMq作为其消息队列 .考虑以下情况： 许多goroutine正在发布到队列名称日志 . 另一组goroutines从队列中读取并将消息写入MongoDB集合 . 每个发布者或消费者分别拥有自己的连接和自己的通道，他们正在无限循环中工作，永不死亡 . （程序启动时 Build 连接和通道 . ） autoAck ... -
5 votesanswersviews
Celery为 生产环境 者和消费者配置单独的连接
我们在heroku上有一个应用程序设置，它使用芹菜来运行后台作业 . 芹菜应用程序使用RabbitMQ作为代理 . 我们使用heroku的RabbitMQ Bigwig插件作为AMQP消息代理 . 此附加组件指定两个单独的URL，一个针对 生产环境 者优化，另一个针对消费者进行了优化 . 另外，根据RabbitMQ文档，建议为 生产环境 者和消费者使用单独的连接 . Celery文档未提供单独指定... -
0 votesanswersviews
将消费者的回复发送给 生产环境 商RabbitMQ
我正在使用RabbitMQ将数据从服务器发送给几个消费者 . 我必须决定何时从队列中删除一条消息，以便我实现消费者向服务器发送消息 . 如果所有消费者都发送了回复，那么我将删除该消息 . 我已经找到了一个RPC调用，但我认为这对我遇到的问题很复杂 . 是否有更快的方式向服务器发送快速响应？我正在使用C＃ . 更新：我想我已经找到了解决方案 . 我将通知代理，以便将其从队列中删除 . -
97 votesanswersviews
RabbitMQ / AMQP：单个队列，同一个消息的多个消费者？
我一般只是开始使用RabbitMQ和AMQP . 我有一个消息队列 我有多个消费者，我想用 same message 做不同的事情 . 大多数RabbitMQ文档似乎都专注于循环，即单个消费者使用单个消息，负载在每个消费者之间传播 . 这确实是我见证的行为 . 例如： 生产环境 者有一个队列，每2秒发送一次消息： var amqp = require('amqp'); var conn... -
14 votesanswersviews
RabbitMQ：快速的 生产环境 者和缓慢的消费者
我有一个应用程序使用RabbitMQ作为消息队列在两个组件之间发送/接收消息：发送方和接收方 . 发件人以非常快的方式发送消息 . 接收器接收消息然后执行一些非常耗时的任务（主要是针对非常大的数据大小的数据库写入） . 由于接收器需要很长时间才能完成任务，然后检索队列中的下一条消息，因此发送方将继续快速填满队列 . 所以我的问题是：这会导致消息队列溢出吗？ 消息使用者如下所示： public vo... -
0 votesanswersviews
消费者和 生产环境 者之间使用哪种消息
我正在使用RabbitMQ作为消息代理 . 我有一个消费者和一个制片人 . 到目前为止，我已经创建了一个具有很少原始属性问题是，只要我需要消费者中有效负载的更多信息，我需要更改有效负载，以便我可以在消费者中处理：最后这个任务可能很重 . 我想知道我是否可以使用某种 Map 作为有效载荷或不推荐？像这样，我有一个通用的有效载荷 . 另一方面，我们的应用程序中有Serializable DTO . 我...