Add Aliyun Mns Driver For Laravel Queue

Author: milkmeowo

.editorconfig

@@ -0,0 +1,15 @@
+; This file is for unifying the coding style for different editors and IDEs.
+; More information at http://editorconfig.org
+
+root = true
+
+[*]
+charset = utf-8
+indent_size = 4
+indent_style = space
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true
+
+[*.md]
+trim_trailing_whitespace = false

.gitignore

@@ -0,0 +1,4 @@
+.idea
+.DS_Store
+vendor
+composer.lock

.styleci.yml

@@ -0,0 +1,8 @@
+preset: psr2
+
+enabled:
+  - length_ordered_imports
+
+finder:
+  exclude:
+    - "lib"

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2018 
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,124 @@
+# Laravel-MNS
+
+Laravel 队列的阿里云消息服务（MNS）驱动。
+
+## 安装
+
+```bash
+composer require milkmeowo/laravel-mns
+```
+
+## 配置
+
+1.在 config/app.php 注册 ServiceProvider(Laravel 5.5 无需手动注册)
+
+```php
+'providers' => [
+       // ...
+   Milkmeowo\LaravelMns\LaravelMnsServiceProvider::class,
+],
+```
+   
+2.在 `config/queue.php` 中增加 `mns` 配置：
+
+```php
+'connections' => [
+    'redis' => [
+        'driver'     => 'redis',
+        'connection' => 'default',
+        'queue'      => 'default',
+        'expire'     => 60,
+    ],
+    // 新增阿里云 MNS。
+    'mns'   => [
+       'driver'       => 'mns',
+       'key'          => env('QUEUE_MNS_ACCESS_KEY', ''),
+       'secret'       => env('QUEUE_MNS_SECRET_KEY', ''),
+       'endpoint'     => env('QUEUE_MNS_ENDPOINT', ''),
+       'queue'        => env('QUEUE_NAME',''),
+       'wait_seconds' => env('QUEUE_WAIT_SECONDS', 30),
+   ],
+],
+```
+
+3.在 `.env` 增加
+
+```bash
+QUEUE_DRIVER=mns
+QUEUE_NAME=your_queue_name
+QUEUE_MNS_ACCESS_KEY=your_acccess_key
+QUEUE_MNS_SECRET_KEY=your_secret_key
+QUEUE_MNS_ENDPOINT=your-endpoint
+# 关于 wait_seconds 可以看 https://help.aliyun.com/document_detail/35136.html
+QUEUE_WAIT_SECONDS=30
+```
+
+## 使用
+
+正常使用 Laravel Queue 即可：
+
+* [Laravel 队列服务（官方英文文档）](https://laravel.com/docs/5.6/queues)
+
+* [Laravel 队列服务（中文文档）](https://laravel-china.org/docs/laravel/5.6/queues/1395)
+
+## 命令
+
+### 列出所有队列
+
+```bash
+php artisan queue:mns:list 
+// 例如
+php artisan queue:mns:list
+// 输入队列名以 prefix 开头的队列
+php artisan queue:mns:list -p
+
+# 请填写prefix:
+# >
+
+```
+
+### 增加队列
+
+```bash
+php artisan queue:mns:create 队列名
+// 例如
+php artisan queue:mns:create wechat-notify
+```
+
+### 删除队列
+
+```bash
+php artisan queue:mns:delete 队列名
+// 例如
+php artisan queue:mns:delete wechat-notify
+```
+
+### 显示队列内容
+
+```bash
+php artisan queue:mns:show 队列名
+// 例如
+php artisan queue:mns:show wechat-notify
+```
+
+### 删除队列所有内容
+
+```bash
+php artisan queue:mns:flush 队列名
+// 例如
+php artisan queue:mns:flush wechat-notify
+```
+
+## 测试
+
+``` bash
+$ composer test
+```
+
+## 参考
+
+- [abrahamgreyson/laravel-mns](https://github.com/abrahamgreyson/laravel-mns)
+
+## 许可
+
+MIT

composer.json

@@ -0,0 +1,41 @@
+{
+    "name": "milkmeowo/laravel-mns",
+    "description": "Aliyun Mns Driver For Laravel Queue",
+    "keywords": ["aliyun", "laravel", "queue", "mns"],
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "milkmeowo",
+            "email": "milkmeowo@gmail.com"
+        }
+    ],
+    "require": {
+        "illuminate/queue": "^5.6",
+        "guzzlehttp/guzzle": "^6.3"
+    },
+    "require-dev": {
+        "phpunit/phpunit": "^7.1",
+        "mockery/mockery": "^1.1"
+    },
+    "autoload": {
+        "psr-4": {
+            "AliyunMNS\\": "lib/AliyunMNS/",
+            "Milkmeowo\\LaravelMns\\": "src/"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "Milkmeowo\\LaravelMns\\Test\\": "tests/"
+        }
+    },
+    "scripts": {
+        "test": "phpunit"
+    },
+    "extra": {
+        "laravel": {
+            "providers": [
+                "Milkmeowo\\LaravelMns\\LaravelMnsServiceProvider"
+            ]
+        }
+    }
+}

lib/AliyunMNS/AsyncCallback.php

@@ -0,0 +1,29 @@
+<?php
+namespace AliyunMNS;
+
+use AliyunMNS\Exception\MnsException;
+use AliyunMNS\Responses\BaseResponse;
+
+class AsyncCallback
+{
+    protected $succeedCallback;
+    protected $failedCallback;
+
+    public function __construct(callable $succeedCallback, callable $failedCallback)
+    {
+        $this->succeedCallback = $succeedCallback;
+        $this->failedCallback = $failedCallback;
+    }
+
+    public function onSucceed(BaseResponse $result)
+    {
+        return call_user_func($this->succeedCallback, $result);
+    }
+
+    public function onFailed(MnsException $e)
+    {
+        return call_user_func($this->failedCallback, $e);
+    }
+}
+
+?>