Skip to content

Jokin-china/php-queue

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

11 Commits
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

php-queue

##1.说明 php-queue是一个对常用对列使用封装的库。

驱动 说明 限制
MySQL MySQL驱动,支持ack 消息个数最大支持42亿
Redis Redis驱动 不支持ack
升级日志
   v-0.3.0
     1.添加ack机制
     2.MySQL驱动表结构添加pop_time和ack_time字段
     3.暂时只有MySQL驱动支持
   v-0.2.0
     1.添加retry机制(ttl)
     2.去掉medoo,使用pdo方式,防止内存泄漏
   v-0.1.0
     1.添加mysql驱动

##2 安装以及使用 ###2.1 安装 composer require d1studio\php-queue ###2.2 使用

<?php
include __DIR__.'/vendor/autoload.php';
$mysql_queue = \d1studio\php_queue\Queue::getQueue('send_coupon',[
    'drive'  => 'Mysql',
    'option' => [
        'database_name' => 'queue',
        'server'        => '127.0.0.1',
        'username'      => 'root',
        'password'      => '123456',

    ],
]);
include __DIR__.'/../vendor/autoload.php';
$mysql_queue = \d1studio\php_queue\Queue::getQueue('send_coupon',[
    'drive'  => 'Mysql',
    'option' => [
        'database_name' => 'queue',
        'server'        => '127.0.0.1',
        'username'      => 'root',
        'password'      => '123456',

    ],
]);
$mysql_queue->push("test",5);
$data = $mysql_queue->pop();

About

PHP队列 支持多种中间件

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages