MassTransit StateMachineSagaTestHarness -双倍消息消耗
MassTransit是一个开源的分布式消息传递框架，用于构建基于消息的应用程序。它提供了一种简单而强大的方式来实现应用程序之间的解耦和可扩展性。
StateMachineSaga是MassTransit框架中的一个组件，用于实现有状态的消息处理。它允许开发人员定义状态机模式，以便根据消息的类型和当前状态来触发不同的行为。通过使用StateMachineSaga，开发人员可以轻松地实现复杂的业务逻辑和工作流程。
TestHarness是MassTransit框架中的一个测试工具，用于帮助开发人员编写单元测试和集成测试。它提供了一套简单而强大的API，用于模拟和验证消息的发送和接收，以及对状态机和Saga的行为进行测试。
双倍消息消耗是指在使用MassTransit StateMachineSagaTestHarness进行测试时，每个消息都会被消耗两次。这是因为在测试环境中，为了确保消息的可靠性和一致性，消息会被复制并存储在持久化存储中。因此，在测试过程中，每个消息都会被消耗两次，一次是从测试代码中发送的，另一次是从持久化存储中读取的。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm
- 腾讯云数据库 TencentDB：https://cloud.tencent.com/product/cdb
- 腾讯云人工智能 AI Lab：https://cloud.tencent.com/product/ai
- 腾讯云物联网 IoV：https://cloud.tencent.com/product/iov
- 腾讯云移动开发 MSDK：https://cloud.tencent.com/product/msdk
- 腾讯云对象存储 COS：https://cloud.tencent.com/product/cos
- 腾讯云区块链 TBaaS：https://cloud.tencent.com/product/tbaas
- 腾讯云元宇宙 TKE：https://cloud.tencent.com/product/tke
请注意，以上链接仅供参考，具体的产品选择应根据实际需求和情况进行评估和决策。
相关·内容
看起来每个发布的消息都被saga消费了两次。如果消息已发送(未发布)，则不会出现问题。当我将字段更改为自定义字段- ProcessId时，问题就开始了。下面是暴露问题的简化示例。消息仅在InMemoryTestHarness中使用两次。 你有什么建议应该解决的吗？乍一看，这似乎是一种错误的行为。
浏览 20提问于2020-12-22得票数 0
回答已采纳
1回答
我正在构建一个应用程序来使用来自RabbitMQ的高容量(流)消息。情况如下：以下是我的疑问(非常快地使用消息)
MassTransit会满足上述要求吗？
浏览 2提问于2021-10-24得票数 3
回答已采纳
MessageType："PublishX“Type1ConsumerXType3ConsumerX
所有的消费者都必须立即捕捉消息，但同时在自己的内部消费。例如，队列中有100个"PublishX“消息。Type1ConsumerX消耗了30条消息(同步)，Type2ConsumerX消耗了50条消息(同步)，Type3ConsumerX消耗了100条消息(同步)。我如何知道消息
浏览 7提问于2015-03-22得票数 2
回答已采纳
如果消息类类型是从同一个项目继承的，但是一旦消息从"messageType“属性中的不同名称空间发送到另一个messageType项目，它会自动转到死信，而我的使用者无法捕捉它，在这种情况下，解决方案是什么因为我不能要求不同的发布者(不同的团队)为该消息类型类设置相同的名称空间，谢谢
浏览 13提问于2022-02-01得票数 0
回答已采纳
1回答
我目前正在使用Nlog存储诊断类型的消息。我正在考虑将这些消息记录到一个消息队列(RabbitMQ和Masstransit)中，然后可以将这些消息消耗到数据库中进行分析。在我的PC上发布/记录消息的当前速度是：-
RabbitMq通过masstransit (出版)：490 via我认为发布到消息队列要快得多。
浏览 4提问于2016-12-22得票数 1
2回答
如何测试自动状态机？
、、、
MyProcessStateMachineTests InMemoryTestHarness _Harness; StateMachineSagaTestHarness// Grab the instance and Assert stuff...}
考虑到_Saga.Match调用找到了匹配，我希望所有消息都已被处理当我在夹具中运行测试时，有时我得到的实例已经消耗
浏览 0提问于2018-06-22得票数 1
回答已采纳
在MassTransit中，我想做一个ASP .NET核心健康检查，当“预取缓冲区”已满，并且每秒消耗的量足够低时，它会认为我的应用程序处于“降级健康”状态。换句话说，如果队列上仍有消息，而消费者速度很慢。然后，我将使用它来配置AWS，以基于健康状况自动缩放我的消费者。 有没有办法从外部访问已预取的消息数量？或者这完全封装在MassTransit中？
浏览 17提问于2021-01-27得票数 0
回答已采纳
我正在为每个使用者实例寻找一种方法来接收通过RabbitMQ通过MassTransit发布的消息。情况是，我们有多个微服务，需要在通知时使缓存失效。Pub-Sub在这个实例中不起作用，因为每个服务实例将有5个与其代码相同类型的消费者，因此只有一个人会在传统的PubSub中接收消息。消息观察可以是一种选择，但这意味着消息永远不会被消耗，并且永远停留在总线上。提前谢谢。
浏览 2提问于2018-04-03得票数 4
回答已采纳
我有一个问题，使用错误消息，它没有处理。endpoint.Consumer(ConsumerFault); });在adim面板中，我看到许多类型的错误消息没有在在rabbitmq中的消息示例：MT-Reason: fault
MT-Fault-Message:Тип "DynamicInternal0
浏览 4提问于2016-05-14得票数 0
回答已采纳
我正在设置一个消息队列，其中消息消费可能会偶尔失败一段时间(例如，由于网络停机)，在这种情况下，我希望在经过一段时间后重试。在MassTransit中有类似的东西吗？
我在MassTransit文档中找不到这个问题的答案。我能在论坛上找到的最接近答案的是，它建议答案是否定的，但提供了一些变通办法，主要涉及在一段时间内阻止消耗线程。我更希望有一个更像我上面提到的两个实现，它继续处理其他消息，直到重试延迟过去。
浏览 0提问于2014-07-02得票数 2
1回答
我有一个MassTransit系统，它将使用两个消息类型，一个用于批处理过程，另一个用于单个实体上的CRUD操作。当批处理正在运行时，CRUD操作不应该被排除队列.使用MassTransit可以实现这一点吗？似乎exchange绑定->类型的名称，可能会使这种行为变得困难。一种解决方案是使用一种消息类型来表示这两个操作，然后询问消息内容以区分单个和批处理，但这感觉就像一种代码气味。此外，这需要并发配置，以确保只有一个使用者处于活动状态。
这里有人能帮上忙吗？本质上，我们需要在事件驱动的进程运行时暂停
浏览 0提问于2018-05-02得票数 0
回答已采纳
我正在创建一个简单的.NET 6.0应用程序，它可以监听来自ActiveMQ的消息，然后将另一条消息发布回ActiveMQ。原始消息是从Java以JSON格式发送的，我看到它被.NET使用者所使用。是否有办法强制发布消息使用普通的JSON？cfg.UseJsonSerializer();似乎没有任何效果。
浏览 8提问于2022-04-14得票数 0
命令使用发送-接收模式，因此总是在MassTransit中使用"Send()“方法分派命令。然而，事件是基于发布-订阅模式的，因此总是以“MassTransit ()”方法分派。出于所有这些原因，我要问的问题是，是否可以配置MassTransit，使其不会自动创建某些类型的消息的主题，因为它们只会使用"Send()“方法发送？这在MassTransit中是有意义的还是不可能/推荐的？谢谢!问候在进行了一些测试之后，我编辑了这个主
浏览 2提问于2021-04-12得票数 0
回答已采纳
我使用的是MassTransit 3.5.7。Bus.Factory.CreateUsingAzureServiceBus(serviceBus => serviceBus.UseSerilog();}我实现了一个Serilog丰富器和一个MassTransit自定义中间件(如 )，但是关联id只记录在接收到的(消耗的)消息中。发布消息时不记录它。有人知道在发布消息时如何
浏览 0提问于2018-02-22得票数 1
1回答
将服务总线实现隐藏在接口后面
、、、、
我目前正在致力于一个项目，允许第三方连接到我们产品的消息代理。其任务是提供一个供这些第三方使用的库。我希望能够打包地铁或NServiceBus，但我想把这些细节隐藏在接口后面。我把服务巴士藏在这里. privatereadonly MassTransit.IBusControl _busControl;
public PanelSawServiceBus(
浏览 0提问于2019-01-16得票数 0
回答已采纳
这反过来会向RabbitMQ发布一条消息。该消息由第一个使用者处理，并在其他地方传递给另一个使用者，依此类推。 }
}最后，我的服务主机是简单的windows服务应用程序，可以静坐并使用已发布的消息correlationId, $"Finished processing: {DateTime.Now}");阅读时，它提到了关于“Conversati
浏览 1提问于2019-03-21得票数 8
回答已采纳
我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息 configurator.ReceiveEndpointcfg.ExchangeType = Direct;因此，当我启动我的应用程序时，我在兔子管理UI中只看到一个使用者(和一个连接)，但是为了扩大消耗并提高应用程序生产力在MassTransit中，我看到了“并发限制”和“并发消息限制”，但它们并不影响Rabbit级别的消
浏览 22提问于2021-05-31得票数 0
回答已采纳
如何为生产者和消费者在Masstransit使用rabbitmq传输时创建两个rabbitmq连接。为发布者和使用者分离连接，以实现高吞吐量。当发布服务器发送太多消息以供服务器处理时，RabbitMQ可以对TCP连接施加回压。如果您在同一个TCP连接上使用，服务器可能不会从客户端接收消息确认，从而影响使用性能。以较低的消耗速度，服务器将不堪重负。
浏览 3提问于2021-07-16得票数 0
回答已采纳
1回答
Consumer 生产者发送n-事件(10) (不运行)滞后显示为n-事件的两倍(20，而生产者只发送了n-events ( sent ))，只消耗n-事件(10)--与生成的<code>f 217</
浏览 0提问于2020-12-02得票数 1
我开始使用MassTransit，并且需要使用RuntimeServices来管理订阅和超时。我要安装到的环境是一个面向外部的网络，使用防火墙将其划分为多个部分。所以理想情况下，我想告诉MassTransit，或者可能是nHibernate，我不需要分布式事务。完整的异常堆栈跟踪：
MassTransit.Context.ServiceBusReceiveContext-'System.Action'1[[MassTransit
浏览 1提问于2013-03-12得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
