fpfgithub / cmq
腾讯云CMQ
Installs: 2 344
Dependents: 0
Suggesters: 0
Security: 0
Stars: 0
Watchers: 2
Forks: 1
Open Issues: 0
Requires
- php: >=5.6.0
Requires (Dev)
- apigen/apigen: ^4.1
- phpunit/phpunit: ^4.8
This package is not auto-updated.
Last update: 2024-05-10 17:08:46 UTC
README
腾讯云CMQ
使用
require 'vendor/autoload.php';
define('APP_ENV', 'test');//根据不同的环境 区分同名队列
$isenv = true; //是否需要拼接环境后缀APP_ENV,默认true
$secretId = ""; //"云 API 密钥 SecretId";
$secretKey = ""; //"云 API 密钥 SecretKey";
$endPoint = 'https://cmq-queue-gz.api.qcloud.com';//endPoint
$cmq = new Qcloud\Cmq($secretId, $secretKey, $endPoint, $isenv);
$queueName = 'test-queue';
//入队列
for ($i=0; $i < 10; $i++) {
$f = $cmq->set($queueName, $i);
echo $f.PHP_EOL;
}
//读队列
do {
$msg = $cmq->get($queueName);
if ($msg) {
$body = $msg->msgBody;
$cmq->ack($queueName, $msg->receiptHandle);//应答 从队列中删除消息
echo $body.PHP_EOL;
}
} while ($msg);
//count
$count = $cmq->count($queueName);
echo 'count=>'.$count.PHP_EOL;
//删除队列
$cmq->set_queue_name($queueName.APP_ENV);
$cmq->delete_queue($queueName.APP_ENV);