在ASP.NET MVC(C#)中通过Amazon SNS配置Amazon SES反馈通知

您走在了正确的轨道上-对于缺失的第4部分，您需要实现从步骤1中创建的AmazonSQS消息队列接收消息。请参阅我对使用AmazonSQS的.net应用程序示例的回答，了解在哪里可以找到相应的示例-它可以归结为以下代码：

// receive a message
ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest();
receiveMessageRequest.QueueUrl = myQueueUrl;
ReceiveMessageResponse receiveMessageResponse = sqs.
   ReceiveMessage(receiveMessageRequest);
if (receiveMessageResponse.IsSetReceiveMessageResult())
{
    Console.WriteLine("Printing received message.'n");
    ReceiveMessageResult receiveMessageResult = receiveMessageResponse.
        ReceiveMessageResult;
    foreach (Message message in receiveMessageResult.Message)
    {
        // process the message (see below)
    }
}

在循环中，您需要调用ProcessQueuedBounce()或ProcessQueuedComplaint()，如处理反弹和投诉中所示。

我最近不得不解决这个问题，但我找不到一个关于如何处理来自.Net网站的SNS反弹通知（以及主题订阅请求）的好代码示例。以下是我提出的Web API方法，用于处理来自Amazon SES的SNS反弹通知。

代码是用VB编写的，但任何在线的VB到C#转换器都应该能够很容易地为您进行转换。

Imports System.Web.Http
Imports Amazon.SimpleNotificationService
Namespace Controllers
    Public Class AmazonController
        Inherits ApiController
        <HttpPost>
        <Route("amazon/bounce-handler")>
        Public Function HandleBounce() As IHttpActionResult
            Try
                Dim msg = Util.Message.ParseMessage(Request.Content.ReadAsStringAsync().Result)
                If Not msg.IsMessageSignatureValid Then
                    Return BadRequest("Invalid Signature!")
                End If
                If msg.IsSubscriptionType Then
                    msg.SubscribeToTopic()
                    Return Ok("Subscribed!")
                End If
                If msg.IsNotificationType Then
                    Dim bmsg = Newtonsoft.Json.JsonConvert.DeserializeObject(Of Message)(msg.MessageText)
                    If bmsg.notificationType = "Bounce" Then
                        Dim emails = (From e In bmsg.bounce.bouncedRecipients
                                      Select e.emailAddress).Distinct()
                        If bmsg.bounce.bounceType = "Permanent" Then
                            For Each e In emails
                                'this email address is permanantly bounced. don't ever send any mails to this address. remove from list.
                            Next
                        Else
                            For Each e In emails
                                'this email address is temporarily bounced. don't send any more emails to this for a while. mark in db as temp bounce.
                            Next
                        End If
                    End If
                End If
            Catch ex As Exception
                'log or notify of this error to admin for further investigation
            End Try
            Return Ok("done...")
        End Function
        Private Class BouncedRecipient
            Public Property emailAddress As String
            Public Property status As String
            Public Property diagnosticCode As String
            Public Property action As String
        End Class
        Private Class Bounce
            Public Property bounceSubType As String
            Public Property bounceType As String
            Public Property reportingMTA As String
            Public Property bouncedRecipients As BouncedRecipient()
            Public Property timestamp As DateTime
            Public Property feedbackId As String
        End Class
        Private Class Mail
            Public Property timestamp As DateTime
            Public Property source As String
            Public Property sendingAccountId As String
            Public Property messageId As String
            Public Property destination As String()
            Public Property sourceArn As String
        End Class
        Private Class Message
            Public Property notificationType As String
            Public Property bounce As Bounce
            Public Property mail As Mail
        End Class
    End Class
End Namespace

我今天也有同样的问题。我通过在SNS配置中配置WebHook（https）解决了这个问题。我现在在网络服务器上处理这些事件。我已经用逻辑创建了一个nuget包。

我的代码-Nager.AmazonSesNotification

[Route("SesNotification")]
[HttpPost]
public async Task<IActionResult> SesNotificationAsync()
{
    var body = string.Empty;
    using (var reader = new StreamReader(Request.Body))
    {
        body = await reader.ReadToEndAsync();
    }
    var notificationProcessor = new NotificationProcessor();
    var result = await notificationProcessor.ProcessNotificationAsync(body);
    //Your processing logic...
    return StatusCode(StatusCodes.Status200OK);
}