mkm/xunfei-wss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新

Browse Source
This commit is contained in:
mkm 2023-09-18 13:45:41 +08:00
parent 7a688304a4
commit 688318d22f
1 changed files with 7 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
app/Pusher.php
View File

@ -16,6 +16,8 @@ class Pusher
private $api_secret = 'MDEyMzE5YTc5YmQ5NjMwOTU1MWY4N2Y2';
private $chatClient;
public function onConnect(TcpConnection $connection)
{
echo "onConnect\n";
@ -32,6 +34,7 @@ class Pusher
$client = new Client($this->assembleAuthUrl('wss://spark-api.xf-yun.com/v2.1/chat'));
// 连接到 WebSocket 服务器
if ($client) {
$this->chatClient=$client;
// 发送数据到 WebSocket 服务器
$data = $this->getBody($this->app_id, $data);
@ -53,30 +56,20 @@ class Pusher
// $total_tokens = $resp['payload']['usage']['text']['total_tokens'];
print("\n本次消耗token用量：\n");
$client->close();
break;
}
}
}
}
// $uri = $this->assembleAuthUrl('ws://spark-api.xf-yun.com/v2.1/chat');
// $con = new AsyncTcpConnection($uri);
// // $con = new AsyncTcpConnection('ws://127.0.0.1:9999');
// $con->onWebSocketConnect = function (AsyncTcpConnection $con,$data) {
// $res = $this->getBody($this->app_id,$data);
// $con->send($res);
// };
// $con->onMessage = function (AsyncTcpConnection $con, $data) use($connection) {
// $connection->send($data);
// };
// $con->connect();
}
}
public function onClose(TcpConnection $connection)
{
if($this->chatClient){
$this->chatClient->close();
}
echo "onClose\n";
}