看起来每个发布的消息都被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备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
