1回答
我有一个RM队列test-queue。在那里，我需要为3个独立的服务中的3个独立进程处理3个独立的消息(message-1, message-2, message-3)。我使用如下所示的@RabbitListener来访问消息 public void getMessage1(Messagemessage) { }
但是我只需要在这个函数
浏览 20提问于2021-02-15得票数 0
回答已采纳
1回答
我需要用java编写一个服务函数，当RabbitMQ从队列中触发消息时，将数据存储在MongoDB中。
RabbitMQ是否有能力将XML文件从队列传递到拾取服务？
浏览 1提问于2016-09-29得票数 0
最终，订阅者的更新将被接收并存储在多个主机和它们的本地单核系统中。Rabbitmq将用于持久化映射(订阅哪个新闻源)。在第一个选项中，为绑定到相关发布服务器交换的每个订阅服务器设置一个队列。并让客户端进程打开到所有这些订阅者队列的连接，并接收更新(并将它们保存到mongodb)。注意，在此选项中，当客户端重新启动时，它必须管理所有susbcriber的列表，并打
浏览 4提问于2013-11-23得票数 0
我在我的微服务项目中使用了rabbitmq，我看到了这两种方法--它们是什么？
浏览 8提问于2021-11-28得票数 1
回答已采纳
1回答
获取不同路由密钥的消息的用户
、、、、
c1 (in php)绑定到exchange 1、queue 1和routing key 1；c2 (在java中)绑定到exchange 1、queue 1和routing key 2，即只有路由密钥不同，但exchange和队列相同。在php中，我们按以下方式进行绑定在java中，以下内容
channel.queueBind(queue, exchange
浏览 2提问于2015-12-03得票数 1
回答已采纳
bus.StopAsync(); }一切看起来都很好，直到我实际检查了底层的RabbitMQ管理，并发现仅仅为了这个非常简单的程序，MassTransit创建了3个交换和2个队列
浏览 2提问于2019-05-09得票数 4
回答已采纳
我想使用来自特定队列或具有给定键的特定交换的多个消息。所以场景是这样的：
发布者发布消息1通过队列1发布者发布消息2通过队列1发布者发布消息3通过队列1发布者发布消息4通过队列2发布者发布消息5通过队列2。消费者消费来自队列</em
浏览 4提问于2014-03-26得票数 4
2回答
我需要使用订阅服务，因为我不能使用多播，因为：
我认为这违背了消息队列的思想，即消息一直保存到接收方可用为止。我认为与订阅服务的通信是通过mt_subscriptions队列完成的，并且启动将不依赖于订阅服务的运行。
浏览 1提问于2014-05-23得票数 2
回答已采纳
假设我已经实现了模式：因此，基本上，我向每个C发送一条消息，这些C订阅了X。
我有P的实例，还有很多订阅者，比如C。如何传递消息，以便只有一个C将从每个组接收一条消息？(我对循环知更鸟很好)
浏览 3提问于2016-07-22得票数 0
回答已采纳
1回答
我想知道，在RabbitMQ中何时创建单个队列以及何时创建多个队列是否有规则？还是由生产者来决定是否将消息发送到单个队列或多个队列，技术上没有区别？它应该依赖于db的模式吗?也就是说，一个表应该对应于单个队列吗？
浏览 2提问于2016-02-01得票数 1
回答已采纳
生产者时不时地运行，并且可以将消息添加到队列中，即使对于已经在队列中具有消息的客户也是如此。我不愿意使用该解决方案，因为它需要连接到数据库，并且它在数据库中保存运行时状态。我希望找到一个可以在我们的消费者/生产者
浏览 0提问于2015-09-10得票数 0
2回答
我们有一个RabbitMQ交换，它在系统的几个组件之间交换消息。我们需要找到一种方法来确保每个应用程序不接收它发送到交换中的消息。我可以看到您可以指定路由属性，但这似乎定义了您想要的消息，而不是您不想要的消息。
有什么想法吗？
浏览 6提问于2016-01-15得票数 5
回答已采纳
1回答
我一直在重写我的nodejs游戏应用程序，让它从redis中读取内存，这样，如果它变得越来越大，我最终可以对它进行缩放。但是，我停了下来，因为我觉得我走错了路。我现在所做的1)让Server 2在不发布到redis__的情况下向Server 1发送消息不是更合适吗？
2) Server 2不跟踪Server 1所拥有的所有连接客户端，因此不可能实现。Server 5上的用户希望向Server 1上的用户发
浏览 1提问于2015-09-19得票数 2
回答已采纳
2回答
我将从Java应用程序发送消息给使用者，即Python应用程序。除了输入命令rabbitmqctl list_queues之外，一切正常工作，它显示了video_queue 0，这意味着队列中没有消息。使用者正在接收消息并执行一些长流程；因此，如果我在一行中发送多个消息，应该会有一些消息在队列中等待。我说的对吗？To exit press CTRL+C')
channelConsumer.start_con
浏览 0提问于2019-09-05得票数 1
回答已采纳
1回答
保存芹菜工人下载的数据
、、、
我现在的问题是，我必须在第二个任务中对工作人员下载的tweet进行预处理，以便合并这两个任务以访问它们，或者将所有的tweet保存在一个公共存储中，并在新任务中获取它们。
浏览 0提问于2015-01-20得票数 1
我想知道是否有一种方法可以在不让邮件被标记为在“慰藉”中被重新传递的情况下破解一条消息。
情况:有一个由多个订阅者服务的保证队列，我们希望另一个订阅服务器处理特定的消息。这是个非常棘手的案子。
浏览 4提问于2015-12-04得票数 1
回答已采纳
1回答
用芹菜调用API
、、、、
我正在为客户设计一个系统，其中的要求是：调用以JSON对象作为有效负载的API如果失败了就重试一次。假设文件中有N行，我应该：使用result列在数据库中创建N个对象(最初为null)。选项B:创建1个芹菜任务，并传递N个对象ids和N个有效载荷的整个列表
循环遍历所有N个对象，并在每个步骤中使用结果更新数据库。
浏览 0提问于2015-04-26得票数 8
我的目标是将对象从IOS(RabbitMQ)发送到服务器端(RabbitMQ)，然后只对队列的所有订阅者进行扇输出。 print(user_id)
} });客户-消费者 print("Attem
浏览 3提问于2017-07-14得票数 0
回答已采纳
我正在通过队列传递与支付相关的数据。因此，我需要在我的消费者接收数据的顺序与我已经发送。
示例- Publisher发布这些消息- msg1、msg2、msg3...msg8。消费者并没有按正确的顺序出版.它像msg1，msg4，msg2，msg7.msg 8.所有的消息都是相同类型的。有没有办法在狂犬病绞盘里处理这件事？
浏览 7提问于2021-06-16得票数 0
回答已采纳
在我的项目中，当数据进入队列时，我将使用rabbitMQ来处理一些数据。我正在使用兔子创业板，一个RabbitMq客户端，它提供与rabbitMQ交互的接口。我的问题是，每当出现异常或服务器在处理队列中的数据时意外停止时，来自队列的消息就会丢失。
我想知道人们如何处理rabbitMQ队列中丢失的消息。有没有办法把这些消息拿回来进行处理。
浏览 1提问于2016-10-16得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
