创建项目

+APP_DEBUG = true [APP]
DEFAULT_TIMEZONE = Asia/Shanghai [DATABASE]
TYPE = mysql
HOSTNAME = 127.0.0.1
DATABASE = test
USERNAME = username
PASSWORD = password
HOSTPORT = 3306
CHARSET = utf8
DEBUG = true [LANG]
default_lang = zh-cn

+/.idea
+/.vscode
+/vendor
+*.log
+.env

+sudo: false
+
+language: php
+
+branches:
+ only:
+ - stable
+
+cache:
+ directories:
+ - $HOME/.composer/cache
+
+before_install:
+ - composer self-update
+
+install:
+ - composer install --no-dev --no-interaction --ignore-platform-reqs
+ - zip -r --exclude='*.git*' --exclude='*.zip' --exclude='*.travis.yml' ThinkPHP_Core.zip .
+ - composer require --update-no-dev --no-interaction "topthink/think-image:^1.0"
+ - composer require --update-no-dev --no-interaction "topthink/think-migration:^1.0"
+ - composer require --update-no-dev --no-interaction "topthink/think-captcha:^1.0"
+ - composer require --update-no-dev --no-interaction "topthink/think-mongo:^1.0"
+ - composer require --update-no-dev --no-interaction "topthink/think-worker:^1.0"
+ - composer require --update-no-dev --no-interaction "topthink/think-helper:^1.0"
+ - composer require --update-no-dev --no-interaction "topthink/think-queue:^1.0"
+ - composer require --update-no-dev --no-interaction "topthink/think-angular:^1.0"
+ - composer require --dev --update-no-dev --no-interaction "topthink/think-testing:^1.0"
+ - zip -r --exclude='*.git*' --exclude='*.zip' --exclude='*.travis.yml' ThinkPHP_Full.zip .
+
+script:
+ - php think unit
+
+deploy:
+ provider: releases
+ api_key:
+ secure: TSF6bnl2JYN72UQOORAJYL+CqIryP2gHVKt6grfveQ7d9rleAEoxlq6PWxbvTI4jZ5nrPpUcBUpWIJHNgVcs+bzLFtyh5THaLqm39uCgBbrW7M8rI26L8sBh/6nsdtGgdeQrO/cLu31QoTzbwuz1WfAVoCdCkOSZeXyT/CclH99qV6RYyQYqaD2wpRjrhA5O4fSsEkiPVuk0GaOogFlrQHx+C+lHnf6pa1KxEoN1A0UxxVfGX6K4y5g4WQDO5zT4bLeubkWOXK0G51XSvACDOZVIyLdjApaOFTwamPcD3S1tfvuxRWWvsCD5ljFvb2kSmx5BIBNwN80MzuBmrGIC27XLGOxyMerwKxB6DskNUO9PflKHDPI61DRq0FTy1fv70SFMSiAtUv9aJRT41NQh9iJJ0vC8dl+xcxrWIjU1GG6+l/ZcRqVx9V1VuGQsLKndGhja7SQ+X1slHl76fRq223sMOql7MFCd0vvvxVQ2V39CcFKao/LB1aPH3VhODDEyxwx6aXoTznvC/QPepgWsHOWQzKj9ftsgDbsNiyFlXL4cu8DWUty6rQy8zT2b4O8b1xjcwSUCsy+auEjBamzQkMJFNlZAIUrukL/NbUhQU37TAbwsFyz7X0E/u/VMle/nBCNAzgkMwAUjiHM6FqrKKBRWFbPrSIixjfjkCnrMEPw=
+ file:
+ - ThinkPHP_Core.zip
+ - ThinkPHP_Full.zip
+ skip_cleanup: true
+ on:
+ tags: true

