初始化目录结构

Author: ouqiang

.gitignore

@@ -0,0 +1,6 @@
+# phpstorm
+.idea
+
+# composer
+composer.lock
+vendor

.travis.yml

@@ -0,0 +1,17 @@
+language: php
+
+php:
+  - 5.5
+  - 5.6
+  - 7.0
+  - 7.1
+
+before_install: bash build_delayqueue.sh
+before_script:
+  - composer install
+
+script: vendor/bin/phpunit
+
+notifications:
+    on_success: never
+    on_failure: always

README.md

@@ -1,2 +1,2 @@
 # delayqueue-php
-延迟队列PHP客户端
+[延迟队列](https://github.com/ouqiang/delay-queue)PHP客户端

bin/delayqueue-php

@@ -0,0 +1,2 @@
+#!/usr/bin/env php
+<?php

build_delayqueue.sh

@@ -0,0 +1,2 @@
+#!/usr/bin/env bash
+set -x -u

composer.json

@@ -0,0 +1,39 @@
+{
+  "name": "start-point/delayqueue-php",
+  "type": "library",
+  "description": "PHP client for DelayQueue",
+  "keywords": ["delayqueue","delayqueue-php"],
+  "homepage": "https://github.com/ouqiang/delayqueue-php",
+  "license": "MIT",
+  "authors": [
+    {
+      "name": "ouqiang",
+      "email": "qingqianludao@gmail.com",
+      "homepage": "https://github.com/ouqiang"
+    }
+  ],
+  "require": {
+    "php": ">= 5.4",
+    "ext-pcntl": "*",
+    "monolog/monolog": "^1.0",
+    "guzzlehttp/guzzle": "^5.0",
+    "psr/container": "^1.0"
+  },
+  "require-dev": {
+    "phpunit/phpunit": "4.5.*"
+  },
+  "bin": [
+    "bin/delayqueue-php"
+  ],
+  "autoload": {
+    "psr-4": {
+      "DelayQueue\\": "src/",
+      "Demo\\": "demo/"
+    }
+  },
+  "autoload-dev": {
+    "psr-4": {
+      "DelayQueue\\Tests\\": "tests/"
+    }
+  }
+}

demo/push_job.php

@@ -0,0 +1,17 @@
+<?php
+
+use DelayQueue\Job;
+use DelayQueue\Util\Time;
+use DelayQueue\DelayQueue;
+
+require '../vendor/autoload.php';
+
+$job = new Job();
+$job->setTopic('order');
+$job->setId('15702398321');
+$job->setDelay(1 * Time::HOUR);
+$job->setTtr(60 * Time::SECOND);
+$job->setBody([
+   'uid' => 10829378,
+    'created' => 1498657365,
+]);

phpunit.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit bootstrap="vendor/autoload.php">
+    <testsuites>
+        <testsuite>
+            <directory>tests</directory>
+        </testsuite>
+    </testsuites>
+</phpunit>

service.php

@@ -0,0 +1,2 @@
+<?php
+

src/Container/Container.php

@@ -0,0 +1,105 @@
+<?php
+
+namespace DelayQueue\Container;
+
+use Closure;
+use ArrayAccess;
+use Psr\Container\ContainerInterface;
+use DelayQueue\Exception\ServiceNotFoundException;
+
+/**
+ * 服务容器
+ */
+class Container implements  ContainerInterface, ArrayAccess
+{
+    /**
+     * @var array 服务定义
+     */
+    protected  $definitions = [];
+    /**
+     * @var array 已实例化的服务
+     */
+    protected  $instances = [];
+
+    /**
+     * 添加服务
+     *
+     * @param string  $id       服务唯一标识
+     * @param Closure $callback
+     */
+    public  function set($id, Closure $callback)
+    {
+        if ($id) {
+            $this->definitions[$id] = $callback;
+        }
+    }
+
+    /**
+     * 查找服务是否存在
+     *
+     * @param  string $id 服务唯一标识
+     * @return bool
+     */
+    public function has($id)
+    {
+        return isset($this->definitions[$id]);
+    }
+
+    /**
+     * 获取服务
+     *
+     * @param  string $id 服务唯一标识
+     * @return mixed
+     * @throws ServiceNotFoundException
+     */
+    public  function get($id)
+    {
+        if (isset($this->instances[$id])) {
+            return $this->instances[$id];
+        }
+
+        if (!isset($this->definitions[$id])) {
+            $message = sprintf('service [%s] not exists', $id);
+            throw new ServiceNotFoundException($message);
+        }
+
+        /** @var Closure $callback */
+        $callback = $this->definitions[$id];
+        $callback = $callback->bindTo($this);
+
+        $this->instances[$id] = $callback();
+
+        return $this->instances[$id];
+    }
+
+    public function __get($name)
+    {
+        return $this->get($name);
+    }
+
+    public function __set($name, $value)
+    {
+        $this->set($name, $value);
+    }
+
+    public function offsetExists($offset)
+    {
+        return $this->has($offset);
+    }
+
+    public function offsetGet($offset)
+    {
+        return $this->get($offset);
+    }
+
+    public function offsetSet($offset, $value)
+    {
+        $this->set($offset, $value);
+    }
+
+    public function offsetUnset($offset)
+    {
+        unset($this->definitions[$offset]);
+        unset($this->instances[$offset]);
+    }
+}