as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

eee

Browse Source
This commit is contained in:
xl
2024-09-11 11:10:15 +08:00
parent 8a4b62b2d8
commit 1790d01730
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test.php
+8 -2
View File
@@ -17,13 +17,17 @@ function faker($page = 0)
run(function () { run(function () {
$offset = 1; $offset = 1;
$success = 0;
for ($i = 1; $i <= 10000; $i++) { for ($i = 1; $i <= 10000; $i++) {
$faker = faker($offset); $faker = faker($offset);
$offset++; $offset++;
go(function () use ($faker, $offset) { go(function () use ($faker, $offset, &$success) {
$socket = new Swoole\Coroutine\Http\Client('43.248.128.57', 14101); $socket = new Swoole\Coroutine\Http\Client('43.248.128.57', 14101);
$socket->upgrade("/ws?access_token=" . $faker['params']['token']); $socket->upgrade("/ws?access_token=" . $faker['params']['token']);
if ($socket->connected) { if ($socket->connected) {
$success += 1;
while (true) { while (true) {
$socket->recv(); $socket->recv();
// $socket->push('hello'); // $socket->push('hello');
@@ -32,13 +36,15 @@ run(function () {
Coroutine::sleep(0.1); Coroutine::sleep(0.1);
} }
} else { } else {
$success -= 1;
echo 'websocket fail: ' . socket_strerror($socket->errCode) . PHP_EOL; echo 'websocket fail: ' . socket_strerror($socket->errCode) . PHP_EOL;
} }
}); });
Coroutine::sleep(0.1); Coroutine::sleep(0.1);
var_dump($offset); var_dump($success);
} }