akimimi / mqutil
适用于具有队列和主题利用的应用程序的消息队列实用库。该库支持阿里云MNS服务,并将支持更多消息队列类型。
1.0.8
2022-09-16 07:43 UTC
Requires
- php: >=7.3.0
- ext-curl: *
- ext-json: *
- ext-openssl: *
- ext-simplexml: *
- aliyun/aliyun-mns-php-sdk: >=1.0.0
Requires (Dev)
- ext-yaml: ^2.2
- phpunit/phpunit: 9.*
README
描述
该库为典型服务调用提供基本的消息队列和主题API。MessageQueueUtil提供支持队列的API。TopicUtil提供支持主题应用的API。这两个工具当前都支持阿里云MNS云服务,并将支持更多消息队列服务驱动程序。
安装
此库支持使用composer CLI添加require。
composer require akimimi/mqutil
否则,将require添加到您的composer.json
文件中。
{ "require": { "akimimi/mqutil": ">=1.0.0" } }
使用Composer安装require
composer install
用法
通过composer安装后,您可以声明使用MessageQueueUtil库类。
<?php use Akimimi\MessageQueueUtil\MessageQueueUtilTest; use Akimimi\MessageQueueUtil\AliyunMnsClientConfig; use Akimimi\MessageQueueUtil\Exception\MquException; $config = new AliyunMnsClientConfig("endpoint", "access_id", "access_key"); $util = new MessageQueueUtil("queue_name", $config); # Create a queue $util->createQueue(); # Send text messages $util->sendTextMessage("some plain text"); # Receive messages try { $messageBody = $util->receiveMessage(30); if ($messageBody != null) { // do something with your business } } catch (MquException $e) { // do something with the exception. }