baocaixiong/aliyun-mqs-lib

阿里云MQS服务PHP SDK

维护者

详细信息

github.com/baocaixiong/aliyun-mqs-lib

源代码

问题

安装次数: 5

依赖项: 0

建议者: 0

安全性: 0

星标: 9

关注者: 2

分支: 0

开放问题: 2

0.0.2 2015-02-08 14:09 UTC

Requires

MIT 1a6d3caa44ac7887aa714d6f91f3aee8a3cf622e

  • baocaixiong <baocaixiong.woop@gmail.com>

aliyunmqs

This package is not auto-updated.

Last update: 2024-09-28 15:49:42 UTC

README

阿里云MQS队列服务PHP非官方SDK。

官方已经更新MQS为MNS服务，更好更快更强，并且发布了最新的官方SDK，地址为：[PHP SDK使用手册_消息服务-阿里云产品文档](https://help.aliyun.com/document_detail/mns/sdk/php-sdk.html)。

安装

使用composer安装

"baocaixiong/aliyun-mqs-lib": "dev-master"

使用

暂时只针对laravel4.2版本，其他环境请自看phpunit测试。

  1. 在app/config/queue.php中添加
'mqs' => [
    'driver' => 'mqs',
    'queue' => '<queue name>',
    'host' => '<queue host>',
    'key' => '<access key>',
    'secret' => '<access secret>',
    'keepalive' => 'receive message waitseconds',
]

将其中 default 键值改为 mqs

  1. 添加provider, 在 app/config/app.php中, providers键中添加
   'Mqs\Laravel\MqsServiceProvider'
  1. 使用Cache::push('', ["x" => ""]) 推送队列数据到mqs

单独使用

创建队列

$req = new \Mqs\Request\CreateQueue('queue-name');
$req->setDelaySeconds(x);
$req->setMaximumMessageSize(x);
// 如果参数已经组好了数组可以直接通过 $req->params($parameters) 设置属性;
$res = $req->send();
$res->isSuccess(); // => true

发送消息

$req = new \Mqs\Request\SendMessage('queue-name');
$req->setMessageBody(xxx);
$req->setDelaySeconds(xxx);
$res = $req->send();
$res->isSuccess(); // => true 成功

接收消息

$req = new \Mqs\Request\ReceiveMessage('queue-name');
$req->setWaitseconds(30);
$res = $req->send();
if ($res->isSuccess()) {
    $message = $res->getMessage(); // => \Mqs\Message
}
$messageBody = $message->getMessageBody();
// do something