public function onConnect($connection, $service): void
{
$service->addGroup("chat_1", $connection);
}
Guruhdan chiqarib yuborish
public function onClose($connection, $service): void
{
print("Connection {$connection->id} has disconnected");
$service->removeGroup("chat_1", $connection);
}
barcha foydalanuvchilarga xabar yuborish
public function onMessage($connection, $message, $service): void
{
$service->sendGroupMessage("chat_1", $message);
}
Controllerda websocket foydalanuvchilarga xabar yuborish
<?php
namespace App\Http\Controllers;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Response;
use JscorpTech\Websocket\Services\WebsocketService;
class WebsocketController extends Controller
{
public function index(Request $request): JsonResponse
{
(new WebsocketService())->sendGroupMessage("all", json_encode([
"message" => $request->get('message'),
]));
return Response::json([
"detail" => "message send"
]);
}
}