腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
您
可以
在
MassTransit
中
对
批处理
使用者
使用范围
筛选
器
吗
?
、
、
我试图
对
批处理
消费者使用作用域
筛选
器
,但在启动时出现异常。我单独测试了
批处理
消费者和过滤器,它们工作得很好。Autofac.Core.DependencyResolutionException:‘激活λ:Microsoft.Extensions.Hosting.IHostedService[] -> CommandProcessor.HostedService ->λ:
MassTransit
.IBusControl->λ:
MassTransit
.Reg
浏览 55
提问于2020-12-02
得票数 0
回答已采纳
2
回答
适用于所有消费者/所有消息类型的公共交通过滤器
、
、
理想情况下,
您
只需注册
筛选
器
一次,而不是为每个
使用者
都注册一次。(我也想在发布端做同样的事情)。我需要它在终生范围内。我看了Chris Patterson
在
Middleware上的twitch视频,我想它接近于我想要的38分钟左右,但他为一个特定的消费者注册了过滤器。
在
消费者方面,我认为我需要一个ConsumeContext的过滤器,但我只是不知道如何注册过滤器,以使它将用于所有消费者。我用的是MT7和Autofac。
浏览 32
提问于2020-08-14
得票数 0
1
回答
使用
masstransit
从通过铲子与RabbitMq链接的Azure服务总线接收消息
、
、
、
我通过铲子链接了rmq实例和azure服务总线,并使用
masstransit
发送/接收消息。我
可以
成功地将消息发送到rmq,并在服务总线
中
查看它,但无法使用
masstransit
接收消息。
浏览 5
提问于2021-10-04
得票数 0
1
回答
在
接收到的每条消息上设置多租户作用域值的
MassTransit
中间件结构是什么?
、
、
我使用
MassTransit
和Autofac,需要一种方法来查询租户Id的入站消息,该Id将用于动态构造连接字符串。因此,合乎逻辑的步骤如下: 消息
使用者
由容器解析,容器使用每个消息作用域组件相应地构造依赖项。
MassTransit
有一个如何创建消息过滤器的示例。乍一看,这似乎是一种潜在的解决方案,但似乎没有使用用于解析每个消息的
使用者
的相同的生存期范围来解析消息
筛选
器</em
浏览 6
提问于2019-12-10
得票数 0
回答已采纳
1
回答
如何测试具有过滤器的消费者(
Masstransit
)
、
、
我正在尝试测试配置了
筛选
器
的
使用者
。我想知道如何
对
它们进行单元测试。 我已经
在
使用InMemoryTestHarness做测试了。我的
Masstransit
配置: cfg.ReceiveEndpoint("queue", ep => ep.UseConsumeFilter(typeofharness = _provider.GetRequiredService<InMemoryTestHarness>()
浏览 81
提问于2021-10-11
得票数 0
1
回答
用于响应消息的通用消费过滤器的全面注册?
这样的响应消息没有显式的
使用者
,并且作为请求-响应模式的一部分,由
MassTransit
作为请求响应模式的一部分来处理,例如在调用IRequestClient<TRequest>.GetResponse
可以
访问强类型消息对象。
可以
将IFilter<ConsumeContext>的实现插入到管道
中
。这种过滤器
在
应用于响应(满足需求1)时,会获得传递给它的ConsumeContext (未能满足要求2)。另一方面,
可以
插入IFilter&l
浏览 2
提问于2020-10-06
得票数 0
1
回答
带有Microsoft依赖项注入的自定义
使用者
实现工厂
是否有办法像以下服务那样登记消费者: return new MyServiceImplementation(2);用AddConsumer<T>()方法?
浏览 2
提问于2021-11-05
得票数 0
回答已采纳
1
回答
装饰消费者并解决消费者
中
的服务问题(IServiceProvider)
我试图使用
MassTransit
来实现命令和处理程序(CQRS)的中介模式。这是可行的--当命令被分派时,将调用正确的处理程序。现在,我想装饰这些处理程序(而不是,用于横切关注点,例如日志记录),但是我想在特定的处理程序
中
添加装饰
器
(这样我就
可以
应用一些权限或授权规则,而不必向处理程序本身添加代码)。我通过使用成功地做到了这一点,所以现在当具有特定消息类型的特定
使用者
被中介调用时,首先调用为它定义的所有过滤器。效果很好。下面是上述场景的请求草稿:为每个
使用者
添加
筛选
<e
浏览 5
提问于2021-08-06
得票数 0
1
回答
试图
在
MassTransit
中
设置并发消息限制时出错
我有一个简单的.NET工作者服务应用程序来测试
MassTransit
。,我试图使用UseConcurrentMessageLimit()方法,但是e.Consumer部分高亮显示了一个错误,即“引用类型'IReceiveEndpointConfigurator‘声称它是
在
'
MassTransit
’
中
定义的,但是找不到它”。我使用的是
MassTransit
8.0.2。 我想知道是否有一些额外的NuGet包,我需要包括使这个工作。
浏览 6
提问于2022-05-05
得票数 0
回答已采纳
1
回答
带有Azure函数和服务总线的
MassTransit
异常处理和错误队列
、
、
我
在
Azure函数
中
运行
MassTransit
7.1.8,使用服务总线作为传输。当
使用者
首次抛出异常时,将在“我的服务总线”命名空间中创建两个主题:
masstransit
~fault (没有任何订阅)和
masstransit
~fault--mynamespace~myevent--(有一个订阅Fault-
MassTransit
)。这样
可以
吗
?吞下一个异常感觉很奇怪,但另一方面,
MassTransit
将错误发送到错误
浏览 17
提问于2021-05-21
得票数 0
回答已采纳
1
回答
MassTransit
生成_skipped队列,我想忽略这些队列
、
有人能猜到问题会是什么
吗
?因为我
对
如何解决这个问题一无所知。
MassTransit
生成_skipped队列,我不知道它为什么要生成这些队列。它是
在
执行发布请求响应时生成的。
在
MassTransit
.RequestClientExtensions中使用以下方法创建请求客户端}TResponse response = TaskUtil.
浏览 0
提问于2018-09-04
得票数 2
回答已采纳
1
回答
使用RabbitMQ使用.net创建2个给定类型的交换
下面是
在
ASP.net Core6.0API
中
开发的一个示例POC,它使用
MassTransit
和RabbitMQ来模拟使用
MassTransit
使用者
的简单发布/订阅。然而,当代码被执行时,它会在RabbitMQ
中
创建2个交换和1个队列。OrderId { get; set; } public int Quantity { get; set; }控制
器
浏览 11
提问于2022-09-15
得票数 0
1
回答
MassTransit
多重消费者
我有一个只有一个应用服务
器
的环境。我有一些需要一段时间才能服务的消息(比如10秒左右),我希望通过配置多个运行代码的
使用者
应用程序实例来处理这些消息来提高吞吐量。我读过关于“竞争消费者”模式的文章,并认为
在
使用
MassTransit
时应该避免这种情况。根据
MassTransit
docs ,每个接收端点应该有一个唯一的队列名。换句话说,我们
可以
在
多个队列而不是一个队列
中
实现“竞争消费者”模式
吗
? 还是我看错了?我真的需要研究一下“发送
浏览 3
提问于2016-08-03
得票数 2
回答已采纳
1
回答
弹簧卡夫卡批量处理的过滤策略与人工提交实例
我计划使用spring
批处理
侦听
器
进行
批处理
。我正在寻找这两个场景的几个样本。@Bean public ConcurrentKafkaListenerContainer
浏览 2
提问于2021-02-20
得票数 1
回答已采纳
1
回答
将服务总线实现隐藏在接口后面
、
、
、
、
readonly
MassTransit
.IBusControl _busControl; public class MyConsumer : IConsumer<SomeMessage> { public Task Consume(ConsumeContext<SomeMessage> ctx) =&g
浏览 0
提问于2019-01-16
得票数 0
回答已采纳
1
回答
用于传输文件和启动远程进程的MSMQ。
、
、
目前工作
在
一个实验室系统,其中有一个管理PC和一系列客户端PC(
在
15-24之间)连接由一个c#程序和共享网络驱动
器
。目前,系统使用各种
批处理
文件来传输文件并运行程序。新系统的想法是使用MSMQ和
MassTransit
来传输文件。然而,在我看来,关于如何实现这一目标的文件很少。我一点也不熟悉MSMQ,所以我想知道更多。所以我想问的是: 我有一个工作队列和客户端,但是我如何发送一条消息说
在
客户
浏览 0
提问于2016-08-31
得票数 0
2
回答
如何使用
MassTransit
和MSMQ正确地设置发布者-订阅者体系结构?
、
、
如何使用
MassTransit
和MSMQ正确地设置具有多个订阅者(它们都接收已发布的消息)的发布者-订阅服务
器
体系结构。特别是,
在
许多示例中使用的sbc.UseSubscriptionService("uri");现在已经过时(我正在使用
MassTransit
2.7)。页面上的
MassTransit
示例最接近我想要的内容,但它设置了消费订阅者。 请向我指出或提供一个示例,说明如何在可能出现多个订阅者的情况下设置发布服务
器
-订阅服务
器
体系结构。耽误<
浏览 2
提问于2013-06-19
得票数 1
1
回答
并发限制
在
MassTransit
RabbitMQ
中
是如何工作的?
、
、
我正在阅读关于 in
MassTransit
RabbitMQ的文章,但我仍然不了解它到底是如何工作的。有人能解释一下它是怎么工作的
吗
?
浏览 14
提问于2021-12-21
得票数 0
回答已采纳
1
回答
根据请求范围自动为消息添加自定义头部
、
我的ApiGateway
中
的RequestClients (使用默认的MS DI)被注入到HTTP请求处理程序
中
(在这些处理程序
中
,我
可以
访问当前请求范围)。我想要的是为每个RequestClient自动添加自定义消息头,我
可以
在其中放置一些来自请求作用域的数据。用例是从请求
中
获取JWT,并将其作为自定义头部添加到消息
中
。然后
在
消费者端,对于每个接收到的请求,我需要检查该自定义头,验证JWT,并将其中的一些数据添加到已使用的请求范围
中
浏览 24
提问于2021-04-08
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
系统方案合集-系统备份方案
智能语音外呼机器人,高频外呼不封号
您应该多久与工作场所管理软件同步HR数据?
光学影像筛选机的价值说明
比特币交易批处理:虽有利于降低费用,但不利于保护隐私
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券