検索

ホームページ  >  記事  >  バックエンド開発  >  PHP を使用した Amazon SES プロキシサーバーの実装

PHP を使用した Amazon SES プロキシサーバーの実装

WBOY
WBOYオリジナル
2016-07-25 08:46:301209ブラウズ

この記事を理解するには、SES を使用するための一定の基礎が必要です。理解できない場合は、この質問の説明を読んでください。 http://segmentfault.com/q/1010000000095210

SES の正式名は Simple Email Service で、Amazon が開始した基本的な電子メール サービスです。 AWS の基本サービスの一部として、AWS の伝統的な利点である安いを継承しています。

はい、本当に安いです。これが、私が mailgun やその他の優れた電子メール サービスを使用しない理由です。毎月 100,000 通の電子メールを送信する場合、基本的に支払う必要があるのは約 10 ドルだけです。数百ドルから始まることが多い他のサービスと比較すると、この価格のメリットは非常に大きいです。したがって、これで私はその多くの欠点を許容できます。

しかし、中国でSESを利用する人が増えるにつれ、昨年末、ある日突然ブロックされてしまい、致命傷となりました。そこで、このサービスを使い続けるために、自分の海外サーバーにプロキシを構築してみました。同時に、これは API を改善して、一斉メール送信などのより価値のある機能を実装する機会にもなります。

なので、海外サーバーを使用せずに直接リバースプロキシを作ってプレイしただけでは、表面的な問題は解決しただけで、機能拡張の必要性は実現されませんでした。したがって、この SES エージェントを設計するために 2 つの基本的な目標を設定しました

元の API インターフェイスと完全な互換性があるため、プロキシを使用するために元のコードを基本的に変更する必要はありません。 一斉メール機能の実装

最初のポイントを達成するのは実際には非常に簡単です。実際には、PHP を使用してリバース プロキシを実装し、送信されたパラメーターを受け取り、アセンブル後にcurl コンポーネントを使用して実際の SES サーバーに送信し、直接出力します。領収書を取得した後、クライアントに渡します。これは標準的な代理店のプロセスです。私のコードを以下に示します。重要な部分についてはコメントしました

。

これらのコードはドメイン名のルート ディレクトリに配置する必要があることに注意してください

