当前位置：首页 > article >正文

Laravel接口中实现WebSocket服务消息发送PHP中使用socket扩展搭建WebSocket服务

article 2024/11/15 11:12:54

要在Laravel接口中实现WebSocket服务消息发送，你可以使用Laravel的Pusher库。首先，你需要安装Pusher库：

composer require pusher/pusher-php-server

然后，在你的Laravel项目中创建一个WebSocket事件类，例如WebSocketEvent.php：

<?php

namespace App\Events;

use Illuminate\Broadcasting\Channel;
use Illuminate\Queue\SerializesModels;
use Illuminate\Foundation\Events\Dispatchable;
use Pusher\Pusher;

class WebSocketEvent implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    public $data;

    public function __construct($data)
    {
        $this->data = $data;
    }

    public function broadcastOn()
    {
        return new Channel('websocket-channel');
    }
}

接下来，你可以在你的控制器中使用这个事件来发送消息：

<?php

namespace App\Http\Controllers;

use App\Events\WebSocketEvent;
use Illuminate\Http\Request;

class WebSocketController extends Controller
{
    public function sendMessage(Request $request)
    {
        $message = $request->input('message');

        event(new WebSocketEvent($message));

        return response()->json(['status' => 'success']);
    }
}

至于在PHP中使用socket扩展搭建WebSocket服务，你可以参考以下示例代码：

<?php
$host = '127.0.0.1';
$port = 8080;

// 创建socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($socket, $host, $port);
socket_listen($socket);

// 接受客户端连接
while (true) {
    $client = socket_accept($socket);
    $client_ip = socket_getpeername($client, true);
    echo "Client connected: {$client_ip}
";

    // 读取客户端发送的数据
    while ($data = socket_read($client, 1024)) {
        echo "Received data: {$data}
";

        // 向客户端发送数据
        $response = "Server response: {$data}";
        socket_write($client, $response, strlen($response));
    }

    // 关闭客户端连接
    socket_close($client);
}

// 关闭socket
socket_close($socket);