腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
Nestjs
监听
多个
RabbitMQ
队列
、
、
、
、
我查看了
Nestjs
文档,以设置一个
监听
RabbitMQ
消息的微服务。当我必须
监听
一个
队列
时,这是非常直接的。如果我的微服务必须侦听
多个
队列
,该怎么办?我
使用
了以下方法,该方法在main.ts文件中完成。5672'], queueOptions: { }, }); 现在我有了
多个
浏览 169
提问于2020-07-17
得票数 2
1
回答
spring ampq注解驱动一个
队列
两个
监听
器区分路由关键字
、
、
、
我正在尝试在同一个
队列
上配置两个
监听
器,相同的交换,但只有路由关键字应该不同。我的问题是,不知何故,事情变得一团糟。结果是
监听
器A收到了发往
监听
器B的消息。但只是有时,有时一切都很正常。Header(AmqpHeaders.CORRELATION_ID) byte[] correlationId) { } 附加信息:我在这个
队列
中有
浏览 9
提问于2017-01-24
得票数 2
回答已采纳
1
回答
如何发送RPC replyTo -
NestJs
Rabbitmq
、
我有一个简单的
NestJs
微服务应用程序,它正在侦听来自
Rabbitmq
服务的消息。message', payload); return { response: 'wow' };当我从
Rabbitmq
UI发布时,它可以很好地
使用
消息。但我未能成功回复另一个
队列
中的消息。不确定这是不受支持还是我做错了什么。
浏览 3
提问于2020-01-17
得票数 1
1
回答
PHP超时执行
多个
curl和fileget
、
、
我有一个php脚本,做一个api的get请求,并与结果必须获取超过1000个图像。我最好的方法应该是什么?我是否应该存储进度,并进行更小的批处理?
浏览 31
提问于2018-07-12
得票数 0
1
回答
Pub-子模式和实例复制
、
、
我正在将事件驱动的体系结构移植到容器环境(Docker),我想知道如何在
使用
pub-sub时利用复制的优势:如果我只是增加副本,我就会得到许多进程进行同样的精化,我认为这不是一个好方法。我想用生产者-消费者取代pub-sub,所以消费者等待
队列
中的事件,只有一个人抓住它,但我想避免紧密耦合。 是否有“负载平衡”发布-订阅的解决方案?此外,商业工具可以检查。
浏览 0
提问于2019-09-17
得票数 4
1
回答
单
RabbitMQ
队列
和多路由密钥
、
、
、
、
我们有一个将
使用
RabbitMQ
的应用程序。该设计是为
多个
团队
使用
具有
多个
路由密钥的单个交换单
队列
,它们将通过这个单一
队列
进行通信。我正在开发一个java应用程序,只需
使用
分配给我的团队的routingKey来侦听该
队列
。: " + request); System.out.println("End:Request from
Rab
浏览 8
提问于2022-07-13
得票数 0
回答已采纳
1
回答
如何
监听
不同的虚拟主机
队列
?
我需要同时连接
多个
虚拟主机,因为我想
监听
多个
主机中的
队列
。默认情况下,基于配置的模式仅创建一个连接。如何创建
多个
连接?在注册带有注释的侦听器时,如何指定不同的连接工厂?spring.
rabbitmq
.host=10.0.0.0spring.
rabbitmq
.username=testspring.
rabbitmq
浏览 30
提问于2019-02-22
得票数 0
1
回答
NestJS
与
rabbitmq
的集成-指定交换名称
、
我正在将一个
NestJS
应用程序与
RabbitMQ
集成,并遵循教程中的此tutorial。我可以看到,消息
使用
者可以
使用
队列
名连接到
rabbitMQ
代理,但实际上我想创建一个连接到exchange的临时
队列
。我在教程中指定的
队列
选项中找不到指定交换名称的选项。谁能指出用来指定交换而不是
队列
的正确配置?是否可以在'queueOptions‘结构中指定交换名称?
浏览 25
提问于2021-08-26
得票数 1
1
回答
以编程方式在
RabbitMQ
/ Node.js中声明
NestJS
使用
者?
、
、
、
我
使用
一个
NestJS
应用程序来
使用
一个
RabbitMQ
队列
。无论订单如何,都可以处理每条消息,所以我想知道为同一
队列
声明新消费者的最佳做法是什么。预期行为:
队列
由该服务处理,该服务
使用
多个
使用
者 在
nestJS
中,您可以
使用
@RabbitSubscribe装饰器分配一个函数来处理数据。我想要做的事情可以通过简单地用装
浏览 22
提问于2021-07-05
得票数 0
1
回答
使用
同一
队列
的
多个
工作人员基于ID的芹菜
队列
、
我对芹菜和构建一个监控应用程序很陌生,在这个应用程序中,主服务器将
使用
芹菜和
rabbitmq
获取所有客户端节点服务器状态。我已经知道了如何
使用
芹菜发送和接收任务,但我仍然坚持
使用
单个
队列
来处理
多个
服务器。将创建10个
队列
,每个
队列
将处理20个服务器。[
rabbitmq
_queue1....10] 我的问题是,当芹菜工人开始
监听
特定
队列
时,它会获取
队列
浏览 4
提问于2022-01-12
得票数 0
回答已采纳
1
回答
RabbitMQ
集群重启时的Spring集成问题
、
、
、
我们的系统中有几个
RabbitMQ
队列
,我们
使用
Spring Integration amqp:inbound-channel-adapter来
使用
消息。Spring应用程序在5个JBoss节点上运行(不在集群中)<rabbit:connection-factoryid="amqpConnectionFactory" user
浏览 0
提问于2016-08-30
得票数 0
1
回答
对
多个
lambda函数
使用
相同的X射线跟踪ID
、
、
、
场景如下:我有一个lambda函数,它
监听
APIGateway并将传入的请求发送到两个
RabbitMQ
队列
。对于每个
RabbitMQ
队列
,都有lambda
监听
并做一些工作。首先,我可以从第一个lambda函数中获取跟踪id,并将其与消息头一起发送到
RabbitMQ
,但是对于侦听
RabbitMQ
的其他lambda函数,我如何配置它们以
使用
相同的跟踪id呢?
浏览 5
提问于2021-11-06
得票数 0
2
回答
DirectMessageListenerContainer:如何在
RabbitMQ
中处理
队列
删除?
、
、
我正在
使用
DirectMessageListenerContainer来
使用
来自
RabbitMQ
的数据。以下是我的场景: 我有两个与
RabbitMQ
交互的模块。第一个模块创建和删除
队列
,而第二个模块
使用
DirectMessageListenerContainer
监听
RabbitMQ
中的
队列
。当
RabbitMQ
中的任何
队列
被删除时,DirectMessageListenerContainer开始不断抛
浏览 0
提问于2019-03-18
得票数 1
1
回答
Spring集成了消费者和Nifi作为调度器
、
、
我们正在开发一个
监听
或
使用
来自
RabbitMQ
队列
的消息的服务。消息从Apache Nifi分派到消息
队列
(例如,
队列
名为“workitem”)。现在,我希望看到一个
使用
Spring Integration的代码片段,用于侦听和处理从Apache Nifi发送到
队列
(
RabbitMQ
)中的消息。 谢谢!
浏览 29
提问于2020-04-21
得票数 0
回答已采纳
1
回答
无模式狂犬病
NestJS
微服务
、
我有一个
rabbitmq
服务,它有一个
队列
,消息中没有模式json。如下所示:但是,
使用
rabbitmq
的
nestjs
需要一个json模式在没有定义模式或模式的情况下,是否存在
使用
任何json消息的方法? 在我的代码中,我
使用
模式,但是我需
浏览 0
提问于2021-07-03
得票数 1
1
回答
RabbitMQ
-
使用
多个
队列
、
、
、
我正在
使用
Python、
RabbitMQ
和Pika。 我有
多个
消费者和
队列
。我想让一个消费者从每个
队列
中获取消息。假设我有2个消费者和3个
队列
。我希望我的每个
使用
者读取
队列
1、2和3中的消息。“问题”是我想要
使用
一个basic_consume来设置qos (让
队列
每次推送n条消息)。我想从
队列
1获取n条消息,然后从
队列
2获取n条消息,从
队列
3获取n条消息,然后返回
浏览 1
提问于2015-08-27
得票数 4
1
回答
RabbitMQ
延迟接收
、
、
、
在spring-amqp中,有没有可能以某种方式推迟
监听
来自某个特定
队列
的消息? 在我的用例中,我有一个服务,它必须侦听两个
RabbitMQ
队列
上的消息。第一个专门用于此服务,第二个用于我的服务的
多个
实例(运行在不同的机器上)的负载平衡作业。 我的statup服务通过first queue接收配置并自我配置。只有在这个配置之后,它才能处理第二个
队列
中的“标准”作业--而不是在此之前。 我怎样才能做到这一点呢?
使用
@RabbitListener(queues = {que
浏览 38
提问于2019-07-03
得票数 2
回答已采纳
1
回答
为什么在创建微服务时需要定义
队列
名?
、
、
我想要一个混合的
NestJS
应用程序,HTTP +
RabbitMQ
。但是不要知道我是否应该为每个
队列
创建不同的微服务。 return (data || []).reduce((a, b) => a + b);正如我所理解的,我需要为ClientsModule.register()中的每个
队列
定义但是,为什么我在创建微服务时也需要定义
RabbitMQ<
浏览 5
提问于2019-11-10
得票数 3
1
回答
为什么
使用
NestJS
createMicroservice而不是NestFactory.create?
、
、
、
、
在我的团队中,我们
使用
NestJS
作为后端。我们希望
使用
微服务体系结构,我已经看到在
NestJS
中有内置的微服务支持。为什么甚至
使用
createMicroservice而不是NestFactory.create?
使用
createMicroservice还使我可以
使用
@MessagePattern并
使用
发射器发送消息如果我的微服务
使用
队列
(如
RabbitMQ
)获取消息,但是我不能在我的微服务中创建RE
浏览 13
提问于2022-10-11
得票数 0
回答已采纳
1
回答
使用
Spring AMQP
监听
许多短暂的、动态创建的
队列
、
、
、
我正在
使用
RabbitMQ
/Spring/Spring AMQP构建一个应用程序,并且在处理我的
队列
布局时遇到了问题。从本质上讲,我有一个每个消费者都会
监听
的
队列
,每个消息基本上都说“这个
队列
已经准备好由一个消费者来处理了”。然后,
使用
者将侦听消息中指示的
队列
,
使用
该
队列
中的所有消息,最后在完成时将其删除。这些短暂的
队列
都是在数据进入处理时动态创建的,不能被
多个
浏览 41
提问于2019-10-02
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列RabbitMQ原理及其Python客户端pika的使用
云计算服务架构任务池与指令池的搭建和使用,RabbitMQ消息队列
SpringBoot中使用RabbitMQ
Rabbitmq-消息队列
SpringBoot整合 Canal、RabbitMQ 监听数据变更
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券