更新push
This commit is contained in:
parent
3350338e07
commit
6a14b5f8d0
@ -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']);
|
||||
}
|
||||
}
|
||||
|
||||
@ -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. "
|
||||
|
||||
25
composer.lock
generated
25
composer.lock
generated
@ -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",
|
||||
|
||||
10
config/plugin/webman/push/app.php
Normal file
10
config/plugin/webman/push/app.php
Normal file
@ -0,0 +1,10 @@
|
||||
<?php
|
||||
return [
|
||||
'enable' => 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'
|
||||
];
|
||||
21
config/plugin/webman/push/process.php
Normal file
21
config/plugin/webman/push/process.php
Normal file
@ -0,0 +1,21 @@
|
||||
<?php
|
||||
|
||||
use Webman\Push\Server;
|
||||
|
||||
return [
|
||||
'server' => [
|
||||
'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'),
|
||||
],
|
||||
]
|
||||
]
|
||||
]
|
||||
];
|
||||
87
config/plugin/webman/push/route.php
Normal file
87
config/plugin/webman/push/route.php
Normal file
@ -0,0 +1,87 @@
|
||||
<?php
|
||||
/**
|
||||
* This file is part of webman.
|
||||
*
|
||||
* Licensed under The MIT License
|
||||
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||
* Redistributions of files must retain the above copyright notice.
|
||||
*
|
||||
* @author walkor<walkor@workerman.net>
|
||||
* @copyright walkor<walkor@workerman.net>
|
||||
* @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';
|
||||
});
|
||||
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user