asa

app/Http/Controllers/Admin/GameUrlController.php

@@ -0,0 +1,142 @@
+<?php
+
+namespace App\Http\Controllers\Admin;
+
+use App\Http\Models\GameUrlData;
+use App\Models\GameUrl;
+use Illuminate\Http\Request;
+use App\Http\Controllers\PublicController;
+
+/**
+ * 游戏url及参数类
+ */
+class GameUrlController extends PublicController
+{
+
+
+    /**
+     * 视图加载
+     *
+     * @access public
+     * @return array
+     */
+    public function index()
+    {
+        return view('admin.gameUrl.index');
+
+    }//end index()
+
+
+    /**
+     * 数据获取
+     *
+     * @access public
+     * @param  mixed $request 参数.
+     * @return array
+     */
+    public function data(Request $request)
+    {
+        $gameUrlDataModel = new GameUrlData;
+        $getGameUrlWhere = [];
+        // 查询参数.
+        if (empty($request->get('gameUrl_name')) !== true) {
+            $getGameUrlWhere['gameUrl_name'] = $request->get('gameUrl_name');
+        }
+
+        // 查询数据.
+        $res = $gameUrlDataModel->getGameUrl($getGameUrlWhere, $request->get('limit', 30));
+        // 返回参数.
+        $data = [
+            'code'  => 0,
+            'msg'   => '正在请求中...',
+            'count' => $res['total'],
+            'data'  => $res['data'],
+        ];
+        return response()->json($data);
+
+    }//end data()
+
+
+    /**
+     * 视图加载
+     *
+     * @access public
+     * @return array
+     */
+    public function create()
+    {
+        return view('admin.gameUrl.create');
+
+    }//end create()
+
+
+    /**
+     * 添加数据
+     *
+     * @access public
+     * @param  mixed $request 参数.
+     * @return array
+     */
+    public function store(Request $request)
+    {
+        $data = $request->only(['gameUrl_name', 'gameUrl_type', 'gameUrl_url', 'gameUrl_data']);
+
+        if ( GameUrl::insert($data)) {
+            return redirect()->to(route('admin.gameUrl'))->with(['status'=>'添加成功']);
+        }
+        return redirect()->to(route('admin.gameUrl'))->withErrors('系统错误');
+
+    }//end store()
+
+
+    /**
+     * Show the form for editing the specified resource.
+     *
+     * @param  int  $id
+     * @return \Illuminate\Http\Response
+     */
+    public function edit($id)
+    {
+        $gameUrlModel = new GameUrl;
+        $gameUrl = $gameUrlModel->where(['gameUrl_id' => $id])->first();
+        return view('admin.gameUrl.edit',compact('gameUrl'));
+    }
+    /**
+     * Update the specified resource in storage.
+     *
+     * @param  \Illuminate\Http\Request  $request
+     * @param  int  $id
+     * @return \Illuminate\Http\Response
+     */
+    public function update(Request $request)
+    {
+        $gameUrlModel = new GameUrl;
+        $gameUrl = $gameUrlModel->where(['gameUrl_id' => $request->get('gameUrl_id')]);
+        $data = $request->only(['gameUrl_name', 'gameUrl_type', 'gameUrl_url', 'gameUrl_data']);
+
+        if ($gameUrl->update($data)){
+            return redirect()->to(route('admin.gameUrl'))->with(['status'=>'更新成功']);
+        }
+        return redirect()->to(route('admin.gameUrl'))->withErrors('系统错误');
+    }
+
+
+    /**
+     * 删除
+     *
+     * @access public
+     * @param  mixed $request 参数.
+     * @return array
+     */
+    public function destroy(Request $request)
+    {
+        $ids = $request->get('ids');
+        if (empty($ids)){
+            return response()->json(['code'=>1,'msg'=>'请选择删除项']);
+        }
+        if (GameUrl::whereIn('id',$ids)->update(['status'=>0])){
+            return response()->json(['code'=>0,'msg'=>'删除成功']);
+        }
+        return response()->json(['code'=>1,'msg'=>'删除失败']);
+    }
+}

app/Http/Controllers/Api/AgentController.php

@@ -13,28 +13,47 @@ use \Exception;
 class AgentController extends Controller
 {
 
-
     /**
-     * 代理登陆、注册
+     * 构造函数
      *
      * @access public
      * @param mixed $req 数据传输
      * @return array JsonString
      */
-    public function login(Request $req)
-    {
+    public function __construct(Request $req) {
         $code = -2;
         $msg = '操作失败';
         try {
-            $agentModel = new Models\Agent;
-            $sportsAgentModel = new Models\SportsAgent;
             // 获取Token url及参数.
             $gmenuId = $req->input('id');
+            $sportsAgentModel = new Models\SportsAgent;
             $backData = $sportsAgentModel->getSportsToken($gmenuId);
             if ($backData !== 1) {
                 $msg = '链接失败';
                 return toJson($code, $msg, []);
             }
+        } catch (Exception $e) {
+            return toJson($code, $msg, []);
+        }
+
+    }
+
+
+    /**
+     * 代理登陆、注册
+     *
+     * @access public
+     * @param mixed $req 数据传输
+     * @return array JsonString
+     */
+    public function login(Request $req)
+    {
+        $code = -2;
+        $msg = '操作失败';
+        try {
+            $agentModel = new Models\Agent;
+            $sportsAgentModel = new Models\SportsAgent;
+            $gmenuId = $req->input('id');
 
             // 获取用户信息.
             $getMemberInfo = $agentModel->getMember();
@@ -67,7 +86,47 @@ class AgentController extends Controller
             $msg = '成功';
             $code = 1;
 
-            return toJson($code, $msg, ['apiToken' => $loginBackData['token']]);
+            return toJson($code, $msg, session('sportsToken'));
+        } catch (Exception $e) {
+            return toJson($code, $msg, []);
+        }
+
+    }//end login()
+
+
+    /**
+     * 代理转账
+     *
+     * @access public
+     * @param mixed $req 数据传输
+     * @return array JsonString
+     */
+    public function turnOutMoney(Request $req)
+    {
+        $code = -2;
+        $msg = '操作失败';
+        try {
+            $agentModel = new Models\Agent;
+            $sportsAgentModel = new Models\SportsAgent;
+            $gmenuId = $req->input('id');
+            $money = $req->input('money');
+            // 获取用户信息.
+            $getMemberInfo = $agentModel->getMember();
+            // 獲取余额.
+            $getMembersDetailed = $agentModel->getMembersDetailed();
+            $cash = ($getMembersDetailed->membersDetailed_cash + $money);
+            $backData = $sportsAgentModel->transferSports($gmenuId, $money, $cash, $getMemberInfo, 'IN');
+            if ($backData !== 1) {
+                $msg = '链接失败';
+                return toJson($code, $msg, []);
+            }
+
+
+
+            $msg = '成功';
+            $code = 1;
+
+            return toJson($code, $msg, session('sportsToken'));
         } catch (Exception $e) {
             return toJson($code, $msg, []);
         }

app/Http/Controllers/Sys/MenuController.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace App\Http\Controllers\Sys;
+
+use Illuminate\Http\Request;
+use App\Http\Controllers\Controller;
+use Illuminate\Support\Facades\Redis;
+
+
+use App\Models\Gmenu;
+
+class MenuController extends Controller
+{
+    public function getMenus(Request $req)
+    {
+        $pid = intval($req->input('pid', 0));
+        $data = (new  Gmenu())->getByPid($pid);
+        if (empty($data)) {
+            return toJson(-1);
+        } else {
+            $md5 = md5(json_encode($data));
+            return toJson(1, '', ['data' => $data, 'md5' => $md5]);
+        }
+    }
+}

app/Http/Controllers/Sys/UserController.php

@@ -4,8 +4,8 @@ namespace App\Http\Controllers\Sys;
 
 use Illuminate\Http\Request;
 use App\Http\Controllers\Controller;
-use PHPMailer\PHPMailer\Exception;
 use Illuminate\Support\Facades\DB;
+use \Exception;
 
 
 class UserController extends Controller
@@ -57,20 +57,20 @@ class UserController extends Controller
     }
     public function register(Request $req)
     {
-        $user=[];
-        $user['name']=$req->input('user');
-        $user['password']=$req->input('password');
-        $cpwd=$req->input('confirm_password');
-        $user['phone']=$req->input('phone');
-        $user['uuid']=getUUID();
-        $user['password']=createPasswd(trim($user['password']),$user['uuid']); 
         try{
+            $user=[];
+            $user['name']=$req->input('user');
+            $user['password']=$req->input('password');
+            $cpwd=$req->input('confirm_password');
+            $user['phone']=$req->input('phone');
+            $user['uuid']=getUUID();
+            $user['password']=createPasswd(trim($user['password']),$user['uuid']);
             $re=\App\Models\Member::insert($user);
+
+            return toJson(1);
         }catch(Exception $ex){
             return toJson(-20001);
-        }      
-       
-        return toJson(1);
+        }
     }
     public function login(Request $req){
         $user['name']=$req->input('user');
@@ -79,7 +79,6 @@ class UserController extends Controller
         if(!$member){
             return toJson(-20002);
         }
-
         if(($member['password'])!=createPasswd(trim($user['password']),$member['uuid'])){
             return toJson(-20003);
         }

app/Http/Models/Agent.php

@@ -12,6 +12,54 @@ class Agent extends Model
 {
 
 
+    /**
+     * 获取游戏token
+     *
+     * @access public
+     * @param mixed $where 查询条件
+     * @return String
+     */
+    public function getAgent($where)
+    {
+        $agentModel = new Models\Agent;
+        $select = [
+            'agent_token',
+            'updated_at',
+        ];
+        $result = $agentModel
+            ->select($select)
+            ->where($where)
+            ->first();
+
+        return $result;
+
+    }//end getAgent()
+
+
+    /**
+     * 修改游戏token
+     *
+     * @access public
+     * @param mixed $where 查询条件
+     * @param mixed $token token
+     * @return String
+     */
+    public function updateAgent($where, $token)
+    {
+        $agentModel = new Models\Agent;
+        $update = [
+            'agent_token' => $token,
+            'updated_at' => date('Y-m-d H:i:s'),
+        ];
+        $result = $agentModel
+            ->where($where)
+            ->update($update);
+
+        return $result;
+
+    }//end updateAgent()
+
+
     /**
      * 获取游戏url及参数
      *

app/Http/Models/Common.php

@@ -86,7 +86,7 @@ class Common extends Model
             $a++;
         }
         $params = base64_encode($paramsSting);
-        $key = md5($params . S('sportsToken'));
+        $key = md5($params . session('sportsToken'));
         $loginUrl = $url . '?params=' . $params . '&Key=' . $key;
 
         return $loginUrl;

app/Http/Models/GameUrlData.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace App\Http\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use \App\Models;
+
+/**
+ * 游戏url及参数模型类
+ */
+class GameUrlData extends Model
+{
+
+
+    /**
+     * 查询游戏url及参数
+     *
+     * @access public
+     * @param mixed $getGameUrlWhere 查询条件
+     * @param mixed $paginate 分页
+     * @return array
+     */
+    public function getGameUrl($getGameUrlWhere='', $paginate)
+    {
+        // 获取游戏地址数据.
+        $gameUrlModel = new Models\GameUrl;
+        $getGameUrl = $gameUrlModel;
+        if (empty($getGameUrlWhere) === false) {
+            $getGameUrl = $getGameUrl->where($getGameUrlWhere);
+        }
+
+        $getGameUrl = $getGameUrl
+            ->orderBy('gameUrl_id','desc')
+            ->paginate($paginate)
+            ->toArray();
+
+        return $getGameUrl;
+
+    }//end getGameUrl()
+
+
+}

app/Http/Models/SportsAgent.php

@@ -5,6 +5,7 @@ namespace App\Http\Models;
 use Illuminate\Database\Eloquent\Model;
 use \App\Http\Models as HttpModel;
 use Illuminate\Support\Facades\DB;
+use \App\Models;
 
 /**
  * 赛事代理管理模型类
@@ -23,10 +24,22 @@ class SportsAgent extends Model
     public function getSportsToken($gmenuId)
     {
         $agentModel = new HttpModel\Agent;
+        // 获取数据库token.
+        $getAgentWhere = [
+            'agent_name' => 'sports',
+        ];
+        $getAgent = $agentModel->getAgent($getAgentWhere);
+        $agent_token = $getAgent && $getAgent->agent_token ? $getAgent->agent_token : '';
+        $updated_at = $getAgent && $getAgent->updated_at ? $getAgent->updated_at : '';
+        $newDate = date('Y-m-d H:i:s',strtotime('-20 hour'));
+        if ($agent_token && $updated_at > $newDate) {
+            session()->put('sportsToken', $agent_token);
+            return 1;
+        }
         // 获取url及参数.
         $getGameUrlWhere = [
             'gmenu_id' => $gmenuId,
-            'gameUrl_type' => 'getToken',
+            'gameUrl_type' => 'getSportsToken',
         ];
         $getGameUrl = $agentModel->getGameUrl($getGameUrlWhere);
 
@@ -43,7 +56,11 @@ class SportsAgent extends Model
         $getToken = $commonModel->make_request($url, $dataString);
         if ($getToken && json_decode($getToken)->status === 1) {
             // 存儲token
-            S('sportsToken', json_decode($getToken)->data->token);
+            $updateAgentWhere = [
+                'agent_name' => 'sports',
+            ];
+            $agentModel->updateAgent($updateAgentWhere, json_decode($getToken)->data->token);
+            session()->put('sportsToken', json_decode($getToken)->data->token);
             return 1;
         } else {
             return 2;
@@ -66,7 +83,7 @@ class SportsAgent extends Model
         // 获取验证用户 url及参数.
         $getGameUrlWhere = [
             'gmenu_id' => $gmenuId,
-            'gameUrl_type' => 'checkAccount',
+            'gameUrl_type' => 'sportsCheckAccount',
         ];
         $getGameUrl = $agentModel->getGameUrl($getGameUrlWhere);
         // 获取验证用户传参.
@@ -106,7 +123,7 @@ class SportsAgent extends Model
         // 获取登陆 url及参数.
         $getGameUrlWhere = [
             'gmenu_id' => $gmenuId,
-            'gameUrl_type' => 'login',
+            'gameUrl_type' => 'sportsLogin',
         ];
         $getGameUrl = $agentModel->getGameUrl($getGameUrlWhere);
         // 获取登陆传参.
@@ -159,7 +176,7 @@ class SportsAgent extends Model
         // 获取转账 url及参数.
         $getGameUrlWhere = [
             'gmenu_id' => $gmenuId,
-            'gameUrl_type' => 'transfer',
+            'gameUrl_type' => 'sportsTransfer',
         ];
         $getGameUrl = $agentModel->getGameUrl($getGameUrlWhere);
         // 获取转账传参.
@@ -205,7 +222,7 @@ class SportsAgent extends Model
         // 获取余额 url及参数.
         $getGameUrlWhere = [
             'gmenu_id' => $gmenuId,
-            'gameUrl_type' => 'seeCash',
+            'gameUrl_type' => 'sportsSeeCash',
         ];
         $getGameUrl = $agentModel->getGameUrl($getGameUrlWhere);
         // 获取余额传参.

app/Models/Agent.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Model;
+
+/**
+ * 数据库gameUrl模型类
+ */
+class Agent extends Model
+{
+
+    protected $table = 'agent';
+
+
+}

app/Vendor/Jwt.php

@@ -86,8 +86,8 @@ class Jwt {
             return false;
 
         //该nbf时间之前不接收处理该Token
-        if (isset($payload['nbf']) && $payload['nbf'] > time())
-            return false;
+        /*if (isset($payload['nbf']) && $payload['nbf'] > time())
+            return false;*/
 
         return $payload;
     }

composer.json

@@ -19,7 +19,8 @@
         "tymon/jwt-auth": "dev-develop",
         "xethron/migrations-generator": "^2.0",
         "yansongda/laravel-pay": "^2.0",
-        "zgldh/qiniu-laravel-storage": "^0.9.2"
+        "zgldh/qiniu-laravel-storage": "^0.9.2",
+        "predis/predis":"1.1.1"
     },
     "require-dev": {
         "filp/whoops": "~2.0",
@@ -68,7 +69,7 @@
     "repositories": {
         "packagist": {
             "type": "composer",
-            "url": "https://packagist.laravel-china.org"
+            "url": "https://packagist.phpcomposer.com"
         }
     }
 }

resources/views/admin/gameUrl/_form.blade.php

@@ -0,0 +1,40 @@
+{{csrf_field()}}
+<div class="layui-form-item">
+    <label for="" class="layui-form-label">游戏地址指向名</label>
+    <div class="layui-input-inline">
+        <input type="text" name="gameUrl_name" value="{{ $gameUrl->gameUrl_name ?? old('gameUrl_name') }}" lay-verify="required" placeholder="请输入游戏地址指向名" class="layui-input" >
+    </div>
+</div>
+
+<div class="layui-form-item">
+    <label for="" class="layui-form-label">游戏地址指向类型</label>
+    <div class="layui-input-inline">
+        <input type="text" name="gameUrl_type" value="{{$gameUrl->gameUrl_type??old('gameUrl_type')}}" required="required" placeholder="请输入游戏地址指向类型" class="layui-input">
+    </div>
+</div>
+
+<div class="layui-form-item">
+    <label for="" class="layui-form-label">游戏地址</label>
+    <div class="layui-input-inline">
+        <input type="text" name="gameUrl_url" value="{{ $gameUrl->gameUrl_url ?? old('gameUrl_url') }}" lay-verify="required"  placeholder="请输入游戏地址" class="layui-input" style="width: 600px">
+    </div>
+    <br/>
+    <div class="layui-form-mid layui-word-aux" style="padding: 20px 0 !important; margin-left: -200px;">实例：http://www.kaiyou.com/InApi-index/dobusiness</div>
+</div>
+
+<div class="layui-form-item">
+    <label for="" class="layui-form-label">所需参数</label>
+    <div class="layui-input-inline">
+        <input type="text" name="gameUrl_data" value="{{ $gameUrl->gameUrl_data ?? old('gameUrl_data') }}" lay-verify="required"  placeholder="请输入所需参数" class="layui-input" style="width: 750px">
+    </div>
+    <br/>
+    <div class="layui-form-mid layui-word-aux" style="padding: 20px 0 !important; margin-left: -200px;">实例：{"agent":"test1agent","method":"gb"}</div>
+</div>
+
+
+<div class="layui-form-item">
+    <div class="layui-input-block">
+        <button type="submit" class="layui-btn" lay-submit="" lay-filter="formDemo">确 认</button>
+        <a  class="layui-btn" href="{{route('admin.gameUrl')}}" >返 回</a>
+    </div>
+</div>

resources/views/admin/gameUrl/_js.blade.php

@@ -0,0 +1,69 @@
+<style>
+    #layui-upload-box li{
+        width: 120px;
+        height: 100px;
+        float: left;
+        position: relative;
+        overflow: hidden;
+        margin-right: 10px;
+        border:1px solid #ddd;
+    }
+    #layui-upload-box li img{
+        width: 100%;
+    }
+    #layui-upload-box li p{
+        width: 100%;
+        height: 22px;
+        font-size: 12px;
+        position: absolute;
+        left: 0;
+        bottom: 0;
+        line-height: 22px;
+        text-align: center;
+        color: #fff;
+        background-color: #333;
+        opacity: 0.6;
+    }
+    #layui-upload-box li i{
+        display: block;
+        width: 20px;
+        height:20px;
+        position: absolute;
+        text-align: center;
+        top: 2px;
+        right:2px;
+        z-index:999;
+        cursor: pointer;
+    }
+</style>
+<script>
+    layui.use(['upload'],function () {
+        var upload = layui.upload
+        //普通图片上传
+        var uploadInst = upload.render({
+            elem: '#uploadPic'
+            ,url: '{{ route("admin.uploadImg") }}'
+            ,multiple: false
+            ,data:{"_token":"{{ csrf_token() }}"}
+            ,before: function(obj){
+                //预读本地文件示例，不支持ie8
+                /*obj.preview(function(index, file, result){
+                 $('#layui-upload-box').append('<li><img src="'+result+'" /><p>待上传</p></li>')
+                 });*/
+                obj.preview(function(index, file, result){
+                    $('#layui-upload-box').html('<li><img src="'+result+'" /><p>上传中</p></li>')
+                });
+
+            }
+            ,done: function(res){
+                //如果上传失败
+                if(res.code == 0){
+                    $("#iconUrl").val(res.url);
+                    $('#layui-upload-box li p').text('上传成功');
+                    return layer.msg(res.msg,{icon:6});
+                }
+                return layer.msg(res.msg,{icon:5});
+            }
+        });
+    });
+</script>

