昨日書いた以下記事。

Spotify APIを使ってLINEBotであなたにおすすめプレイリストを全自動で作ってもらう - Qiita

Spotify APIを使ってLINEBotであなたにおすすめプレイリストを全自動で作ってもらう - Qiita...

とにかくSpotify APIを利用することに注力していたため全くレスポンスなどを考えていなかった。
昨日も書いたがとにかく素早くレスポンスを返すことを目指して、しかもPHPでできるのかわからなかったけど、とりあえず非同期で処理させることができたので記載する。

キーワード

非同期
Que
SQS
Supervisor

フローチャート

メッセージをキューにためる（送信側）

今回サーバにはAWSを利用していたので、いろいろ調べたところ、非同期処理にはSQSを利用している情報が多かった。
またSQSを利用するときにはSNSを前に噛ますといいよと言う事で調べてみた。

PHPでもaws-sdkを利用すれば随分簡単に利用することができた。

front.php

require __DIR__."/vendor/autoload.php";
use Aws\Sns\SnsClient;

// object to array
$data = messageEventToJson($events);

// push SNS -> SQS
try{
    $sns = SnsClient::factory(array(
      'key'    => '{YOUR_KEY}',
      'secret' => '{YOUR_SECRET}',
      'region' => 'ap-northeast-1'
    ));
    $response = $sns->publish(array(
        'TopicArn' => '{YOUR_ARN}',
        'Message' => $data
    ));

}catch (Exception $e){
    //
    getLog($e->getMessage());
}

//
function messageEventToJson($events) {
  $eventArray = array();
  foreach($events as $event) {
    if($event instanceof TextMessage) {
      array_push($eventArray, array(
        'type' => $event->getMessageType(),
        'timestamp' => $event->getTimestamp(),
        'replyToken' => $event->getReplyToken(),
        'userId' => $event->getUserId(),
        'text' => $event->getText()
      ));
    }
    else if($event instanceof PostbackEvent) {
      array_push($eventArray, array(
        'type' => $event->getType(),
        'timestamp' => $event->getTimestamp(),
        'replyToken' => $event->getReplyToken(),
        'userId' => $event->getUserId(),
        'postBackData' => $event->getPostbackData()
      ));
    }
  }

  return json_encode($eventArray);
}

下の汚いコードはObjectをJson化できなかったので仕方なくこうやってみたが、たぶん間違っているんだろうと思う。ほんとはObjectそのままをシリアライズしてSQSのメッセージに放り込みたかった。

以上だ。とても簡単。AWS最高。

非同期でキューを取得（受信側）

こちらはSQSから直接取り出す。
非同期については全く知識がなかったのでいろいろ調べた。PHPじゃだめだ、Node.jsだ！Rubyだ！などの情報があって回り道をしたが、結局挫折してPHPでやってみた。
このソースは全く自信がないので真似しないほうがいいです。自分で調べてください。

woker.php

require __DIR__."/vendor/autoload.php";

use Aws\Sqs\SqsClient;

$sqs = SqsClient::factory(array(
      'key'    => '{YOUR_KEY}',
      'secret' => '{YOUR_SECRET}',
    'region'    => 'ap-northeast-1',
    'version' => 'latest',
));

$queueurl = $sqs->getQueueUrl(array(
    'QueueName' => '{YOUR_QUE_NAME}',
));


//メッセージを待機します
while(true){
  try {
    $result = $sqs->receiveMessage(array(
        'QueueUrl' => $queueurl['QueueUrl'],
    ));
    //
    if ($result['Messages'] == null) {
      sleep(1);
    }
    else {
        // Exec Something! # ここにSpotify連携とLINEへの返信処理を記述した


        // status ok is delete sqs message
        if($response->isSucceeded()) {
          try {
            $sqs->deleteMessage(array(
                'QueueUrl' => $queueurl['QueueUrl'],
                'ReceiptHandle' => $receiptHandle
            ));
          }
          catch(Exception $e) {
            echo $e->getMessage();
          }
        }
        else {
          // under construction
        }

      }

    }
  }
  catch(Exception $e) {
    echo $e->getMessage();
  }
}
exit(0);