xy_jx / redis
redis
0.0.3
2023-04-15 16:02 UTC
Requires
- php: >=7.2
README
一个简单的示例
安装
第一步:
composer require xy_jx/redis
第二步:
<?php
use xy_jx\Redis\Redis;
use xy_jx\Redis\RedisQueue;
class xy
{
//redis 配置
$config = [
'host' => '127.0.0.1',
'port' => 6379,
'password' => '',
'select' => 0,
'timeout' => 0,
'expire' => 0,
'prefix' => 'key_da',//前缀
];
//可以直接使用静态方法
$RedisQueue = new RedisQueue($config);
//队列名称
$queue = 'send_user';
//设置队列名称
$RedisQueue->setQueue($queue);
$sendData = ['content' => 'hello', 'db' => 0, 'id' => 1];
//投递及时消息
$RedisQueue->send($sendData);
//投递延迟消息
$RedisQueue->send($sendData, 600);
//获取到消息
if ($message = RedisQueue::consume()) {
$data = json_decode($message, true);
//业务代码
$isSuccess = 1;
if ($isSuccess) {//业务处理成功
//处理成功后删除消息
$RedisQueue->delData($message);
} else {
//处理失败后重新投递消息
$RedisQueue->retryData($message, $data);
}
}
//redis 使用
$redis = new Redis($config);
$redis->set('aaaa',11111);
echo $redis->get('aaaa').PHP_EOL;
echo Redis::get('aaaa');
}