+
+ThinkPHP遵循Apache2开源协议发布，并提供免费使用。
+版权所有Copyright © 2006-2016 by ThinkPHP (http://thinkphp.cn)
+All rights reserved。
+ThinkPHP® 商标和著作权所有者为上海顶想信息科技有限公司。
+
+Apache Licence是著名的非盈利开源组织Apache采用的协议。
+该协议和BSD类似，鼓励代码共享和尊重原作者的著作权，
+允许代码修改，再作为开源或商业软件发布。需要满足
+的条件： 
+1． 需要给代码的用户一份Apache Licence ；
+2． 如果你修改了代码，需要在被修改的文件中说明；
+3． 在延伸的代码中（修改和有源代码衍生的代码中）需要
+带有原来代码中的协议，商标，专利声明和其他原来作者规
+定需要包含的说明；
+4． 如果再发布的产品中包含一个Notice文件，则在Notice文
+件中需要带有本协议内容。你可以在Notice中增加自己的
+许可，但不可以表现为对Apache Licence构成更改。 
+具体的协议参考：http://www.apache.org/licenses/LICENSE-2.0
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
+BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
+ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+POSSIBILITY OF SUCH DAMAGE.

+ThinkPHP 6.0
+===============
+
+> 运行环境要求PHP7.1+。
+
+## 主要新特性
+
+* 采用`PHP7`强类型（严格模式）
+* 支持更多的`PSR`规范
+* 原生多应用支持
+* 更强大和易用的查询
+* 全新的事件系统
+* 模型事件和数据库事件统一纳入事件系统
+* 模板引擎分离出核心
+* 内部功能中间件化
+* SESSION/Cookie机制改进
+* 对Swoole以及协程支持改进
+* 对IDE更加友好
+* 统一和精简大量用法
+
+## 安装
+
+~~~
+composer create-project topthink/think tp 6.0.*
+~~~
+
+如果需要更新框架使用
+~~~
+composer update topthink/framework
+~~~
+
+## 文档
+
+[完全开发手册](https://www.kancloud.cn/manual/thinkphp6_0/content)
+
+## 参与开发
+
+请参阅 [ThinkPHP 核心框架包](https://github.com/top-think/framework)。
+
+## 版权信息
+
+ThinkPHP遵循Apache2开源协议发布，并提供免费使用。
+
+本项目包含的第三方源码和二进制文件之版权信息另行标注。
+
+版权所有Copyright © 2006-2020 by ThinkPHP (http://thinkphp.cn)
+
+All rights reserved。
+
+ThinkPHP® 商标和著作权所有者为上海顶想信息科技有限公司。
+
+更多细节参阅 [LICENSE.txt](LICENSE.txt)

+deny from all

+<?php
+declare (strict_types = 1);
+
+namespace app;
+
+use think\Service;
+
+/**
+ * 应用服务类
+ */
+class AppService extends Service
+{
+ public function register()
+ {
+ // 服务注册
+ }
+
+ public function boot()
+ {
+ // 服务启动
+ }
+}

+<?php
+declare (strict_types = 1);
+
+namespace app;
+
+use think\App;
+use think\exception\ValidateException;
+use think\Validate;
+
+/**
+ * 控制器基础类
+ */
+abstract class BaseController
+{
+ /**
+ * Request实例
+ * @var \think\Request
+ */
+ protected $request;
+
+ /**
+ * 应用实例
+ * @var \think\App
+ */
+ protected $app;
+
+ /**
+ * 是否批量验证
+ * @var bool
+ */
+ protected $batchValidate = false;
+
+ /**
+ * 控制器中间件
+ * @var array
+ */
+ protected $middleware = [];
+
+ /**
+ * 构造方法
+ * @access public
+ * @param App $app 应用对象
+ */
+ public function __construct(App $app)
+ {
+ $this->app = $app;
+ $this->request = $this->app->request;
+
+ // 控制器初始化
+ $this->initialize();
+ }
+
+ // 初始化
+ protected function initialize()
+ {}
+
+ /**
+ * 验证数据
+ * @access protected
+ * @param array $data 数据
+ * @param string|array $validate 验证器名或者验证规则数组
+ * @param array $message 提示信息
+ * @param bool $batch 是否批量验证
+ * @return array|string|true
+ * @throws ValidateException
+ */
+ protected function validate(array $data, $validate, array $message = [], bool $batch = false)
+ {
+ if (is_array($validate)) {
+ $v = new Validate();
+ $v->rule($validate);
+ } else {
+ if (strpos($validate, '.')) {
+ // 支持场景
+ [$validate, $scene] = explode('.', $validate);
+ }
+ $class = false !== strpos($validate, '\\') ? $validate : $this->app->parseClass('validate', $validate);
+ $v = new $class();
+ if (!empty($scene)) {
+ $v->scene($scene);
+ }
+ }
+
+ $v->message($message);
+
+ // 是否批量验证
+ if ($batch || $this->batchValidate) {
+ $v->batch(true);
+ }
+
+ return $v->failException(true)->check($data);
+ }
+
+}

+<?php
+namespace app;
+
+use think\db\exception\DataNotFoundException;
+use think\db\exception\ModelNotFoundException;
+use think\exception\Handle;
+use think\exception\HttpException;
+use think\exception\HttpResponseException;
+use think\exception\ValidateException;
+use think\Response;
+use Throwable;
+
+/**
+ * 应用异常处理类
+ */
+class ExceptionHandle extends Handle
+{
+ /**
+ * 不需要记录信息（日志）的异常类列表
+ * @var array
+ */
+ protected $ignoreReport = [
+ HttpException::class,
+ HttpResponseException::class,
+ ModelNotFoundException::class,
+ DataNotFoundException::class,
+ ValidateException::class,
+ ];
+
+ /**
+ * 记录异常信息（包括日志或者其它方式记录）
+ *
+ * @access public
+ * @param Throwable $exception
+ * @return void
+ */
+ public function report(Throwable $exception): void
+ {
+ // 使用内置的方式记录异常日志
+ parent::report($exception);
+ }
+
+ /**
+ * Render an exception into an HTTP response.
+ *
+ * @access public
+ * @param \think\Request $request
+ * @param Throwable $e
+ * @return Response
+ */
+ public function render($request, Throwable $e): Response
+ {
+ // 添加自定义异常处理机制
+
+ // 其他错误交给系统处理
+ return parent::render($request, $e);
+ }
+}

+<?php
+namespace app;
+
+// 应用请求对象类
+class Request extends \think\Request
+{
+
+}

+<?php
+// 应用公共文件

+<?php
+namespace app\controller;
+use app\BaseController;
+use GatewayClient\Gateway;
+use Workerman\Worker;
+use think\facade\Log;
+use think\facade\Cache;
+
+class Index extends BaseController
+{
+ public function index(){
+ $data_data_data = array('ownwe' => 'group_9','auto_login' => false,'password' => '密码', 'login_type' => '2', 'data62' => '62xxxxxxxxxxxxxxxxxxxxxxx', 'json' => '长环境', 'device_type' => '1', 'type' => 0, 'username' => '账号', 'lateset' =>false );
+ $data_data = array('data' => json_encode($data_data_data),'task_id' => '1', 'wxid' => '账号', 'timeInMillis' => time(), 'type' => 'login' );
+ $data = array('data' => json_encode(array($data_data)),'type' => 'task' );
+
+
+ //登录包
+ $data = array('type' => 'login', 'username' => '0085585623604', 'password' => 'bfefebf45e','json' => 'https://android-1257892566.cos.ap-guangzhou.myqcloud.com/android%5Fenv/0085585623604.txt','a16' => 'Adac9e7360d9731d','uuid' => 'aa002247ac3334e7a8c66561d39a5205');
+ //下线包
+ $data = array('type' => 'logout', 'username' => '0085585623604');
+ // 发送消息
+ $data = array('type' => 'textMsg', 'wxid' => '0085585623604', 'data' => '{"to":"wuzijun6647","content":"99999","msgSource":null}','msgId' => '4207702845635483641','agreement' => 1,"sign" => 'ng_send_services',"theme" => 'chat');
+ print_r(json_encode($data));
+ // print_r(cache('taskId_13'));
+ }
+
+ public function hello($name = 'ThinkPHP6'){
+ return 'hello,' . $name;
+ }
+
+ // test队列kafka消费者挂载
+ public function kafka_test(){
+ //设置消费分组名称kafka地址
+ $conf = new \RdKafka\Conf();
+ $conf->set('group.id', 'group_1');
+ $conf->set('metadata.broker.list', '47.112.163.25:9092,47.112.185.243:9092,47.112.189.251:9092');
+ //运行消费者队列
+ $consumer = new \RdKafka\KafkaConsumer($conf);
+ $consumer->subscribe(['text']);
+ //开启循环
+ while (true) {
+ $message = $consumer->consume(3e3);
+ switch ($message->err) {
+ case RD_KAFKA_RESP_ERR_NO_ERROR:
+ // 打印成功接收的消费者消息log
+ trace($message->payload,'consumer');
+ // 获取到消息发送到workerman
+ $res = $this->send_ws($message->payload);
+ break;
+ case RD_KAFKA_RESP_ERR__PARTITION_EOF:
+ sleep(2);
+ case RD_KAFKA_RESP_ERR__TIMED_OUT:
+ // 超时不做操作
+ // echo $message->errstr() . PHP_EOL;
+ break;
+ default:
+ //补获异常
+ throw new \Exception($message->errstr(), $message->err);
+ break;
+ }
+ }
+ }
+
+ // test队列kafka消费者挂载
+ public function kafka_login(){
+ //设置消费分组名称kafka地址
+ $conf = new \RdKafka\Conf();
+ $conf->set('group.id', 'group_1');
+ $conf->set('metadata.broker.list', '47.112.163.25:9092,47.112.185.243:9092,47.112.189.251:9092');
+ //运行消费者队列
+ $consumer = new \RdKafka\KafkaConsumer($conf);
+ $consumer->subscribe(['login']);
+ //开启循环
+ while (true) {
+ $message = $consumer->consume(3e3);
+ switch ($message->err) {
+ case RD_KAFKA_RESP_ERR_NO_ERROR:
+ // 打印成功接收的消费者消息log
+ trace($message->payload,'consumer');
+ // 获取到消息发送到workerman
+ $res = $this->send_ws_login($message->payload);
+ break;
+ case RD_KAFKA_RESP_ERR__PARTITION_EOF:
+ sleep(2);
+ case RD_KAFKA_RESP_ERR__TIMED_OUT:
+ // 超时不做操作
+ // echo $message->errstr() . PHP_EOL;
+ break;
+ default:
+ //补获异常
+ throw new \Exception($message->errstr(), $message->err);
+ break;
+ }
+ }
+ }
+
+ //发送消息到workerman
+ public function send_ws($data){
+ // 建立socket连接到内部推送端口
+ $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
+ // 推送的数据，包含uid字段，表示是给这个uid推送
+ $send = array('id'=>1, 'message'=>$data);
+ // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
+ fwrite($client, json_encode($send)."\n");
+ // 读取推送结果
+ $res = str_replace("\n","",fread($client, 8192));
+ // 打印发送消息返回LOG
+ trace($res,'consumer');
+ }
+
+ //发送消息到workerman
+ public function send_ws_login($data){
+ // 建立socket连接到内部推送端口
+ $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
+ // 推送的数据，包含uid字段，表示是给这个uid推送
+ $res = json_decode($data,true);
+ // 判断类型组包
+ if ($res['type'] == 'login') {
+ $data_data_data = array('ownwe' => 'group_9','auto_login' => false,'password' => md5($res['password']), 'login_type' => '2', 'a16' => $res['a16'], 'json' => $res['json'], 'device_type' => '0', 'type' => 0, 'username' => $res['username'], 'lateset' =>false );
+ $data_data = array('data' => json_encode($data_data_data),'task_id' => '1', 'wxid' => $res['username'], 'timeInMillis' => time(), 'type' => 'login' );
+ $data = array('data' => json_encode(array($data_data)),'type' => 'task' );
+ //取出uuid对应的服务端ID
+ $id = cache('ws_'.$res['uuid']);
+ }elseif ($res['type'] == 'logout') {
+ $id = cache('ws_'.$res['username']);
+ $data = array('type' => 'logout', 'data' => $res['username'], 'timeInMillis' => time());
+ }
+ trace(json_encode(array('id'=>$id, 'message'=>$data)),'consumer');
+ if($id){
+ // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
+ fwrite($client, json_encode(array('id'=>$id, 'message'=>$data))."\n");
+ // 读取推送结果
+ $res = str_replace("\n","",fread($client, 8192));
+ }else{
+ $res = 'false';
+ }
+ // 打印发送消息返回LOG
+ trace($res,'consumer');
+ }
+
+ //查看PHP版本是否有安装php-rdkafka,php-redis等插件
+ public function phpinfo(){
+ return phpinfo();
+ }
+
+
+ public function isOnline($uuid,$wxid){
+ //获取全部当前列表
+ $online = (array)cache($uuid.'_online');
+ return in_array($wxid,$online)?1:0;
+ }
+}

+<?php
+namespace app\controller;
+use app\BaseController;
+use GatewayClient\Gateway;
+use Workerman\Worker;
+use think\facade\Log;
+use think\facade\Cache;
+
+class KafkaCallback extends BaseController
+{
+ public function kafka_callback(){
+ //设置消费分组名称kafka地址
+ $conf = new \RdKafka\Conf();
+ $conf->set('group.id', 'group_1');
+ $conf->set('metadata.broker.list', '47.112.163.25:9092,47.112.185.243:9092,47.112.189.251:9092');
+ //运行消费者队列
+ $consumer = new \RdKafka\KafkaConsumer($conf);
+ $consumer->subscribe(['ng_chat_services']);
+ //开启循环
+ while (true) {
+ $message = $consumer->consume(3e3);
+ switch ($message->err) {
+ case RD_KAFKA_RESP_ERR_NO_ERROR:
+ // 打印成功接收的消费者消息log
+ trace($message->payload,'consumer');
+ // 获取到消息发送到workerman
+ $res = $this->send_ws_send($message->payload);
+ break;
+ case RD_KAFKA_RESP_ERR__PARTITION_EOF:
+ sleep(2);
+ case RD_KAFKA_RESP_ERR__TIMED_OUT:
+ // 超时不做操作
+ // echo $message->errstr() . PHP_EOL;
+ break;
+ default:
+ //补获异常
+ throw new \Exception($message->errstr(), $message->err);
+ break;
+ }
+ }
+ }
+
+ //发送消息到workerman
+ public function send_ws_send($json_data){
+ }
+
+ //判断在线状态
+ public function isOnline($uuid,$wxid){
+ //获取全部当前列表
+ $online = (array)cache($uuid.'_online');
+ return in_array($wxid,$online)?1:0;
+ }
+}

+<?php
+namespace app\controller;
+use app\BaseController;
+use GatewayClient\Gateway;
+use Workerman\Worker;
+use think\facade\Log;
+
+class KafkaLogin extends BaseController
+{
+ public function kafka_login(){
+ //设置消费分组名称kafka地址
+ $conf = new \RdKafka\Conf();
+ $conf->set('group.id', 'group_1');
+ $conf->set('metadata.broker.list', '47.112.163.25:9092,47.112.185.243:9092,47.112.189.251:9092');
+ //运行消费者队列
+ $consumer = new \RdKafka\KafkaConsumer($conf);
+ $consumer->subscribe(['ng_login']);
+ //开启循环
+ while (true) {
+ $message = $consumer->consume(3e3);
+ switch ($message->err) {
+ case RD_KAFKA_RESP_ERR_NO_ERROR:
+ // 打印成功接收的消费者消息log
+ trace($message->payload,'consumer');
+ // 获取到消息发送到workerman
+ $res = $this->send_ws_login($message->payload);
+ break;
+ case RD_KAFKA_RESP_ERR__PARTITION_EOF:
+ sleep(2);
+ case RD_KAFKA_RESP_ERR__TIMED_OUT:
+ // 超时不做操作
+ // echo $message->errstr() . PHP_EOL;
+ break;
+ default:
+ //补获异常
+ throw new \Exception($message->errstr(), $message->err);
+ break;
+ }
+ }
+ }
+
+ //发送消息到workerman
+ public function send_ws_login($data){
+ // 建立socket连接到内部推送端口
+ $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
+ // 推送的数据，包含uid字段，表示是给这个uid推送
+ $res = json_decode($data,true);
+ // 判断类型组包
+ if ($res['type'] == 'login') {
+ //取出name对应的服务端ID
+ $id = cache($res['name']);
+ //组包安卓登录数据
+ $data_data_data = array('ownwe' => 'group_9','auto_login' => false,'password' => md5($res['password']), 'login_type' => '2', 'a16' => $res['a16'], 'json' => $res['json'], 'device_type' => '0', 'type' => 0, 'username' => $res['username'], 'lateset' =>false );
+ $data_data = array('data' => json_encode($data_data_data),'task_id' => '1', 'wxid' => $res['username'], 'timeInMillis' => time(), 'type' => 'login' );
+ $data = array('data' => json_encode(array($data_data)),'type' => 'task' );
+ }elseif ($res['type'] == 'logout') {
+ //判断是否存在用户
+ $name = cache($res['username']);
+ //判断在线
+ if($this->isOnline($name,$res['username'])){
+ $id = cache($name);
+ }else{
+ $id = '';
+ }
+ $data = array('type' => 'logout', 'data' => $res['username'], 'timeInMillis' => time());
+ }
+ trace(json_encode(array('id'=>$id, 'message'=>$data)),'consumer');
+ if($id){
+ // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
+ fwrite($client, json_encode(array('id'=>$id, 'message'=>$data))."\n");
+ // 读取推送结果
+ $res = str_replace("\n","",fread($client, 8192));
+ }else{
+ $res = 'false';
+ }
+ // 打印发送消息返回LOG
+ trace($res,'consumer');
+ }
+
+ //判断在线状态
+ public function isOnline($name,$wxid){
+ //获取全部当前列表
+ $online = (array)cache($name.'_online');
+ return in_array($wxid,$online)?1:0;
+ }
+}

+<?php
+namespace app\controller;
+use app\BaseController;
+use GatewayClient\Gateway;
+use Workerman\Worker;
+use think\facade\Log;
+use think\facade\Cache;
+
+class KafkaSend extends BaseController
+{
+ public function kafka_send(){
+ //设置消费分组名称kafka地址
+ $conf = new \RdKafka\Conf();
+ $conf->set('group.id', 'group_1');
+ $conf->set('metadata.broker.list', '47.112.163.25:9092,47.112.185.243:9092,47.112.189.251:9092');
+ //运行消费者队列
+ $consumer = new \RdKafka\KafkaConsumer($conf);
+ $consumer->subscribe(['ng_send_services']);
+ //开启循环
+ while (true) {
+ $message = $consumer->consume(3e3);
+ switch ($message->err) {
+ case RD_KAFKA_RESP_ERR_NO_ERROR:
+ // 打印成功接收的消费者消息log
+ trace($message->payload,'consumer');
+ // 获取到消息发送到workerman
+ $res = $this->send_ws_send($message->payload);
+ break;
+ case RD_KAFKA_RESP_ERR__PARTITION_EOF:
+ sleep(2);
+ case RD_KAFKA_RESP_ERR__TIMED_OUT:
+ // 超时不做操作
+ // echo $message->errstr() . PHP_EOL;
+ break;
+ default:
+ //补获异常
+ throw new \Exception($message->errstr(), $message->err);
+ break;
+ }
+ }
+ }
+
+ //发送消息到workerman
+ public function send_ws_send($json_data){
+ // 建立socket连接到内部推送端口
+ $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
+ // 推送的数据，包含uid字段，表示是给这个uid推送
+ $res = json_decode($json_data,true);
+ // 判断类型组包
+ if ($res['agreement'] == 1) {
+ // 获取当前taskId
+ $taskId = Cache::inc('taskId');
+ // 缓存taskId与消息ID
+ cache('taskId_'.$taskId,array($res['msgId'],$res['theme']), 300);
+ $data_data = array('type' => $res['type'], 'taskId' => $taskId, 'wxid' => $res['wxid'], 'date' => time(), 'data' => $res['data'], 'timeInMillis' => time());
+ $data = array('data' => json_encode(array($data_data)),'type' => 'task');
+ //取出name对应的服务端ID
+ //判断是否存在用户
+ $name = cache($res['wxid']);
+ //判断在线
+ if($this->isOnline($name,$res['wxid'])){
+ $id = cache($name);
+ }else{
+ $id = '';
+ }
+ trace(json_encode(array('id'=>$id, 'message'=>$data)),'consumer');
+ if($id){
+ // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
+ fwrite($client, json_encode(array('id'=>$id, 'message'=>$data))."\n");
+ // 读取推送结果
+ $res = str_replace("\n","",fread($client, 8192));
+ }else{
+ $res = 'false';
+ }
+ // 打印发送消息返回LOG
+ trace($res,'consumer');
+ }else{
+ trace('协议暂未支持','consumer');
+ }
+ }
+
+ //判断在线状态
+ public function isOnline($name,$wxid){
+ //获取全部当前列表
+ $online = (array)cache($name.'_online');
+ return in_array($wxid,$online)?1:0;
+ }
+}

+<?php
+// 事件定义文件
+return [
+ 'bind' => [
+ ],
+
+ 'listen' => [
+ 'AppInit' => [],
+ 'HttpRun' => [],
+ 'HttpEnd' => [],
+ 'LogLevel' => [],
+ 'LogWrite' => [],
+ ],
+
+ 'subscribe' => [
+ ],
+];

+<?php
+namespace app\http;
+
+use think\worker\Server;
+use think\facade\Env;
+use think\facade\Queue;
+
+class Worker extends Server
+{
+ protected $socket = 'websocket://0.0.0.0:8282';
+ protected $option = [ 
+ 'name' => 'thinkphp',
+ 'count' => 4,
+ ];
+ public $kafka;
+
+ public function onWorkerStart($connection)
+ {
+ //开启kafka
+ $rk = new \RdKafka\Producer();
+ $rk->addBrokers("47.112.163.25:9092,47.112.185.243:9092,47.112.189.251:9092");
+ $this->kafka = $rk;
+
+
+ $server = $this->worker;
+ // 开启一个内部端口，方便内部系统推送数据，Text协议格式 文本+换行符
+ $inner_text_worker = new \Workerman\Worker('Text://0.0.0.0:5678');
+ // print_r($inner_text_worker); 
+ $inner_text_worker->onMessage = function($connection, $buffer)use($server)
+ {
+ // $data数组格式，里面有uid，表示向那个uid的页面推送数据
+ $data = json_decode($buffer, true);
+ // 通过workerman，向id的页面推送数据
+ $ret = '';
+ if($server->connections){
+ foreach ($server->connections as $_connection ){
+ if ($data['id'] == $_connection->id) {
+ $ret = $_connection->send(json_encode($data['message']));
+ }
+ }
+ }
+ // 返回推送结果
+ $connection->send($ret ? 'ok' : 'fail');
+ };
+ $inner_text_worker->listen();
+ }
+
+ public function onMessage($connection,$data)
+ {
+ $data = json_decode($data,true);
+ print_r($data);
+ //接收到发送的消息发送出去kafka
+ if(isset($data['sign']) && $data['sign'] == 'ng_send_services'){
+ // kafka推送->send类型
+ trace('producer->'.json_encode($data), 'producer');
+ $topic = $this->kafka->newTopic("ng_send_services");
+ $topic->produce(RD_KAFKA_PARTITION_UA, 0, json_encode($data));
+ //判断WebSocket初始化
+ }else if ($data['type'] == 'initialize') {
+ //记录接收到的所有数据
+ trace(json_encode($data), 'send');
+ //解析data中data数据
+ $data_data = json_decode($data['data'],true);
+ //缓存终端<->workerman_id
+ $cache = cache($data_data['name'], $connection->id);
+ $cache = cache($connection->id, $data_data['name']);
+ //缓存终端在线列表
+ $cache_online = cache($data_data['name'].'_online', $data_data['online']);
+ //缓存成功返回数据给廖总
+ if ($cache && $cache_online) {
+ $res = array('type' => 'initialize', 'data' => array('code' => 1,'disableSync' => false,'parseEmojiToHtml' => true,'encoding' => 'utf-8'));
+ $connection->send(json_encode($res,JSON_UNESCAPED_SLASHES));
+ }
+ }else if($data['type'] == 'login' || $data['type'] == 'logout') {
+ // kafka推送->login类型
+ trace('producer->'.json_encode($data), 'producer');
+ $topic = $this->kafka->newTopic("ng_login");
+ $topic->produce(RD_KAFKA_PARTITION_UA, 0, json_encode($data));
+ }else if($data['type'] == 'notify') {
+ //捕捉登录信息
+ $data_data = json_decode($data['data'],true);
+ if ($data_data['type'] == 'account') {
+ $body = json_decode($data_data['body'],true);
+ //登录成功记录redis
+ if ($body['event'] == 'onLoginSuccess') {
+ //取出当前终端数据进行绑定
+ $name = cache($connection->id);
+ cache($data_data['username'], $name);
+ //退出成功删除redis
+ }else if($body['event'] == 'onExit'){
+ cache($data_data['username'], NULL);
+ }
+ }else if($data_data['type'] == 'wm_task'){
+ trace('producer->'.json_encode($data), 'producer');
+ //判断消息是否超时5分钟
+ $data_data_body = json_decode($data_data['body'],true);
+ if ($data_data_body['code'] > 0) {
+ $msgId = cache('taskId_'.$data_data_body['taskId']);
+ if ($msgId) {
+ $data['msgId'] = $msgId[0];
+ //回调->回调kafka
+ $topic = $this->kafka->newTopic('ng_'.$msgId[1].'_services');
+ $topic->produce(RD_KAFKA_PARTITION_UA, 0, json_encode($data)); 
+ }
+ }
+ }else{
+ // kafka推送->type类型
+ trace('producer->'.json_encode($data), 'producer');
+ $topic = $this->kafka->newTopic('ng_'.$data_data['type']);
+ $topic->produce(RD_KAFKA_PARTITION_UA, 0, json_encode($data));
+ }
+ }else if($data['type'] == 'online'){
+ //捕捉在线信息进行即时更新
+ $data_data = json_decode($data['data'],true);
+ $cache_online = cache($data_data['name'].'_online', $data_data['online']);
+ }
+ // $isPushed = Queue::push('app\module\Job1' , $data, 'send');
+ // $connection->send(json_encode($data));
+ }
+
+ // 针对id推送数据
+ function sendMessageById($id, $message)
+ {
+ foreach ( $this->worker->connections as $_connection ){
+ if ($id == $_connection->id) {
+ $_connection->send($message);
+ }
+ }
+ }
+
+}

+<?php
+// 全局中间件定义文件
+return [
+ // 全局请求缓存
+ // \think\middleware\CheckRequestCache::class,
+ // 多语言加载
+ // \think\middleware\LoadLangPack::class,
+ // Session初始化
+ // \think\middleware\SessionInit::class
+];

+<?php
+namespace app\module;
+
+use think\queue\Job;
+
+class Job1{
+ 
+ public function fire(Job $job, $data){
+ 
+ //....这里执行具体的任务 
+ 
+ if ($job->attempts() > 3) {
+ //通过这个方法可以检查这个任务已经重试了几次了
+ $job->delete();
+ }
+ 
+ 
+ //如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
+ // $job->delete();
+ print_r(123);
+ // 也可以重新发布这个任务
+ $job->release($delay); //$delay为延迟时间
+ 
+ }
+ 
+ public function failed($data){
+ 
+ // ...任务达到最大重试次数后，失败了
+ }
+
+}

+<?php
+use app\ExceptionHandle;
+use app\Request;
+
+// 容器Provider定义文件
+return [
+ 'think\Request' => Request::class,
+ 'think\exception\Handle' => ExceptionHandle::class,
+];

+<?php
+
+use app\AppService;
+
+// 系统服务定义文件
+// 服务在完成全局初始化之后执行
+return [
+ AppService::class,
+];

+{
+ "name": "topthink/think",
+ "description": "the new thinkphp framework",
+ "type": "project",
+ "keywords": [
+ "framework",
+ "thinkphp",
+ "ORM"
+ ],
+ "homepage": "http://thinkphp.cn/",
+ "license": "Apache-2.0",
+ "authors": [
+ {
+ "name": "liu21st",
+ "email": "[email protected]"
+ },
+ {
+ "name": "yunwuxin",
+ "email": "[email protected]"
+ } 
+ ],
+ "require": {
+ "php": ">=7.1.0",
+ "topthink/framework": "^6.0.0",
+ "topthink/think-orm": "^2.0",
+ "topthink/think-worker": "^3.0",
+ "topthink/think-queue": "^3.0",
+ },
+ "require-dev": {
+ "symfony/var-dumper": "^4.2",
+ "topthink/think-trace":"^1.0"
+ },
+ "autoload": {
+ "psr-4": {
+ "app\\": "app"
+ },
+ "psr-0": {
+ "": "extend/"
+ }
+ },
+ "config": {
+ "preferred-install": "dist"
+ },
+ "scripts": {
+ "post-autoload-dump": [
+ "@php think service:discover",
+ "@php think vendor:publish"
+  ]
+ }
+}

+{
+ "_readme": [
+ "This file locks the dependencies of your project to a known state",
+ "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
+ "This file is @generated automatically"
+ ],
+ "content-hash": "ac205b20d442bc57c099a3e0efdfd83b",
+ "packages": [
+ {
+ "name": "league/flysystem",
+ "version": "1.0.66",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/thephpleague/flysystem.git",
+ "reference": "021569195e15f8209b1c4bebb78bd66aa4f08c21"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/thephpleague/flysystem/zipball/021569195e15f8209b1c4bebb78bd66aa4f08c21",
+ "reference": "021569195e15f8209b1c4bebb78bd66aa4f08c21",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "ext-fileinfo": "*",
+ "php": ">=5.5.9"
+ },
+ "conflict": {
+ "league/flysystem-sftp": "<1.0.6"
+ },
+ "require-dev": {
+ "phpspec/phpspec": "^3.4",
+ "phpunit/phpunit": "^5.7.26"
+ },
+ "suggest": {
+ "ext-fileinfo": "Required for MimeType",
+ "ext-ftp": "Allows you to use FTP server storage",
+ "ext-openssl": "Allows you to use FTPS server storage",
+ "league/flysystem-aws-s3-v2": "Allows you to use S3 storage with AWS SDK v2",
+ "league/flysystem-aws-s3-v3": "Allows you to use S3 storage with AWS SDK v3",
+ "league/flysystem-azure": "Allows you to use Windows Azure Blob storage",
+ "league/flysystem-cached-adapter": "Flysystem adapter decorator for metadata caching",
+ "league/flysystem-eventable-filesystem": "Allows you to use EventableFilesystem",
+ "league/flysystem-rackspace": "Allows you to use Rackspace Cloud Files",
+ "league/flysystem-sftp": "Allows you to use SFTP server storage via phpseclib",
+ "league/flysystem-webdav": "Allows you to use WebDAV storage",
+ "league/flysystem-ziparchive": "Allows you to use ZipArchive adapter",
+ "spatie/flysystem-dropbox": "Allows you to use Dropbox storage",
+ "srmklive/flysystem-dropbox-v2": "Allows you to use Dropbox storage for PHP 5 applications"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "1.1-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "League\\Flysystem\\": "src/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Frank de Jonge",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "Filesystem abstraction: Many filesystems, one API.",
+ "keywords": [
+ "Cloud Files",
+ "WebDAV",
+ "abstraction",
+ "aws",
+ "cloud",
+ "copy.com",
+ "dropbox",
+ "file systems",
+ "files",
+ "filesystem",
+ "filesystems",
+ "ftp",
+ "rackspace",
+ "remote",
+ "s3",
+ "sftp",
+ "storage"
+ ],
+ "time": "2020-03-17T18:58:12+00:00"
+ },
+ {
+  "name": "league/flysystem-cached-adapter",
+ "version": "1.0.9",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/thephpleague/flysystem-cached-adapter.git",
+ "reference": "08ef74e9be88100807a3b92cc9048a312bf01d6f"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/thephpleague/flysystem-cached-adapter/zipball/08ef74e9be88100807a3b92cc9048a312bf01d6f",
+ "reference": "08ef74e9be88100807a3b92cc9048a312bf01d6f",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "league/flysystem": "~1.0",
+ "psr/cache": "^1.0.0"
+ },
+ "require-dev": {
+ "mockery/mockery": "~0.9",
+ "phpspec/phpspec": "^3.4",
+ "phpunit/phpunit": "^5.7",
+ "predis/predis": "~1.0",
+ "tedivm/stash": "~0.12"
+ },
+ "suggest": {
+ "ext-phpredis": "Pure C implemented extension for PHP"
+ },
+ "type": "library",
+ "autoload": {
+ "psr-4": {
+ "League\\Flysystem\\Cached\\": "src/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "frankdejonge",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "An adapter decorator to enable meta-data caching.",
+  "time": "2018-07-09T20:51:04+00:00"
+ },
+ {
+ "name": "nesbot/carbon",
+ "version": "2.32.1",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/briannesbitt/Carbon.git",
+ "reference": "ecb525c766deb3bbbb6a0082ea0e41d3d9ae477c"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/briannesbitt/Carbon/zipball/ecb525c766deb3bbbb6a0082ea0e41d3d9ae477c",
+ "reference": "ecb525c766deb3bbbb6a0082ea0e41d3d9ae477c",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "ext-json": "*",
+ "php": "^7.1.8 || ^8.0",
+ "symfony/translation": "^3.4 || ^4.0 || ^5.0"
+ },
+ "require-dev": {
+ "doctrine/orm": "^2.7",
+ "friendsofphp/php-cs-fixer": "^2.14 || ^3.0",
+ "kylekatarnls/multi-tester": "^1.1",
+ "phpmd/phpmd": "^2.8",
+ "phpstan/phpstan": "^0.11",
+ "phpunit/phpunit": "^7.5 || ^8.0",
+ "squizlabs/php_codesniffer": "^3.4"
+ },
+ "bin": [
+ "bin/carbon"
+ ],
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "2.x-dev"
+ },
+ "laravel": {
+ "providers": [
+  "Carbon\\Laravel\\ServiceProvider"
+ ]
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Carbon\\": "src/Carbon/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Brian Nesbitt",
+ "email": "[email protected]",
+ "homepage": "http://nesbot.com"
+ },
+ {
+ "name": "kylekatarnls",
+ "homepage": "http://github.com/kylekatarnls"
+ }
+ ],
+ "description": "An API extension for DateTime that supports 281 different languages.",
+ "homepage": "http://carbon.nesbot.com",
+ "keywords": [
+ "date",
+ "datetime",
+ "time"
+ ],
+ "time": "2020-03-26T13:04:10+00:00"
+ },
+ {
+ "name": "opis/closure",
+ "version": "3.5.1",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/opis/closure.git",
+ "reference": "93ebc5712cdad8d5f489b500c59d122df2e53969"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/opis/closure/zipball/93ebc5712cdad8d5f489b500c59d122df2e53969",
+ "reference": "93ebc5712cdad8d5f489b500c59d122df2e53969",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": "^5.4 || ^7.0"
+ },
+ "require-dev": {
+ "jeremeamia/superclosure": "^2.0",
+ "phpunit/phpunit": "^4.0 || ^5.0 || ^6.0 || ^7.0"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "3.5.x-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Opis\\Closure\\": "src/"
+ },
+ "files": [
+ "functions.php"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Marius Sarca",
+ "email": "[email protected]"
+ },
+ {
+ "name": "Sorin Sarca",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "A library that can be used to serialize closures (anonymous functions) and arbitrary objects.",
+ "homepage": "https://opis.io/closure",
+ "keywords": [
+ "anonymous functions",
+ "closure",
+ "function",
+ "serializable",
+ "serialization",
+ "serialize"
+ ],
+ "time": "2019-11-29T22:36:02+00:00"
+ },
+ {
+ "name": "psr/cache",
+ "version": "1.0.1",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/php-fig/cache.git",
+ "reference": "d11b50ad223250cf17b86e38383413f5a6764bf8"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/php-fig/cache/zipball/d11b50ad223250cf17b86e38383413f5a6764bf8",
+ "reference": "d11b50ad223250cf17b86e38383413f5a6764bf8",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=5.3.0"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "1.0.x-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Psr\\Cache\\": "src/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "PHP-FIG",
+ "homepage": "http://www.php-fig.org/"
+ }
+ ],
+ "description": "Common interface for caching libraries",
+ "keywords": [
+ "cache",
+ "psr",
+ "psr-6"
+ ],
+ "time": "2016-08-06T20:24:11+00:00"
+ },
+ {
+ "name": "psr/container",
+ "version": "1.0.0",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/php-fig/container.git",
+ "reference": "b7ce3b176482dbbc1245ebf52b181af44c2cf55f"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/php-fig/container/zipball/b7ce3b176482dbbc1245ebf52b181af44c2cf55f",
+ "reference": "b7ce3b176482dbbc1245ebf52b181af44c2cf55f",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=5.3.0"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "1.0.x-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Psr\\Container\\": "src/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "PHP-FIG",
+ "homepage": "http://www.php-fig.org/"
+ }
+ ],
+ "description": "Common Container Interface (PHP FIG PSR-11)",
+ "homepage": "https://github.com/php-fig/container",
+ "keywords": [
+ "PSR-11",
+ "container",
+ "container-interface",
+ "container-interop",
+ "psr"
+ ],
+ "time": "2017-02-14T16:28:37+00:00"
+ },
+ {
+ "name": "psr/log",
+ "version": "1.1.3",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/php-fig/log.git",
+ "reference": "0f73288fd15629204f9d42b7055f72dacbe811fc"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/php-fig/log/zipball/0f73288fd15629204f9d42b7055f72dacbe811fc",
+ "reference": "0f73288fd15629204f9d42b7055f72dacbe811fc",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=5.3.0"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "1.1.x-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Psr\\Log\\": "Psr/Log/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "PHP-FIG",
+ "homepage": "http://www.php-fig.org/"
+ }
+ ],
+ "description": "Common interface for logging libraries",
+ "homepage": "https://github.com/php-fig/log",
+ "keywords": [
+ "log",
+ "psr",
+ "psr-3"
+ ],
+ "time": "2020-03-23T09:12:05+00:00"
+ },
+ {
+ "name": "psr/simple-cache",
+ "version": "1.0.1",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/php-fig/simple-cache.git",
+ "reference": "408d5eafb83c57f6365a3ca330ff23aa4a5fa39b"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/php-fig/simple-cache/zipball/408d5eafb83c57f6365a3ca330ff23aa4a5fa39b",
+ "reference": "408d5eafb83c57f6365a3ca330ff23aa4a5fa39b",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=5.3.0"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "1.0.x-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Psr\\SimpleCache\\": "src/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "PHP-FIG",
+ "homepage": "http://www.php-fig.org/"
+ }
+ ],
+ "description": "Common interfaces for simple caching",
+ "keywords": [
+ "cache",
+ "caching",
+ "psr",
+ "psr-16",
+ "simple-cache"
+ ],
+ "time": "2017-10-23T01:57:42+00:00"
+ },
+ {
+ "name": "symfony/polyfill-mbstring",
+ "version": "v1.15.0",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/symfony/polyfill-mbstring.git",
+ "reference": "81ffd3a9c6d707be22e3012b827de1c9775fc5ac"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/symfony/polyfill-mbstring/zipball/81ffd3a9c6d707be22e3012b827de1c9775fc5ac",
+ "reference": "81ffd3a9c6d707be22e3012b827de1c9775fc5ac",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=5.3.3"
+ },
+ "suggest": {
+ "ext-mbstring": "For best performance"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "1.15-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Symfony\\Polyfill\\Mbstring\\": ""
+ },
+ "files": [
+ "bootstrap.php"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Nicolas Grekas",
+ "email": "[email protected]"
+ },
+ {
+ "name": "Symfony Community",
+ "homepage": "https://symfony.com/contributors"
+ }
+ ],
+ "description": "Symfony polyfill for the Mbstring extension",
+ "homepage": "https://symfony.com",
+ "keywords": [
+ "compatibility",
+ "mbstring",
+ "polyfill",
+ "portable",
+ "shim"
+ ],
+ "time": "2020-03-09T19:04:49+00:00"
+ },
+ {
+ "name": "symfony/process",
+ "version": "v4.4.6",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/symfony/process.git",
+ "reference": "b9863d0f7b684d7c4c13e665325b5ff047de0aee"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/symfony/process/zipball/b9863d0f7b684d7c4c13e665325b5ff047de0aee",
+ "reference": "b9863d0f7b684d7c4c13e665325b5ff047de0aee",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": "^7.1.3"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "4.4-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Symfony\\Component\\Process\\": ""
+ },
+ "exclude-from-classmap": [
+ "/Tests/"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Fabien Potencier",
+ "email": "[email protected]"
+ },
+ {
+ "name": "Symfony Community",
+ "homepage": "https://symfony.com/contributors"
+ }
+ ],
+ "description": "Symfony Process Component",
+ "homepage": "https://symfony.com",
+ "time": "2020-03-23T12:37:11+00:00"
+ },
+ {
+ "name": "symfony/translation",
+ "version": "v5.0.6",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/symfony/translation.git",
+ "reference": "91855689b557481ff2d3d97c535d74284e7b814a"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/symfony/translation/zipball/91855689b557481ff2d3d97c535d74284e7b814a",
+ "reference": "91855689b557481ff2d3d97c535d74284e7b814a",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": "^7.2.5",
+ "symfony/polyfill-mbstring": "~1.0",
+ "symfony/translation-contracts": "^2"
+ },
+ "conflict": {
+ "symfony/config": "<4.4",
+ "symfony/dependency-injection": "<5.0",
+ "symfony/http-kernel": "<5.0",
+ "symfony/twig-bundle": "<5.0",
+ "symfony/yaml": "<4.4"
+ },
+ "provide": {
+ "symfony/translation-implementation": "2.0"
+ },
+ "require-dev": {
+ "psr/log": "~1.0",
+ "symfony/config": "^4.4|^5.0",
+ "symfony/console": "^4.4|^5.0",
+ "symfony/dependency-injection": "^5.0",
+ "symfony/finder": "^4.4|^5.0",
+ "symfony/http-kernel": "^5.0",
+ "symfony/intl": "^4.4|^5.0",
+ "symfony/service-contracts": "^1.1.2|^2",
+ "symfony/yaml": "^4.4|^5.0"
+ },
+ "suggest": {
+ "psr/log-implementation": "To use logging capability in translator",
+ "symfony/config": "",
+ "symfony/yaml": ""
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "5.0-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Symfony\\Component\\Translation\\": ""
+ },
+ "exclude-from-classmap": [
+ "/Tests/"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Fabien Potencier",
+ "email": "[email protected]"
+ },
+ {
+ "name": "Symfony Community",
+ "homepage": "https://symfony.com/contributors"
+ }
+ ],
+ "description": "Symfony Translation Component",
+ "homepage": "https://symfony.com",
+ "time": "2020-03-18T08:00:37+00:00"
+ },
+ {
+ "name": "symfony/translation-contracts",
+ "version": "v2.0.1",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/symfony/translation-contracts.git",
+ "reference": "8cc682ac458d75557203b2f2f14b0b92e1c744ed"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/symfony/translation-contracts/zipball/8cc682ac458d75557203b2f2f14b0b92e1c744ed",
+ "reference": "8cc682ac458d75557203b2f2f14b0b92e1c744ed",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": "^7.2.5"
+ },
+ "suggest": {
+ "symfony/translation-implementation": ""
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "2.0-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Symfony\\Contracts\\Translation\\": ""
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Nicolas Grekas",
+ "email": "[email protected]"
+ },
+ {
+ "name": "Symfony Community",
+ "homepage": "https://symfony.com/contributors"
+ }
+ ],
+ "description": "Generic abstractions related to translation",
+ "homepage": "https://symfony.com",
+ "keywords": [
+ "abstractions",
+ "contracts",
+ "decoupling",
+ "interfaces",
+ "interoperability",
+ "standards"
+ ],
+ "time": "2019-11-18T17:27:11+00:00"
+ },
+ {
+ "name": "topthink/framework",
+ "version": "v6.0.2",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/top-think/framework.git",
+ "reference": "1444cce94b40a836958380b160a5fb7bfc165daf"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/top-think/framework/zipball/1444cce94b40a836958380b160a5fb7bfc165daf",
+ "reference": "1444cce94b40a836958380b160a5fb7bfc165daf",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "ext-json": "*",
+ "ext-mbstring": "*",
+ "league/flysystem": "^1.0",
+ "league/flysystem-cached-adapter": "^1.0",
+ "opis/closure": "^3.1",
+ "php": ">=7.1.0",
+ "psr/container": "~1.0",
+ "psr/log": "~1.0",
+ "psr/simple-cache": "^1.0",
+ "topthink/think-helper": "^3.1.1",
+ "topthink/think-orm": "^2.0"
+ },
+ "require-dev": {
+ "mikey179/vfsstream": "^1.6",
+ "mockery/mockery": "^1.2",
+ "phpunit/phpunit": "^7.0"
+ },
+ "type": "library",
+ "autoload": {
+ "files": [],
+ "psr-4": {
+ "think\\": "src/think/"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "Apache-2.0"
+ ],
+ "authors": [
+ {
+ "name": "liu21st",
+ "email": "[email protected]"
+ },
+ {
+ "name": "yunwuxin",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "The ThinkPHP Framework.",
+ "homepage": "http://thinkphp.cn/",
+ "keywords": [
+ "framework",
+ "orm",
+ "thinkphp"
+ ],
+ "time": "2020-01-13T05:48:05+00:00"
+ },
+ {
+ "name": "topthink/think-factory",
+ "version": "v1.0.1",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/top-think/think-factory.git",
+ "reference": "b8080a6472aae1cff47ceb8c30feec3c2835364b"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/top-think/think-factory/zipball/b8080a6472aae1cff47ceb8c30feec3c2835364b",
+ "reference": "b8080a6472aae1cff47ceb8c30feec3c2835364b",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "topthink/framework": "^6.0.0",
+ "topthink/think-helper": "^3.0.0"
+ },
+ "type": "library",
+ "autoload": {
+ "psr-4": {
+ "think\\": "src"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "Apache-2.0"
+ ],
+ "authors": [
+ {
+ "name": "yunwuxin",
+ "email": "[email protected]"
+ }
+ ],
+ "time": "2019-04-15T06:55:28+00:00"
+ },
+ {
+ "name": "topthink/think-helper",
+ "version": "v3.1.3",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/top-think/think-helper.git",
+ "reference": "4d85dfd3778623bbb1de3648f1dcd0c82f4439f4"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/top-think/think-helper/zipball/4d85dfd3778623bbb1de3648f1dcd0c82f4439f4",
+ "reference": "4d85dfd3778623bbb1de3648f1dcd0c82f4439f4",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=7.1.0"
+ },
+ "type": "library",
+ "autoload": {
+ "psr-4": {
+ "think\\": "src"
+ },
+ "files": [
+ "src/helper.php"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "Apache-2.0"
+ ],
+ "authors": [
+ {
+ "name": "yunwuxin",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "The ThinkPHP6 Helper Package",
+ "time": "2019-09-30T02:36:48+00:00"
+ },
+ {
+ "name": "topthink/think-orm",
+ "version": "v2.0.31",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/top-think/think-orm.git",
+ "reference": "d6965dfae21f150e29cc899ab6f9b1bd2c0f2ee4"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/top-think/think-orm/zipball/d6965dfae21f150e29cc899ab6f9b1bd2c0f2ee4",
+ "reference": "d6965dfae21f150e29cc899ab6f9b1bd2c0f2ee4",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "ext-json": "*",
+ "php": ">=7.1.0",
+ "psr/log": "~1.0",
+ "psr/simple-cache": "^1.0",
+ "topthink/think-helper": "^3.1"
+ },
+ "type": "library",
+ "autoload": {
+ "psr-4": {
+ "think\\": "src"
+ },
+ "files": []
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "Apache-2.0"
+ ],
+ "authors": [
+ {
+ "name": "liu21st",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "think orm",
+ "keywords": [
+ "database",
+ "orm"
+ ],
+ "time": "2020-01-07T10:05:10+00:00"
+ },
+ {
+ "name": "topthink/think-queue",
+ "version": "v3.0.4",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/top-think/think-queue.git",
+ "reference": "a993295b68a483dc3cb2c0fee05683908fa2572e"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/top-think/think-queue/zipball/a993295b68a483dc3cb2c0fee05683908fa2572e",
+ "reference": "a993295b68a483dc3cb2c0fee05683908fa2572e",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "ext-json": "*",
+ "nesbot/carbon": "^2.16",
+ "symfony/process": "^4.2",
+ "topthink/framework": "^6.0.0",
+ "topthink/think-factory": "^1.0.0",
+ "topthink/think-helper": "^3.0.4"
+ },
+ "require-dev": {
+ "mockery/mockery": "^1.2",
+ "phpunit/phpunit": "^6.2",
+ "topthink/think-migration": "^3.0.0"
+ },
+ "type": "library",
+ "extra": {
+ "think": {
+ "services": [
+ "think\\queue\\Service"
+ ],
+ "config": {
+ "queue": "src/config.php"
+ }
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "think\\": "src"
+ },
+ "files": [
+ "src/common.php"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "Apache-2.0"
+ ],
+ "authors": [
+ {
+ "name": "yunwuxin",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "The ThinkPHP5 Queue Package",
+ "time": "2019-10-13T03:51:32+00:00"
+ },
+ {
+ "name": "topthink/think-worker",
+ "version": "v3.0.4",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/top-think/think-worker.git",
+ "reference": "188f6af276b780382fbc244fa25d0ed92d476bd5"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/top-think/think-worker/zipball/188f6af276b780382fbc244fa25d0ed92d476bd5",
+ "reference": "188f6af276b780382fbc244fa25d0ed92d476bd5",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "ext-fileinfo": "*",
+ "topthink/framework": "^6.0.0",
+ "workerman/gateway-worker": "^3.0.0",
+ "workerman/workerman": "^3.3.0"
+ },
+ "type": "library",
+ "extra": {
+ "think": {
+ "services": [
+ "think\\worker\\Service"
+ ],
+ "config": {
+ "worker": "src/config/worker.php",
+ "worker_server": "src/config/server.php",
+ "gateway_worker": "src/config/gateway.php"
+ }
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "think\\worker\\": "src"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "Apache-2.0"
+ ],
+ "authors": [
+ {
+ "name": "liu21st",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "workerman extend for thinkphp6.0",
+ "time": "2019-11-07T03:56:14+00:00"
+ },
+ {
+ "name": "workerman/gateway-worker",
+ "version": "v3.0.15",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/walkor/GatewayWorker.git",
+ "reference": "d633fe52c792839a80ed2cfea7697bf705350d62"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/walkor/GatewayWorker/zipball/d633fe52c792839a80ed2cfea7697bf705350d62",
+ "reference": "d633fe52c792839a80ed2cfea7697bf705350d62",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "workerman/workerman": ">=3.5.0"
+ },
+ "type": "library",
+ "autoload": {
+ "psr-4": {
+ "GatewayWorker\\": "./src"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "homepage": "http://www.workerman.net",
+ "keywords": [
+ "communication",
+ "distributed"
+ ],
+ "time": "2020-03-09T12:03:30+00:00"
+ },
+ {
+ "name": "workerman/workerman",
+ "version": "v3.5.29",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/walkor/Workerman.git",
+ "reference": "eaf533eaa82f7f0237aa1d5502c6d0bced0919f7"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/walkor/Workerman/zipball/eaf533eaa82f7f0237aa1d5502c6d0bced0919f7",
+ "reference": "eaf533eaa82f7f0237aa1d5502c6d0bced0919f7",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=5.3"
+ },
+ "suggest": {
+ "ext-event": "For better performance. "
+ },
+ "type": "library",
+ "autoload": {
+ "psr-4": {
+ "Workerman\\": "./"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "walkor",
+ "email": "[email protected]",
+ "homepage": "http://www.workerman.net",
+ "role": "Developer"
+ }
+ ],
+ "description": "An asynchronous event driven PHP framework for easily building fast, scalable network applications.",
+ "homepage": "http://www.workerman.net",
+ "keywords": [
+ "asynchronous",
+ "event-loop"
+ ],
+ "time": "2020-03-05T11:08:04+00:00"
+ }
+ ],
+ "packages-dev": [
+ {
+ "name": "symfony/polyfill-php72",
+ "version": "v1.15.0",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/symfony/polyfill-php72.git",
+ "reference": "37b0976c78b94856543260ce09b460a7bc852747"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/symfony/polyfill-php72/zipball/37b0976c78b94856543260ce09b460a7bc852747",
+ "reference": "37b0976c78b94856543260ce09b460a7bc852747",
+ "shasum": "",
+ "mirrors": [
+  {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": ">=5.3.3"
+ },
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "1.15-dev"
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "Symfony\\Polyfill\\Php72\\": ""
+ },
+ "files": [
+ "bootstrap.php"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Nicolas Grekas",
+ "email": "[email protected]"
+ },
+ {
+ "name": "Symfony Community",
+ "homepage": "https://symfony.com/contributors"
+ }
+ ],
+ "description": "Symfony polyfill backporting some PHP 7.2+ features to lower PHP versions",
+ "homepage": "https://symfony.com",
+ "keywords": [
+ "compatibility",
+ "polyfill",
+ "portable",
+ "shim"
+ ],
+ "time": "2020-02-27T09:26:54+00:00"
+ },
+ {
+ "name": "symfony/var-dumper",
+ "version": "v4.4.5",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/symfony/var-dumper.git",
+ "reference": "2572839911702b0405479410ea7a1334bfab0b96"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/symfony/var-dumper/zipball/2572839911702b0405479410ea7a1334bfab0b96",
+  "reference": "2572839911702b0405479410ea7a1334bfab0b96",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+ "php": "^7.1.3",
+ "symfony/polyfill-mbstring": "~1.0",
+ "symfony/polyfill-php72": "~1.5"
+ },
+ "conflict": {
+ "phpunit/phpunit": "<4.8.35|<5.4.3,>=5.0",
+ "symfony/console": "<3.4"
+ },
+ "require-dev": {
+ "ext-iconv": "*",
+ "symfony/console": "^3.4|^4.0|^5.0",
+ "symfony/process": "^4.4|^5.0",
+ "twig/twig": "^1.34|^2.4|^3.0"
+ },
+ "suggest": {
+ "ext-iconv": "To convert non-UTF-8 strings to UTF-8 (or symfony/polyfill-iconv in case ext-iconv cannot be used).",
+ "ext-intl": "To show region name in time zone dump",
+ "symfony/console": "To use the ServerDumpCommand and/or the bin/var-dump-server script"
+ },
+ "bin": [
+ "Resources/bin/var-dump-server"
+ ],
+ "type": "library",
+ "extra": {
+ "branch-alias": {
+ "dev-master": "4.4-dev"
+ }
+ },
+ "autoload": {
+ "files": [
+ "Resources/functions/dump.php"
+ ],
+ "psr-4": {
+ "Symfony\\Component\\VarDumper\\": ""
+ },
+ "exclude-from-classmap": [
+ "/Tests/"
+ ]
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "MIT"
+ ],
+ "authors": [
+ {
+ "name": "Nicolas Grekas",
+ "email": "[email protected]"
+ },
+ {
+ "name": "Symfony Community",
+ "homepage": "https://symfony.com/contributors"
+ }
+ ],
+ "description": "Symfony mechanism for exploring and dumping PHP variables",
+ "homepage": "https://symfony.com",
+ "keywords": [
+ "debug",
+ "dump"
+ ],
+ "time": "2020-02-24T13:10:00+00:00"
+ },
+ {
+ "name": "topthink/think-trace",
+ "version": "v1.2",
+ "source": {
+ "type": "git",
+ "url": "https://github.com/top-think/think-trace.git",
+ "reference": "4589d06a07945d57478cc2236f4b23d51ff919cc"
+ },
+ "dist": {
+ "type": "zip",
+ "url": "https://api.github.com/repos/top-think/think-trace/zipball/4589d06a07945d57478cc2236f4b23d51ff919cc",
+ "reference": "4589d06a07945d57478cc2236f4b23d51ff919cc",
+ "shasum": "",
+ "mirrors": [
+ {
+ "url": "https://mirrors.aliyun.com/composer/dists/%package%/%reference%.%type%",
+ "preferred": true
+ }
+ ]
+ },
+ "require": {
+  "php": ">=7.1.0",
+ "topthink/framework": "^6.0.0"
+ },
+ "type": "library",
+ "extra": {
+ "think": {
+ "services": [
+ "think\\trace\\Service"
+ ],
+ "config": {
+ "trace": "src/config.php"
+ }
+ }
+ },
+ "autoload": {
+ "psr-4": {
+ "think\\trace\\": "src"
+ }
+ },
+ "notification-url": "https://packagist.org/downloads/",
+ "license": [
+ "Apache-2.0"
+ ],
+ "authors": [
+ {
+ "name": "liu21st",
+ "email": "[email protected]"
+ }
+ ],
+ "description": "thinkphp debug trace",
+ "time": "2019-10-17T02:14:09+00:00"
+ }
+ ],
+ "aliases": [],
+ "minimum-stability": "stable",
+ "stability-flags": [],
+ "prefer-stable": false,
+ "prefer-lowest": false,
+ "platform": {
+ "php": ">=7.1.0"
+ },
+ "platform-dev": []
+}

+<?php
+// +----------------------------------------------------------------------
+// | 应用设置
+// +----------------------------------------------------------------------
+
+return [
+ // 应用地址
+ 'app_host' => env('app.host', ''),
+ // 应用的命名空间
+ 'app_namespace' => '',
+ // 是否启用路由
+ 'with_route' => true,
+ // 是否启用事件
+ 'with_event' => true,
+ // 默认应用
+ 'default_app' => 'index',
+ // 默认时区
+ 'default_timezone' => 'Asia/Shanghai',
+
+ // 应用映射（自动多应用模式有效）
+ 'app_map' => [],
+ // 域名绑定（自动多应用模式有效）
+ 'domain_bind' => [],
+ // 禁止URL访问的应用列表（自动多应用模式有效）
+ 'deny_app_list' => [],
+
+ // 异常页面的模板文件
+ 'exception_tmpl' => app()->getThinkPath() . 'tpl/think_exception.tpl',
+
+ // 错误显示信息,非调试模式有效
+ 'error_message' => '页面错误！请稍后再试～',
+ // 显示错误信息
+ 'show_error_msg' => true,
+];

+<?php
+
+// +----------------------------------------------------------------------
+// | 缓存设置
+// +----------------------------------------------------------------------
+
+return [
+ 'default' => 'redis',
+ 'stores' => [
+ // 文件缓存
+ 'file' => [
+ // 驱动方式
+ 'type' => 'file',
+ // 设置不同的缓存保存目录
+ 'path' => '../runtime/file/',
+ ], 
+ // redis缓存
+ 'redis' => [
+ // 驱动方式
+ 'type' => 'redis',
+ // 服务器地址
+ 'host' => '127.0.0.1',
+ 'serialize' => ['json_encode','json_decode'],
+ 'prefix' => 'ws:',
+ ], 
+ ],
+];

+<?php
+// +----------------------------------------------------------------------
+// | 控制台配置
+// +----------------------------------------------------------------------
+return [
+ // 指令定义
+ 'commands' => [
+ ],
+];

+<?php
+// +----------------------------------------------------------------------
+// | Cookie设置
+// +----------------------------------------------------------------------
+return [
+ // cookie 保存时间
+ 'expire' => 0,
+ // cookie 保存路径
+ 'path' => '/',
+ // cookie 有效域名
+ 'domain' => '',
+ // cookie 启用安全传输
+ 'secure' => false,
+ // httponly设置
+ 'httponly' => false,
+ // 是否使用 setcookie
+ 'setcookie' => true,
+];

+<?php
+
+return [
+ // 默认使用的数据库连接配置
+ 'default' => env('database.driver', 'mysql'),
+
+ // 自定义时间查询规则
+ 'time_query_rule' => [],
+
+ // 自动写入时间戳字段
+ // true为自动识别类型 false关闭
+ // 字符串则明确指定时间字段类型 支持 int timestamp datetime date
+ 'auto_timestamp' => true,
+
+ // 时间字段取出后的默认时间格式
+ 'datetime_format' => 'Y-m-d H:i:s',
+
+ // 数据库连接配置信息
+ 'connections' => [
+ 'mysql' => [
+ // 数据库类型
+ 'type' => env('database.type', 'mysql'),
+ // 服务器地址
+ 'hostname' => env('database.hostname', '127.0.0.1'),
+ // 数据库名
+ 'database' => env('database.database', ''),
+ // 用户名
+ 'username' => env('database.username', 'root'),
+ // 密码
+ 'password' => env('database.password', ''),
+ // 端口
+ 'hostport' => env('database.hostport', '3306'),
+ // 数据库连接参数
+ 'params' => [],
+ // 数据库编码默认采用utf8
+ 'charset' => env('database.charset', 'utf8'),
+ // 数据库表前缀
+ 'prefix' => env('database.prefix', ''),
+
+ // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
+ 'deploy' => 0,
+ // 数据库读写是否分离 主从式有效
+ 'rw_separate' => false,
+ // 读写分离后 主服务器数量
+ 'master_num' => 1,
+ // 指定从服务器序号
+ 'slave_no' => '',
+ // 是否严格检查字段是否存在
+ 'fields_strict' => true,
+ // 是否需要断线重连
+ 'break_reconnect' => false,
+ // 监听SQL
+ 'trigger_sql' => env('app_debug', true),
+ // 开启字段缓存
+ 'fields_cache' => false,
+ // 字段缓存路径
+ 'schema_cache_path' => app()->getRuntimePath() . 'schema' . DIRECTORY_SEPARATOR,
+ ],
+
+ // 更多的数据库配置信息
+ ],
+];

+<?php
+
+return [
+ // 默认磁盘
+ 'default' => env('filesystem.driver', 'local'),
+ // 磁盘列表
+ 'disks' => [
+ 'local' => [
+ 'type' => 'local',
+ 'root' => app()->getRuntimePath() . 'storage',
+ ],
+ 'public' => [
+ // 磁盘类型
+ 'type' => 'local',
+ // 磁盘路径
+ 'root' => app()->getRootPath() . 'public/storage',
+ // 磁盘路径对应的外部URL路径
+ 'url' => '/storage',
+ // 可见性
+ 'visibility' => 'public',
+ ],
+ // 更多的磁盘配置信息
+ ],
+];

+<?php
+// +----------------------------------------------------------------------
+// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2006-2018 http://thinkphp.cn All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: liu21st <[email protected]>
+// +----------------------------------------------------------------------
+// +----------------------------------------------------------------------
+// | Workerman设置 仅对 php think worker:gateway 指令有效
+// +----------------------------------------------------------------------
+return [
+ // 扩展自身需要的配置
+ 'protocol' => 'websocket', // 协议 支持 tcp udp unix http websocket text
+ 'host' => '0.0.0.0', // 监听地址
+ 'port' => 2348, // 监听端口
+ 'socket' => '', // 完整监听地址
+ 'context' => [], // socket 上下文选项
+ 'register_deploy' => true, // 是否需要部署register
+ 'businessWorker_deploy' => true, // 是否需要部署businessWorker
+ 'gateway_deploy' => true, // 是否需要部署gateway
+
+ // Register配置
+ 'registerAddress' => '127.0.0.1:1236',
+
+ // Gateway配置
+ 'name' => 'thinkphp',
+ 'count' => 1,
+ 'lanIp' => '127.0.0.1',
+ 'startPort' => 2000,
+ 'daemonize' => false,
+ 'pingInterval' => 30,
+ 'pingNotResponseLimit' => 0,
+ 'pingData' => '{"type":"ping"}',
+
+ // BusinsessWorker配置
+ 'businessWorker' => [
+ 'name' => 'BusinessWorker',
+ 'count' => 1,
+ 'eventHandler' => '\think\worker\Events',
+ ],
+
+];

+<?php
+// +----------------------------------------------------------------------
+// | 多语言设置
+// +----------------------------------------------------------------------
+
+return [
+ // 默认语言
+ 'default_lang' => env('lang.default_lang', 'zh-cn'),
+ // 允许的语言列表
+ 'allow_lang_list' => [],
+ // 多语言自动侦测变量名
+ 'detect_var' => 'lang',
+ // 是否使用Cookie记录
+ 'use_cookie' => true,
+ // 多语言cookie变量
+ 'cookie_var' => 'think_lang',
+ // 扩展语言包
+ 'extend_list' => [],
+ // Accept-Language转义为对应语言包名称
+ 'accept_language' => [
+ 'zh-hans-cn' => 'zh-cn',
+ ],
+ // 是否支持语言分组
+ 'allow_group' => false,
+];

+<?php
+
+// +----------------------------------------------------------------------
+// | 日志设置
+// +----------------------------------------------------------------------
+return [
+ // 默认日志记录通道
+ 'default' => env('log.channel', 'file'),
+ // 日志记录级别
+ 'level' => [],
+ // 日志类型记录的通道 ['error'=>'email',...]
+ 'type_channel' => [],
+ // 关闭全局日志写入
+ 'close' => false,
+ // 全局日志处理 支持闭包
+ 'processor' => null,
+
+ // 日志通道列表
+ 'channels' => [
+ 'file' => [
+ // 日志记录方式
+ 'type' => 'File',
+ // 日志保存目录
+ 'path' => '',
+ // 单文件日志写入
+ 'single' => false,
+ // 独立日志级别
+ 'apart_level' => ['consumer','producer','send','receive'],
+ // 最大日志文件数量
+ 'max_files' => 0,
+ // 使用JSON格式记录
+ 'json' => false,
+ // 日志处理
+ 'processor' => null,
+ // 关闭通道日志写入
+ 'close' => false,
+ // 日志输出格式化
+ 'format' => '[%s][%s] %s',
+ // 是否实时写入
+ 'realtime_write' => false,
+ // 存入时间
+ 'time_format' => 'Y-m-d H:i:s',
+ ],
+ // 其它日志通道配置
+ ],
+
+];

+<?php
+// 中间件配置
+return [
+ // 别名或分组
+ 'alias' => [],
+ // 优先级设置，此数组中的中间件会按照数组中的顺序优先执行
+ 'priority' => [],
+];

+<?php
+// +----------------------------------------------------------------------
+// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2006-2016 http://thinkphp.cn All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: yunwuxin <[email protected]>
+// +----------------------------------------------------------------------
+
+return [
+ 'default' => 'sync',
+ 'connections' => [
+ 'sync' => [
+ 'type' => 'redis',
+ ],
+ 'database' => [
+ 'type' => 'database',
+ 'queue' => 'default',
+ 'table' => 'jobs',
+ ],
+ 'redis' => [
+ 'type' => 'redis',
+ 'queue' => 'default',
+ 'host' => '127.0.0.1',
+ 'port' => 6379,
+ 'password' => '',
+ 'select' => 7,
+ 'timeout' => 0,
+ 'persistent' => false,
+ ],
+ ],
+ 'failed' => [
+ 'type' => 'none',
+ 'table' => 'failed_jobs',
+ ],
+];

+<?php
+// +----------------------------------------------------------------------
+// | 路由设置
+// +----------------------------------------------------------------------
+
+return [
+ // pathinfo分隔符
+ 'pathinfo_depr' => '/',
+ // URL伪静态后缀
+ 'url_html_suffix' => 'html',
+ // URL普通方式参数 用于自动生成
+ 'url_common_param' => true,
+ // 是否开启路由延迟解析
+ 'url_lazy_route' => false,
+ // 是否强制使用路由
+ 'url_route_must' => false,
+ // 合并路由规则
+ 'route_rule_merge' => false,
+ // 路由是否完全匹配
+ 'route_complete_match' => false,
+ // 访问控制器层名称
+ 'controller_layer' => 'controller',
+ // 空控制器名
+ 'empty_controller' => 'Error',
+ // 是否使用控制器后缀
+ 'controller_suffix' => false,
+ // 默认的路由变量规则
+ 'default_route_pattern' => '[\w\.]+',
+ // 是否开启请求缓存 true自动缓存 支持设置请求缓存规则
+ 'request_cache' => false,
+ // 请求缓存有效期
+ 'request_cache_expire' => null,
+ // 全局请求缓存排除规则
+ 'request_cache_except' => [],
+ // 默认控制器名
+ 'default_controller' => 'Index',
+ // 默认操作名
+ 'default_action' => 'index',
+ // 操作方法后缀
+ 'action_suffix' => '',
+ // 默认JSONP格式返回的处理方法
+ 'default_jsonp_handler' => 'jsonpReturn',
+ // 默认JSONP处理方法
+ 'var_jsonp_handler' => 'callback',
+];

+<?php
+// +----------------------------------------------------------------------
+// | 会话设置
+// +----------------------------------------------------------------------
+
+return [
+ // session name
+ 'name' => 'PHPSESSID',
+ // SESSION_ID的提交变量,解决flash上传跨域
+ 'var_session_id' => '',
+ // 驱动方式 支持file cache
+ 'type' => 'file',
+ // 存储连接标识 当type使用cache的时候有效
+ 'store' => null,
+ // 过期时间
+ 'expire' => 1440,
+ // 前缀
+ 'prefix' => '',
+];

+<?php
+// +----------------------------------------------------------------------
+// | Trace设置 开启调试模式后有效
+// +----------------------------------------------------------------------
+return [
+ // 内置Html和Console两种方式 支持扩展
+ 'type' => 'Html',
+ // 读取的日志通道名
+ 'channel' => '',
+];

+<?php
+// +----------------------------------------------------------------------
+// | 模板设置
+// +----------------------------------------------------------------------
+
+return [
+ // 模板引擎类型使用Think
+ 'type' => 'Think',
+ // 默认模板渲染规则 1 解析为小写+下划线 2 全部转换小写 3 保持操作方法
+ 'auto_rule' => 1,
+ // 模板目录名
+ 'view_dir_name' => 'view',
+ // 模板后缀
+ 'view_suffix' => 'html',
+ // 模板文件名分隔符
+ 'view_depr' => DIRECTORY_SEPARATOR,
+ // 模板引擎普通标签开始标记
+ 'tpl_begin' => '{',
+ // 模板引擎普通标签结束标记
+ 'tpl_end' => '}',
+ // 标签库标签开始标记
+ 'taglib_begin' => '{',
+ // 标签库标签结束标记
+ 'taglib_end' => '}',
+];

+<?php
+// +----------------------------------------------------------------------
+// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2006-2018 http://thinkphp.cn All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: liu21st <[email protected]>
+// +----------------------------------------------------------------------
+
+// +----------------------------------------------------------------------
+// | Workerman设置 仅对 php think worker 指令有效
+// +----------------------------------------------------------------------
+return [
+ // 扩展自身需要的配置
+ 'host' => '0.0.0.0', // 监听地址
+ 'port' => 2346, // 监听端口
+ 'root' => '', // WEB 根目录 默认会定位public目录
+ 'app_path' => '', // 应用目录 守护进程模式必须设置（绝对路径）
+ 'file_monitor' => false, // 是否开启PHP文件更改监控（调试模式下自动开启）
+ 'file_monitor_interval' => 2, // 文件监控检测时间间隔（秒）
+ 'file_monitor_path' => [], // 文件监控目录 默认监控application和config目录
+
+ // 支持workerman的所有配置参数
+ 'name' => 'thinkphp',
+ 'count' => 4,
+ 'daemonize' => false,
+ 'pidFile' => '',
+];

+<?php
+// +----------------------------------------------------------------------
+// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2006-2018 http://thinkphp.cn All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: liu21st <[email protected]>
+// +----------------------------------------------------------------------
+
+// +----------------------------------------------------------------------
+// | Workerman设置 仅对 php think worker:server 指令有效
+// +----------------------------------------------------------------------
+return [
+ // 扩展自身需要的配置
+ 'protocol' => 'websocket', // 协议 支持 tcp udp unix http websocket text
+ 'host' => '0.0.0.0', // 监听地址
+ 'port' => 8282, // 监听端口
+ 'socket' => '', // 完整监听地址
+ 'context' => [], // socket 上下文选项
+ 'worker_class' => 'app\http\Worker', // 自定义Workerman服务类名 支持数组定义多个服务
+
+ // 支持workerman的所有配置参数
+ 'name' => 'thinkphp',
+ 'count' => 4,
+ 'daemonize' => false,
+ 'pidFile' => '',
+
+ // 支持事件回调
+ // onWorkerStart
+ 'onWorkerStart' => function ($worker) {
+
+ },
+ // onWorkerReload
+ 'onWorkerReload' => function ($worker) {
+
+ },
+ // onConnect
+ 'onConnect' => function ($connection) {
+
+ },
+ // onMessage
+ 'onMessage' => function ($connection, $data) {
+ $connection->send('receive success');
+ },
+ // onClose
+ 'onClose' => function ($connection) {
+
+ },
+ // onError
+ 'onError' => function ($connection, $code, $msg) {
+ echo "error [ $code ] $msg\n";
+ },
+];

+*
+!.gitignore

+<IfModule mod_rewrite.c>
+ Options +FollowSymlinks -Multiviews
+ RewriteEngine On
+
+ RewriteCond %{REQUEST_FILENAME} !-d
+ RewriteCond %{REQUEST_FILENAME} !-f
+ RewriteRule ^(.*)$ index.php/$1 [QSA,PT,L]
+</IfModule>

+<?php
+// +----------------------------------------------------------------------
+// | ThinkPHP [ WE CAN DO IT JUST THINK ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2006-2019 http://thinkphp.cn All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: liu21st <[email protected]>
+// +----------------------------------------------------------------------
+
+// [ 应用入口文件 ]
+namespace think;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+// 执行HTTP应用并响应
+$http = (new App())->http;
+
+$response = $http->run();
+
+$response->send();
+
+$http->end($response);

+User-agent: *
+Disallow:

+<?php
+// +----------------------------------------------------------------------
+// | ThinkPHP [ WE CAN DO IT JUST THINK ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2006~2019 http://thinkphp.cn All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: liu21st <[email protected]>
+// +----------------------------------------------------------------------
+// $Id$
+
+if (is_file($_SERVER["DOCUMENT_ROOT"] . $_SERVER["SCRIPT_NAME"])) {
+ return false;
+} else {
+ $_SERVER["SCRIPT_FILENAME"] = __DIR__ . '/index.php';
+
+ require __DIR__ . "/index.php";
+}

+*
+!.gitignore

+<?php
+// +----------------------------------------------------------------------
+// | ThinkPHP [ WE CAN DO IT JUST THINK ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2006~2018 http://thinkphp.cn All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: liu21st <[email protected]>
+// +----------------------------------------------------------------------
+use think\facade\Route;
+
+Route::get('think', function () {
+ return 'hello,ThinkPHP6!';
+});
+
+Route::get('isOnline/:uuid/:wxid', 'index/isOnline'); //查看是否在线
+Route::get('kafka_test', 'kafka_test/index'); //kafka test队列
+Route::get('kafka_login', 'KafkaLogin/kafka_login'); //kafka login队列
+Route::get('kafka_send', 'KafkaSend/kafka_send'); //kafka send队列
+Route::get('kafka_callback', 'KafkaCallback/kafka_callback'); //kafka send队列
+Route::get('phpinfo', 'index/phpinfo'); //phpinfo查看

+*
+!.gitignore

+#!/usr/bin/env php
+<?php
+namespace think;
+
+// 命令行入口文件
+// 加载基础文件
+require __DIR__ . '/vendor/autoload.php';
+
+// 应用初始化
+(new App())->console->run();

+如果不使用模板，可以删除该目录