boursecu/boursecu_server
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added wss tools 8

Browse Source
This commit is contained in:
mohmdsdg
2026-06-18 20:00:25 +03:30
parent c15136c5e7
commit 21341c7f13
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Http/Controllers/Site/PriceStreamController.php
+6 -3
View File
@@ -53,6 +53,9 @@ class PriceStreamController extends Controller
$lastId = $service->currentSeq(); $lastId = $service->currentSeq();
$heartbeatTicks = 0; $heartbeatTicks = 0;
echo "retry: 5000\n\n";
@flush();
while (! connection_aborted()) { while (! connection_aborted()) {
foreach ($service->consumeSince($lastId) as $event) { foreach ($service->consumeSince($lastId) as $event) {
$send((string) $event['event'], $event['data']); $send((string) $event['event'], $event['data']);
@@ -60,9 +63,9 @@ class PriceStreamController extends Controller
} }
$heartbeatTicks++; $heartbeatTicks++;
if ($heartbeatTicks >= 30) { // هر ۵ ثانیه — LiteSpeed/پروکسی اتصال بیکار را نمی‌بندد
echo ': ping '.time()."\n\n"; if ($heartbeatTicks >= 10) {
@flush(); $send('ping', ['ts' => time()]);
$heartbeatTicks = 0; $heartbeatTicks = 0;
} }