麻省理工学院RabbitMq-为什么我的所有消息都被跳过
我正在使用.Net Core 3.1应用程序，由于某种原因，我的消息没有被使用。 服务配置： services.AddMassTransit(x => { x.AddConsumer(); x.AddBus(provider => Bus.Factory.CreateUsingRabb
..
masstransit相关内容
使用重试设置与批量运输的间隔
我正在尝试使用具有间隔设置的UseReter，使用MassTransport和Azure Service Bus作为传输。 消费者代码： public async Task Consume(ConsumeContext context) { _log.InfoFormat("Strated working on {0}", co
..
在Azure ServiceBus上使用MassTransport时如何在传奇中使用指定主题
我希望特定传奇故事的所有消息都发生在同一主题上。 我是这样设置我的传奇故事的： public void ConfigureServices(IServiceCollection services) { services.AddMassTransit(x => { var machine = new MyStateMachine(); va
..
大量传输的本地堆栈未收到消息
我在使用LocalStack测试MassTransport时遇到了问题，但在AWS中使用真正的SNS/SQS一切正常，所以我怀疑这是LocalStack的问题，除非MassTransport需要配置ServiceURL以外的其他东西。请参见https://github.com/MassTransit/MassTransit/issues/1476 我只使用SNS和SQS运行LocalStac
..
有没有可能让一个大规模运输传奇对来自多个巴士(多巴士)的事件做出反应？
我有一个MassTransport Saga，可以很好地处理已为其配置了Saga的Bus(Azure Service Bus)上下文中的事件、活动等。 在其中一种状态下，我需要将消息发送到另一条不同的总线(另一条Azure服务总线)。这在使用MultiBus时工作得很好。但是，在下一步中，我希望从该单独的总线接收主题消息并对其做出反应。 在MassTransport Saga中支持自动
..
MasstranSite-长时间运行的流程和即时响应
我正在使用具有Azure Service Bus的MasstranSite，我希望实现的是从API调用Bus，其中的一些请求将触发较长的进程，但也会立即获得已收到请求的响应。 实现这一目标的最佳方式是什么？ 我应该将JobConsumer和GetResponse与JobSubmissionAccept一起使用，还是有更好的选择？ 推荐答案 如果您的使用者需要很长时间，通常超过五分
..
在ASP.NET Core Web API中使用批量传输消息时如何对用户进行身份验证？
我有几个ASP.NET Core WebAPI，它们使用持有者身份验证和IdentityServer4.AccessTokenValidation中间件来自省令牌、身份验证用户和创建声明。这适用于HTTP请求。 我正在使用RabbitMQ作为传输将这些API配置为MassTransfer端点(用于发布和消费消息)。我按照here的说明将MassTransport添加到API并设置消息使用者。
..
MassTransit 信息输入错误
我在尝试通过 MassTransit 发布消息时遇到了基本类型问题.考虑以下几点: [可序列化]公共抽象类事件:CorrelatedBy{公共 Guid CorrelationId { 获取；放;}公共抽象字符串 EventName { get;}公共覆盖字符串 ToString() {return string.Format("{0} - {1}", EventName, Co
..
使用 RabbitMQ 的 MassTransit:消息何时移至错误队列
我正在使用 RabbitMQ 版本 3.0.2 &我在错误队列中看到近 1000 条消息.我想知道 消息何时移至错误队列? 有没有办法知道为什么某条消息被移动到错误队列中? 有没有办法将消息从错误队列移动到正常队列? 谢谢 解决方案 a) 他们未能反序列化或 b) 消费者抛出异常处理该消息五次 不是...如果您查看队列中的消息，有效负载标头可能包含注释，但我认为我们没有这
..
MassTransit 将消息率封顶为 10
我有一个公共交通消费者服务设置为与 RabbitMQ 一起使用，但我不知道如何提高消费者的速度 - 它似乎硬限制每秒接收 10 条消息. 我已尝试此处列出的步骤:https://groups.google.com/forum/#!msg/masstransit-discuss/plP4n2sixrY/xfORgTPqcwsJ，但没有成功 - 将预取和并发消费者设置为 25 除了增加确认的消息
..
RabbitMq - ConversationId 与 CorrelationId - 哪个更适合跟踪特定请求?
RabbitMQ 似乎有两个非常相似的属性，我并不完全理解其中的区别.ConversationId 和 CorrelationId. 我的用例如下.我有一个生成 Guid 的网站.该网站调用一个 API，将该唯一标识符添加到 HttpRequest 标头中.这反过来将消息发布到 RabbitMQ.该消息由第一个消费者处理并在其他地方传递给另一个消费者，依此类推. 出于记录目的，我想记录
..
Masstransit 使用 RabbitMQ 性能很慢?
我在没有 Masstransit 的情况下使用 RabbitMQ，每秒发送 10,000 条消息和 100 秒内发送 100 万条消息. 但是在将 Masstransit 与 RabbitMQ 一起使用后，我的机器上的性能非常低. 当发布/消费消息时，硬盘非常活跃(99% 的使用率)，并且此进程的 CPU 活动几乎为 0%. 当使用此代码运行发布者/订阅者控制台应用程序时: v
..
具有 MassTransit、RabbitMQ 和 SignalR 的分布式架构
我在 MassTransit 和 rabbitmq 我必须提供在网页上生成报告的能力，而无需通过单击按钮重新加载页面，我还应该调用 Windows 服务进行数据准备(该服务处理每个请求 30 秒 - 1 分钟). 我基于此示例的第一次尝试:https://github.com/MassTransit/Sample-RequestResponse [HttpPost]公共异步任务
..
MassTransit Consumer 从未收到消息
我正在按照文档构建一个演示应用程序，以在 ASP.NET Core 应用程序中使用 MassTransit 与 RabbitMQ 和 Autofac: 我的程序代码: 命名空间 MessageDemo{公开课程序{公共静态无效主要(字符串[]参数){var host = Host.CreateDefaultBuilder(args).UseServiceProviderFactory(ne
..
获取 MassTransit 消息重试次数
我正在使用 Masstransit+RabbitMQ.我的一位消费者实施了重试策略，我想知道一旦消息在错误队列中，是否有任何方法可以重试消息? 我还想知道 MT 计数是如何重试的，因为我没有使用 RabbitMq 服务器在消息头中查找任何相关信息. 谢谢. 解决方案 您可以在您的消费者中使用以下方法重试重试次数. consumeContext.GetRetryAttempt(
..
MassTransit 为 RabbitMQ 添加了什么?
与直接在 RabbitMQ? 我相信 MassTransit 提供的一个好处是“类型"交换(按接口/类型发布订阅)，因此消息的内容是结构化的，与消息内容是非结构化文本/blob 的普通 RabbitMQ 交换相比. MassTransit 还提供哪些其他好处? 解决方案 MT 在仅使用 RabbitMQ 之上添加的东西: 多线程并发消费者 消息序列化，包括接口和版本控制
..
为什么我们需要在 MSMQ/RabbitMQ 等消息队列系统之上使用 NService Bus/MassTransit 等服务总线框架?
在分布式消息事务世界中，我试图了解开发分布式系统所涉及的不同部分.据我了解，您可以使用支持消息队列系统的企业总线来设计消息系统.为什么同时使用两者是个好主意?通过仅针对消息队列系统进行编程可以实现同样的目的吗?两者一起使用有什么好处? 解决方案 您当然可以直接针对消息传递基础架构进行编码，您会发现各有利弊.每次运输.不过，您需要在此过程中做出许多决定，而这正是服务总线可以提供帮助的地方.
..
指定公共交通中的发布超时
在使用 MassTransit 库发布消息时，是否可以指定超时值.消息代理宕机时如何处理场景.现在看来 Publish 调用无限期地等待.控制这些行为会很好.我们应该依赖取消令牌吗?超时实现可能会更好. 解决方案 您可以将 CancellationToken 传递给 Publish.如果取消，将抛出 OperationCanceledException.如果你想使用超时，你可以创建一个带有
..
带有 MassTransit 的 Kafka Producer - IBusInstance 尚未注册
我正在尝试使用 MassTransit 构建 Kafka 消费者 我有这段代码 var services = new ServiceCollection();services.AddMassTransit(x =>{x.AddRider(骑手 =>{Rider.AddProducer(“request", m => m.Message.RequestId);骑手.使用Kafka((上下文，k
..
每次我发布消息时，只有一个消费者随机触发
我在示例项目中使用了 MassTransit 和 RabbitMQ.我只是尝试发布一条消息，然后由 2 个独立的消费者使用它.但每次只有一名消费者随机开火！有什么问题? 这是发送方方法 await _publishEndpoint.Publish(new ConsultantFinishedEvent(50)); Publisher 中应用程序启动中的此配置: #region 服务总
..