akimimi/mqutil

适用于具有队列和主题利用的应用程序的消息队列实用库。该库支持阿里云MNS服务,并将支持更多消息队列类型。

1.0.8 2022-09-16 07:43 UTC

This package is auto-updated.

Last update: 2024-09-16 12:11:01 UTC


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.
}