MNS SDK for PHP

官方地址:'https://help.aliyun.com/document_detail/32381.html?spm=5176.doc27477.6.679.CKsLzZ'

操作

<?php require_once('./vendor/autoload.php'); use AliyunMNSClient; use AliyunMNSRequestsSendMessageRequest; use AliyunMNSRequestsCreateQueueRequest; use AliyunMNSExceptionMnsException; $accessId = ''; $accessKey = ''; $endPoint = ''; /* 发送数据 */ $queue = $client->getQueueRef($queueName); $messageBody = '数据,字符串类型'; // 3个参数(数据,指定的秒数延后可被消费，单位为秒,消息的优先级权值，取值范围：1~16，其中1为最高优先级) // 参考 https://help.aliyun.com/document_detail/35134.html?spm=5176.doc35135.6.719.L2LVs6#h2-request $request = new SendMessageRequest($messageBody,0,4); try { $res = $queue->sendMessage($request); echo "MessageSent! n"; } catch (MnsException $e) { echo "SendMessage Failed: " . $e; return; } /* 获取数据 */ $receiptHandle = NULL; try{ // 1. 直接调用receiveMessage函数 // 1.1 receiveMessage函数接受waitSeconds参数，无特殊情况这里都是建议设置为30 // 1.2 waitSeconds非0表示这次receiveMessage是一次http long polling，如果queue内刚好没有message，那么这次request会在server端等到queue内有消息才返回。最长等待时间为waitSeconds的值，最大为30。 $res = $queue->receiveMessage(30); echo "ReceiveMessage Succeed! n"; // 2. 获取ReceiptHandle，这是一个有时效性的Handle，可以用来设置Message的各种属性和删除Message。具体的解释请参考：help.aliyun.com/document_detail/27477.html 页面里的ReceiptHandle $receiptHandle = $res->getReceiptHandle(); $messageBody = $res->getMessageBody(); var_dump($messageBody); } catch (MnsException $e) { // 3. 像前面的CreateQueue和SendMessage一样，我们认为ReceiveMessage也是有可能出错的，所以这里加上CatchException并做对应的处理。 echo "ReceiveMessage Failed: " . $e . "n"; echo "MNSErrorCode: " . $e->getMnsErrorCode() . "n"; return; } /* 删除拿到的消息 */ try { // 5. 直接调用deleteMessage即可。 $res = $queue->deleteMessage($receiptHandle); echo "DeleteMessage Succeed! n"; } catch (MnsException $e) { // 6. 这里CatchException并做异常处理 // 6.1 如果是receiptHandle已经过期，那么ErrorCode是MessageNotExist，表示通过这个receiptHandle已经找不到对应的消息。 // 6.2 为了保证receiptHandle不过期，VisibilityTimeout的设置需要保证足够消息处理完成。并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。 echo "DeleteMessage Failed: " . $e . "n"; echo "MNSErrorCode: " . $e->getMnsErrorCode() . "n"; return; }