使用C#通过AWS SDK向AWS SNS主题发布JSON消息遇问题求助

看起来你遇到的问题主要有两个核心点：一是JSON消息被当成纯字符串处理，二是消息属性没有正确填充。我来帮你拆解问题并给出具体的修正方案：

问题根源分析 #

1. 消息格式被识别为字符串：当你设置MessageStructure = "json"时，AWS SNS要求你的Message内容必须是一个包含多协议字段（比如default、email、sms）的JSON对象。如果只是想发送自定义的JSON业务消息，这个参数反而会导致SNS无法正确解析你的消息，最终当成字符串处理。
2. 消息属性未填充：消息属性不会自动生成，你需要显式在PublishRequest中设置MessageAttributes字典，指定每个属性的数据类型和对应值。

修正后的代码示例 #

场景1：发送自定义JSON业务消息（最常用场景） #

如果不需要针对不同协议（比如邮件、短信）发送不同内容，直接发送JSON格式的消息体即可：

// 初始化SNS客户端
var snsClient = new AmazonSimpleNotificationServiceClient(accessId, secretrkey, RegionEndpoint.USEast1);

// 假设这是你的业务消息对象
var message = new 
{
    OrderId = "12345",
    Status = "Shipped",
    CustomerEmail = "user@example.com"
};

// 序列化为JSON字符串
string jsonMessage = JsonConvert.SerializeObject(message);

// 构造发布请求
PublishRequest publishReq = new PublishRequest
{
    TargetArn = topicARN,
    Message = jsonMessage, // 直接传入JSON字符串，无需设置MessageStructure
    // 填充消息属性
    MessageAttributes = new Dictionary<string, MessageAttributeValue>
    {
        { "MessageType", new MessageAttributeValue
            {
                DataType = "String", // 指定数据类型：String/Number/Binary
                StringValue = "OrderNotification"
            }
        },
        { "Priority", new MessageAttributeValue
            {
                DataType = "Number",
                StringValue = "2"
            }
        }
    }
};

// 异步发送消息（同步场景用Publish方法即可）
var publishResponse = await snsClient.PublishAsync(publishReq);

场景2：针对不同协议发送不同消息（多协议分发） #

如果需要给订阅不同协议的终端发送不同内容，才需要设置MessageStructure = "json"，此时Message必须是包含对应协议字段的JSON对象：

var snsClient = new AmazonSimpleNotificationServiceClient(accessId, secretrkey, RegionEndpoint.USEast1);

// 构造多协议消息内容
var multiProtocolMessage = new
{
    default = JsonConvert.SerializeObject(new { OrderId = "12345", Status = "Shipped" }), // 默认消息，适配所有协议
    email = "你的订单12345已发货，详情可查看官网", // 邮件接收的纯文本内容
    sms = "订单12345已发货" // 短信接收的短内容
};

// 序列化为符合SNS要求的JSON字符串
string jsonMessage = JsonConvert.SerializeObject(multiProtocolMessage);

PublishRequest publishReq = new PublishRequest
{
    TargetArn = topicARN,
    MessageStructure = "json", // 必须设置这个参数，告诉SNS按多协议解析
    Message = jsonMessage,
    // 同样填充消息属性
    MessageAttributes = new Dictionary<string, MessageAttributeValue>
    {
        { "NotificationCategory", new MessageAttributeValue
            {
                DataType = "String",
                StringValue = "OrderUpdate"
            }
        }
    }
};

var publishResponse = await snsClient.PublishAsync(publishReq);

关键注意事项 #

• 如果你只是发送单一的JSON消息，不要设置MessageStructure = "json"，否则SNS会将你的JSON字符串当作纯文本处理。
• 消息属性的DataType必须严格匹配：字符串用"String"，数字用"Number"，二进制数据用"Binary"，对应的值要设置StringValue或BinaryValue。
• 确保你的AWS凭证拥有SNS主题的Publish权限，否则会出现权限错误。

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