feat: 实现delay-queue所有API接口

Author: ouqiang

.gitignore

@@ -3,4 +3,7 @@
 
 # composer
 composer.lock
-vendor
+vendor
+
+# node
+node_modules

.travis.yml

@@ -1,6 +1,7 @@
 language: php
 
 php:
+  - 5.4
   - 5.5
   - 5.6
   - 7.0

README.md

@@ -1,2 +1,4 @@
 # delayqueue-php
 [延迟队列](https://github.com/ouqiang/delay-queue)PHP客户端
+
+[![Build Status](https://travis-ci.org/ouqiang/delayqueue-php.png)](https://travis-ci.org/ouqiang/delayqueue-php)

bin/delayqueue-php

@@ -1,2 +1,34 @@
 #!/usr/bin/env php
 <?php
+
+use DelayQueue\Process\Worker;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+if (!defined('STDIN') || php_sapi_name() !== 'cli') {
+    echo 'only run in cli';
+    exit(1);
+}
+
+if (!extension_loaded('pcntl') || !extension_loaded('posix')) {
+    echo 'extension pcntl, posix not loaded';
+    exit(2);
+}
+
+// 启动的worker数量
+$workerNum = 5;
+// 延迟队列服务器地址
+$server = 'http://127.0.0.1:9277';
+
+for ($i = 0; $i < $workerNum; $i++) {
+    $pid = pcntl_fork();
+    if ($pid < 0) {
+        throw new Exception('fork failed');
+    }
+    if ($pid === 0) {
+        // 子进程
+        $worker = new Worker();
+        $worker->run();
+        break;
+    }
+}

build_delayqueue.sh

@@ -1,2 +1,7 @@
 #!/usr/bin/env bash
-set -x -u
+
+wget -c https://github.com/ouqiang/delay-queue/releases/download/v0.3/delay-queue-linux-amd64.tar.gz
+tar xzf delay-queue-linux-amd64.tar.gz
+cd delay-queue
+
+./delay-queue &> /dev/null &

composer.json

@@ -15,6 +15,7 @@
   "require": {
     "php": ">= 5.4",
     "ext-pcntl": "*",
+    "ext-posix": "*",
     "monolog/monolog": "^1.0",
     "guzzlehttp/guzzle": "^5.0",
     "psr/container": "^1.0"
@@ -27,13 +28,13 @@
   ],
   "autoload": {
     "psr-4": {
-      "DelayQueue\\": "src/",
-      "Demo\\": "demo/"
+      "DelayQueue\\": "src/"
     }
   },
   "autoload-dev": {
     "psr-4": {
-      "DelayQueue\\Tests\\": "tests/"
+      "DelayQueue\\Tests\\": "tests/",
+      "Demo\\Handler\\": "demo/Handler"
     }
   }
 }

demo/Handler/OrderHandler.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Demo\Handler;
+
+use DelayQueue\Handler\AbstractHandler;
+
+class OrderHandler extends AbstractHandler
+{
+    protected function perform()
+    {
+
+    }
+}

demo/demo.php

@@ -0,0 +1,41 @@
+<?php
+
+use DelayQueue\Job;
+use DelayQueue\Util\Time;
+use DelayQueue\DelayQueue;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$job = new Job();
+$job->setTopic('order');
+$job->setId('15702398321');
+$job->setDelay(1 * Time::MINUTE);
+$job->setTtr(20 * Time::SECOND);
+$job->setBody([
+   'uid' => 10829378,
+  'created' => 1498657365,
+]);
+
+
+$delayQueue = new DelayQueue('http://127.0.0.1:9277');
+$className = 'Demo\\Handler\\OrderHandler';
+try {
+    // 添加一个Job到延迟队列
+    $delayQueue->push($className, $job);
+
+    // 从延迟队列中删除Job
+    $delayQueue->delete('15702398321');
+
+    // 从队列中取出已过期的Job
+    $data = $delayQueue->pop(['order']);
+    // $data['className'] 处理Job的类名
+    // $data['id']        Job唯一标识
+    // $data['body']      Job自定义Body
+
+
+    // Job处理完成, 确认删除
+    $delayQueue->finish('15702398321');
+} catch (Exception $exception) {
+    echo $exception->getMessage();
+}
+

demo/push_job.php

@@ -0,0 +1,31 @@
+{
+  "name": "delayqueue-php",
+  "version": "1.0.0",
+  "description": "[延迟队列](https://github.com/ouqiang/delay-queue)PHP客户端",
+  "main": "index.js",
+  "directories": {
+    "test": "tests"
+  },
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/ouqiang/delayqueue-php.git"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "bugs": {
+    "url": "https://github.com/ouqiang/delayqueue-php/issues"
+  },
+  "homepage": "https://github.com/ouqiang/delayqueue-php#readme",
+  "devDependencies": {
+    "cz-conventional-changelog": "^2.0.0"
+  },
+  "config": {
+    "commitizen": {
+      "path": "./node_modules/cz-conventional-changelog"
+    }
+  }
+}