MassTransit接收消息异常：ReceiveTransport中Guid格式错误问题

问题描述 #

MassTransit 7.3.0尝试从队列接收消息时抛出以下异常，消费者未执行，消息被转入_error队列，相同代码在另一台UAT服务器运行正常：

Guid应包含32位数字加4个连字符（格式为xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx）。

异常堆栈：

at System.Guid.GuidResult.SetFailure(Boolean overflow, String failureMessageID)
at System.Guid.TryParseExactD(ReadOnlySpan`1 guidString, GuidResult& result)
at System.Guid.TryParseGuid(ReadOnlySpan`1 guidString, GuidResult& result)
at System.Guid..ctor(String g)
at System.ComponentModel.GuidConverter.ConvertFrom(ITypeDescriptorContext context, CultureInfo culture, Object value)
at System.ComponentModel.TypeConverter.ConvertFromInvariantString(String text)
at Microsoft.Extensions.Configuration.ConfigurationBinder.TryConvertValue(Type type, String value, String path, Object& result, Exception& error)
--- End of stack trace from previous location ---
at MassTransit.Util.TaskUtil.<>c__DisplayClass21_0`1.<DisposeAsync>g__Faulted|0>d.MoveNext()
--- End of stack trace from previous location ---
at MassTransit.Scoping.ScopeConsumerFactory`1.Send[TMessage](ConsumeContext`1 context, IPipe`1 next)
at MassTransit.Pipeline.Filters.ConsumerMessageFilter`2.GreenPipes.IFilter<MassTransit.ConsumeContext<TMessage>>.Send(ConsumeContext`1 context, IPipe`1 next)
at MassTransit.Pipeline.Filters.ConsumerMessageFilter`2.GreenPipes.IFilter<MassTransit.ConsumeContext<TMessage>>.Send(ConsumeContext`1 context, IPipe`1 next)
at MassTransit.Pipeline.Filters.ConcurrencyLimit.ConsumeConcurrencyLimitFilter`1.Send(ConsumeContext`1 context, IPipe`1 next)
at GreenPipes.Filters.TeeFilter`1.<>c__DisplayClass5_0.<Send>g__SendAsync|1>d.MoveNext()
--- End of stack trace from previous location ---
at GreenPipes.Filters.OutputPipeFilter`2.SendToOutput(IPipe`1 next, TOutput pipeContext)
at GreenPipes.Filters.OutputPipeFilter`2.SendToOutput(IPipe`1 next, TOutput pipeContext)
at MassTransit.Pipeline.Filters.DeserializeFilter.Send(ReceiveContext context, IPipe`1 next)
at GreenPipes.Filters.RescueFilter`2.GreenPipes.IFilter<TContext>.Send(TContext context, IPipe`1 next)

排查步骤 #

• 检查_error队列中的消息内容
  直接查看_error队列内的原始消息（包括消息头和消息体），定位所有Guid类型字段：

  • 重点检查MessageId、CorrelationId等框架级消息头，以及消息体中自定义的Guid属性
  • 对比正常UAT环境中成功消费的同类型消息，确认是否存在格式不符合标准的Guid字符串（比如缺少连字符、长度错误、包含非十六进制字符）

• 验证消息生产者一致性

  • 确认两台环境的消息生产者版本、配置完全一致：包括代码版本、MassTransit序列化配置（默认JsonSerializer是否被修改）
  • 检查生产者生成Guid的逻辑，是否在异常环境中存在手动拼接Guid、使用非标准生成方式的情况

• 对比环境配置差异

  • 核对两台服务器的.NET运行时版本：不同版本的Guid解析逻辑可能存在细微差异
  • 检查系统区域/文化设置：虽然Guid解析默认使用不变文化，但特殊区域配置可能影响字符串解析
  • 确认MassTransit配置：异常环境是否添加了自定义序列化器、中间件，或配置了不同的队列前缀，导致消费了非预期来源的消息

• 排查序列化/反序列化问题

  • 确认异常环境的MassTransit序列化配置是否与正常环境一致：是否切换了序列化方式（如Json→Xml）或自定义了JsonConverter
  • 检查消息体中Guid字段的序列化结果：是否被转换为无连字符、短格式等非标准字符串

• 临时调试定位

  • 在异常环境中添加日志，打印接收到的原始消息完整内容，精准定位触发异常的Guid字段
  • 编写测试代码，使用异常环境的.NET版本，尝试解析疑似错误的Guid字符串，验证是否会抛出相同异常

• 清理队列脏消息
  异常环境的队列中可能存在遗留的格式错误消息，持续触发报错。可临时清理队列旧消息，或单独提取错误消息进行格式修正后重试

内容的提问来源于stack exchange，提问作者Alexey Shirshov