Amazon SES と SNS を使ってバウンスメールを PHPでハンドリング

システムにメール送信機能を組み込む際に気を付けなければいけないのは、バウンスメール（エラーメール）の処理。

バウンスになったメールアドレスには今後はメールを送信しない仕組みを作らないと、送信元のサーバがブラックリスト入りしてしまい、問題ないメールアドレスにもメールが届かなくなってしまいます。

特にAmazon SESはバウンスメールが多くなると利用を制限されてしまうので注意が必要です。

今回はAmazon SES と SNS を使ってバウンスメールを PHPでハンドリングする処理を紹介していきます。

1 コーディング
2 AWS側の準備
3 確認方法

コーディング

まずは先にコーディングを行い、サーバーにプログラムを配置します。

サーバーでバウンスメールをAmazon SNSから取得するには、以下の2つのプログラムを組んでおく必要があります。

SubscribeURLに自動でアクセスする処理（受信登録の確認）
バウンスメール（エラーメール）を取得する処理

※コーディングはAWS側の設定が済んでからでもOKです。

SubscribeURLに自動でアクセスする処理（受信登録の確認）

Amazon SNSの設定をすると、指定のサーバ（指定のURL）へJSON形式のデータがPOSTで送られてくることになります。

Amazon SNSの設定が済んだら、まずは受信登録の確認用のデータが送信されてきます。

その際、POSTされてくるデータの中にSubscribeURLという認証用のURLが含まれているので、そのURLにアクセスして認証をさせる必要があります。

PHP上でPOSTされてきたデータを解析して、SubscribeURLに自動でアクセスして自動で認証させる処理を記述します。

受信登録の確認の詳しいデータ形式は「公式サイト」を参照してください。

// AWS SDK for PHPをインクルード
include_once 'aws/aws-autoloader.php';

use GuzzleHttp\Client;

// Amazon SNSから送信されたPOSTデータ（JSON形式）を取得し、解析。
$snsObj = json_decode(file_get_contents('php://input'));

// 認証用のデータは TypeがSubscriptionConfirmationになっている
if ($snsObj->Type == 'SubscriptionConfirmation') {
    $client = new GuzzleHttp\Client();
    // SubscribeURLにアクセスする
    $client->get($snsObj->SubscribeURL)->send();
}

バウンス（エラー）になったメールアドレスを取得する

続いて、バウンス（エラー）になったメールアドレスを取得します。

バウンスの通知の詳しいデータ形式は「公式サイト」を参照してください。


// Amazon SNSから送信されたPOSTデータ（JSON形式）を取得し、解析。
$snsObj = json_decode(file_get_contents('php://input'));

// バウンスメールの場合は、TypeがNotificacion
if ($snsObj->Type == 'Notification') {
    // バウンスメールのデータはMssageの中にjson形式で保存されているので、
　　//　デコードする
    $msgObj = json_decode($snsObj->Message);

    // バウンスメールの通知か確認
    if ($msgObj->notificationType == 'Bounce') {
        // バウンスになったメールアドレスを取得
        foreach ($msgObj->bounce->bouncedRecipients as $bounce) {
            // バウンスになったメールアドレス
            print $bounce->emailAddress;
        }
    }
}

最終コード

今回は上記の2つのコードを1つのphpにまとめてしまいます。

ファイル名をget.phpにして、サーバーの任意の場所に配置しましょう。

include_once 'aws/aws-autoloader.php';

use GuzzleHttp\Client;

$msg_body = '';
$msgs     = json_decode(file_get_contents('php://input'));

if ($msgs->Type == 'SubscriptionConfirmation') {
    $client = new GuzzleHttp\Client();
    // SubscribeURLにアクセスする
    $client->get($msgs->SubscribeURL)->send();
} else {
    $msgs = json_decode($str);
    if ($msgObj->notificationType == 'Bounce') {
        foreach ($msgs->bounce->bouncedRecipients as $bounce) {
            // バウンスされたメールアドレスに対する処理を記述
            print $bounce->emailAddress;
        }
    }
}