腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
同一
接收
端点
上
具有
相同
消息
类型
的
多个
使用者
c#
、
rabbitmq
、
masstransit
在单个
接收
端点
上
使用
相同
消息
类型
的
不同
使用者
是有效
的
解决方案,还是应该为每个
使用者
使用一个
接收
端点
?IConsumer<MyMessage> {} public class MyOtherConsumer : IConsumer<MyMessage> {} 上面的解决方案起作用了,每个消费者都会收到
消息
我们目前
的
解决方案
浏览 6
提问于2019-02-14
得票数 4
回答已采纳
1
回答
MassTransit:针对每个消费者
的
通用消费过滤器
c#
、
asp.net-core
、
.net-core
、
azureservicebus
、
masstransit
首先,请原谅我
的
英语,这很糟糕。我使用MassTransit与Azure服务总线进行微服务之间
的
异步通信。我需要使用中间件使用过滤器从
消息
中获取元数据。目前,我有几个“消费”不同
消息
的
使用者
,但它们都来自
同一
个
接收
端点
。这些
使用者
中
的
每一个都有自己
的
"ConsumeFilter“(零,一个或
多个
),它们是IFilter
类型
范围
的
浏览 5
提问于2021-04-16
得票数 0
回答已采纳
3
回答
MassTransit / RabbitMQ -为什么会跳过这么多
消息
?
rabbitmq
、
masstransit
我正在使用.NET /RabbitMQ
的
生产者/消费者场景中
的
2个核心控制台应用程序。我需要确保,即使没有消费者启动和运行,来自生产者
的
消息
仍然成功排队。这似乎不适用于Publish() --
消息
只是消失了,所以我使用Send()代替。
消息
至少会排队,但是如果没有任何用户运行这些
消息
,所有
消息
都会在"_skipped“队列中结束。这就是我
的
第一个问题:这是基于需求
的
正确方法(即使没有消费
浏览 1
提问于2019-05-08
得票数 1
2
回答
使用RabbitMQ -
多个
生产者和
多个
消费者
python
、
rabbitmq
、
rabbitmq-exchange
我想知道是否可以有
多个
生产者和
多个
消费者?->消费者A仅
接收
来自生产者A
的
消息
或者我需要创建
多个
队列? 有没有人可以发帖举例?
浏览 13
提问于2015-11-27
得票数 2
1
回答
如果一个现有的
使用者
死亡,
消息
分组如何影响
消息
的
分布?
activemq-artemis
下图描述了我使用
消息
组和基于Spring
的
JMS
使用者
的
基本用例。请注意,这里
的
并发引用配置集,如下所示: 如果G1侦听器关闭,该组
的
其余
消息
会自动重新分发到另一个侦听器吗
浏览 2
提问于2020-10-28
得票数 1
回答已采纳
1
回答
Masstransit+ RabbitMQ.在两种不同
的
消息
类型
之间共享一个队列
rabbitmq
、
message-queue
、
messaging
、
masstransit
我有一个发布者,它将
消息
发布到rabbitmq://localhost/test123队列中。一个
消息
具有
TestMessage
类型
,另一个TestMessage2
类型
。); sbc.ReceiveFrom(new MessageUrn("rabbitmq://localhost/test123")); 每个
消息
类型
有两个独立<em
浏览 9
提问于2017-07-07
得票数 0
回答已采纳
2
回答
对于一个Pulsar主题,
多个
消费者是否有可能使用
相同
的
消息
?
language-agnostic
、
apache-pulsar
假设有一个用于持久主题topic1
的
Pulsar生成器(名称空间和租户与问题无关)。是否可以将
使用者
配置为
接收
相同
的
消息
?例如,如果
消息
msg1被发送到主题,那么consumer1和consumer2都会收到这条
消息
吗?
使用者
和生产者都是用Java编写<e
浏览 2
提问于2020-02-04
得票数 3
回答已采纳
1
回答
拥有
相同
groupId
的
多个
星火卡夫卡消费者
apache-spark
、
apache-kafka
、
spark-streaming
、
kafka-consumer-api
我试图让
多个
用户使用
相同
的
groupId来处理卡夫卡主题
的
多个
分区,这将帮助我扩展
消息
的
消耗。根据Kafka
的
文件,它说: 如果所有
使用者
实例都有
相同
的
使用者
组,那么记录将有效地在
使用者
实例
上
实现负载平衡。将消费者作为
同一
个消费者组
的
一部分意味着提供来自主题分区
的
消息
分布在组
浏览 1
提问于2019-10-14
得票数 2
1
回答
在
同一
个ftp上有
多个
使用者
端点
的
路由配置出现问题
ftp
、
apache-camel
Camel文档说:“FTP
使用者
(
具有
相同
端点
)不支持并发性(后台FTP客户端不是线程安全
的
)。您可以使用
多个
FTP
使用者
从不同
的
端点
轮询。它只是一个不支持并发
使用者
的
单一
端点
。” 。存在
的
问题是,路由配置在
同一
个ftp服务器上有
多个
使用者
端点
,
具有
相同
<e
浏览 2
提问于2013-11-15
得票数 2
回答已采纳
1
回答
为什么MassTransit中
的
简单配置会创建2个队列和3个交换?
c#
、
.net-core
、
rabbitmq
、
masstransit
Console.ReadKey(); }} 我想知道为什么所有这些都是必要
的
,
浏览 2
提问于2019-05-09
得票数 4
回答已采纳
1
回答
UseInMemoryOutbox没有和MultiBus Saga合作?
c#
、
state-machine
、
masstransit
、
saga
我实现了一个支持多总线传奇
的
定制活动。但是我发现了一个问题,那就是我收到了SecondBus发布
的
消息
,然后才把州传奇保存给Redis。
浏览 0
提问于2022-02-23
得票数 0
回答已采纳
1
回答
无法在.NetCore中
接收
Masstransit
消息
c#
、
.net
、
rabbitmq
、
messaging
、
masstransit
当我想发布
消息
和
接收
消息
时,我遇到了问题。我
的
UserEventHandler和UserCommandHandler类从不调用。有人能帮我吗?公共汽车开动了。当我从注册中删除UserEventHandler类时,我也遇到了断点停止在UserCommandHandler类
上
的
情况。这是我
的
UserEventHandler课程:{ private
浏览 0
提问于2020-07-08
得票数 0
回答已采纳
1
回答
使用MassTransit订阅ActiveMQ主题
asp.net-core
、
activemq
、
masstransit
有没有办法通过ActiveMQ
的
ActiveMqTransport来订阅一个主题呢?我使用MassTransit作为Asp.Net Core Mvc项目中
的
HostedService,下面的代码创建了对队列
的
订阅,但我找不到任何允许我订阅主题
的
参数或配置。
浏览 17
提问于2019-07-24
得票数 0
1
回答
添加
使用者
时,遮罩下
的
MassTransit
.net
、
rabbitmq
、
masstransit
x.AddConsumer<FactCategoryHandler>(); })); 在这一点
上
请跟我来,到目前为止,我们有这样
的
情况:当我检查正在创建哪些队列时 FactAddedHandler 0 1
浏览 2
提问于2020-02-10
得票数 1
回答已采纳
1
回答
自定义Camel组件-在FTP
使用者
中调用FTP
apache-camel
然后我需要做
的
是创建另一个FTP连接--从技术
上
讲,连接到
同一
台计算机,但路径不同。在我
的
实验中,我使用了一个带有构造
的
URI
的
消费者模板来为我获取另一个文件(基于被投票文件
的
内容)。这在很高
的
层次上起了作用,并获得了我需要
的
文件。有人能确认这是否是一件危险
的
事吗? FTP
使用者
(
具有
相同
端点
)不支持并发(后台FTP客户端不是线程安
浏览 1
提问于2019-07-02
得票数 1
3
回答
不能同时使用Bind和ConfigureConsumer
c#
、
masstransit
在将exchange绑定到
接收
端点
之后,不应该使用IServiceProvider配置
使用者
吗?如果没有,那么我如何正确地配置它(嗯,我仍然希望东西被注入到我
的
消费者中)?
浏览 13
提问于2020-03-05
得票数 3
回答已采纳
1
回答
如何扩展
多个
监听器
的
SQS FIFO队列
amazon-web-services
、
.net-core
、
amazon-sqs
、
fifo
、
event-sourcing
所有队列都
具有
如下
相同
的
设置(稍后设置
的
死信队列)。DynamoDB Stream => Lambda SQS => SQS队列
的
事件源架构
的
一部分(由于SNS不支持作为订阅者
的
先进先出队列) 启用Content-Based Deduplication以避免队列中
的
重复
消息
,因为任何队列
的
Lambda路由器中总是可能出现错误。现在,我还将每条
消息
的
MessageGrou
浏览 16
提问于2019-05-03
得票数 2
回答已采纳
1
回答
MassTransit多重消费者
masstransit
我有一个只有一个应用服务器
的
环境。我有一些需要一段时间才能服务
的
消息
(比如10秒左右),我希望通过配置
多个
运行代码
的
使用者
应用程序实例来处理这些
消息
来提高吞吐量。我读过关于“竞争消费者”模式
的
文章,并认为在使用MassTransit时应该避免这种情况。根据MassTransit docs ,每个
接收
端点
应该有一个唯一
的
队列名。我很难理解如何将这个建议映射到我
的
环境中。是否有可能让消
浏览 3
提问于2016-08-03
得票数 2
回答已采纳
1
回答
MassTransit -发布到所有
使用者
实例
masstransit
我正在为每个
使用者
实例寻找一种方法来
接收
通过RabbitMQ通过MassTransit发布
的
消息
。情况是,我们有
多个
微服务,需要在通知时使缓存失效。Pub-Sub在这个实例中不起作用,因为每个服务实例将有5个与其代码
相同
类型
的
消费者,因此只有一个人会在传统
的
PubSub中
接收
消息
。
消息
观察可以是一种选择,但这意味着
消息
永远不会被消耗,并且永远停留在总线上。 有人能
浏览 2
提问于2018-04-03
得票数 4
回答已采纳
1
回答
Apache Camel Ftp消费者并发支持
java
、
ftp
、
apache-camel
在官方
的
骆驼文档中,它说它不支持并发,并解释如下: FTP
使用者
(
具有
相同
端点
)不支持并发(后台FTP客户端不是线程安全
的
)。FTP生成器没有此问题,它支持并发。 这里
的
“单个
端点
”是指<em
浏览 5
提问于2016-07-21
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Moldex3D远端计算的常见问题之一
GraphQL,API的新工具规范
socket 通信必知必会|Python 标准库
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
CCIX(六)
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券