From 795032554c2dba54404551cebe1522f5f66be3cb Mon Sep 17 00:00:00 2001 From: Fanli2 <374861669@qq.com> Date: Wed, 11 Nov 2020 11:17:53 +0800 Subject: [PATCH] gateway-worker --- app/Console/Commands/GatewayWorkerServer.php | 113 +++++++++++++++ app/Console/Kernel.php | 2 + app/GatewayWorker/Events.php | 129 ++++++++++++++++++ app/Http/Controllers/Admin/AdController.php | 2 +- .../Controllers/Admin/AdminController.php | 2 +- .../Controllers/Admin/AdminRoleController.php | 2 +- .../Controllers/Admin/ArticleController.php | 2 +- app/Http/Controllers/Admin/BaseController.php | 2 +- .../Controllers/Admin/BonusController.php | 2 +- .../Controllers/Admin/CategoryController.php | 2 +- .../Controllers/Admin/CommonController.php | 2 +- .../Controllers/Admin/DatabaseController.php | 2 +- .../Controllers/Admin/FeedbackController.php | 2 +- .../Admin/FriendlinkController.php | 2 +- .../Admin/GoodsBrandController.php | 2 +- .../Controllers/Admin/GoodsController.php | 2 +- .../Controllers/Admin/GoodstypeController.php | 2 +- .../Controllers/Admin/GuestbookController.php | 2 +- .../Controllers/Admin/KeywordController.php | 2 +- .../Controllers/Admin/KuaidiController.php | 2 +- app/Http/Controllers/Admin/LogController.php | 2 +- .../Controllers/Admin/LoginController.php | 2 +- app/Http/Controllers/Admin/MenuController.php | 2 +- .../Controllers/Admin/OrderController.php | 2 +- app/Http/Controllers/Admin/PageController.php | 2 +- .../Admin/SearchwordController.php | 2 +- .../Controllers/Admin/SlideController.php | 2 +- .../Controllers/Admin/SysconfigController.php | 2 +- app/Http/Controllers/Admin/TagController.php | 2 +- app/Http/Controllers/Admin/UserController.php | 2 +- .../Controllers/Admin/UserRankController.php | 2 +- .../Admin/UserWithdrawController.php | 2 +- .../Admin/WeixinMenuController.php | 2 +- .../Controllers/Api/ArctypeController.php | 4 +- .../Controllers/Api/ArticleController.php | 4 +- app/Http/Controllers/Api/BonusController.php | 4 +- app/Http/Controllers/Api/CartController.php | 4 +- .../Api/CollectGoodsController.php | 4 +- .../Controllers/Api/CommentController.php | 4 +- .../Controllers/Api/FeedBackController.php | 4 +- .../Controllers/Api/GoodsBrandController.php | 4 +- app/Http/Controllers/Api/GoodsController.php | 4 +- .../Api/GoodsSearchwordController.php | 4 +- .../Controllers/Api/GoodsTypeController.php | 4 +- app/Http/Controllers/Api/NotifyController.php | 4 +- app/Http/Controllers/Api/OrderController.php | 4 +- app/Http/Controllers/Api/PageController.php | 4 +- .../Controllers/Api/PaymentController.php | 4 +- app/Http/Controllers/Api/RegionController.php | 4 +- app/Http/Controllers/Api/SlideController.php | 4 +- .../Controllers/Api/UserAddressController.php | 4 +- .../Controllers/Api/UserBonusController.php | 4 +- app/Http/Controllers/Api/UserController.php | 4 +- .../Api/UserGoodsHistoryController.php | 4 +- .../Controllers/Api/UserMessageController.php | 4 +- .../Controllers/Api/UserMoneyController.php | 4 +- .../Controllers/Api/UserPointController.php | 4 +- .../Api/UserRechargeController.php | 4 +- .../Api/UserWithdrawController.php | 4 +- .../Controllers/Api/VerifyCodeController.php | 4 +- .../Controllers/Weixin/WxPayController.php | 4 +- app/Http/Logic/CommentLogic.php | 4 +- app/Http/Logic/OrderLogic.php | 4 +- app/Http/Logic/UserLogic.php | 4 +- app/Http/Logic/UserMoneyLogic.php | 2 +- app/Http/Logic/UserPointLogic.php | 2 +- app/Http/Logic/UserWithdrawLogic.php | 2 +- app/Http/Model/Access.php | 4 +- app/Http/Model/Ad.php | 4 +- app/Http/Model/Admin.php | 4 +- app/Http/Model/AdminRole.php | 4 +- app/Http/Model/Arctype.php | 4 +- app/Http/Model/Article.php | 4 +- app/Http/Model/BaseModel.php | 4 +- app/Http/Model/Bonus.php | 4 +- app/Http/Model/Cart.php | 4 +- app/Http/Model/CollectGoods.php | 4 +- app/Http/Model/Comment.php | 4 +- app/Http/Model/FeedBack.php | 4 +- app/Http/Model/Friendlink.php | 4 +- app/Http/Model/Goods.php | 4 +- app/Http/Model/GoodsBrand.php | 4 +- app/Http/Model/GoodsImg.php | 4 +- app/Http/Model/GoodsSearchword.php | 4 +- app/Http/Model/GoodsType.php | 4 +- app/Http/Model/Guestbook.php | 4 +- app/Http/Model/Jobs.php | 4 +- app/Http/Model/Keyword.php | 4 +- app/Http/Model/Kuaidi.php | 4 +- app/Http/Model/Log.php | 2 +- app/Http/Model/Menu.php | 4 +- app/Http/Model/Order.php | 4 +- app/Http/Model/OrderGoods.php | 4 +- app/Http/Model/Page.php | 4 +- app/Http/Model/Payment.php | 4 +- app/Http/Model/Region.php | 4 +- app/Http/Model/Searchword.php | 4 +- app/Http/Model/Slide.php | 4 +- app/Http/Model/SmsLog.php | 4 +- app/Http/Model/Sysconfig.php | 5 +- app/Http/Model/Tagindex.php | 4 +- app/Http/Model/Taglist.php | 4 +- app/Http/Model/User.php | 4 +- app/Http/Model/UserAddress.php | 4 +- app/Http/Model/UserBonus.php | 4 +- app/Http/Model/UserGoodsHistory.php | 4 +- app/Http/Model/UserMessage.php | 4 +- app/Http/Model/UserMoney.php | 4 +- app/Http/Model/UserPoint.php | 4 +- app/Http/Model/UserRecharge.php | 4 +- app/Http/Model/UserRole.php | 4 +- app/Http/Model/UserWithdraw.php | 4 +- app/Http/Model/VerifyCode.php | 4 +- app/Http/Model/WeixinMenu.php | 4 +- composer.json | 11 +- 115 files changed, 439 insertions(+), 193 deletions(-) create mode 100644 app/Console/Commands/GatewayWorkerServer.php create mode 100644 app/GatewayWorker/Events.php diff --git a/app/Console/Commands/GatewayWorkerServer.php b/app/Console/Commands/GatewayWorkerServer.php new file mode 100644 index 0000000..340d58c --- /dev/null +++ b/app/Console/Commands/GatewayWorkerServer.php @@ -0,0 +1,113 @@ +argument('action'); + if (!in_array($action, ['start', 'stop', 'restart', 'reload', 'status'])) { + exit('Arguments Error'); + } + + $argv[0] = 'artisan gateway-worker'; + $argv[1] = $action; + $argv[2] = $this->option('d') ? '-d' : ''; //必须是一个-，上面定义命令两个--，后台启动用两个-- + + $this->start(); + } + + private function start() + { + $this->startGateWay(); + $this->startBusinessWorker(); + $this->startRegister(); + Worker::runAll(); + } + + private function startBusinessWorker() + { + $worker = new BusinessWorker(); + $worker->name = 'BusinessWorker'; + $worker->count = 1; + $worker->registerAddress = '127.0.0.1:1236'; + $worker->eventHandler = \App\GatewayWorker\Events::class; //设置使用哪个类来处理业务,业务类至少要实现onMessage静态方法，onConnect和onClose静态方法可以不用实现 + } + + private function startGateWay() + { + $gateway = new Gateway("websocket://0.0.0.0:2346"); + $gateway->name = 'Gateway'; //设置BusinessWorker进程的名称 + $gateway->count = 1; //设置BusinessWorker进程的数量 + $gateway->lanIp = '127.0.0.1'; #内网ip,多服务器分布式部署的时候需要填写真实的内网ip + $gateway->startPort = 2300; //监听本机端口的起始端口 + $gateway->pingInterval = 30; //心跳间隔时间(秒) + $gateway->pingNotResponseLimit = 0; //心跳检测的时间间隔数 + $gateway->pingData = '{"type":"ping"}'; //心跳消息 + $gateway->registerAddress = '127.0.0.1:1236'; //注册服务地址 + } + + private function startRegister() + { + new Register('text://0.0.0.0:1236'); + } + + private function init() + { + + } + + //php artisan gateway-worker start --d之后，打开浏览器F12将内容复制到console里return就行 + /* ws = new WebSocket("ws://127.0.0.1:2346?token=123456"); + ws.onopen = function() { + ws.send('{"name":"one","user_id":"111"}'); + ws.send('{"name":"two","user_id":"222"}'); + //定义一个定时器，每10秒钟发送一个包，包的内容随意，一般发送心跳包的间隔在60秒以内 + setInterval(function () { + ws.send('{"type":"heart","msg":"Heartbeat reply"}'); + }, 10000); + }; + ws.onmessage = function(e) { + console.log("收到服务端的消息：" + e.data); + }; + ws.onclose = function(e) { + console.log("服务已断开" ); + }; */ +} diff --git a/app/Console/Kernel.php b/app/Console/Kernel.php index ceb97c0..031920d 100644 --- a/app/Console/Kernel.php +++ b/app/Console/Kernel.php @@ -6,6 +6,7 @@ use DB; use Log; use Illuminate\Console\Scheduling\Schedule; use Illuminate\Foundation\Console\Kernel as ConsoleKernel; +use App\Console\Commands\GatewayWorkerServer; class Kernel extends ConsoleKernel { @@ -15,6 +16,7 @@ class Kernel extends ConsoleKernel * @var array */ protected $commands = [ + GatewayWorkerServer::class, Commands\UnpayOrderSetInvalid::class, Commands\SendEmail::class, ]; diff --git a/app/GatewayWorker/Events.php b/app/GatewayWorker/Events.php new file mode 100644 index 0000000..11155c1 --- /dev/null +++ b/app/GatewayWorker/Events.php @@ -0,0 +1,129 @@ + 'onConnect', 'client_id' => $client_id])); + } + + /** + * 当客户端连接上gateway完成websocket握手时触发的回调函数 + * 注意：此回调只有gateway为websocket协议并且gateway没有设置onWebSocketConnect时才有效 + * @param int $client_id + * @param mixed $data websocket握手时的http头数据，包含get、server等变量 + */ + public static function onWebSocketConnect($client_id, $data) + { + Log::info('onWebSocketConnect，client_id:' . $client_id . '-' . json_encode($data)); + echo "onWebSocketConnect\r\n"; + if (!isset($data['get']['token'])) { + echo "closeClient\r\n"; + return Gateway::closeClient($client_id); + } + $access_token = $data['get']['token']; + //通过client_id绑定用户ID + $res = self::bing_client($client_id, ['access_token' => $access_token]); + if ($res['code'] != ReturnData::SUCCESS) { + return Gateway::sendToClient($client_id, json_encode($res)); + } + Gateway::sendToClient($client_id, json_encode(ReturnData::create(ReturnData::SUCCESS))); + } + + /** + * 有消息时 + * @param int $client_id 发消息的client_id + * @param mixed $message 完整的客户端请求数据，数据类型取决于Gateway所使用协议的decode方法返的回值类型 + */ + public static function onMessage($client_id, $data) + { + echo "onMessage\r\n"; + // Debug输出 + echo "client:{$_SERVER['REMOTE_ADDR']}:{$_SERVER['REMOTE_PORT']} gateway:{$_SERVER['GATEWAY_ADDR']}:{$_SERVER['GATEWAY_PORT']} client_id:$client_id session:" . json_encode($_SESSION) . " onMessage:" . $message . "\n"; + + // data = {"type":"login", "uid":"666"} + $data = json_decode($data, true); + Log::info('onMessage，client_id:' . $client_id . '-' . json_encode($data)); + + // 没有传消息类型视为非法请求，关闭连接 + if (!isset($data['type'])) { + return Gateway::closeClient($client_id); + } + + $uid = Gateway::getUidByClientId($client_id); + + // 判断绑定的UID为空，消息类型不是心跳视为非法请求，关闭连接 + if (empty($uid) && $data['type'] !== 'heart') { + return Gateway::closeClient($client_id); + } + + switch ($data['type']) { + case 'heart': //心跳回复 + Gateway::sendToCurrentClient(json_encode(ReturnData::create(ReturnData::SUCCESS))); + break; + default: + Gateway::sendToCurrentClient(json_encode(ReturnData::create(ReturnData::PARAMS_ERROR))); + } + } + + /** + * 当客户端断开连接时 + * @param integer $client_id 断开连接的客户端client_id + * @return void + */ + public static function onClose($client_id) + { + // debug + echo "client:{$_SERVER['REMOTE_ADDR']}:{$_SERVER['REMOTE_PORT']} gateway:{$_SERVER['GATEWAY_ADDR']}:{$_SERVER['GATEWAY_PORT']} client_id:$client_id onClose:''\n"; + + Log::info('Workerman close connection，client_id:' . $client_id); + echo "onClose\r\n"; + } + + /** + * 通过client_id绑定用户ID + * @param int $client_id + * @param mixed $message ['access_token'] + */ + public static function bing_client($client_id, $message) + { + if (!Gateway::isOnline($client_id)) { + return ReturnData::create(ReturnData::PARAMS_ERROR, null, 'client_id错误'); + } + + //client_id绑定用户ID + $token = DB::table('token')->where(['token' => $message['access_token']])->first(); + if (!$token) { + return ReturnData::create(ReturnData::PARAMS_ERROR, null, '鉴权失败'); + } + Gateway::bindUid($client_id, $token->uid); + + return ReturnData::create(ReturnData::SUCCESS); + } + +} diff --git a/app/Http/Controllers/Admin/AdController.php b/app/Http/Controllers/Admin/AdController.php index dbf4aa3..248e17d 100644 --- a/app/Http/Controllers/Admin/AdController.php +++ b/app/Http/Controllers/Admin/AdController.php @@ -1,6 +1,6 @@ =5.6.4", + "intervention/image": "^2.3", + "jpush/jpush": "v3.5.*", "laravel/framework": "5.4.*", "laravel/tinker": "~1.0", - "predis/predis": "^1.1", "maatwebsite/excel": "~2.1.0", - "simplesoftwareio/simple-qrcode": "~1", - "intervention/image": "^2.3", - "yansongda/pay": "^1.0", "overtrue/laravel-wechat": "~3.1", - "jpush/jpush": "v3.5.*" + "predis/predis": "^1.1", + "simplesoftwareio/simple-qrcode": "~1", + "workerman/gateway-worker": "^3.0", + "yansongda/pay": "^1.0" }, "require-dev": { "fzaninotto/faker": "~1.4",