resources/views/admin/gameUrl/create.blade.php

@@ -0,0 +1,18 @@
+@extends('admin.base')
+
+@section('content')
+    <div class="layui-card">
+        <div class="layui-card-header layuiadmin-card-header-auto">
+            <h2>添加数据</h2>
+        </div>
+        <div class="layui-card-body">
+            <form class="layui-form" action="{{route('admin.gameUrl.store')}}" method="post">
+                @include('admin.gameUrl._form')
+            </form>
+        </div>
+    </div>
+@endsection
+
+@section('script')
+    @include('admin.gameUrl._js')
+@endsection

resources/views/admin/gameUrl/edit.blade.php

@@ -0,0 +1,20 @@
+@extends('admin.base')
+
+@section('content')
+    <div class="layui-card">
+        <div class="layui-card-header layuiadmin-card-header-auto">
+            <h2>更新</h2>
+        </div>
+        <div class="layui-card-body">
+            <form class="layui-form" action="{{route('admin.gameUrl.update',['gameUrl'=>$gameUrl])}}" method="post">
+                <input type="hidden" name="gameUrl_id" value="{{$gameUrl->gameUrl_id}}">
+                {{method_field('put')}}
+                @include('admin.gameUrl._form')
+            </form>
+        </div>
+    </div>
+@endsection
+
+@section('script')
+    @include('admin.gameUrl._js')
+@endsection

resources/views/admin/gameUrl/index.blade.php

@@ -0,0 +1,128 @@
+@extends('admin.base')
+
+@section('content')
+    <div class="layui-card">
+        <div class="layui-card-header layuiadmin-card-header-auto">
+            <div class="layui-btn-group ">
+                {{--@can('config.gameUrl.destroy')
+                    <button class="layui-btn layui-btn-sm layui-btn-danger" id="listDelete">删除</button>
+                @endcan--}}
+                @can('config.gameUrl.create')
+                    <a class="layui-btn layui-btn-sm" href="{{ route('admin.gameUrl.create') }}">添加</a>
+                @endcan
+                <button class="layui-btn layui-btn-sm" id="memberSearch">搜索</button>
+            </div>
+            <div class="layui-form">
+
+                <div class="layui-input-inline">
+                    <input type="text" name="gameUrl_name" id="gameUrl_name" placeholder="名称" class="layui-input">
+                </div>
+
+            </div>
+        </div>
+
+        <div class="layui-card-body">
+            <table id="dataTable" lay-filter="dataTable"></table>
+            <script type="text/html" id="options">
+                <div class="layui-btn-group">
+                    @can('config.gameUrl.edit')
+                        <a class="layui-btn layui-btn-sm" lay-event="edit">编辑</a>
+                    @endcan
+                    {{--@can('config.gameUrl.destroy')
+                        <a class="layui-btn layui-btn-danger layui-btn-sm" lay-event="del">删除</a>
+                    @endcan--}}
+                </div>
+            </script>
+            {{--<script type="text/html" id="avatar">
+                <a href="@{{d.avatar}}" target="_blank" title="点击查看"><img src="@{{d.avatar}}" alt="" width="28" height="28"></a>
+            </script>--}}
+        </div>
+    </div>
+@endsection
+
+@section('script')
+    @can('config.gameUrl')
+        <script>
+            layui.use(['layer','table','form'],function () {
+                var layer = layui.layer;
+                var form = layui.form;
+                var table = layui.table;
+                //用户表格初始化
+                var dataTable = table.render({
+                    elem: '#dataTable'
+                    ,height: 500
+                    ,url: "{{ route('admin.gameUrl.data') }}" //数据接口
+                    ,where:{model:"gameUrl"}
+                    ,page: true //开启分页
+                    ,cols: [[ //表头
+                        {checkbox: true,fixed: true}
+                        ,{field: 'gameUrl_id', title: 'ID', sort: true,width:80}
+                        ,{field: 'gameUrl_name', title: '游戏地址指向名'}
+                        ,{field: 'gameUrl_type', title: '游戏地址指向类型'}
+                        ,{field: 'gameUrl_url', title: '游戏地址'}
+                        ,{field: 'gameUrl_data', title: '所需参数'}
+                        ,{field: 'created_at', title: '创建时间'}
+                        ,{field: 'updated_at', title: '更新时间'}
+
+                        ,{fixed: 'right', width: 120, align:'center', toolbar: '#options'}
+                    ]]
+                });
+
+                //监听工具条
+                table.on('tool(dataTable)', function(obj){ //注：tool是工具条事件名，dataTable是table原始容器的属性 lay-filter="对应的值"
+                    var data = obj.data //获得当前行数据
+                        ,layEvent = obj.event; //获得 lay-event 对应的值
+                    if(layEvent === 'del'){
+                        layer.confirm('确认删除吗？', function(index){
+                            $.post("{{ route('admin.gameUrl.destroy') }}",{_method:'delete',ids:[data.gameUrl_id]},function (result) {
+                                if (result.code==0){
+                                    obj.del(); //删除对应行（tr）的DOM结构
+                                }
+                                layer.close(index);
+                                layer.msg(result.msg)
+                            });
+                        });
+                    } else if(layEvent === 'edit'){
+                        location.href = '/admin/gameUrl/'+data.gameUrl_id+'/edit';
+                    }
+                });
+
+                //按钮批量删除
+                $("#listDelete").click(function () {
+                    var ids = []
+                    var hasCheck = table.checkStatus('dataTable')
+                    var hasCheckData = hasCheck.data
+                    if (hasCheckData.length>0){
+                        $.each(hasCheckData,function (index,element) {
+                            ids.push(element.gameUrl_id)
+                        })
+                    }
+                    if (ids.length>0){
+                        layer.confirm('确认删除吗？', function(index){
+                            $.post("{{ route('admin.gameUrl.destroy') }}",{_method:'delete',ids:ids},function (result) {
+                                if (result.code==0){
+                                    dataTable.reload()
+                                }
+                                layer.close(index);
+                                layer.msg(result.msg)
+                            });
+                        })
+                    }else {
+                        layer.msg('请选择删除项')
+                    }
+                })
+                //搜索
+                $("#memberSearch").click(function () {
+                    var gameUrl_name = $("#gameUrl_name").val();
+                    dataTable.reload({
+                        where:{gameUrl_name:gameUrl_name},
+                        page:{curr:1}
+                    })
+                })
+            })
+        </script>
+    @endcan
+@endsection
+
+
+

