rabbitmq 相关问题

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

如何在Rabbit队列上使用同步消息？

我有一个node.js函数，需要针对我的应用程序上的每个订单执行该函数。在此函数中，我的应用程序从oracle数据库获取订单号，处理订单，然后在该订单号上加+1 ...

node.js asynchronous rabbitmq queue message-queue

回答 1 投票 0

Spring AMQP RabbitListener与2个Rabbit集群连接

我有一个用@RabbitListener注释的侦听器方法，当前将其配置为从1个兔子群集中侦听。现在我有另一个具有相同队列/交换/路由的兔子集群（cluster2）...

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 1

Celery（Django）速率限制

我正在使用Celery处理多个数据挖掘任务。这些任务之一连接到远程服务，该服务最多允许每个用户同时进行10个连接（换句话说，它可以超过...

rabbitmq amqp celery carrot

回答 3 投票 9

RabbitMQ返回404，经纪人关闭

我有一个使用以下命令运行的RabbitMQ docker映像：docker pull rabbitmq sudo docker run -d -p 5672：5672 -p 15672：15672 --name Rabbitmq rabbitmq之后，我尝试运行一个...

python docker rabbitmq pika

回答 1 投票 0

如何从RabbitMQ死信队列中逐个使用消息

该要求就像通过公开REST服务API（Spring Boot）来处理死信队列中的消息。这样，一旦调用REST服务，就会从DL队列中消耗一条消息...

spring-boot rabbitmq spring-amqp

回答 2 投票 2

收听RabbitMQ并在同一服务器上运行flask

[我有一个Flask应用程序，例如烧瓶导入，flask_restful导入资源，Api从mq_handler导入，MessageBroker导入pika应用= Flask（__ name__）api = Api（app）连接= ...

python flask rabbitmq

回答 1 投票 0

MassTransit发送和发布

Masstransit的发送和发布方法之间有什么区别？你能举个例子解释吗？我在记录更新过程之后使用“发送”。在...

.net .net-core rabbitmq masstransit

回答 1 投票 1

使用rabbitmq的Spring Boot故障转移重试器：无法调用目标方法

我实际上是在尝试使用Rabbit MQ实现故障转移重试器功能。因此，要求是我从队列中获取一条消息并进行处理。如果发生任何问题，则消息...

java spring-boot rabbitmq spring-rabbitmq

回答 1 投票 0

如何避免RabbitMQ中出现重复消息？

是否可以避免使用RabbitMQ配置将相同的消息（数据）发送到特定队列？还是应该以编程方式执行此操作？

rabbitmq

回答 1 投票 0

MQTT代理与RabbitMQ有什么区别

我正在构建消息传递应用程序。我发现所需的技术是MQTT或RabbitMQ。在我看来，两个人都以相同的方式（就订阅和发布主题而言）做同样的事情。所以...

java spring-boot rabbitmq mqtt

回答 1 投票 0

ConnectionFactory Rabbitmq C＃配置

我想使用ConnectionFactory connectionFactory.Uri = new Uri（“ rabbitmq：//xxx.xx.xx.xx”）;进行配置connectionFactory.UserName =“ 12345678io”; connectionFactory.Password =“ ...

c# .net rabbitmq

回答 1 投票 0

RabbitMQ云上高可用性最佳实践

我计划在Kubernetes Engine群集上部署RabbitMQ。我看到有两种位置类型，即1.区域2.区域有人可以帮我理解我能想到的哪些好处...

kubernetes rabbitmq google-kubernetes-engine high-availability message-bus

回答 1 投票 0

RabbitMq侦听器引发的问题处理异常

我在我的项目中有此侦听器：@Service @RequiredArgsConstructor @ Slf4j公共类ConsumerService {@RabbitListener（queues =“ $ {queue.treatment.request}”））public void ...

java spring-boot rabbitmq spring-amqp

回答 1 投票 0

从数据库在Nodejs中基于FCFS运行作业

我正在开发NodeJS应用程序，其中用户可以安排要运行的作业（CPU密集型）。我保持事件循环自由，并希望在一个单独的过程中运行作业。用户提交时...