如何配置NServiceBus接收非NServiceBus格式的Amazon SQS消息？

NServiceBus支持接收非自身发布的原生SQS消息，核心是通过自定义消息反序列化逻辑替换默认解析规则，以下是针对.NET 6应用的具体实现步骤：

• 核心原理：NServiceBus默认仅识别自带格式的消息（含Headers字段、Base64编码Body），要处理原生JSON，需自定义解析逻辑，将SQS原生消息映射到你的业务消息类。

• 具体配置步骤：

  1. 定义与JSON结构匹配的业务消息类：

     public class MyMessage
     {
         public int Id { get; set; }
         public string Name { get; set; }
         public string Field1 { get; set; }
         public int Field2 { get; set; }
         public bool Field3 { get; set; }
     }
     

  2. 在Endpoint配置中添加自定义消息反序列化逻辑：

     var endpointConfiguration = new EndpointConfiguration("YourEndpointName");
     var transport = endpointConfiguration.UseTransport<SqsTransport>();
     
     transport.CustomMessageDeserializer(context =>
     {
         // 读取SQS消息原生Body内容
         var rawBody = context.Message.Body;
         var jsonContent = Encoding.UTF8.GetString(rawBody);
     
         // 解析外层带"MyMessage"键的JSON结构
         var messageWrapper = JsonSerializer.Deserialize<Dictionary<string, MyMessage>>(jsonContent);
         if (messageWrapper.TryGetValue("MyMessage", out var targetMessage))
         {
             // 返回NServiceBus所需的消息实例与元数据
             return new MessageDeserializerResult(
                 messageType: typeof(MyMessage),
                 messageInstance: targetMessage,
                 headers: new Dictionary<string, string>() // 可按需添加自定义Header
             );
         }
         throw new InvalidOperationException("无法识别消息格式");
     });
     

  3. 调整有毒消息判定规则（可选）：
     若仍出现误判，可通过endpointConfiguration.Recoverability()配置错误队列策略，或在自定义反序列化中捕获并处理预期内的格式异常，避免合法消息被标记为有毒消息。

• 注意事项：

  • 确保业务消息类的字段名、类型与JSON结构完全匹配，否则会解析失败。
  • 若原生JSON无外层"MyMessage"键，直接将jsonContent反序列化为MyMessage即可。

内容的提问来源于stack exchange，提问作者Mr. Spock