aliyun-mqs-lib
阿里云MQS队列服务PHP非官方SDK。
官方已经更新MQS为MNS服务, 更好更快更强, 且发布了最新的官方sdk,地址为: PHP SDK_SDK使用手册_消息服务-阿里云产品文档
安装
使用composer安装
"baocaixiong/aliyun-mqs-lib": "dev-master"
使用
暂时只针对laravel4.2版本，其他环境请自看phpunit测试。
'mqs' => [
'driver' => 'mqs',
'queue' => '<queue name>',
'host' => '<queue host>',
'key' => '<access key>',
'secret' => '<access secret>',
'keepalive' => 'receive message waitseconds',
]
将其中 default 键值改为 mqs
app/config/app.php中, providers键中添加
'MqsLaravelMqsServiceProvider'
使用Cache::push('', ["x" => ""]) 推送队列数据到mqs
单独使用
创建Queue
$req = new MqsRequestCreateQueue('queue-name');
$req->setDelaySeconds(x);
$req->setMaximumMessageSize(x);
// 如果参数已经组好了数组可以直接通过 $req->params($parameters) 设置属性;
$res = $req->send();
$res->isSuccess(); // => true
发送消息
$req = new MqsRequestSendMessage('queue-name');
$req->setMessageBody(xxx);
$req->setDelaySeconds(xxx);
$res = $req->send();
$res->isSuccess(); // => true 成功
接受消息
$req = new MqsRequestReceiveMessage('queue-name');
$req->setWaitseconds(30);
$res = $req->send();
if ($res->isSuccess()) {
$message = $res->getMessage(); // => MqsMessage
}
$messageBody = $message->getMessageBody();
// do something
版权声明：
1、该文章(资料)来源于互联网公开信息，我方只是对该内容做点评，所分享的下载地址为原作者公开地址。2、网站不提供资料下载，如需下载请到原作者页面进行下载。
3、本站所有内容均由合作方或网友上传，本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺！文档内容仅供研究参考学习用！
4、如文档内容存在违规，或者侵犯商业秘密、侵犯著作权等，请点击“违规举报”。