もちろん、第 2 レベルのドメイン名も使用できます。
  2. include __DIR__ . '/includes.php';
  4. // さらに重要なヘッダーがいくつかありますが、その他は注意する必要はありません
  5. $headers = array(
  6. 'Date : ' . get_header ('Date'),
  7. 'Host: ' . SES_HOST,
  8. 'X-Amzn-Authorization: ' . get_header('X-Amzn-Authorization')
  9. );
  11. // 次に、URL を再度アセンブルします。この正しい SES サーバーをリクエストするには
  12. $url = 'https://' . '/'
  13. . (empty($_SERVER['QUERY_STRING']) ? '' : '?' . $_SERVER['QUERY_STRING'] );
  15. $ch =curl_init();
  16. curl_setopt($ch, CURLOPT_USERAGENT, 'SimpleEmailService/php');
  17. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1);
  18. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1);
  20. // 処理が必要です `POST` メソッドと `DELETE` メソッドだけです。 `GET` メソッドはたくさんあるので、一つずつ実装しません
  21. // 実際には、これらはすべて取得するためのメソッドです。この情報はバックグラウンドで直接表示できます。
  22. switch ($_SERVER ['REQUEST_METHOD']) {
  23. case 'GET':
  24. Break;
  25. case 'POST':
  26. global $HTTP_RAW_POST_DATA;
  27. $data = empty( $HTTP_RAW_POST_DATA) ? file_get_contents('php://input')
  28. : $ HTTP_RAW_POST_DATA;
  29. $headers[] = 'Content-Type: application/x-www-form-urlencoded';
  30. parse_data($data);
  32. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
  33. curl_setopt($ch , CURLOPT_POSTFIELDS, $data);
  34. ブレーク;
  35. case 'DELETE':
  36. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
  37. ブレーク;
  38. デフォルト:
  39. Break;
  40. }
  42. curl_setopt($ch, CURLOPT_HTTPHEADER, $ headers);
  43. curl_setopt($ch, CURLOPT_HEADER, false);
  45. curl_setopt($ch, CURLOPT_URL, $url);
  46. curl_setopt($ch, curlopt_returntransfer、true）;
  47. curl_setopt（$ ch、curlopt_folowlocation、true）; ;
  49. curl_close($ch);
  51. header('Content-Type : ' . $content_type, true, $status);
  52. echo $response;
  56. コードをコピー

このコードは非常にシンプルですが、注意する必要があるいくつかのトリックがあります。その中で、POST メソッドを処理するときに、この関数が実際に大量メールを実装するための鍵となります。

そう言えば、SES の電子メール送信 API について触れなければなりません。SES は、複数の送信オブジェクトをサポートする単純な電子メール送信 API のみを提供します。ただし、複数の受信者に送信する場合は、受信者列にも表示されます。他の受信者のアドレス。もちろん、ccやbccのカーボンコピー機能にも対応していますが、このカーボンコピー機能を使ってグループメールを送信すると、受信者には受信者ではなく、カーボンコピーの対象の中に含まれることになります。通常の Web サイトでは、これらは明らかに許容できません。

つまり、電子メールを送信するには、実際の同時インターフェースが必要です。SES によって割り当てられた割り当ては、1 秒あたり 28 件の電子メールを送信することであることを知っておく必要があります (各人に異なる割り当てが設定されています)。フル活用すると、1 時間あたり 100,000 件の電子メールを送信できるようになります。 、これは完全に中規模のウェブサイトのニーズを満たすことができます。

そこで私はアイデアを思いつきました。 クライアント インターフェイスをまったく変更せずに、プロキシ サーバー経由で送信された複数の受信者を含む電子メールを 1 つの受信者を含む複数の電子メールに解凍し、これらの電子メールを非同期を使用して SES に送信します。行列。これは parse_data 関数が行うことです。以下に、使用するすべてのプライベート関数を含むコードを直接記述します

。
  2. define('REDIS_HOST', '127.0.0.1');
  3. define('REDIS_PORT', 6379);
  4. define('SES_HOST', 'email.us-east-1.amazonaws .com');
  5. define('SES_KEY', '');
  6. define('SES_SECRET', '');
  8. /**
  9. * get_header
  10. *
  11. * @parammixed $name
  12. * @access public
  13. * @return void
  14. */
  15. function get_header($name) {
  16. $name = ' HTTP_' 。 strtoupper(str_replace('-', '_', $name));
  17. return isset($_SERVER[$name]) ? $_SERVER[$name] : '';
  18. }
  20. /**
  21. * my_parse_str
  22. *
  23. * @parammixed $query
  24. * @parammixed$params
  25. * @access public
  26. * @return void
  27. */
  28. function my_parse_str($query, &$params) {
  29. if (empty($query)) {
  30. return;
  31. }
  33. $decode = function ($str) {
  34. return rawurldecode(str_replace('~', '%7E', $str));
  35. };
  37. $data =explode('&', $query);
  38. $ params = array();
  39. foreach ($data as $value) {
  40. list ($key, $val) =explode('=', $value, 2);
  41. if (isset($params[$key]) ) {
  42. if (!is_array($params[$key])) {
  43. $params[$key] = array($params[$key]);
  44. }
  45. $params[$key][] = $val;
  46. } else {
  47. $params[$key] = $decode($val);
  48. }
  49. }
  50. }
  52. /**
  53. * my_urlencode
  54. *
  55. * @parammixed $str
  56. * @access public
  57. * @return void
  58. */
  59. function my_urlencode($str) {
  60. return str_replace('%7E ', '~', rawurlencode($str));
  61. }
  63. /**
  64. * my_build_query
  65. *
  66. * @parammixed $params
  67. * @access public
  68. * @return void
  69. */
  70. function my_build_query($parameters) {
  71. $params = array();
  72. foreach ($parameters as $var = > $value) {
  73. if (is_array($value)) {
  74. foreach ($value as $v) {
  75. $params[] = $var.'='.my_urlencode($v);
  76. }
  77. } else {
  78. $params[] = $var.'='.my_urlencode($value);
  79. }
  80. }
  82. sort($params, SORT_STRING);
  83. return implode('&', $params);
  84. }
  86. /**
  87. * my_headers
  88. *
  89. * @parammixed $headers
  90. * @access public
  91. * @return void
  92. */
  93. function my_headers() {
  94. $date = gmdate('D, d M Y H:i:s e');
  95. $sig = Base64_encode(hash_hmac('sha256', $date, SES_SECRET, true));
  97. $headers = array();
  98. $headers[] = '日付: ' 。 $date;
  99. $headers[] = 'ホスト: ' 。 SES_HOST;
  101. $auth = 'AWS3-HTTPS AWSAccessKeyId=' 。 SES_KEY;
  102. $auth .= ',アルゴリズム=HmacSHA256,署名=' 。 $sig;
  104. $headers[] = 'X-Amzn-Authorization: ' . $auth;
  105. $headers[] = 'Content-Type: application/x-www-form-urlencoded';
  107. return $headers;
  108. }
  110. /**
  111. * parse_data
  112. *
  113. * @parammixed $data
  114. * @access public
  115. * @return void
  116. */
  117. function parse_data(&$data ) {
  118. my_parse_str($data, $params);
  120. if (!empty($params)) {
  121. $redis = new Redis();
  122. $redis->connect(REDIS_HOST, REDIS_PORT);
  124. //多送信地址
  125. if (isset($params['Destination.ToAddresses.member.2'])) {
  126. $address = array();
  127. $mKey = uniqid();
  129. $i = 2;
  130. while (isset($params['Destination.ToAddresses.member.' . $i])) {
  131. $aKey = uniqid();
  132. $key = 'Destination.ToAddresses.member.' 。 $i;
  133. $address[$aKey] = $params[$key];
  134. unset($params[$key]);
  136. $i ++;
  137. }
  139. $data = my_build_query($params);
  141. unset($params['Destination.ToAddresses.member.1']);
  142. $redis->set('m:' . $mKey, my_build_query($params));
  143. foreach ($address as $k = > $a) {
  144. $redis->hSet('a:' . $mKey, $k, $a);
  145. $redis->lPush('mail', $k . '|' . $mKey );
  146. }
  147. }
  148. }
  149. }
复制發

parse_data 関数が 2 番目の受信者から開始され、それらを個別のメールにまとめて、他の独立したプロセスが読み取って送信できるように Redis キューに入れていることがわかります。

最初の受信者から始めてみませんか?

元のプロトコルと互換性がある必要があるため、クライアントがメールリクエストを送信するときは、常に何かを返す必要があるため、最初の受信者のメールリクエストが直接送信されます。はキューに入らないので、実際の SES サーバーのレシートを取得してクライアントに返すことができ、クライアント コードは変更を加えずにこの戻りを処理できます。

SES メールに署名が必要な場合はどうすればよいですか?

はい、すべての SES メールには署名が必要です。したがって、解凍すると電子メールのデータが変更されるため、署名も変更する必要があります。 my_build_query 関数はこれを実行し、リクエスト パラメーターに再署名します。

以下は、このプロキシ システムの最後のコンポーネントであるメール送信キューの実装です。これも php ファイルであり、nohup php コマンドを使用して、独自のクォータ サイズに従ってバックグラウンドで複数の php プロセスを開始し、同時メールを実現できます。送信。その構造も非常にシンプルで、キュー内のメールを読んでから、curl を使用してリクエストを送信します

  2. include __DIR__ . '/includes.php';
  4. $redis = new Redis();
  5. $redis->connect(REDIS_HOST, REDIS_PORT);
  7. do {
  8. $pop = $redis->brPop('mail', 10);
  9. if (empty($pop)) {
  10. continue;
  11. }
  13. list ($k, $id) = $pop;
  14. list($aKey, $mKey) =explode('|', $id);
  16. $address = $redis->hGet('a:' . $mKey, $aKey);
  17. if (empty($address)) {
  18. continue ;
  19. }
  21. $data = $redis->get('m:' . $mKey);
  22. if (empty($data)) {
  23. continue;
  24. }
  26. my_parse_str($data, $params);
  27. $params['Destination.ToAddresses.member.1'] = $address;
  28. $data = my_build_query($params);
  29. $headers = my_headers();
  30. $url = 'https://' 。 /';
  32. $ch =curl_init();
  33. curl_setopt($ch, CURLOPT_USERAGENT, 'SimpleEmailService/php');
  34. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  35. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  37. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
  38. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  39. curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  40. curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  41. curl _setopt ($ch, CURLOPT_URL, $url);
  42. curl_setopt($ch, CURLOPT_TIMEOUT, 10);
  44. curl_exec($ch);
  45. curl_close($ch);
  47. unset($ch);
  48. unset($data) ;
  50. } while (true);
コードをコピー

上記は、SES メール プロキシ サーバーの作成に関する私のアイデア全体です。ぜひ一緒に議論してください。

プロキシサーバー、PHP、Amazon


声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：PHPループ内の「参照」によって引き起こされる奇妙な問題次の記事：PHPループ内の「参照」によって引き起こされる奇妙な問題

関連記事

続きを見る