腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如
何在
DDD
中
实现
RabbitMQ
消费者
?
rabbitmq
、
microservices
、
domain-driven-design
我正在通过
DDD
实现
一个系统,我有3层(应用程序|基础设施|域) 我在微服务同步和异步之间有两种连接 在同步连接
中
,我在应用层创建了一个应用程序接口,但我不知道哪一层适合为
RabbitMQ
实现
消费者
我应该在哪里写
消费者
?
浏览 76
提问于2020-07-13
得票数 0
回答已采纳
1
回答
我如
何在
芹菜-狂犬病中设定
消费者
优先?
python
、
rabbitmq
、
celery
为了
实现
数据局部性,我需要在我的芹菜-
rabbitmq
设置
中
的使用者优先级,即
消费者
从特定队列中选择具有偏好的任务。我如何使用这个功能?如果它还没有
实现
,我如何
实现
它? 在
rabbitmq
示例代码(在链接中提供)
中
,x-priority参数已经并提供给了basicConsume。我如
何在
芹菜代码
中
实现
这一点?
浏览 4
提问于2016-03-08
得票数 1
回答已采纳
1
回答
用
rabbitmq
实现
作业队列
php
、
rabbitmq
、
job-queue
我已经构建了一个
rabbitmq
包装器,它发布消息给
消费者
,这是很好的工作。我还可以在
rabbitmq
中
构建一个工作队列(
如
gearman),它可以将长时间运行的任务分发给使用者和使用者,然后将结果通知发布者。 我想这将需要出版商作为
消费者
,我不知道如何
实现
。
浏览 2
提问于2015-04-27
得票数 0
回答已采纳
1
回答
如何使用Docker - NodeJS运行NodeJS使用者
node.js
、
docker
、
rabbitmq
、
microservices
我有一个使用
RabbitMQ
的微服务应用程序。如
何在
RabbitMQ
启动和运行之后才能从应用程序后端容器
中
运行
RabbitMQ
使用者。我的撰写文件如下所示。image: "
rabbitmq
:3-management" restart: always - 15672/
rabbitmq
.conf:/
浏览 8
提问于2021-02-01
得票数 0
回答已采纳
2
回答
Java Spring
RabbitMq
使用者
rabbitmq
、
spring-amqp
、
spring-rabbit
我正在尝试在Java Spring框架
中
创建一个
RabbitMq
消费者
。我需要
实现
RabbitMq
RPC模型,所以基本上
消费者
应该从
RabbitMq
broker接收一些消息,对其进行处理,然后将其发送回相关的应答队列。有没有人能给我一个在Spring
中
实现
这个需求的整洁的示例代码? 提前谢谢。
浏览 1
提问于2015-10-21
得票数 0
1
回答
如
何在
java中用
RabbitMQ
实现
远程过程调用机制
java
、
rpc
、
rabbitmq
如
何在
java中使用
RabbitMQ
实现
RPC机制(生产者和
消费者
)?我也访问了官方网站,但我正在获得关于这方面的详细描述。 谢谢
浏览 1
提问于2010-09-08
得票数 5
回答已采纳
1
回答
卡夫卡
中
的延迟包消耗
apache-kafka
、
kafka-consumer-api
卡夫卡
消费者
在数据包
中
规定时间后,
消费者
是否可以选择数据包,或者我们如
何在
kafka
中
实现
这一目标? 找到了相关的问题,但没什么用。
rabbitMQ
也有同样的可能。
浏览 1
提问于2022-06-09
得票数 1
2
回答
用于Pub/Sub的副翼消息传递模式,单向和竞争的
消费者
messaging
、
aeron
这是与
RabbitMQ
类似的更高层次的
实现
,
如
竞争
消费者
、公平调度或模式? 谢谢
浏览 0
提问于2020-08-21
得票数 1
回答已采纳
1
回答
RabbitMQ
Spring一段时间后的消息处理
java
、
spring
、
spring-boot
、
rabbitmq
、
spring-amqp
使用Spring (使用
RabbitMQ
作为message ),我正在准备一条消息,有时我希望使用我的消息。在此之前,它可以在一些队列(
如
等待队列)中等待,然后移动到我们的主队列
中
,在那里有
消费者
正在等待处理来自主队列的消息。我搞不懂是否应该在这个场景
中
应用死信交换,以及如
何在
其中应用死信交换,这对我来说是的一个大问题,。 知道我们怎么能让它运转起来吗。如果没有
rabbitmq
_delayed_message_exchange插件是可能的话。
浏览 3
提问于2016-12-22
得票数 0
1
回答
在xml
中
设置启用自动恢复的Spring amqp
rabbitmq
rabbitmq
、
spring-amqp
使用
rabbitmq
客户端,我可以让它与下面的com.
rabbitmq
.client.ConnectionFactory一起工作。我听说CachingConnectionFactory有另一个构造函数来应用bean,这将有助于
实现
自动恢复,但它的属性有限。由于我们计划抽象出消息总线的内部细节,因此有必要提供我们需要在
消费者
端和生产者端启用的属性类型。" name="${
rabbitmq
.queue.mr}" /> 你能解释一下如
何在
这个xml
浏览 1
提问于2015-07-23
得票数 1
1
回答
NameValueCollection c#:一个
消费者
是否应该只接受一种类型的消息,或者我们可以使用
Rabbitmq
发送不同类型的消息?
c#
、
rabbitmq
我在
rabbitmq
中
读到了多个交换,
如
扇出等,用于组播、广播消息。 广播/多播的一种方式可以是在
rabbitmq
消息主体本身
中
具有标识符,而不是通过路由密钥/报头等来区分它。与通过NameValueCollection推送所有数据并决定单个
消费者
相比,使用routing-key/headers来决定
消费者
的好处是什么?要采取什么行动?我在这里看到的一个好处是,每个
消费者
都有一种类型的对象,看起来每个
消费者</em
浏览 1
提问于2017-05-03
得票数 0
1
回答
RabbitMQ
同时发布和使用相同的队列
rabbitmq
、
message-queue
我有一个
RabbitMQ
消息队列,我希望从web服务调用ServiceA向队列发布多条消息。同时,还有一个名为ServiceB的web服务,用于在10秒的时间间隔内使用来自
RabbitMQ
相同队列的消息。对于
RabbitMQ
队列的
实现
,这种用例可能吗?
RabbitMQ
是否支持发布者和使用者同时(同时)访问相同的队列?
浏览 2
提问于2020-01-03
得票数 2
回答已采纳
1
回答
RabbitMQ
队列的多个订阅者
rabbitmq
、
queue
、
publish-subscribe
我希望有多个订阅者接收相同的消息,比如
RabbitMQ
的扇出模型。 但我不知道如果订户数量达到10,000或更多,扇出模式是否有效,而且每秒钟可以有大约100-200包数据被推入。
浏览 0
提问于2018-04-06
得票数 0
回答已采纳
2
回答
如
何在
后台Docker
中
运行Symfony命令
symfony
、
docker
、
rabbitmq
我需要在后台运行
rabbitMQ
消费者
如
何在
码头容器
中
运行他?
浏览 2
提问于2016-11-24
得票数 2
回答已采纳
1
回答
来自MassTransit/
RabbitMQ
中
的负载平衡应用程序的竞争
消费者
c#
、
load-balancing
、
rabbitmq
、
high-availability
、
masstransit
我刚刚创建了一个API,其中来自API的请求将使用请求/响应模式通过MassTransit/
RabbitMQ
转发到后端服务。我正在考虑在服务器之间创建一个
RabbitMQ
集群(每个服务器都有一个本地安装),并且想知道如
何在
这个实例
中
设置竞争的
消费者
。
RabbitMQ
或MassTransit是否会处理此问题,以便只有一个
消费者
会收到请求,还是所有
消费者
都会收到请求并尝试响应?另外,对于
RabbitMQ
集群,MassT
浏览 0
提问于2012-06-17
得票数 1
回答已采纳
1
回答
如果还没有队列绑定到
RabbitMQ
中
的交换,如何“缓冲”消息?
c#
、
rabbitmq
我对
RabbitMQ
非常陌生,所以这可能是我所缺少的东西。我的“问题”是,我的应用程序将使用发布/订阅和交换通过
RabbitMQ
发送“事件”。但是,这些事件可能有
消费者
,也可能没有
消费者
,但一旦有了
消费者
,我希望该
消费者
获得在连接之前发生的任何事件/消息。因此,基本上我希望交换“缓冲”所有消息,一旦有一个队列绑定到交换(由
消费者
创建和绑定的队列),交换就应该将所有缓冲的消息推送到该队列,供
消费者
使用。好吧..。消费。我读过关于“备用
浏览 16
提问于2021-06-30
得票数 0
回答已采纳
1
回答
在mule esb
中
为amqp配置多个使用者
java
、
spring
、
rabbitmq
、
mule
、
esb
我使用以下配置为mule
中
的
rabbitMQ
创建了一个连接器,但问题是只创建了一个
消费者
,我想知道是否可以将mule配置为一次创建多个
消费者
。<amqp:connector name="amqpfiledetailConnector" username="
浏览 2
提问于2015-12-02
得票数 0
1
回答
如何从主项目源代码中提取
RabbitMQ
使用者和生产者
java
、
rabbitmq
、
spring-amqp
、
spring-rabbit
我有一个项目,其中包含"n“个使用
RabbitMQ
的微服务模块。目前,每个微服务都有自己的
RabbitMQ
消费者
和生产者
实现
。但我希望将这种与
RabbitMQ
的交互抽象并隔离到外部库
中
的一个公共方法
中
,这样我的项目就不会与
RabbitMQ
broker紧密耦合--我希望将来可以相对轻松地将其更改为ActiveMQ等。生产者抽象看起来很简单,但是我如何
实现
消费者
抽象呢?我希望能够使用队列名称作为参数从外部
浏览 1
提问于2020-07-16
得票数 0
2
回答
我在Spring框架中使用了
rabbitmq
,如
何在
连接创建上调用basicRecover?
java
、
spring
、
rabbitmq
我使用的是
rabbitmq
弹簧框架。在我的队列中有一个问题,在我的
rabbitmq
消费者
部署过程
中
,突然断开连接将留下未加标记的消息。connection-factory="MyRabbitConsumerConnectionFactory"MyConsumer
实现
了如
何在
创建连接时发出basicRecover(true)方法? 谢谢
浏览 1
提问于2015-10-01
得票数 1
回答已采纳
7
回答
为什么我们需要使用
rabbitmq
python
、
django
、
twisted
、
rabbitmq
当我们在Python语言中有一个更强大的网络框架
RabbitMQ
时,我们为什么还需要Twisted呢?我正在尝试理解为什么有人会想要使用
RabbitMQ
。您能提供一个使用
RabbitMQ
的场景或示例吗? 另外,我在哪里可以找到关于如何使用
RabbitMQ
的教程?
浏览 0
提问于2011-02-27
得票数 68
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RabbitMQ 入门系列(一)
RabbitMQ在分布式系统中的应用
SpringBoot 第十二章:RabbitMQ 集成使用
RabbitMQ 核心概念(交换机、队列、路由键),队列类型等介绍
掌握了这个,就知道分布式服务器的推送消息的精髓
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券