scienta/php-rsmq-client

一个用于向 RSMQ（一个 Node.js 消息队列）发布消息的客户端。

维护者

详细信息

github.com/ScientaNL/php-rsmq-client

源代码

问题

安装次数: 35,657

依赖项: 0

建议者: 0

安全性: 0

星标: 4

关注者: 6

分支: 1

开放问题: 0

1.0.1 2020-12-01 14:48 UTC

Requires

  • php: ^7.1 || ^8.0

Requires (Dev)

Suggests

  • ext-redis: PHPRedis extension to communicate with Redis

MIT df487eff1cc6adc0fe9417cf83220a258a013605

redisqueuemessage-queuersmq

This package is auto-updated.

Last update: 2024-08-29 05:07:13 UTC

README

Latest Stable Version Total Downloads License

php-rsmq-client

一个用于在 Redis 中排队 RSMQ 消息的库。

简述

一个 RSMQ 的 enqueue-code 的 PHP 实现，用于将消息添加到队列。支持新消息的 实时 发布。

安装

推荐通过 Composer 安装 php-rsmq-client。将以下依赖项添加到您的 composer.json 中

{
	"require": {
		"scienta/php-rsmq-client": "~1.0"
	}
}

或者，您可以将 源代码 下载为文件并解压缩。

用法

队列和消息的配置可以比下面指定的更详细，所有 RSMQ 选项都受支持。该库使用 Redis 适配器，使得使用其他 PHP Redis 客户端成为可能。默认（在此示例中使用）是 phpredis C 扩展。

创建基本队列

use Scienta\RSMQClient\Config;
use Scienta\RSMQClient\Message;
use Scienta\RSMQClient\Queue;
use Scienta\RSMQClient\Redis\RedisAdapter;

//Create a redis connection
$redis = new \Redis();
$redis->connect('127.0.0.1', '6379');

//Configure and create/sync a queue
$config = new Config('myqueue');
$redisAdapter = new RedisAdapter($redis);
$queue = new Queue($config, $redisAdapter);

//Create a message
$message = new Message('Hello World');

//Send the message
$sentId = $queue->sendMessage($message);