官方地址:'https://help.aliyun.com/document_detail/32381.html?spm=5176.doc27477.6.679.CKsLzZ'
- SDK版本:Version 1.3.4
- 更新日期:2017-04-13
<?php
require_once('./vendor/autoload.php');
use AliyunMNS\Client;
use AliyunMNS\Requests\SendMessageRequest;
use AliyunMNS\Requests\CreateQueueRequest;
use AliyunMNS\Exception\MnsException;
$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;
}