腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
MassTransit
:
如何
配置
发送
/
发布
的
重试
策略
我正在将
MassTransit
与Azure Service Bus一起使用,并希望为
发送
/
发布
配置
重试
策略
。我这样做
的
方式是: ```private void ConfigureUsingAzureServiceBus(IServiceCollectionConfigurator x) });`
浏览 15
提问于2020-10-14
得票数 0
回答已采纳
1
回答
MassTransit
-当消息
发送
到错误队列时运行代码
在
MassTransit
中,
如何
通知用户在
重试
策略
停止
重试
后发生了错误?当消息被
发送
到错误队列时,我是否可以运行自定义代码,也许作为某种中间件?我使用
的
是
MassTransit
3.0.11测试版和RabbitMQ。
浏览 1
提问于2015-09-08
得票数 1
回答已采纳
1
回答
目标系统长时间停机时
的
MassTransit
使用者故障处理
、
我已经阅读了有关错误处理和故障
的
MT文档,并放置了一些代码来
发布
故障,并编写了一个故障使用者,以便在Polly
重试
一些次数后监听故障消息。我有一个队列消费者,它使用MassTranasit从RabbitMQ获取消息,然后通过Http api
发送
到云系统。我已经处理了所有可能
的
异常,还在Polly
重试
中包装了http调用,以防止短暂
的
网络错误。但这种方法
的
问题是,在
重试
耗尽后,消息实际上会从处理中丢弃。如果目标系统停机10小时(我们之前
浏览 14
提问于2020-09-14
得票数 0
回答已采纳
1
回答
如何
在
MassTransit
中创建系统范围
的
重试
策略
,并在特定
的
使用者中修改/覆盖?
我想创建系统范围
的
重试
策略
(每y秒
重试
x次),但是在特定
的
使用者中修改/覆盖它(一些异常应该被忽略并移到错误队列中,而不需要
重试
) services.AddMassTransit<T>( {
massTransit</
浏览 5
提问于2022-07-28
得票数 0
回答已采纳
1
回答
Masstransit
:
如何
重新
发布
或
发送
负面确认?
、
、
、
他们通过message broker进行通信,因为我目前使用
的
是
Masstransit
rabbitmq。事情运行得很好。 现在,我有一个案例,一个服务A
发布
一条消息,另一个服务B使用它。服务B
发送
大量电子邮件,这需要一些时间。如果失败,它将调用一个新事件,在该事件中,我希望
发送
否定确认,并希望服务A在一段延迟后再次重新
发布
。我知道我可以通过服务B消费方法中
的
异常,但这在这里是不可能
的
。
发送
电子邮件以独立
的
方式运行。
浏览 0
提问于2021-03-21
得票数 0
1
回答
事务发件箱高度可靠吗?
我想知道事务发件箱是
如何
工作
的
,以及MT
如何
保证数据库事务和消息
发送
操作
的
一致性。 在aspnetcore MVC示例中,当数据库事务成功提交,但由于某种原因无法
发送
消息时,MT会
重试
发送
消息吗?我没有看到任何关于数据库存储
的
配置
,我在考虑
如何
保证这种可靠性
浏览 4
提问于2020-02-04
得票数 2
回答已采纳
2
回答
MassTransit
补偿失败-死信?
、
我是
MassTransit
的
新手,所以如果这是个愚蠢
的
问题,请原谅我。任何帮助都将不胜感激。
浏览 1
提问于2018-03-10
得票数 0
回答已采纳
1
回答
带有Azure函数和服务总线
的
MassTransit
异常处理和错误队列
、
、
当使用者首次抛出异常时,将在“我
的
服务总线”命名空间中创建两个主题:
masstransit
~fault (没有任何订阅)和
masstransit
~fault--mynamespace~myevent--我
的
问题: MyFunction正在吞咽异常,以防止消息被
发送
到DLQ。这样可以吗?吞下一个异常感觉很奇怪,但另一方面,
MassTransit
将错误
发送
到错误队列,因此它不会丢失。文档讨论了创建_error队列(前缀适当)
的
问题,但我没有看到任何这样<e
浏览 17
提问于2021-05-21
得票数 0
回答已采纳
1
回答
获取
MassTransit
消息
重试
数量
、
、
我在用
Masstransit
+RabbitMQ。我
的
消费者之一实现了
重试
策略
,我想知道是否有任何方法可以在错误队列中获得消息
的
重试
?另外,我想知道MT计数
重试
是
如何
进行
的
,因为我不想在使用RabbitMq服务器
的
消息头中找到任何相关信息。 谢谢。
浏览 4
提问于2016-11-08
得票数 4
回答已采纳
1
回答
如何
在
MassTransit
中
配置
多个
重试
策略
、
我想要针对特定消费者
的
两个单独
的
重试
策略
。我之所以这样做,是因为我希望对这两种情况都有单独
的
指数
重试
间隔。我有以下
配置
: cfg.ReceiveEndpoint( "ExampleQueueName", { ec.Consumer<ExampleConsumer我还尝试
配置
二级
重试
,如下所示: cfg.ReceiveEndpoint
浏览 12
提问于2019-03-14
得票数 1
回答已采纳
2
回答
发生非瞬态错误时
MassTransit
旁路
重试
策略
、
什么是对短路
重试
策略
对非瞬态误差
的
指导。使用附加到
MassTransit
v3
的
RabbitMq。一个简单
的
重试
策略
尝试在管道中设置5次。在消息
的
使用中,会发生不可恢复
的
错误,而不是抛出异常并再次尝试4次,我想将此消息移到错误队列中。
浏览 0
提问于2016-04-11
得票数 1
回答已采纳
1
回答
ConsumerDefinition中忽略了
MassTransit
终结点名称
、
ConsumerDefinition文件中
的
EndpointName属性似乎已被
MassTransit
忽略。我知道正在使用ConsumerDefinition,因为
重试
逻辑起作用了。
如何
让不同
的
命令转到不同
的
队列?似乎我可以让它们都通过一个中央队列,但我不认为这是命令
的
最佳实践。 下面是我
的
应用程序
配置
,它在创建
MassTransit
总线时在启动时执行。definition files
浏览 49
提问于2019-12-28
得票数 1
回答已采纳
1
回答
防止消息进入_error队列(
masstransit
,rabbitmq)
、
、
我正在成功地使用
MassTransit
(与RabbitMQ一起)实现了一个竞争
的
使用者拓扑:我可以在一个队列中有0或多个消费者,每个用户一次预取和使用一个消息(典型
的
负载平衡场景)。为了处理可能
的
故障,我可以想象两种情况: ,使用者在处理数据时抛出一个异常,消息被
发送
到在本例中,我希望消息遵循与上面步骤相同
的
规则:如果没有其他消费者或被传递给正
浏览 4
提问于2021-09-28
得票数 1
回答已采纳
1
回答
MassTransit
在内存中存储消息
重试
尝试?
MassTransit
重试
策略
允许我们设置
重试
尝试。在消费者方面,我们可以通过打电话但是当消费者应用程序重新启动时,它将从0开始。我需要它在服务器停止之前从离开
的
地方开始。 作为RabbitMQ死信
的
交换,帮助我实现它。代码样本附在这里。我可以在
MassTransit
中做类似的事情吗?
浏览 3
提问于2019-11-09
得票数 0
回答已采纳
2
回答
如何
延迟重发消息?
、
我使用
的
是Cloud Pub/Sub
的
异步拉取 现在,当我调用message.nack()方法时,它会立即重新提交这条消息。subscription.on('message', (message) => {})
如何
延迟重新发货?例如,我收到一条关于publishTime: '2019-05-28T10:24:31.055Z'
的
消息 我想让这条消息在上次
发送
后20秒(计算)重新
发送
。
浏览 28
提问于2019-05-28
得票数 0
回答已采纳
1
回答
根据请求范围自动为消息添加自定义头部
、
我
的
ApiGateway中
的
RequestClients (使用默认
的
MS DI)被注入到HTTP请求处理程序中(在这些处理程序中,我可以访问当前请求范围)。我想要
的
是为每个RequestClient自动添加自定义消息头,我可以在其中放置一些来自请求作用域
的
数据。用例是从请求中获取JWT,并将其作为自定义头部添加到消息中。然后在消费者端,对于每个接收到
的
请求,我需要检查该自定义头,验证JWT,并将其中
的
一些数据添加到已使用
的
请求范围中,这样我就可以访问
浏览 24
提问于2021-04-08
得票数 0
回答已采纳
1
回答
ActiveMQ -如果任何队列中发生异常,则
发送
到多个队列
的
消息将被困在队列中
、
、
我正在使用虚拟目的地来实现ActiveMQ 5.15.13中
的
发布
订阅模型。 我有一个虚拟主题VirtualTopic,并且有两个队列绑定到它。每个队列都有自己
的
重新传递
策略
。假设在处理消息时出现异常,Queue 1将
重试
消息2次,而Queue 2将
重试
消息3次。Post
重试
消息将被
发送
到死信队列。我观察到,当一条消息被
发送
到VirtualTopic时,它会同时被传递到两个队列。我正面临一个问题,如果两个队列
的
使用者
浏览 19
提问于2020-07-26
得票数 1
3
回答
C#
Masstransit
当队列不可用或关闭时
如何
处理异常
、
、
我正在使用带有RabbitMQ
的
Masstransit
来消费队列中
的
消息。谁能告诉我,当队列关闭或无法获取消息时,
如何
处理异常?下面是我
的
设置: { var host = cfg.Host
浏览 0
提问于2016-09-15
得票数 3
1
回答
如何
配置
MassTransit
以在发生故障时
重试
context.Publish()?
、
如何
将
MassTransit
配置
为在失败之前
重试
context.Publish(),例如,当RabbitMQ服务器暂时不可用时?
浏览 1
提问于2017-06-07
得票数 3
回答已采纳
2
回答
在用户异常rabbitmq公共交通上重新排队
、
、
设想
的
情况是: 当Redis脱机时,我尝试在其中持久化一些数据,它将在使用者中抛出一个异常(RedisException),当这种情况发生时,我希望请求消息来维护订单到达
的
顺序,并一直使用该消息直到成功
浏览 2
提问于2021-01-14
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何配置GOLDENGATE的数据库日志策略、TRAILFILE策略以及存在坑
如何在数字时代成功发表广告发布策略的文章
关于 HttpClient 重试策略的研究
7.kafka分区
11.kafka重试机制解读
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券