routes/admin.php

@@ -170,6 +170,23 @@ Route::group(['namespace' => 'Admin', 'prefix' => 'admin', 'middleware' => ['aut
         Route::delete('gmenu/destroy', 'GmenuController@destroy')->name('admin.gmenu.destroy')->middleware('permission:config.gmenu.destroy');
 
 
+    });
+
+    //游戏导航菜单
+    Route::group(['middleware' => 'permission:config.gameUrl'], function () {
+
+        Route::get('gameUrl/data', 'GameUrlController@data')->name('admin.gameUrl.data');
+        Route::get('gameUrl', 'GameUrlController@index')->name('admin.gameUrl');
+        //添加
+        Route::get('gameUrl/create', 'GameUrlController@create')->name('admin.gameUrl.create')->middleware('permission:config.gameUrl.create');
+        Route::post('gameUrl/store', 'GameUrlController@store')->name('admin.gameUrl.store')->middleware('permission:config.gameUrl.create');
+        //编辑
+        Route::get('gameUrl/{id}/edit', 'GameUrlController@edit')->name('admin.gameUrl.edit')->middleware('permission:config.gameUrl.edit');
+        Route::put('gameUrl/update', 'GameUrlController@update')->name('admin.gameUrl.update')->middleware('permission:config.gameUrl.edit');
+        //删除
+        Route::delete('gameUrl/destroy', 'GameUrlController@destroy')->name('admin.gameUrl.destroy')->middleware('permission:config.gameUrl.destroy');
+
+
     });
 
     //广告位

websockServ/app/lib/DB_pool.php

@@ -0,0 +1,177 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/27
+ * Time: 8:56
+ */
+
+namespace app\lib;
+
+
+/**
+ *  swoole 数据库连接池 BY 凌晨
+ * 'worker_num' => 20, //worker进程数量
+ * 'task_worker_num' => 10, //task进程数量 即为维持的MySQL连接的数量
+ * 'daemonize'=> 1,          //设置守护进程
+ * 'max_request' => 10000, //最大请求数,超过了进程重启
+ * 'dispatch_mode' => 2,/
+ */
+class DB_pool
+{    //swoole set params
+    protected $task_worker_num;
+    protected $work_num;
+    protected $max_request;
+    protected $dispatch_mode;
+    protected $daemonize;
+    protected $server_port;
+    protected $log_file;
+    //db params
+    protected $db_type;
+    protected $db_host;
+    protected $db_user;
+    protected $db_pwd;
+    protected $db_name;
+    protected $db_port;
+
+    public function __construct($config = [])
+    {
+        $this->host = $config['poole_host'] ? $config['poole_host'] : "127.0.0.1"; // server监听的端口
+        $this->server_port = $config['poole_port'] ? $config['poole_port'] : 9091;  // server监听的端口
+        $this->worker_num = 5;
+        $this->task_worker_num = 5;
+        $this->dispatch_mode = 2;
+        $this->daemonize = 0;
+        $this->max_request = 10000;
+        $filename = date("Y-m-d", time());
+        $this->log_file = "../logs/mysqlpoole_" . $filename . '.log';
+        $this->serv = new \swoole\server($this->host, $this->server_port);
+        $this->serv->set(array(
+            'worker_num' => $this->worker_num,
+            'task_worker_num' => $this->task_worker_num,
+            'max_request' => $this->max_request,
+            'daemonize' => $this->daemonize,
+            'log_file' => $this->log_file,
+            'dispatch_mode' => $this->dispatch_mode,
+            'package_max_length'=> 4 * 1024 *1024,
+            'buffer_output_size'=> 4 * 1024 *1024,
+            'socket_buffer_size' => 8 * 1024 *1024
+        ));
+
+        $this->db_type = $config['db_type'] ? $config['db_type'] : 'mysql';
+        $this->db_host = $config['db_host'] ? $config['db_host'] : '127.0.0.1';
+        $this->db_port = $config['db_port'] ? $config['db_port'] : 3306;
+        $this->db_name = $config['db_name'] ? $config['db_name'] : 'test';
+        $this->db_user = $config['db_user'] ? $config['db_user'] : 'test';
+        $this->db_pwd = $config['db_pwd'] ? $config['db_pwd'] : 'test';
+    }
+
+    public function run()
+    {
+        $this->serv->on('Receive', array($this, 'onReceive'));
+        // Task 回调的2个必须函数
+        $this->serv->on('Task', array($this, 'onTask'));
+        $this->serv->on('Connect', array($this, 'onConnect'));
+        $this->serv->on('Finish', array($this, 'onFinish'));
+        //$this->serv->on('Error', array($this, 'onError'));
+
+        $this->serv->start();
+    }
+
+    public function onConnect(\swoole\server $server, int $fd, int $reactorId)
+    {
+        //$clientinfo = $server->getClientInfo($fd) ;
+        //$cinfo = $clientinfo['remote_ip'].':'. $clientinfo['remote_port'] ;
+        //echo "有客户接入：reactorId:$reactorId --> fd:$fd  --> $cinfo  \n";
+    }
+
+
+    public function onReceive($serv, $fd, $from_id, $data)
+    {
+        $resultStr = $this->serv->taskwait($data);
+        if ($resultStr !== false) {
+            $this->serv->send($fd, $resultStr );
+            return ;
+            $result = json_decode($resultStr, true);
+            if (isset($result['status']) && $result['status'] == 'success') {
+                $this->serv->send($fd, $resultStr );
+            } else {
+                $this->serv->send($fd, $resultStr);
+            }
+            return;
+        } else {
+            $this->serv->send($fd, json_encode(['status' => 'false', 'data' => "Error. Task timeout"]));
+        }
+    }
+
+    public function onTask($serv, $task_id, $from_id, $sql)
+    {
+        static $link = null;
+        HELL:
+        if ($link == null) {
+            try {
+                $conStr = $this->db_type . ":host=$this->db_host;dbname=$this->db_name;port=$this->db_port";
+                $link = new \PDO($conStr, $this->db_user, $this->db_pwd);
+                $link->exec("set names 'utf8'");
+                echo "新建连接成功：Taskid=$task_id  Fromid=$from_id \n";
+            } catch (\PDOException $e) {
+                $link = null;
+                $this->serv->finish(json_encode(['status' => 'false', 'data' => $e->getMessage()], 256));
+                echo "新建连接失败：Taskid=$task_id  Fromid=$from_id " . $e->getMessage() . "\n";
+                return;
+            }
+        }
+
+        $sql = trim($sql);
+        if (preg_match("/^select/i", $sql)){
+            $result = $link->query($sql);
+        }else{
+            $result = $link->exec($sql);
+        }
+
+        $data = ['status'=>false] ;
+        if (!$result) { //如果查询失败了
+            if (in_array($link->errorCode(), [2013, 2006])) {//错误码为2013，或者2006，则重连数据库，重新执行sql
+                $link = null;
+                goto HELL;
+            } else {
+                $data['status'] = 'false';
+                $data['data'] = $link->errorInfo();
+                $this->serv->finish(json_encode($data, 256));
+                return;
+            }
+        }
+        if (preg_match("/^select/i", $sql)) { //如果是select操作，就返回关联数组
+            $dataRet = $result->fetchAll(\PDO::FETCH_CLASS);
+            $data['data'] = $dataRet ;
+        } else {//否则直接返回结果
+            $data['data'] = $result;
+        }
+        $data['status'] = "success";
+        $this->serv->finish(json_encode($data, 256));
+    }
+
+    public function onFinish($serv, $task_id, $data)
+    {
+        echo "任务完成";//taskwait  不触发这个函数。。
+        return $data;
+    }
+}
+
+/**服务启动
+ * $serv=new DB_pool();
+ * $serv->run();
+ */
+
+/**客户端
+ * $client    = new \swoole_client(SWOOLE_SOCK_TCP);
+ * $num=rand(111111,999999);
+ * $rts=$client->connect('127.0.0.1', 9508, 10) or die("连接失败");//链接mysql客户端
+ * $sql =("select  * from zdk_test");
+ * $client->send($sql);
+ * $resdata = $client->recv();
+ *
+ * $resda=json_decode($resdata,true);
+ * $client->close();
+ * return json_encode($resda);
+ */

websockServ/app/lib/DataPack.php

@@ -0,0 +1,73 @@
+<?php
+
+namespace app\lib;
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/20
+ * Time: 13:33
+ */
+
+//服务端下发数据包标准格式;
+
+class DataPack
+{
+    private static $Datas = [];
+    private static $Instance = null ;
+
+    public function getInstance($cache = true)
+    {
+        if ($cache && self::$Instance) {
+            return self::$Instance;
+        }
+        self::$Instance = new self();
+        return self::$Instance;
+    }
+
+    public static function Create($array)
+    {
+        self::$Datas = $array;
+    }
+
+    public static function toJson($array = [])
+    {
+        if (!empty($array)) {
+            self::Create($array);
+        }
+        $ret = [
+            'id' => self::UUID(),
+            'fr' => isset(self::$Datas['from']) ? self::$Datas['from'] : 0,
+            'to' => isset(self::$Datas['to']) ? self::$Datas['to'] : 0,
+            'ct' => time(),
+            'mt' => isset(self::$Datas['mtype']) ? self::$Datas['mtype'] : '',
+            'st' => isset(self::$Datas['stype']) ? self::$Datas['stype'] : '',
+            'cf' => isset(self::$Datas['confirm']) ? self::$Datas['confirm'] : 0,
+            'data' => isset(self::$Datas['data']) ? self::$Datas['data'] : 0,
+        ];
+        return json_encode($ret, JSON_UNESCAPED_UNICODE);
+    }
+
+    public static function setKey($key, $val)
+    {
+        self::$Datas[$key] = $val;
+    }
+
+    public static function getKey($key, $default = '')
+    {
+        if (isset(self::$Datas[$key])) {
+            return self::$Datas[$key];
+        }
+        return $default;
+    }
+
+    public static function reset()
+    {
+        self::$Datas = [];
+    }
+
+    public static function UUID()
+    {
+        return md5(microtime() . uniqid('pack_') . rand(1, 999999));
+    }
+
+}

websockServ/app/lib/GlobConfigs.php

@@ -0,0 +1,53 @@
+<?php
+namespace  app\lib;
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/20
+ * Time: 9:17
+ */
+
+
+class GlobConfigs {
+    public static $file = '';
+    public static $configs = [] ;
+    public static $isload = false ;
+    private static $instance = null ;
+
+    public static function  getInstance(){
+        if (self::$instance){
+            return self::$instance;
+        }
+        self::$instance = new  GlobConfigs();
+        return   self::$instance ;
+    }
+
+    public static function  getKey($key,$default=''){
+         if (!self::$isload) { self::load();  }
+         if (isset(self::$configs[$key])){
+             return self::$configs[$key];
+         }
+         return $default ;
+    }
+    public static  function  setKey($key,$val){
+        if (!self::$isload) { self::load();  }
+        self::$configs[$key] = $val;
+    }
+
+    public static function getAll(){
+        if (!self::$isload) { self::load();  }
+        return self::$configs ;
+    }
+
+    public static function  load($file=''){
+        if ( self::$isload  ){            return true ;       }
+
+        if (empty($file)){
+            $file =  CONFIG_PATH.DS.'configs.php';
+        }
+        self::$configs = require_once ($file);
+        self::$isload = true ;
+    }
+
+
+}

websockServ/app/lib/Mconsts.php

@@ -0,0 +1,36 @@
+<?php
+//
+defined('DS') or define("DS", DIRECTORY_SEPARATOR);
+defined('BASE_PATH') or define("BASE_PATH", realpath(dirname(dirname(dirname(__FILE__)))));
+defined('APP_PATH') or define("APP_PATH", BASE_PATH . DS . 'app');
+defined('CONFIG_PATH') or define("CONFIG_PATH", BASE_PATH . DS . 'configs');
+defined('LOG_PATH') or define("LOG_PATH", BASE_PATH . DS . 'logs');
+defined('LOGIC_PATH') or define("LOGIC_PATH", APP_PATH . DS . 'logic');
+defined('CMDPRO_PATH') or define("CMDPRO_PATH", LOGIC_PATH . DS . 'cmdpro');
+
+defined('ENV') or define("ENV", 'dev');
+
+//业务相关 redis Keys
+defined('DOWN_MSG') or define("DOWN_MSG", 'DOWN_MSG');                                     //需要下发的消息队列名
+defined('DOWN_MSG_SN') or define("DOWN_MSG_SN", 'DOWN_MSG_SN');                            //需要下发的消息队列名 计数器(1-1000切换)
+defined('DOWN_MSG_SN') or define("DOWN_MSG_WRITEFLAG", 'DOWN_MSG_WRITEFLAG');              //需要下发的写锁
+defined('DOWN_MSG_TMP') or define("DOWN_MSG_TMP", 'DOWN_MSG_TMP_');                        //需要下发的消息队列名 前缀(临时)
+
+defined('RUN_LOGS_OVTIME_KEY') or define("RUN_LOGS_OVTIME_KEY", 'RUN_LOGS_OVTIME_KEY');                //自动过期日志        has
+defined('RUN_LOGS_OVTIME') or define("RUN_LOGS_OVTIME", 180);                                          //自动过期日志超时时间
+defined('RUN_LOGS_QUEUE_KEY') or define("RUN_LOGS_QUEUE_KEY", 'RUN_LOGS_QUEUE_KEY');                   //重要日志，不会过期  队列
+
+defined('MAPS_UID_FID') or define("MAPS_UID_FID", 'MAPS_UID_FID');                         //登陆用户UID-FID MAP  HAS表
+defined('MAPS_FID_UID') or define("MAPS_FID_UID", 'MAPS_FID_UID');                         //登陆用户FID-UID MAP  HAS表
+defined('MAPS_USER_TOKEN') or define("MAPS_USER_TOKEN", 'MAPS_USER_TOKEN');                //登陆用户TOKEN-UID MAP  HAS表
+defined('ON_OPEN') or define("ON_OPEN", 'ON_OPEN');                                         //接入时 HAS表
+
+defined('TIME_RSYNC_KEY') or define("TIME_RSYNC_KEY", 'TIME_RSYNC_KEY');                     //时间同步的写获取者
+
+defined('MSG_REDIS_SUBSCRIBE') or define("MSG_REDIS_SUBSCRIBE", 'MSG_REDIS_SUBSCRIBE');      //redis 消息订阅key
+
+////
+
+
+
+

websockServ/app/lib/Wlog.php

@@ -0,0 +1,130 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/22
+ * Time: 11:07
+ */
+
+namespace app\lib;
+
+use app\lib\GlobConfigs as GlobConfigs;
+use \Swoole\Async ;
+
+class Wlog
+{
+    private static $inCrVel = 0;
+    private static $Instance = null;
+    private $redis = null;
+    private $redis_ctime = 0;
+
+    public static function getInstance($cache = true)
+    {
+        if ($cache && self::$Instance) {
+            return self::$Instance;
+        }
+        self::$Instance = new self();
+        return self::$Instance;
+    }
+
+    public function GetRedis()
+    {
+        $now = time();
+        if ($now - $this->redis_ctime > 60 * 15) {
+            if ($this->redis) {
+                $this->redis->close();
+                $this->redis = false;
+                $this->redis_ctime = 0 ;
+            }
+        }
+
+        if ($this->redis) {
+            return $this->redis;
+        }
+
+        echo "新建一个Wlog->Coroutine_redis ".date("Y-m-d H:i:s")."\n";
+        $config = GlobConfigs::getKey('redis');
+        $redis = new \Swoole\Coroutine\Redis();
+        $ret = $redis->connect($config['host'], $config['port']);
+        if ($ret) {
+            $this->redis = $redis;
+            $this->redis_ctime = time();
+        } else {
+            $this->redis = false;
+        }
+        return $redis;
+    }
+
+    public function WriteLog($msg, $type = 3, $worker_id = 0)
+    {
+        $mself= $this;
+        go(function()use ($msg,$type,$worker_id,$mself){
+            $msg = json_encode([date("Y-m-d H:i:s"), $msg], 256);
+
+            if (in_array($type, [1, 2])) {
+                $redis = $mself->GetRedis();
+                if ($redis) {
+                    if ($type == 1) {
+                        $minit = date("i");
+                        $ktype = RUN_LOGS_OVTIME_KEY . '_' . $minit;
+                        $key = 'Log' . ":" . $worker_id . '_' . $this->IncrKey();
+                        $otime = RUN_LOGS_OVTIME;
+                        $redis->hset($ktype, $key, $msg);
+                        $redis->expire($ktype, $otime);
+                    } else {
+                        $ktype = RUN_LOGS_OVTIME_KEY;
+                        $redis->lpush($ktype, $msg);
+                    }
+                    return true;
+                }
+            }
+
+            //redis 失败时，写到日志文件中
+            $fileName = date("Y-m-d") . '.log';
+            $fullName = LOG_PATH . DS . $fileName;
+            //\swoole_async_writefile($fullName, $msg . "\r\n", null, FILE_APPEND);
+            //\Swoole\Async::writeFile($fullName, $msg . "\r\n", null, FILE_APPEND);
+            file_put_contents($fullName,$msg."\r\n",FILE_APPEND);
+            return true;
+        });
+        /*
+        $msg = json_encode([date("Y-m-d H:i:s"), $msg], 256);
+
+        if (in_array($type, [1, 2])) {
+            $redis = $this->GetRedis();
+            if ($redis) {
+                if ($type == 1) {
+                    $minit = date("i");
+                    $ktype = RUN_LOGS_OVTIME_KEY . '_' . $minit;
+                    $key = $ktype . ":" . $worker_id . '_' . $this->IncrKey();
+                    $otime = RUN_LOGS_OVTIME;
+                    $redis->hset($ktype, $key, $msg);
+                    $redis->expire($ktype, $otime);
+                } else {
+                    $ktype = RUN_LOGS_OVTIME_KEY;
+                    $redis->lpush($ktype, $msg);
+                }
+                return true;
+            }
+        }
+
+        //redis 失败时，写到日志文件中
+        $fileName = date("Y-m-d") . '.log';
+        $fullName = LOG_PATH . DS . $fileName;
+        swoole_async_writefile($fullName, $msg . "\r\n", null, FILE_APPEND);
+
+        return true;
+        */
+    }
+
+    public function IncrKey()
+    {
+        self::$inCrVel++;
+        if (self::$inCrVel >= 99999999) {
+            self::$inCrVel = 1;
+        }
+        return self::$inCrVel;
+    }
+
+
+}

websockServ/app/lib/boot.php

@@ -0,0 +1,23 @@
+<?php
+namespace  app\lib;
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/20
+ * Time: 9:19
+ */
+
+class boot
+{
+    public static  function init(){
+        self::loadConsts();
+
+    }
+
+    public static function  loadConsts(){
+        require_once (realpath(dirname(__FILE__)).DIRECTORY_SEPARATOR.'Mconsts.php');
+    }
+
+
+}
+

websockServ/app/lib/wclient/PacketHandler.php

@@ -0,0 +1,136 @@
+<?php
+namespace  app\lib\wclient;
+/**
+ * Created by PhpStorm.
+ * User: marsnowxiao
+ * Date: 2017/6/15
+ * Time: 下午5:12
+ */
+use app\lib\wclient\WebSocketFrame as WebSocketFrame;
+
+class PacketHandler {
+    const GUID = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11';
+    const TOKEN_LENGHT = 16;
+    const maxPacketSize = 2000000;
+    private $key = "";
+
+    private static function generateToken($length)
+    {
+        $characters = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ!"§$%&/()=[]{}';
+
+        $useChars = array();
+        // select some random chars:
+        for ($i = 0; $i < $length; $i++) {
+            $useChars[] = $characters[mt_rand(0, strlen($characters) - 1)];
+        }
+        // Add numbers
+        array_push($useChars, rand(0, 9), rand(0, 9), rand(0, 9));
+        shuffle($useChars);
+        $randomString = trim(implode('', $useChars));
+        $randomString = substr($randomString, 0, self::TOKEN_LENGHT);
+
+        return base64_encode($randomString);
+    }
+
+    public function buildHandShakeRequest($host, $port)
+    {
+        $this->key = static::generateToken(self::TOKEN_LENGHT);
+
+        return "GET / HTTP/1.1" . "\r\n" .
+            "Origin: null" . "\r\n" .
+            "Host: {$host}:{$port}" . "\r\n" .
+            "Sec-WebSocket-Key: {$this->key}" . "\r\n" .
+            "User-Agent: SwooleWebsocketClient"."/0.1.4" . "\r\n" .
+            "Upgrade: Websocket" . "\r\n" .
+            "Connection: Upgrade" . "\r\n" .
+            "Sec-WebSocket-Protocol: wamp" . "\r\n" .
+            "Sec-WebSocket-Version: 13" . "\r\n" . "\r\n";
+    }
+
+    public function verifyUpgrade($packet)
+    {
+        $headers = explode("\r\n", $packet);
+        unset($headers[0]);
+        $headerInfo = [];
+        foreach ($headers as $header) {
+            $arr = explode(":", $header);
+            if (count($arr) == 2) {
+                list($field, $value) = $arr;
+                $headerInfo[trim($field)] = trim($value);
+            }
+        }
+
+        return (isset($headerInfo['Sec-WebSocket-Accept']) && $headerInfo['Sec-WebSocket-Accept'] == base64_encode(pack('H*', sha1($this->key.self::GUID))));
+    }
+
+    public function processDataFrame(&$packet)
+    {
+        if (strlen($packet) < 2)
+            return null;
+        $header = substr($packet, 0, 2);
+        $index = 0;
+
+        //fin:1 rsv1:1 rsv2:1 rsv3:1 opcode:4
+        $handle = ord($packet[$index]);
+        $finish = ($handle >> 7) & 0x1;
+        $rsv1 = ($handle >> 6) & 0x1;
+        $rsv2 = ($handle >> 5) & 0x1;
+        $rsv3 = ($handle >> 4) & 0x1;
+        $opcode = $handle & 0xf;
+        $index++;
+
+        //mask:1 length:7
+        $handle = ord($packet[$index]);
+        $mask = ($handle >> 7) & 0x1;
+
+        //0-125
+        $length = $handle & 0x7f;
+        $index++;
+        //126 short
+        if ($length == 0x7e)
+        {
+            if (strlen($packet) < $index + 2)
+                return null;
+            //2 byte
+            $handle = unpack('nl', substr($packet, $index, 2));
+            $index += 2;
+            $length = $handle['l'];
+        }
+        //127 int64
+        elseif ($length > 0x7e)
+        {
+            if (strlen($packet) < $index + 8)
+                return null;
+            //8 byte
+            $handle = unpack('Nh/Nl', substr($packet, $index, 8));
+            $index += 8;
+            $length = $handle['l'];
+            if ($length > static::maxPacketSize)
+            {
+                throw new \Exception("frame length is too big.\n");
+            }
+        }
+
+        //mask-key: int32
+        if ($mask)
+        {
+            if (strlen($packet) < $index + 4)
+                return null;
+            $mask = array_map('ord', str_split(substr($packet, $index, 4)));
+            $index += 4;
+        }
+
+        if (strlen($packet) < $index + $length)
+            return null;
+        $data = substr($packet, $index, $length);
+        $index += $length;
+
+        $packet = substr($packet, $index);
+
+        $frame = new WebSocketFrame;
+        $frame->finish = $finish;
+        $frame->opcode = $opcode;
+        $frame->data = $data;
+        return $frame;
+    }
+}

websockServ/app/lib/wclient/WebSocketClient.php

@@ -0,0 +1,160 @@
+<?php
+
+namespace app\lib\wclient;
+
+use app\lib\wclient\PacketHandler as PacketHandler;
+
+
+class WebSocketClient
+{
+    private $client;
+    private $state;
+    private $host;
+    private $port;
+    private $handler;
+    private $buffer;
+    private $openCb;
+    private $messageCb;
+    private $closeCb;
+
+    const HANDSHAKING = 1;
+    const HANDSHAKED = 2;
+
+
+    const WEBSOCKET_OPCODE_CONTINUATION_FRAME = 0x0;
+    const WEBSOCKET_OPCODE_TEXT_FRAME = 0x1;
+    const WEBSOCKET_OPCODE_BINARY_FRAME = 0x2;
+    const WEBSOCKET_OPCODE_CONNECTION_CLOSE = 0x8;
+    const WEBSOCKET_OPCODE_PING = 0x9;
+    const WEBSOCKET_OPCODE_PONG = 0xa;
+
+    const TOKEN_LENGHT = 16;
+
+    public function __construct()
+    {
+        $this->client = new \swoole\client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
+        $this->client->on("connect", [$this, "onConnect"]);
+        $this->client->on("receive", [$this, "onReceive"]);
+        $this->client->on("close", [$this, "onClose"]);
+        $this->client->on("error", [$this, "onError"]);
+        $this->handler = new PacketHandler();
+        $this->buffer = "";
+    }
+
+    public function connect($host, $port)
+    {
+        $this->host = $host;
+        $this->port = $port;
+        $this->client->connect($host, $port);
+    }
+
+    public function sendHandShake()
+    {
+        $this->state = static::HANDSHAKING;
+        $request = $this->handler->buildHandShakeRequest($this->host, $this->port);
+        $this->client->send($request);
+    }
+
+    public function onConnect($cli)
+    {
+        $this->sendHandShake();
+    }
+
+    public function onReceive($cli, $data)
+    {
+        if ($this->state == static::HANDSHAKING) {
+            $this->buffer .= $data;
+            $pos = strpos($this->buffer, "\r\n\r\n", true);
+
+            if ($pos != false) {
+                $header = substr($this->buffer, 0, $pos + 4);
+                $this->buffer = substr($this->buffer, $pos + 4);
+
+                if (true == $this->handler->verifyUpgrade($header)) {
+                    $this->state = static::HANDSHAKED;
+                    if (isset($this->openCb))
+                        call_user_func($this->openCb, $this);
+                } else {
+                    echo "handshake failed\n";
+                }
+            }
+        } else if ($this->state == static::HANDSHAKED) {
+            $this->buffer .= $data;
+        }
+        if ($this->state == static::HANDSHAKED) {
+            try {
+                $frame = $this->handler->processDataFrame($this->buffer);
+            } catch (\Exception $e) {
+                $cli->close();
+                return;
+            }
+            if ($frame != null) {
+                if (isset($this->messageCb))
+                    call_user_func($this->messageCb, $this, $frame);
+            }
+        }
+
+    }
+
+    public function onClose($cli)
+    {
+        if (isset($this->closeCb))
+            call_user_func($this->closeCb, $this);
+    }
+
+    public function onError($cli)
+    {
+        echo "error occurred\n";
+    }
+
+    public function on($event, $callback)
+    {
+        if (strcasecmp($event, "open") === 0) {
+            $this->openCb = $callback;
+        } else if (strcasecmp($event, "message") === 0) {
+            $this->messageCb = $callback;
+        } else if (strcasecmp($event, "close") === 0) {
+            $this->closeCb = $callback;
+        } else {
+            echo "$event is not supported\n";
+        }
+    }
+
+    public function send($data, $type = 'text')
+    {
+        switch ($type) {
+            case 'text':
+                $_type = self::WEBSOCKET_OPCODE_TEXT_FRAME;
+                break;
+            case 'binary':
+            case 'bin':
+                $_type = self::WEBSOCKET_OPCODE_BINARY_FRAME;
+                break;
+            case 'ping':
+                $_type = self::WEBSOCKET_OPCODE_PING;
+                break;
+            case 'close':
+                $_type = self::WEBSOCKET_OPCODE_CONNECTION_CLOSE;
+                break;
+
+            case 'ping':
+                $_type = self::WEBSOCKET_OPCODE_PING;
+                break;
+
+            case 'pong':
+                $_type = self::WEBSOCKET_OPCODE_PONG;
+                break;
+
+            default:
+                echo "$type is not supported\n";
+                return;
+        }
+        $data = \swoole_websocket_server::pack($data, $_type);
+        $this->client->send($data);
+    }
+
+    public function getTcpClient()
+    {
+        return $this->client;
+    }
+}

websockServ/app/lib/wclient/WebSocketFrame.php

@@ -0,0 +1,17 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/24
+ * Time: 11:26
+ */
+
+namespace app\lib\wclient;
+
+
+class WebSocketFrame
+{
+    public $finish;
+    public $opcode;
+    public $data;
+}

websockServ/app/logic/CmdProxy.php

@@ -0,0 +1,95 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/21
+ * Time: 16:03
+ */
+
+namespace app\logic;
+
+///composer update或者composer install或者composer dump-autoload.
+///
+
+use app\lib\DataPack;
+
+use  app\logic\cmdpro\CmdTest as CmdTest;
+use  app\logic\cmdpro\CmdQuery as CmdQuery;
+use  app\logic\cmdpro\CmdLogin as CmdLogin;
+
+class CmdProxy
+{
+    private static $Instance = null;
+
+    public static function getInstance($cache = true)
+    {
+        if ($cache && self::$Instance) {
+            return self::$Instance;
+        }
+        self::$Instance = new self();
+        return self::$Instance;
+    }
+
+    public function ParaCMD($serv, \Swoole\Server\Task $task)
+    {
+
+        $fd = $task->data->fd;
+        $dataPack = json_decode(trim($task->data->data),true);
+        $cmd = isset($dataPack['cmd']) ? $dataPack['cmd'] : '';
+        $cmdcls = $this->getParaCmd($cmd);
+
+        if (!$cmdcls) {
+            $serv->push($fd, DataPack::toJson(['mt' => 'errorMsg', 'data' => 'error cmd!']));
+            $serv->disconnect($fd);
+            return;
+        }
+        $cmdObj = $this->getClsObj($cmdcls);
+        try{
+            $cmdObj->paraCmd($serv, $task);
+        }catch (\Exception $e){
+
+        }
+        unset($cmdObj) ;
+    }
+
+    public function  getClsObj($cmd)
+    {
+        $obj = null ;
+        switch ($cmd){
+            case "CmdTest":
+                $obj = new CmdTest();
+                break ;
+            case "CmdQuery":
+                $obj = new CmdQuery();
+                break;
+            case "CmdLogin":
+                $obj = new CmdLogin();
+                break;
+            default:
+                break;
+        }
+        return $obj ;
+    }
+
+
+    public function allCmdMaps()
+    {
+        $arrs = [
+            'login' => 'CmdLogin',
+            'query' => 'CmdQuery',
+            'test' => 'CmdTest',
+        ];
+        return $arrs;
+    }
+
+    public function getParaCmd($cmd)
+    {
+        $arr = $this->allCmdMaps();
+        if (isset($arr[$cmd])) {
+           return $arr[$cmd];
+        }
+       return false;
+    }
+
+
+}

websockServ/app/logic/MsgRedisSend.php

@@ -0,0 +1,16 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/22
+ * Time: 11:51
+ */
+
+namespace app\logic;
+
+
+//把redis里要下发的数据下发给客户,只发在线用户，不在线不处理，也不写日志
+class MsgRedisSend
+{
+
+}

websockServ/app/logic/MyPgsql.php

@@ -0,0 +1,49 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/24
+ * Time: 17:40
+ */
+
+namespace app\logic;
+
+use  app\pplus\Instance;
+use Illuminate\Database\Capsule\Manager as Capsule;
+use app\lib\GlobConfigs;
+
+class MyPgsql
+{
+    use Instance;
+    private $pgsql = null;
+    private $ctime = 0;
+
+    public function getDb()
+    {
+        if ((time() - $this->ctime) <= 60 * 5) {
+            if ($this->pgsql) {
+                return $this->pgsql;
+            }
+        }
+
+        if ($this->pgsql) {
+            return $this->pgsql;
+        }
+        return $this->Init();
+    }
+
+    public function Init()
+    {
+        echo "MyPgsql--Init" . "\n";
+        $conf = GlobConfigs::getKey('pgsql');
+        $pgsql = new Capsule();
+        $pgsql->addConnection($conf);
+        $pgsql->setAsGlobal();
+        $pgsql->bootEloquent();
+        $this->pgsql = $pgsql;
+        $this->ctime = time();
+        return $pgsql;
+    }
+
+
+}

websockServ/app/logic/MyServerV2.php

@@ -0,0 +1,334 @@
+<?php
+
+namespace app\logic;
+
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/20
+ * Time: 11:22
+ */
+
+use app\lib\GlobConfigs;
+use Illuminate\Database\Capsule\Manager as Capsule;
+use Illuminate\Database\Capsule\Manager as DB;
+use  app\lib\Wlog;
+use app\logic\MyPgsql as MyPgsql;
+
+class MyServerV2
+{
+    public $serv;
+
+    //线程连接实例
+    private $workRedis = null;
+    private $workMysql = null;
+    private $workPgsql = null ;
+
+    public function __construct()
+    {
+        $this->serv = new \swoole_websocket_server("0.0.0.0", 9090);
+        $this->serv->set(GlobConfigs::getKey('swoolev2'));
+
+        $this->serv->on('Start', array($this, 'onStart'));
+        $this->serv->on('WorkerStart', array($this, 'onWorkerStart'));
+        $this->serv->on('message', array($this, 'onMessage'));
+        $this->serv->on('close', array($this, 'onClose'));
+        $this->serv->on('open', array($this, 'onOpen'));
+        $this->serv->on('task', array($this, 'onTask'));
+        $this->serv->on('Finish', array($this, 'onFinish'));
+
+        return $this->serv->start();
+    }
+
+    public function onStart($serv)
+    {
+        echo "Main on Start " . "\n";
+        $this->startInit();
+    }
+
+    public function onWorkerStart($serv, $worker_id)
+    {
+        $type = $serv->taskworker ? 'Task' : 'Work';
+        echo "onWorkerStart.. " . $type . '-' . $worker_id . "\n";
+
+        if (!$serv->taskworker) {
+            $this->PingRedis($serv, $worker_id);
+            $serv->tick(8000, function () use ($serv, $worker_id) {
+                $this->PingRedis($serv, $worker_id);
+            });
+
+            /*
+            $this->PingMysql($serv, $worker_id);
+            $serv->tick(5000, function () use ($serv, $worker_id) {
+                $this->PingMysql($serv, $worker_id);
+            });
+            */
+            $this->PingPgsql($serv, $worker_id);
+            $serv->tick(5000, function () use ($serv, $worker_id) {
+                $this->PingPgsql($serv, $worker_id);
+            });
+
+
+            $nowRedis = $this->workRedis;
+            TimeRsync::getInstance()->DoTimePublic($serv, $worker_id, $this->workRedis);
+            $serv->tick(60000, function () use ($serv, $worker_id, $nowRedis) {
+                TimeRsync::getInstance()->DoTimePublic($serv, $worker_id, $this->workRedis);
+            });
+
+            MyPgsql::getInstance();
+
+            //消息订阅
+            if ($worker_id == 0){
+
+                if ( !$worker_id ){      return ;   }
+
+                go(function() use ($serv,$worker_id){
+                    $config = GlobConfigs::getKey('redis');
+                    $redis = new \Swoole\Coroutine\Redis();
+                    $redis->setOptions(['compatibility_mode' => true]);
+                    $redis->connect($config['host'], $config['port']);
+                    $r = $redis->SUBSCRIBE([MSG_REDIS_SUBSCRIBE,'TEST']);
+                    if ($r){
+                        while ($msg = $redis->recv()) {
+                            print_r($msg);
+                            // msg是一个数组, 包含以下信息
+                            // $type # 返回值的类型：显示订阅成功
+                            // $name # 订阅的频道名字 或 来源频道名字
+                            // $info  # 目前已订阅的频道数量 或 信息内容
+                            list($type, $name, $info) = $msg;
+                            if ($type == 'subscribe') // 或psubscribe
+                            {
+                                // 频道订阅成功消息，订阅几个频道就有几条
+                            }
+                            else if ($type == 'unsubscribe' && $info == 0) // 或punsubscribe
+                            {
+                                break; // 收到取消订阅消息，并且剩余订阅的频道数为0，不再接收，结束循环
+                            }
+                            else if ($type == 'message') // 若为psubscribe，此处为pmessage
+                            {
+                                /*
+                                if ($need_unsubscribe) // 某个情况下需要退订
+                                {
+                                    $redis->unsubscribe(); // 继续recv等待退订完成
+                                }
+                                */
+                            }
+                        }
+
+
+                    }
+                });
+            }
+        }
+    }
+
+    function onWorkerStop(swoole_server $server, int $worker_id)
+    {
+        echo "onWorkerStop.. " . $worker_id . ' ' . "\n";
+        if ($this->workRedis) {
+            $this->workRedis->close();
+        }
+        if ($this->workMysql) {
+            $this->workMysql->close();
+        }
+    }
+
+
+    public function onMessage($serv, $frame)
+    {
+        Wlog::getInstance()->WriteLog($frame);
+        $serv->task($frame);
+    }
+
+    public function onOpen($serv, $request)
+    {
+
+        $token = isset($request->get['token']) ? $request->get['token'] : '';
+        $uid = isset($request->get['uid']) ? $request->get['uid'] : '';
+        $fd = $request->fd;
+        $redis = $this->workRedis;
+        if (!$redis) {
+            return;
+        }
+
+        $redis->hset(ON_OPEN, $fd, json_encode(['fd' => $fd, 'token' => $token, 'uid' => $uid], JSON_UNESCAPED_UNICODE));
+        $str = '你好 !  fd=' . $fd . ' ,ip=' . $request->server['remote_addr'] . ' ,port=' . $request->server['remote_port'] . ' ,time=' . date('Y-m-d H:i:s');
+
+        echo $str ."\n" ;
+
+        $serv->push($fd, $str);
+
+        /*
+        $serv->after(120000,function() use($serv,$fd,$redis){
+            if ($serv->exist($fd)){
+                $serv->disconnect($fd,1000,json_encode('未验证用户关闭',JSON_UNESCAPED_UNICODE));
+                $redis->hdel('onOpen',$fd);
+            }
+        });
+        */
+    }
+
+    public function onTask($serv, \Swoole\Server\Task $task)
+    {
+        try {
+            Wlog::getInstance()->WriteLog($task, 1, $serv->worker_id);
+            CmdProxy::getInstance()->ParaCMD($serv, $task);
+        } catch (\Exception $e) {
+            echo "发生异常." . $e->getCode() . ' ' . $e->getMessage() . "\n";
+        }
+    }
+
+    public function onFinish($serv, $task_id, $data)
+    {
+    }
+
+    public function onClose($serv, $fd, $from_id)
+    {
+        $this->workRedis->hdel(ON_OPEN, $fd);
+        echo "Client {$fd} close connection!\n";
+    }
+
+
+    //redis Ping检测
+    private function PingRedis($serv, $worker_id)
+    {
+        if (empty($this->workRedis)) {
+            $this->ConectToRedis($serv, $worker_id);
+            return true;
+        }
+        $redis = $this->workRedis;
+        if (!$redis) {
+            $ping_ret = false;
+        } else {
+            $ping_ret_s = $redis->ping();
+            $ping_ret = "+pong" === strtolower($ping_ret_s) ? true : false;
+        }
+
+        if (!$ping_ret) {
+            return $this->ConectToRedis($serv, $worker_id);
+        }
+        return true;
+    }
+
+    //工作线程 同步阻塞 redis客户端
+    private function ConectToRedis($serv, $worker_id)
+    {
+        $conf = GlobConfigs::getKey('redis');
+        $redis = new \Redis();
+        try {
+            $ret = $redis->connect($conf['host'], $conf['port'], $conf['overtime']);
+        } catch (\Exception $e) {
+            $ret = false;
+        }
+
+        if ($ret) {
+            Wlog::getInstance()->WriteLog("success:成功建立redis连接 " . date("Y-m-d H:i:s") . ' ' . $worker_id);
+            $this->workRedis = $redis;
+            return $redis;
+        } else {
+            Wlog::getInstance()->WriteLog("error:建立redis连接 " . date("Y-m-d H:i:s") . ' ' . $worker_id);
+            $this->workRedis = null;
+        }
+        return false;
+    }
+
+    //Mysql Ping检测
+    private function PingMysql($serv, $worker_id)
+    {
+        if (empty($this->workMysql)) {
+            $this->ConectToMysql($serv, $worker_id);
+            return true;
+        }
+        $mysql = $this->workMysql;
+        if (!$mysql) {
+            $ping_ret = false;
+        } else {
+            $ping_ret_s = DB::select("select version() as v");
+            $ping_ret = !empty($ping_ret_s) ? true : false;
+        }
+
+        if (!$ping_ret) {
+            return $this->ConectToMysql($serv, $worker_id);
+        }
+        return true;
+    }
+
+    //工作线程 同步阻塞 Mysql 客户端
+    private function ConectToMysql($serv, $worker_id)
+    {
+        $conf = GlobConfigs::getKey('mysql');
+        $mysql = new Capsule();
+        $mysql->addConnection($conf);
+        $mysql->setAsGlobal();
+        $mysql->bootEloquent();
+
+        Wlog::getInstance()->WriteLog("success:成功建立Mysql连接 " . date("Y-m-d H:i:s") . ' ' . $worker_id);
+        $this->workMysql = $mysql;
+        return $mysql;
+
+    }
+
+
+
+    //Mysql Ping检测
+    private function PingPgsql($serv, $worker_id)
+    {
+        if (empty($this->workPgsql)) {
+            $this->ConectToPgsql($serv, $worker_id);
+            return true;
+        }
+        $pgsql = $this->workPgsql;
+        if (!$pgsql) {
+            $ping_ret = false;
+        } else {
+            $ping_ret_s = DB::select("select version() as v");
+            $ping_ret = !empty($ping_ret_s) ? true : false;
+        }
+
+        if (!$ping_ret) {
+            return $this->ConectToPgsql($serv, $worker_id);
+        }
+        return true;
+    }
+
+    //工作线程 同步阻塞 Mysql 客户端
+    private function ConectToPgsql($serv, $worker_id)
+    {
+        $conf = GlobConfigs::getKey('pgsql');
+        $pgsql = new Capsule();
+        $pgsql->addConnection($conf);
+        $pgsql->setAsGlobal();
+        $pgsql->bootEloquent();
+
+        Wlog::getInstance()->WriteLog("success:成功建立Pgsql连接 " . date("Y-m-d H:i:s") . ' ' . $worker_id);
+        $this->workPgsql = $pgsql;
+        return $pgsql;
+
+    }
+
+
+    //服务启动作做一些初始化操作
+    private function startInit()
+    {
+        $conf = GlobConfigs::getKey('redis');
+        $redis = new \Redis();
+        $ret = $redis->connect($conf['host'], $conf['port'], $conf['overtime']);
+        if ($ret) {
+            $redis->pipeline();
+            $redis->del(MAPS_UID_FID);
+            $redis->del(MAPS_FID_UID);
+            $redis->del(MAPS_USER_TOKEN);
+            $redis->del(ON_OPEN);
+            $redis->exec();
+            $redis->close();
+        }
+    }
+
+    //redis推送消息
+    private function MsgRedisList($serv, $worker_id)
+    {
+
+    }
+
+
+}

websockServ/app/logic/Mypack.php

@@ -0,0 +1,29 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/22
+ * Time: 17:05
+ */
+
+namespace app\logic;
+
+use app\pplus\Instance;
+class Mypack
+{
+    use Instance ;
+
+    public $fd;
+    public $data;
+    public $opcode=1;
+    public $finish=1;
+
+    public function  makeData($data,$fd=0,$opcode=1,$finish=1){
+        $this->fd= $fd;
+        $this->data = $data;
+        $this->opcode = $opcode;
+        $this->finish = $finish ;
+        return  $this;
+    }
+
+}

websockServ/app/logic/TimeRsync.php

@@ -0,0 +1,40 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/22
+ * Time: 15:20
+ */
+
+namespace app\logic;
+
+
+use app\pplus\Instance;
+use app\lib\GlobConfigs;
+use app\logic\Mypack;
+
+class TimeRsync
+{
+    use  Instance;
+
+    public function DoTimePublic($serv, $worker_id, $redis)
+    {
+        $key = TIME_RSYNC_KEY;
+        $val = intval($redis->get($key));
+        //有其它进程正在操作，不用重复
+        if (!empty($val)) {   return;     }
+
+        $selfval = $worker_id + 1;
+        $redis->SETEX($key, 55 , $selfval);
+        $newvel = $redis->get($key);
+        if ($selfval != intval($newvel)){   return;   }
+
+        $time = time();
+        $data = json_encode(['cmd'=>'test','act'=>'timeRsync','data'=>['t'=>$time,'s'=>date('Y-m-d H:i:s',$time)]]);
+        $serv->task(Mypack::getInstance()->makeData($data));
+        return ;
+
+    }
+
+
+}

websockServ/app/logic/cmdpro/CmdInf.php

@@ -0,0 +1,75 @@
+<?php
+namespace  app\logic\cmdpro;
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/21
+ * Time: 16:48
+ */
+
+/*
+ Swoole\Server\Task Object
+(
+    [data] => Swoole\WebSocket\Frame Object
+        (
+            [fd] => 1
+            [data] => {'cmd':'xxx','act'=>'xxx','data':'xxxx','time':xxxx,'token':xxx}
+            [opcode] => 1
+            [finish] => 1
+        )
+
+    [id] => 0
+    [worker_id] => 2
+    [flags] => 6
+)
+
+data:
+{'cmd':'xxx','act'=>'xxx','data':'xxxx','time':xxxx,'token':xxx}
+ **/
+
+use app\lib\DataPack;
+use app\lib\Wlog;
+
+class   CmdInf
+{
+    public function paraCmd($serv, \Swoole\Server\Task $task){
+        $fd = $task->data->fd;
+        $dataPack = json_decode($task->data->data, true);
+        $method = isset($dataPack['act']) ? $dataPack['act'] : '';
+
+        if (empty($method) || !(method_exists($this, $method))) {
+            $this->sendTo($serv, $fd, DataPack::toJson(['mtype' => 'error', 'data' => '无效的参数']), true);
+            return;
+        }
+
+        try{
+            return $this->$method($serv,$task);
+        }catch (\Exception $e){
+            echo "发生异常或错误：".$e->getFile().' '.$e->getLine().' '.$e->getCode().' '.$e->getMessage()."\r\n";
+            return ;
+        }
+
+    }
+
+    //单发
+    public function sendTo($serv,$fd,$dataString,$close=false)
+    {
+        $serv->push($fd,$dataString);
+        if ($close){
+            $serv->disconnect($fd);
+        }
+        return true;
+    }
+
+    //在线广播
+    public function onlineBroad($serv,$dataString){
+        foreach($serv->connections as $fd)
+        {
+            $serv->push($fd,$dataString);
+        }
+    }
+
+
+
+
+}

websockServ/app/logic/cmdpro/CmdLogin.php

@@ -0,0 +1,21 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/21
+ * Time: 16:57
+ */
+namespace app\logic\cmdpro;
+
+use app\logic\cmdpro\CmdInf as CmdInf;
+
+class CmdLogin  extends CmdInf
+{
+    public function   paraCmd($serv, \Swoole\Server\Task $task){
+
+    }
+
+
+
+
+}

websockServ/app/logic/cmdpro/CmdQuery.php

@@ -0,0 +1,19 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/21
+ * Time: 16:57
+ */
+
+namespace app\logic\cmdpro;
+
+use app\logic\cmdpro\CmdInf as CmdInf;
+
+class CmdQuery  extends CmdInf
+{
+    public function paraCmd($serv, \Swoole\Server\Task $task){
+
+
+    }
+}

websockServ/app/logic/cmdpro/CmdTest.php

@@ -0,0 +1,161 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/21
+ * Time: 16:57
+ */
+
+namespace app\logic\cmdpro;
+
+use app\lib\DataPack;
+use app\lib\GlobConfigs;
+use app\logic\cmdpro\CmdInf as CmdInf;
+
+
+use app\logic\MyPgsql as MyPgsql;
+
+use swoole ;
+
+class CmdTest extends CmdInf
+{
+
+    //异步回调实现 mysql
+    public function sqlold($serv, $task)
+    {
+        $db = new \swoole_mysql();
+        $config = GlobConfigs::getKey('mysql');
+        $db->connect($config, function (\swoole_mysql $db, $r) use ($serv, $task) {
+            if ($r === false) {
+                $serv->push($task->data->fd, json_encode(['data' => $task->data, 'err' => [$db->connect_errno, $db->connect_error], 'fd' => $task->data->fd], 256));
+                return false;
+            }
+            $packdata = json_decode($task->data->data, true);
+            $sql = 'select *  from bm_admin where admin_id=' . intval($packdata['data']);
+            $db->query($sql, function (\swoole_mysql $db, $r2) use ($serv, $task) {
+                if ($r2) {
+                    $serv->push($task->data->fd, json_encode(['record' => $r2, 'fd' => $task->data->fd], 256));
+                }
+                $db->close();
+            });
+        });
+    }
+
+    //协程实现mysql
+    public function mysqlgo($serv, $task)
+    {
+        $swoole_mysql = new \Swoole\Coroutine\MySQL();
+        $config = GlobConfigs::getKey('mysql');
+        $swoole_mysql->connect($config);
+
+        $Pack = json_decode($task->data->data, true);
+        $DataArr = $Pack['data'];
+        $table = isset($DataArr['table']) ? $DataArr['table'] : '';
+        $field = isset($DataArr['field']) ? $DataArr['field'] : '';
+        $value = isset($DataArr['value']) ? $DataArr['value'] : '';
+        if (empty($task) || empty($field)) {
+            return;
+        }
+
+        try {
+            $ret = $swoole_mysql->query("select  *  from   $table where  $field='$value' ");
+            if ($ret) {
+                $this->sendTo($serv, $task->data->fd, DataPack::toJson(['data' => $ret]));
+            }
+        } catch (\Exception $e) {
+            echo "Exception:" . $e->getCode() . ' - ' . $e->getMessage();
+        }
+        $swoole_mysql->close();
+    }
+
+
+    //协程redis
+    public function redis($serv, $task)
+    {
+        $config = GlobConfigs::getKey('redis');
+        go(function () use ($serv, $task, $config) {
+            $redis = new \Swoole\Coroutine\Redis();
+            $redis->connect($config['host'], $config['port']);
+            $redis->set('test', date('Y-m-d H:i:s'));
+            $val = $redis->get('test');
+            $this->sendTo($serv, $task->data->fd, DataPack::toJson(['data' => $val]));
+        });
+    }
+
+    public function broad($serv, $task)
+    {
+        $pack = json_decode($task->data->data, true);
+        $msg = $pack['data'];
+        $this->onlineBroad($serv, $msg . ' ' . $this->dotest());
+    }
+
+    public function dotick($serv, $task)
+    {
+        $pack = json_decode($task->data->data, true);
+        $data = $pack['data'];
+        $fid = isset($data['fid']) ? intval($data['fid']) : 0;
+        $msg = isset($data['msg']) ? $data['msg'] : '';
+        if (!$serv->exist($fid)) {
+            $this->sendTo($serv, $task->data->fd, '此用户不在线!' . $fid);
+            return;
+        }
+        if ($fid == $task->data->fd) {
+            $this->sendTo($serv, $task->data->fd, '自己不能踢自己!');
+            return;
+        }
+        $this->sendTo($serv, $fid, $msg);
+        $serv->disconnect($fid);
+        return;
+    }
+
+
+    //时间同步用
+    public function timeRsync($serv,$task){
+        $dataArr = json_decode($task->data->data,true);
+        $msg = DataPack::toJson(['mtype'=>'system','stype'=>'TimeSync','data'=>$dataArr['data']]);
+        $this->onlineBroad($serv,$msg);
+        return ;
+    }
+
+
+    public function pgsql($serv,$task){
+        $dataArr = json_decode($task->data->data,true);
+        $config = GlobConfigs::getKey('pgsql');
+        go(function () use ($serv, $task, $config,$dataArr) {
+            $conf = $config ;
+            $mysql = new Capsule();
+            $mysql->addConnection($conf);
+            $mysql->setAsGlobal();
+            $mysql->bootEloquent();
+
+            $ret = DB::table('account')->where('id',83859)->first();
+            $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype'=>'system','data'=>$ret]));
+
+        });
+
+    }
+
+
+    public function pgsqlquery($serv,$task){
+        $dataArr = json_decode($task->data->data,true);
+        $ret = MyPgsql::getInstance()->getDb()->table('members')->where('id',intval($dataArr['data']))->first();
+        $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype'=>'system','data'=>$ret]));
+    }
+
+    public function pgsqlexec($serv,$task){
+        $dataArr = json_decode($task->data->data,true);
+        $ret = MyPgsql::getInstance()->getDb()->table('members')->where('id',57)->update(['name'=>'12-'.$dataArr['data']]);
+        $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype'=>'system','data'=>$ret]));
+    }
+
+
+    private function dotest()
+    {
+        return " hellow,baby,at " . date("Y-m-d H:i:s");
+    }
+
+
+
+
+
+}

websockServ/app/pplus/Instance.php

@@ -0,0 +1,26 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/22
+ * Time: 15:24
+ */
+
+namespace app\pplus;
+
+
+trait  Instance
+{
+    private static $Instance = null;
+
+    public static function getInstance($cache = true)
+    {
+        if ($cache && self::$Instance) {
+            return self::$Instance;
+        }
+        self::$Instance = new self();
+        return self::$Instance;
+    }
+
+
+}

websockServ/commands/clientws1.php

@@ -0,0 +1,42 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/23
+ * Time: 17:42
+ */
+
+define('START_TIME', microtime(true));
+require __DIR__ . '/../vendor/autoload.php';
+\app\lib\boot::init();
+
+use  app\lib\wclient\WebSocketClient ;
+
+
+$client = new WebSocketClient();
+
+$client->on("open",function ($client) {
+    $fd = $client->getTcpClient()->sock;
+    echo "fd: $fd is open\n";
+    $msg = '{"cmd":"test","act":"broad","data":"你好,朋友们!","time":1558492565,"token":"aasasfa"}';
+    $client->send($msg);
+});
+
+$client->on("message", function ($client, $frame) {
+    $fd = $client->getTcpClient()->sock;
+    echo "fd: $fd received: {$frame->data}\n";
+});
+
+
+$client->on("close", function ($client) {
+    $fd = $client->getTcpClient()->sock;
+    echo "fd: $fd is closed\n";
+});
+
+$client->connect("192.168.2.200", 9090);
+
+
+
+
+
+

websockServ/commands/clientws2.php

@@ -0,0 +1,45 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/23
+ * Time: 17:42
+ */
+
+
+define('START_TIME', microtime(true));
+require __DIR__.'/../vendor/autoload.php';
+\app\lib\boot::init();
+
+
+
+use WebSocket\Client as Client;
+
+$client = new Client("ws://192.168.2.200:9090");
+
+
+$str = '{"cmd":"test","act":"broad","data":"你好,朋友们!","time":1558492565,"token":"aasasfa"}';
+
+$r = $client->send($str);
+$msg = $client->receive();
+echo "Recive: ".$msg."\n\n\n";
+$msg = $client->receive();
+echo "Recive: ".$msg."\n\n\n";
+sleep(1);
+
+$r = $client->send($str);
+$msg = $client->receive();
+echo "Recive: ".$msg."\n\n\n";
+sleep(1);
+
+$r = $client->send($str);
+$msg = $client->receive();
+echo "Recive: ".$msg."\n\n\n";
+
+
+$client->close();
+
+
+
+
+

websockServ/commands/mysql_poole_client_test.php

@@ -0,0 +1,63 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/27
+ * Time: 9:28
+ */
+
+define('START_TIME', microtime(true));
+require __DIR__.'/../vendor/autoload.php';
+\app\lib\boot::init();
+
+
+
+$config  = \app\lib\GlobConfigs::getKey('pgsqlpoole');
+
+$client    = new swoole_client(SWOOLE_SOCK_TCP);
+$client->set(array(
+    'socket_buffer_size'     => 1024*1024*8, //2M缓存区
+));
+$rts= $client->connect('192.168.2.200', $config['poole_port'], 10) or die("连接失败");//链接mysql客户端
+
+
+
+$sql =("select  * from members where id=57");
+$client->send($sql);
+$resdata = $client->recv();
+print_r(json_decode($resdata,true)) ;
+
+
+$sql ="update  members  set  name='12-".rand(100,500)."'  where id=57";
+$client->send($sql);
+$resdata = $client->recv();
+print_r(json_decode($resdata,true)) ;
+
+$sql ="select  * from \"districts\" where id=1";
+$client->send($sql);
+$resdata = $client->recv();
+print_r(json_decode($resdata,true)) ;
+
+
+/*
+$sql ="select  * from \"districts\" where id>=1 and id<=300" ;
+$client->send($sql);
+$resdata = $client->recv();
+print_r(json_decode($resdata,true)) ;
+*/
+
+
+
+
+
+$client->close();
+
+
+
+
+/*
+echo "收到： ".$resdata."\n" ;
+$resda=json_decode($resdata,true);
+$client->close();
+return json_encode($resda);
+*/

websockServ/commands/mysql_poole_server.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/27
+ * Time: 9:16
+ */
+
+define('START_TIME', microtime(true));
+require __DIR__.'/../vendor/autoload.php';
+\app\lib\boot::init();
+
+$config  = \app\lib\GlobConfigs::getKey('pgsqlpoole');
+$ser = new app\lib\DB_pool($config);
+$ser->run();

websockServ/commands/test1.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/20
+ * Time: 9:36
+ */
+
+define('START_TIME', microtime(true));
+require __DIR__.'/../vendor/autoload.php';
+\app\lib\boot::init();
+
+$ser = new app\logic\MyServer();
+//$ser->start();
+

websockServ/commands/test2.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/20
+ * Time: 9:36
+ */
+
+define('START_TIME', microtime(true));
+require __DIR__.'/../vendor/autoload.php';
+\app\lib\boot::init();
+
+$ser = new app\logic\MyServerV2();
+//$ser->start();
+

websockServ/composer.json

@@ -0,0 +1,28 @@
+{
+    "name": "swoole/servers",
+    "description": "swoole user ORM",
+    "keywords": ["swole", "ROM"],
+    "license": "MIT",
+    "type": "project",
+    "require": {
+        "php": ">=7.0.0",
+        "illuminate/database": "*",
+        "textalk/websocket":"1.2.*"
+    },
+    "autoload": {
+        "classmap": [
+            "app/lib",
+            "app/logic",
+            "app/logic/cmdpro"
+        ],
+        "psr-4": {
+            "app\\": "app/"
+        }
+    },
+    "repositories": {
+        "packagist": {
+            "type": "composer",
+            "url": "https://packagist.laravel-china.org"
+        }
+    }
+}

websockServ/composer.lock

@@ -0,0 +1,770 @@
+{
+    "_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": "a7bc80d4b7f1c019b3006b02e3589bc3",
+    "packages": [
+        {
+            "name": "doctrine/inflector",
+            "version": "v1.3.0",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/doctrine/inflector.git",
+                "reference": "5527a48b7313d15261292c149e55e26eae771b0a"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/doctrine/inflector/zipball/5527a48b7313d15261292c149e55e26eae771b0a",
+                "reference": "5527a48b7313d15261292c149e55e26eae771b0a",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "php": "^7.1"
+            },
+            "require-dev": {
+                "phpunit/phpunit": "^6.2"
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "1.3.x-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Doctrine\\Common\\Inflector\\": "lib/Doctrine/Common/Inflector"
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Roman Borschel",
+                    "email": "roman@code-factory.org"
+                },
+                {
+                    "name": "Benjamin Eberlei",
+                    "email": "kontakt@beberlei.de"
+                },
+                {
+                    "name": "Guilherme Blanco",
+                    "email": "guilhermeblanco@gmail.com"
+                },
+                {
+                    "name": "Jonathan Wage",
+                    "email": "jonwage@gmail.com"
+                },
+                {
+                    "name": "Johannes Schmitt",
+                    "email": "schmittjoh@gmail.com"
+                }
+            ],
+            "description": "Common String Manipulations with regard to casing and singular/plural rules.",
+            "homepage": "http://www.doctrine-project.org",
+            "keywords": [
+                "inflection",
+                "pluralize",
+                "singularize",
+                "string"
+            ],
+            "time": "2018-01-09T20:05:19+00:00"
+        },
+        {
+            "name": "illuminate/container",
+            "version": "v5.8.18",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/illuminate/container.git",
+                "reference": "9405989993a48c2cd50ad1e5b2b08a33383c3807"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/illuminate/container/zipball/9405989993a48c2cd50ad1e5b2b08a33383c3807",
+                "reference": "9405989993a48c2cd50ad1e5b2b08a33383c3807",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "illuminate/contracts": "5.8.*",
+                "illuminate/support": "5.8.*",
+                "php": "^7.1.3",
+                "psr/container": "^1.0"
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "5.8-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Illuminate\\Container\\": ""
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Taylor Otwell",
+                    "email": "taylor@laravel.com"
+                }
+            ],
+            "description": "The Illuminate Container package.",
+            "homepage": "https://laravel.com",
+            "time": "2019-04-22T13:12:35+00:00"
+        },
+        {
+            "name": "illuminate/contracts",
+            "version": "v5.8.18",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/illuminate/contracts.git",
+                "reference": "8e2466437516edaa30201a8b5d4eaa56fa99eacd"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/illuminate/contracts/zipball/8e2466437516edaa30201a8b5d4eaa56fa99eacd",
+                "reference": "8e2466437516edaa30201a8b5d4eaa56fa99eacd",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "php": "^7.1.3",
+                "psr/container": "^1.0",
+                "psr/simple-cache": "^1.0"
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "5.8-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Illuminate\\Contracts\\": ""
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Taylor Otwell",
+                    "email": "taylor@laravel.com"
+                }
+            ],
+            "description": "The Illuminate Contracts package.",
+            "homepage": "https://laravel.com",
+            "time": "2019-05-15T00:29:13+00:00"
+        },
+        {
+            "name": "illuminate/database",
+            "version": "v5.8.18",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/illuminate/database.git",
+                "reference": "421138e05c149e2e82edb0a6a86dca59a79a65a0"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/illuminate/database/zipball/421138e05c149e2e82edb0a6a86dca59a79a65a0",
+                "reference": "421138e05c149e2e82edb0a6a86dca59a79a65a0",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "ext-json": "*",
+                "illuminate/container": "5.8.*",
+                "illuminate/contracts": "5.8.*",
+                "illuminate/support": "5.8.*",
+                "php": "^7.1.3"
+            },
+            "suggest": {
+                "doctrine/dbal": "Required to rename columns and drop SQLite columns (^2.6).",
+                "fzaninotto/faker": "Required to use the eloquent factory builder (^1.4).",
+                "illuminate/console": "Required to use the database commands (5.8.*).",
+                "illuminate/events": "Required to use the observers with Eloquent (5.8.*).",
+                "illuminate/filesystem": "Required to use the migrations (5.8.*).",
+                "illuminate/pagination": "Required to paginate the result set (5.8.*)."
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "5.8-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Illuminate\\Database\\": ""
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Taylor Otwell",
+                    "email": "taylor@laravel.com"
+                }
+            ],
+            "description": "The Illuminate Database package.",
+            "homepage": "https://laravel.com",
+            "keywords": [
+                "database",
+                "laravel",
+                "orm",
+                "sql"
+            ],
+            "time": "2019-05-15T00:48:07+00:00"
+        },
+        {
+            "name": "illuminate/support",
+            "version": "v5.8.18",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/illuminate/support.git",
+                "reference": "eb6ad85fd80163fdaa5b97983e0e32d811128242"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/illuminate/support/zipball/eb6ad85fd80163fdaa5b97983e0e32d811128242",
+                "reference": "eb6ad85fd80163fdaa5b97983e0e32d811128242",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "doctrine/inflector": "^1.1",
+                "ext-json": "*",
+                "ext-mbstring": "*",
+                "illuminate/contracts": "5.8.*",
+                "nesbot/carbon": "^1.26.3 || ^2.0",
+                "php": "^7.1.3"
+            },
+            "conflict": {
+                "tightenco/collect": "<5.5.33"
+            },
+            "suggest": {
+                "illuminate/filesystem": "Required to use the composer class (5.8.*).",
+                "moontoast/math": "Required to use ordered UUIDs (^1.1).",
+                "ramsey/uuid": "Required to use Str::uuid() (^3.7).",
+                "symfony/process": "Required to use the composer class (^4.2).",
+                "symfony/var-dumper": "Required to use the dd function (^4.2).",
+                "vlucas/phpdotenv": "Required to use the env helper (^3.3)."
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "5.8-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Illuminate\\Support\\": ""
+                },
+                "files": [
+                    "helpers.php"
+                ]
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Taylor Otwell",
+                    "email": "taylor@laravel.com"
+                }
+            ],
+            "description": "The Illuminate Support package.",
+            "homepage": "https://laravel.com",
+            "time": "2019-05-17T18:49:15+00:00"
+        },
+        {
+            "name": "nesbot/carbon",
+            "version": "2.18.0",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/briannesbitt/Carbon.git",
+                "reference": "8322b7bd1805be31867c13bf3cdaab948a0dd406"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/briannesbitt/Carbon/zipball/8322b7bd1805be31867c13bf3cdaab948a0dd406",
+                "reference": "8322b7bd1805be31867c13bf3cdaab948a0dd406",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "ext-json": "*",
+                "php": "^7.1.8 || ^8.0",
+                "symfony/translation": "^3.4 || ^4.0"
+            },
+            "require-dev": {
+                "friendsofphp/php-cs-fixer": "^2.14 || ^3.0",
+                "kylekatarnls/multi-tester": "^1.1",
+                "phpmd/phpmd": "^2.6",
+                "phpstan/phpstan": "^0.11",
+                "phpunit/phpunit": "^7.5 || ^8.0",
+                "squizlabs/php_codesniffer": "^3.4"
+            },
+            "type": "library",
+            "extra": {
+                "laravel": {
+                    "providers": [
+                        "Carbon\\Laravel\\ServiceProvider"
+                    ]
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Carbon\\": "src/Carbon/"
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Brian Nesbitt",
+                    "email": "brian@nesbot.com",
+                    "homepage": "http://nesbot.com"
+                }
+            ],
+            "description": "A simple API extension for DateTime.",
+            "homepage": "http://carbon.nesbot.com",
+            "keywords": [
+                "date",
+                "datetime",
+                "time"
+            ],
+            "time": "2019-05-16T18:44:35+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://dl.laravel-china.org/%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/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://dl.laravel-china.org/%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/contracts",
+            "version": "v1.1.0",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/symfony/contracts.git",
+                "reference": "d3636025e8253c6144358ec0a62773cae588395b"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/symfony/contracts/zipball/d3636025e8253c6144358ec0a62773cae588395b",
+                "reference": "d3636025e8253c6144358ec0a62773cae588395b",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "php": "^7.1.3"
+            },
+            "require-dev": {
+                "psr/cache": "^1.0",
+                "psr/container": "^1.0",
+                "symfony/polyfill-intl-idn": "^1.10"
+            },
+            "suggest": {
+                "psr/cache": "When using the Cache contracts",
+                "psr/container": "When using the Service contracts",
+                "symfony/cache-contracts-implementation": "",
+                "symfony/event-dispatcher-implementation": "",
+                "symfony/http-client-contracts-implementation": "",
+                "symfony/service-contracts-implementation": "",
+                "symfony/translation-contracts-implementation": ""
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "1.1-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Symfony\\Contracts\\": ""
+                },
+                "exclude-from-classmap": [
+                    "**/Tests/"
+                ]
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Nicolas Grekas",
+                    "email": "p@tchwork.com"
+                },
+                {
+                    "name": "Symfony Community",
+                    "homepage": "https://symfony.com/contributors"
+                }
+            ],
+            "description": "A set of abstractions extracted out of the Symfony components",
+            "homepage": "https://symfony.com",
+            "keywords": [
+                "abstractions",
+                "contracts",
+                "decoupling",
+                "interfaces",
+                "interoperability",
+                "standards"
+            ],
+            "time": "2019-04-27T14:29:50+00:00"
+        },
+        {
+            "name": "symfony/polyfill-mbstring",
+            "version": "v1.11.0",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/symfony/polyfill-mbstring.git",
+                "reference": "fe5e94c604826c35a32fa832f35bd036b6799609"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/symfony/polyfill-mbstring/zipball/fe5e94c604826c35a32fa832f35bd036b6799609",
+                "reference": "fe5e94c604826c35a32fa832f35bd036b6799609",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "php": ">=5.3.3"
+            },
+            "suggest": {
+                "ext-mbstring": "For best performance"
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "1.11-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Symfony\\Polyfill\\Mbstring\\": ""
+                },
+                "files": [
+                    "bootstrap.php"
+                ]
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Nicolas Grekas",
+                    "email": "p@tchwork.com"
+                },
+                {
+                    "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": "2019-02-06T07:57:58+00:00"
+        },
+        {
+            "name": "symfony/translation",
+            "version": "v4.2.8",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/symfony/translation.git",
+                "reference": "181a426dd129cb496f12d7e7555f6d0b37a7615b"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/symfony/translation/zipball/181a426dd129cb496f12d7e7555f6d0b37a7615b",
+                "reference": "181a426dd129cb496f12d7e7555f6d0b37a7615b",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require": {
+                "php": "^7.1.3",
+                "symfony/contracts": "^1.0.2",
+                "symfony/polyfill-mbstring": "~1.0"
+            },
+            "conflict": {
+                "symfony/config": "<3.4",
+                "symfony/dependency-injection": "<3.4",
+                "symfony/yaml": "<3.4"
+            },
+            "provide": {
+                "symfony/translation-contracts-implementation": "1.0"
+            },
+            "require-dev": {
+                "psr/log": "~1.0",
+                "symfony/config": "~3.4|~4.0",
+                "symfony/console": "~3.4|~4.0",
+                "symfony/dependency-injection": "~3.4|~4.0",
+                "symfony/finder": "~2.8|~3.0|~4.0",
+                "symfony/http-kernel": "~3.4|~4.0",
+                "symfony/intl": "~3.4|~4.0",
+                "symfony/var-dumper": "~3.4|~4.0",
+                "symfony/yaml": "~3.4|~4.0"
+            },
+            "suggest": {
+                "psr/log-implementation": "To use logging capability in translator",
+                "symfony/config": "",
+                "symfony/yaml": ""
+            },
+            "type": "library",
+            "extra": {
+                "branch-alias": {
+                    "dev-master": "4.2-dev"
+                }
+            },
+            "autoload": {
+                "psr-4": {
+                    "Symfony\\Component\\Translation\\": ""
+                },
+                "exclude-from-classmap": [
+                    "/Tests/"
+                ]
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Fabien Potencier",
+                    "email": "fabien@symfony.com"
+                },
+                {
+                    "name": "Symfony Community",
+                    "homepage": "https://symfony.com/contributors"
+                }
+            ],
+            "description": "Symfony Translation Component",
+            "homepage": "https://symfony.com",
+            "time": "2019-05-01T12:55:36+00:00"
+        },
+        {
+            "name": "textalk/websocket",
+            "version": "1.2.0",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/Textalk/websocket-php.git",
+                "reference": "bfa18bb6bf523680c7803f6b04694fbbf2f67bbf"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/Textalk/websocket-php/zipball/bfa18bb6bf523680c7803f6b04694fbbf2f67bbf",
+                "reference": "bfa18bb6bf523680c7803f6b04694fbbf2f67bbf",
+                "shasum": "",
+                "mirrors": [
+                    {
+                        "url": "https://dl.laravel-china.org/%package%/%reference%.%type%",
+                        "preferred": true
+                    }
+                ]
+            },
+            "require-dev": {
+                "cboden/ratchet": "0.3.*",
+                "phpunit/phpunit": "4.1.*",
+                "phpunit/phpunit-selenium": "1.3.3",
+                "satooshi/php-coveralls": "dev-master"
+            },
+            "type": "library",
+            "autoload": {
+                "psr-4": {
+                    "WebSocket\\": "lib"
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Fredrik Liljegren",
+                    "email": "fredrik.liljegren@textalk.se"
+                }
+            ],
+            "description": "WebSocket client and server",
+            "time": "2015-10-09T07:32:42+00:00"
+        }
+    ],
+    "packages-dev": [],
+    "aliases": [],
+    "minimum-stability": "stable",
+    "stability-flags": [],
+    "prefer-stable": false,
+    "prefer-lowest": false,
+    "platform": {
+        "php": ">=7.0.0"
+    },
+    "platform-dev": []
+}

