全部产品
媒体转码

队列方式接收通知

更新时间:2017-07-03 10:26:37   分享:   

返回:简介 >>

接收消息通知-队列-PHP

这里简单介绍一下消息服务的要求和安装说明,详细请参考消息服务提供的文档:SDK下载队列使用手册

示例的语言采用PHP,其他语言使用说明,请参考消息服务提供的文档:SDK使用手册

  • 环境要求

    PHP 5.5+

  • 安装

    从Aliyun下载消息服务的PHP SDK

    解压到项目目录,解压后的目录名是php_sdk

  • 示例代码

    • 引用消息服务SDK

      1. require_once(dirname(__FILE__).'/php_sdk/mns-autoloader.php');
    • 初始化消息服务

      MNS对用户的每个区域都配置了一个单独的服务域名,规则是:https://${UserId}.mns.${Region}.aliyuncs.com 。示例代码使用的华东1区域(cn-hangzhou),也可以替换为其他区域,例如华北2区域(cn-beijing)。

      1. use AliyunMNS\Client;
      2. use AliyunMNS\Exception\MnsException;
      1. $mns_client = new Client('https://'.$user_id.'.mns.cn-hangzhou.aliyuncs.com',
      2. $access_key_id, $access_key_secret);
      3. $queue = $mns_client->getQueueRef($queue_name);
    • 接收消息

      MNS接收到的每条消息都对应一个句柄,后续可以使用句柄操作这条消息(例如删除消息)。

      另外,MNS支持批量接收消息来提高性能。参考MNS的文档批量消费消息

      接收消息时,可以指定超时时间(示例设置了3秒超时),如果队列中没有消息,会发生超时并触发异常。

      1. $receipt_handle = NULL;
      2. $message = null;
      3. try
      4. {
      5. $res = $queue->receiveMessage(3);
      6. echo "ReceiveMessage Succeed! \n";
      7. $message = $res->getMessageBody();
      8. $receipt_handle = $res->getreceiptHandle();
      9. }
      10. catch (MnsException $e)
      11. {
      12. echo "ReceiveMessage Failed: " . $e . "\n";
      13. }
    • 删除消息

      消息不会主动从队列删除,必须主动调用删除消息,否则消息会一直保持在队列中,下次还会继续接收到同一个消息。另外,删除消息操作必须在接收到消息后指定时间内调用才能成功,参见消费服务-删除消息说明

      1. try
      2. {
      3. $res = $queue->deleteMessage($receipt_handle);
      4. echo "DeleteMessage Succeed! \n";
      5. }
      6. catch (MnsException $e)
      7. {
      8. echo "DeleteMessage Failed: " . $e . "\n";
      9. }
    • 分析消息

      消息体是字符串,内容是一个JSON对象,需要通过json_decode转换成对象,然后就可以分析JSON对象来获取详细信息了,示例打印了这次消息是哪个输出文件触发的媒体工作流执行。

      1. $json_message = json_decode($message);
      2. $input_file = $json_message->{'MediaWorkflowExecution'}->{'Input'}->{'InputFile'};
      3. echo '输入文件 location:'.$input_file->{'Location'}.
      4. ' bucket:'.$input_file->{'Bucket'}.
      5. ' object:'.$input_file->{'Object'}."\n";
    • 获取视频输出的详细信息

      获取到消息详细内容后,可以配合使用媒体库服务API获取工作流执行的视频详细信息。示例打印出这次转码和截图作业的输出地址。

      如何安装和配置媒体库服务的PHP SDK,参考文档媒体库SDK-PHP

      1. include_once 'aliyun-php-sdk-core/Config.php';
      2. use Mts\Request\V20140618 as Mts;

      初始媒体库服务的client。

      1. $profile = DefaultProfile::getProfile('cn-hangzhou',
      2. $access_key_id,
      3. $access_key_secret);
      4. $mts_client = new DefaultAcsClient($profile);

      打印所有转码作业的输出地址和基本信息。

      1. if (strcmp($json_message->{'Type'}, 'Report') == 0) {
      2. $activities = $json_message->{'MediaWorkflowExecution'}->{'ActivityList'};
      3. $transcode_job_ids = Array();
      4. for ($i=0; $i < count($activities); $i++) {
      5. if (strcmp($activities[$i]->{'Type'}, 'Transcode') == 0) {
      6. $transcode_job_ids[] = $activities[$i]->{'JobId'};
      7. }
      8. }
      9. $request = new Mts\QueryJobListRequest();
      10. $request->setJobIds(join(',', $transcode_job_ids));
      11. $request->setRegionId('cn-hangzhou');
      12. $response = $mts_client->getAcsResponse($request);
      13. for ($i=0; $i < count($response->{'JobList'}->{'Job'}); $i++) {
      14. $output = $response->{'JobList'}->{'Job'}[$i]->{'Output'};
      15. $output_file = $response->{'JobList'}->{'Job'}[$i]->{'Output'}->{'OutputFile'};
      16. $video_properties = $response->{'JobList'}->{'Job'}[$i]->{'Output'}->{'Properties'};
      17. echo '转码输出文件URL '.'http://'.$output_file->{'Bucket'}.'.'.
      18. $output_file->{'Location'}.'.aliyuncs.com/'.
      19. urldecode($output_file->{'Object'})."\n";
      20. echo '转码输出文件基本信息 '.$video_properties->{'Width'}.'x'.$video_properties->{'Height'}.
      21. ' duration:'.$video_properties->{'Duration'}."\n";
      22. }
      23. }

      打印所有截图作业的输出地址。

      1. if (strcmp($json_message->{'Type'}, 'Report') == 0) {
      2. $activities = $json_message->{'MediaWorkflowExecution'}->{'ActivityList'};
      3. $snapshot_job_ids = Array();
      4. for ($i=0; $i < count($activities); $i++) {
      5. if (strcmp($activities[$i]->{'Type'}, 'Snapshot') == 0) {
      6. $snapshot_job_ids[] = $activities[$i]->{'JobId'};
      7. }
      8. }
      9. $request = new Mts\QuerySnapshotJobListRequest();
      10. $request->setSnapshotJobIds(join(',', $snapshot_job_ids));
      11. $request->setRegionId('cn-hangzhou');
      12. $response = $mts_client->getAcsResponse($request);
      13. for ($i=0; $i < count($response->{'SnapshotJobList'}->{'SnapshotJob'}); $i++) {
      14. $snapshot_config = $response->{'SnapshotJobList'}->{'SnapshotJob'}[$i]->{'SnapshotConfig'};
      15. $output_file = $response->{'SnapshotJobList'}->{'SnapshotJob'}[$i]->{'SnapshotConfig'}->{'OutputFile'};
      16. echo '截图输出文件URL '.'http://'.$output_file->{'Bucket'}.'.'.
      17. $output_file->{'Location'}.'.aliyuncs.com/'.
      18. urldecode($output_file->{'Object'})."\n";
      19. }
      20. }

返回:简介 >>

本文导读目录
本文导读目录
以上内容是否对您有帮助?