我有一个生产者服务器和一个消费者服务器。生产者服务器将时间发送到rabbitmq队列。消费者获取时间并将其放入ScheduledExecutorService池中。在指定的时间，使用者完成任务。我担心我的消费者会跌倒，我会丢失数据。所以我需要实时知道我的消费者服务器什么时候会崩溃。但是我没有找
浏览 34提问于2020-10-21得票数 1
当一个新的消费者上线时，我很困惑rabbitmq是如何工作的。
我知道当前有x个消费者连接，然后生产者发送一条消息，消费者将收到这些消息。但是假设consumerX停机了，现在又上线了，或者它是一个全新的消费者。是否可以回放过去24小时内的消息？
浏览 0提问于2016-09-15得票数 0
我是RabbitMQ的新手，正在检查是否有内置的带有插件的警报系统。是否可以设置监视系统，例如在队列中没有使用者或RabbitMQ失败时发送电子邮件警报。有一个内置命令
但不确定如何</em
浏览 3提问于2020-06-02得票数 1
1回答
我正在开发一个使用消息队列的分布式生产者/消费者系统。我对并行化感兴趣的部分是它的消费者方面，我对我所拥有的很满意。
但是，我不确定如何处理生产者。我只需要一次运行一个生产者，因为我的系统的生产部分的负载不是太高，但我想要一种可靠的方式来管理它，例如启动、停止、重新
浏览 2提问于2012-12-18得票数 0
回答已采纳
1回答
我有几个消息生成线程，它们只是偶尔发布消息(例如，短时间的消息突发，然后休眠6个小时)。在发布后启动一个新的连接并将其关闭是不是更好？或者，通过心跳来保持连接更好？
至于消费者线程。处理每条消息并不需要很长时间(在心跳间隔内)，但大多数时候接收方连接是空闲的，因为没有发布消息。我注意到，通常情况下，如果连接处于空闲状态太长时间，它将被断开。这是预期的行为吗？我认为只有当整个使用者线程被长时间运行的消息处理函数阻塞时，连接才会断开，这样
浏览 0提问于2018-11-26得票数 0
我对spring框架完全陌生。我正在尝试创建一个java maven项目，在该项目中我可以连接到rabbitMq，甚至在发布消息之前，我就想检查队列是否处于活动状态。我对这个rabbitMQ完全是新手。谢谢你的回答
浏览 4提问于2015-07-29得票数 3
1回答
带Vue JS的RabbitMq
、、、、
我尝试使用rabbitMq来处理来自前端的消息，我已经有了rabbitMq和(AMQP)。我在rabbitMq中搜索Vue-Js或JavaScript，但没有找到任何有用的信息。那么我如何使用javaScript/vue-Js从rabbitMq中消费呢？
谢谢。
浏览 1提问于2020-02-28得票数 0
我使用basic_consume()来接收消息，使用basic_cancel来取消消费，但是有一个问题。下面是pika.channel的代码 http://www.rabbitmq.com/amqp-0-9-1-reference.html如果我</
浏览 3提问于2013-12-18得票数 6
我有一个带有rabbitmq-native 3.3.1插件的Grails 3.1.12应用程序。我可以使用每个消费者中的static块将消费者绑定到队列： "queue": "my.queue.that.is.bound.to.some.exchange我设法转储了RabbitMQ状态报告，该报告显示消费者
浏览 2提问于2016-10-22得票数 3
我刚刚创建了一个API，其中来自API的请求将使用请求/响应模式通过MassTransit/RabbitMQ转发到后端服务。这使我们处于这样一个位置，如果由于任何原因其中一台服务器被移出池，我们可能会丢失所有消息。我正在考虑在服务器之间创建一个RabbitMQ集群(每个服务器都有一个本地安装)，并且想知道如何在这个实例中设置竞争的消费者。RabbitMQ或Mas
浏览 0提问于2012-06-17得票数 1
回答已采纳
1回答
我正在使用RabbitMQ，并且希望在每次Exchange收到消息时在服务器端进行计算。服务器端逻辑有哪些选项？我读过关于Spring RabbitMQ的文章，但我不确定？
浏览 0提问于2015-05-17得票数 1
回答已采纳
我将严格遵循以下教程：。我这样启动RabbitMQ服务器：docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672工作进程死后不久，所有未确认的消息都将被重新传递。
我产生了两个消费者，当我对其中一个消费者执行CTRL+C操作时，另一个正在运行的消费者不会收到最初发往前一个消
浏览 173提问于2017-10-10得票数 0
1回答
我有一个使用Spring Websokcets (with STOMP)构建的聊天应用程序，而我使用的message是RabbitMQ。
首先，我将尝试解释一下流程。在我的应用程序中，同一个用户可以从不同的设备连接到websocket服务器。为了保持简单，每个用户都将订阅/topic/{userId}。在我前面提到的问题中，Brian提到可以从RabbitMQ
浏览 4提问于2015-07-28得票数 1
2回答
我使用EC2上的spot实例来使用RabbitMQ队列中的数据。每个作业都需要几秒钟，并且需要手动“确认”。
销毁实例时会出现问题。没有时间干净利落地关闭AMQP消费者，所以我留下了RabbitMQ服务器，仍然认为死亡的消费者仍然存在。它不会重新提供他们的工作，它仍然会向他们发送新的工作。如何让RabbitMQ自动使僵尸消费者超时，并将其从工作池
浏览 0提问于2012-11-16得票数 7
我创建了一个基本架构，其中将有一个单一的主进程，它基本上是一个处理多个请求的快速服务器，主进程的主要任务是将来自请求的传入数据写入到REDIS实例中。其他工作进程(NumOfCPUs 1)将是非主控的，即他们不会处理任何请求，因为他们只是消费者。我有两个特性，即ABC和DEF。通过分配类型，我将非主工作线程均匀地分布在多个功能中。由于特定功能有多个使用者，每个使用者都读取相同的消息并开始单独处理，这
浏览 0提问于2019-05-18得票数 1
1回答
客户端使用iOS app + RabbitMQ在服务器上发送消息。如何使用ASP.NET MVC的RabbitMQ从服务器获取消息？如果我作为控制器内部的消费者订阅了RabbitMQ通道，这将不起作用，因为控制器返回视图并且EventHanlder不会触发。
浏览 1提问于2017-05-11得票数 0
我对RabbitMQ有一个比较独特的用例，我不确定如何解决这个问题。我希望有一个绑定了多个消费者的队列，然后让RabbitMQ一次只向一个消费者发送一条消息，并在向任何其他消费者发送另一条消息之前等待ACK。我意识到这会扼杀吞吐量，基本上会让其他消费者挨饿，但对我来说，这是可以接受的。出现这种奇怪用例的
浏览 1提问于2013-05-23得票数 1
1回答
MassTransit与RabbitMQ状态的文档：
这里我不清楚结果；在我的系统中，我需要队列是持久的，消息要持久。如果我需要关闭使用者进程(例如，更新)，或者需要重新启动服务器(比如Windows修补程序)，我希望现有的队列保持不变，不丢失任何当前消息，这样，一旦一切恢复正常，处理就可以继续进行，而不需要删除已发布的消息如果没有可用的消费者
浏览 0提问于2016-06-24得票数 2
回答已采纳
我正在使用spring云基础设施运行RabbitMq消费者。文件规定如下：应用程序的已部署实例数。必须设置为在生产者端进行分区。在使用和卡夫卡if autoRebalanceEnabled=false时，必须将其设置在消费者端。应用程序的实例索引:从0到instanceCount - 1的一个数字。用
浏览 3提问于2020-06-28得票数 1
回答已采纳
1回答
我知道RabbitMQ不支持JMSXGroupId，而且从上看，这个特性似乎很快就会被整合到RabbitMQ中。对于使用交换/队列/主题的组合，有什么解决方法吗？这是我的用例。假设我有一个生产者服务器和两个消费者服务器，其中有多个消费者线程在使用队列中的线程。生产者服务器创建一个网络、一个子网和多个端口。所有这些请求都被转换为json/
浏览 2提问于2017-05-19得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
实时音视频活动推荐
腾讯云开发者