websockServ/configs/configs.php

@@ -0,0 +1,108 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2019/5/20
+ * Time: 9:09
+ */
+
+$tmp_config = [
+    'common' => [
+        'mysql' => [
+            'driver' => 'mysql',
+            'host' => '192.168.2.200',
+            'port' => 3306,
+            'database' => 'ds_cms',
+            'username' => 'vali',
+            'user' => 'vali',
+            'password' => '1234',
+            'charset' => 'utf8mb4',
+            'collation' => 'utf8mb4_unicode_ci'
+        ],
+        'pgsql' => [
+            'driver' => 'pgsql',
+            'host' => '192.168.2.200',
+            'port' => 10432,
+            'database' => 'pai',
+            'username' => 'kaiyou',
+            'password' => '123456',
+            'charset' => 'utf8',
+            'collation' => 'utf8_unicode_ci',
+            'prefix' => ''
+        ],
+        'redis' => [
+            'host' => '192.168.2.200',
+            'port' => 26379,
+            'passwd' => '',
+            'db' => 0,
+            'overtime' => 1,
+        ],
+        'swoole' => [
+            'worker_num' => 4,
+            'daemonize' => true,
+            'max_request' => 50,
+            'task_enable_coroutine' => true,
+            'dispatch_mode' => 2,
+            'debug_mode' => 1,
+            'task_worker_num' => 20,
+            'log_file' => '../logs/err.log',
+        ],
+
+        'swoolev2' => [
+            'worker_num' => 2,
+            'daemonize' => false,
+            'max_request' => 5000,
+            'task_enable_coroutine' => true,
+            'dispatch_mode' => 2,
+            'debug_mode' => 1,
+            'task_worker_num' => 10,
+            'log_file' => '../logs/errv2.log',
+        ],
+        'pgsqlpoole'=>[
+            'poole_host' => '0.0.0.0' ,
+            'poole_port' => 9091,
+
+            'db_type' => 'pgsql',
+            'db_host' => '192.168.2.200',
+            'db_port' => 10432,
+            'db_name' => 'pai',
+            'db_user' => 'kaiyou',
+            'db_pwd' => '123456',
+        ],
+        'mysqlpoole'=>[
+            'poole_host' => '0.0.0.0' ,
+            'poole_port' => 9091,
+
+            'db_type' => 'mysql',
+            'db_host' => '192.168.2.200',
+            'db_port' => 3306,
+            'db_name' => 'ds_cms',
+            'db_user' => 'vali',
+            'db_pwd' => '1234',
+        ],
+        'commpoole'=>[
+            'poole_host' => '0.0.0.0' ,
+            'poole_port' => 9091,
+
+            'db_type' => 'mysql',
+            'db_host' => '192.168.2.200',
+            'db_port' => 3306,
+            'db_name' => 'ds_cms',
+            'db_user' => 'vali',
+            'db_pwd' => '1234',
+
+        ],
+
+
+    ],
+    'dev' => [
+
+    ],
+    'test' => [
+
+    ],
+    'prod' => [
+    ],
+];
+
+return array_merge($tmp_config['common'], $tmp_config[ENV]);