diff --git a/app/controller/IndexController.php b/app/controller/IndexController.php index 5fe68b2..56486f1 100644 --- a/app/controller/IndexController.php +++ b/app/controller/IndexController.php @@ -2,24 +2,16 @@ namespace app\controller; -use app\extend\ChatGLM\Core; -use app\extend\IFlytek\Xfyun\Speech\TtsClient; -use support\App; use support\Request; use Webman\Container; -use Workerman\Protocols\Websocket; +use Webman\Push\Api; class IndexController { public function index(Request $request) { - $chat=(new Container())->get(Core::class); - // (new Core())->getUrl(); - static $readme; - if (!$readme) { - $readme = file_get_contents(base_path('README.md')); - } - return $readme; + return json(['code' => 0, 'msg' => 'ok']); + } public function view(Request $request) @@ -32,4 +24,19 @@ class IndexController return json(['code' => 0, 'msg' => 'ok']); } + public function push(Request $request){ + $parmas=$request->get('name'); + $api = new Api( + // webman下可以直接使用config获取配置，非webman环境需要手动写入相应配置 + 'http://127.0.0.1:3232', + config('plugin.webman.push.app.app_key'), + config('plugin.webman.push.app.app_secret') + ); + // 给订阅 user-1 的所有客户端推送 message 事件的消息 + $api->trigger('user-1', 'message', [ + 'from_uid' => 1, + 'content' => $parmas + ]); + return json(['code' => 0, 'msg' => 'ok']); + } } diff --git a/composer.json b/composer.json index e35606d..f443197 100644 --- a/composer.json +++ b/composer.json @@ -32,7 +32,8 @@ "yzh52521/easyhttp": "^1.1", "psr/container": "^1.1.1", "php-di/php-di": "^6", - "doctrine/annotations": "^1.14" + "doctrine/annotations": "^1.14", + "webman/push": "^1.0" }, "suggest": { "ext-event": "For better performance. " diff --git a/composer.lock b/composer.lock index dbe4562..c73d250 100644 --- a/composer.lock +++ b/composer.lock @@ -4,7 +4,7 @@ "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies", "This file is @generated automatically" ], - "content-hash": "4bf8701922041fb93cac2a5101032617", + "content-hash": "925eb31b037c538d5ddaba7603395749", "packages": [ { "name": "doctrine/annotations", @@ -1262,6 +1262,29 @@ "description": "JSON Web Token (JWT) for webman plugin", "time": "2023-09-16T03:25:47+00:00" }, + { + "name": "webman/push", + "version": "v1.0.16", + "dist": { + "type": "zip", + "url": "https://mirrors.cloud.tencent.com/repository/composer/webman/push/v1.0.16/webman-push-v1.0.16.zip", + "reference": "cd838ea76ffd90ef165564e4f35cebbe87462e77", + "shasum": "" + }, + "require": { + "php": ">=7.2" + }, + "type": "library", + "autoload": { + "psr-4": { + "Webman\\Push\\": "src" + } + }, + "license": [ + "MIT" + ], + "time": "2023-06-17T13:34:32+00:00" + }, { "name": "workerman/webman-framework", "version": "v1.5.9", diff --git a/config/plugin/webman/push/app.php b/config/plugin/webman/push/app.php new file mode 100644 index 0000000..17c0bf7 --- /dev/null +++ b/config/plugin/webman/push/app.php @@ -0,0 +1,10 @@ + true, + 'websocket' => 'websocket://0.0.0.0:3131', + 'api' => 'http://0.0.0.0:3232', + 'app_key' => 'aaea61749929eb53a4bd75a1474c1d27', + 'app_secret' => '0a9e0ed62646cdff1e63c5f1ea64504d', + 'channel_hook' => 'http://127.0.0.1:8686/plugin/webman/push/hook', + 'auth' => '/plugin/webman/push/auth' +]; \ No newline at end of file diff --git a/config/plugin/webman/push/process.php b/config/plugin/webman/push/process.php new file mode 100644 index 0000000..01c545d --- /dev/null +++ b/config/plugin/webman/push/process.php @@ -0,0 +1,21 @@ + [ + 'handler' => Server::class, + 'listen' => config('plugin.webman.push.app.websocket'), + 'count' => 1, // 必须是1 + 'reloadable' => false, // 执行reload不重启 + 'constructor' => [ + 'api_listen' => config('plugin.webman.push.app.api'), + 'app_info' => [ + config('plugin.webman.push.app.app_key') => [ + 'channel_hook' => config('plugin.webman.push.app.channel_hook'), + 'app_secret' => config('plugin.webman.push.app.app_secret'), + ], + ] + ] + ] +]; \ No newline at end of file diff --git a/config/plugin/webman/push/route.php b/config/plugin/webman/push/route.php new file mode 100644 index 0000000..ea54c37 --- /dev/null +++ b/config/plugin/webman/push/route.php @@ -0,0 +1,87 @@ + + * @copyright walkor + * @link http://www.workerman.net/ + * @license http://www.opensource.org/licenses/mit-license.php MIT License + */ + +use support\Request; +use Webman\Route; +use Webman\Push\Api; + +/** + * 推送js客户端文件 + */ +Route::get('/plugin/webman/push/push.js', function (Request $request) { + return response()->file(base_path().'/vendor/webman/push/src/push.js'); +}); + +/** + * 私有频道鉴权，这里应该使用session辨别当前用户身份，然后确定该用户是否有权限监听channel_name + */ +Route::post(config('plugin.webman.push.app.auth'), function (Request $request) { + $pusher = new Api(str_replace('0.0.0.0', '127.0.0.1', config('plugin.webman.push.app.api')), config('plugin.webman.push.app.app_key'), config('plugin.webman.push.app.app_secret')); + $channel_name = $request->post('channel_name'); + $session = $request->session(); + // 这里应该通过session和channel_name判断当前用户是否有权限监听channel_name + $has_authority = true; + if ($has_authority) { + return response($pusher->socketAuth($channel_name, $request->post('socket_id'))); + } else { + return response('Forbidden', 403); + } +}); + +/** + * 当频道上线以及下线时触发的回调 + * 频道上线：是指某个频道从没有连接在线到有连接在线的事件 + * 频道下线：是指某个频道的所有连接都断开触发的事件 + */ +Route::post(parse_url(config('plugin.webman.push.app.channel_hook'), PHP_URL_PATH), function (Request $request) { + + // 没有x-pusher-signature头视为伪造请求 + if (!$webhook_signature = $request->header('x-pusher-signature')) { + return response('401 Not authenticated', 401); + } + + $body = $request->rawBody(); + + // 计算签名，$app_secret 是双方使用的密钥，是保密的，外部无从得知 + $expected_signature = hash_hmac('sha256', $body, config('plugin.webman.push.app.app_secret'), false); + + // 安全校验，如果签名不一致可能是伪造的请求，返回401状态码 + if ($webhook_signature !== $expected_signature) { + return response('401 Not authenticated', 401); + } + + // 这里存储这上线 下线的channel数据 + $payload = json_decode($body, true); + + $channels_online = $channels_offline = []; + + foreach ($payload['events'] as $event) { + if ($event['name'] === 'channel_added') { + $channels_online[] = $event['channel']; + } else if ($event['name'] === 'channel_removed') { + $channels_offline[] = $event['channel']; + } + } + + // 业务根据需要处理上下线的channel，例如将在线状态写入数据库，通知其它channel等 + // 上线的所有channel + echo 'online channels: ' . implode(',', $channels_online) . "\n"; + // 下线的所有channel + echo 'offline channels: ' . implode(',', $channels_offline) . "\n"; + + return 'OK'; +}); + + +