??? ??? ???? ??? ???? ?? ??? ?? ??? ?? ?? ???? ??????? ??? ??? ?????. ??? ?? ???? ???, ????? ???, ??? ?????? ? ??? ?? ??? ???? ??? ?? ?? ??? ?? ? ??? ?? ?? ???? ???? ??? ??? ??? ? ????. ? ????? ThinkPHP6 ?????? ???? ??? ?? ??? ???? ??? ?????.

ThinkPHP6? ??? ?? ????? ????? ??? ? ?????? ??? ?? ???? ??? PHP ?? ????????. ThinkPHP6? ???? ??? ? ?? ???? ?? ??? ? ??? ?? ?? API? ?????. ???? ThinkPHP6 ?????? ???? ??? ?? ??? ???? ??? ?? ???? ??? ???????.

1. ??

?? ??? ???? ?? ??? ??? ??? ???? ???. ?? PHP ??? MySQL ??????? ????, ??????? ??? ???? ???? ???. ?? ?? ???? ???? ???? ?? ????? ?? ????? ??? ? ?? ??? ???? ThinkPHP6? ???? ???.

composer create-project topthink/think my-project

??? ??? ? ???? ?? ????? ???? ?? ??? ???? http? ?????. ?????? //localhost:8000/ ? ???? ??? ? ????.

2. ?? ??

1. ??? ?? ???? ???

???? ?? ???? ?? app/controller ????? ? ???? ?? Push.php? ????. ? ???? push?? ???? ???? ???? ??? ??? ?????. ??? ??? ????.

<?php
namespace appcontroller;

use thinkworkerServer;

class Push extends Server
{
    protected $socket = 'websocket://0.0.0.0:2346';

    public function onWorkerStart()
    {
        echo "WorkerStart
";
    }

    public function onMessage($connection, $data)
    {
        $connection->send('hello,thinkphp6');
    }

    public function onClose($connection)
    {
        echo "onClose
";
    }
}

2. WebSocket ??? ??

ThinkPHP6??? thinkworkerServer ???? ???? WebSocket ???? ??? ? ????. ?? ??? ????? ??? ??? ???? ???.

? ?????? $socket ?? ??? ? ?? ???(onWorkerStart ???, onMessage ??? ? onClose ???)? ???? ???. $socket ??? WebSocket? ??? ???? ? ?????. onWorkerStart ???? ???? ??? ? ???? ???? onMessage ???? onClose ???? ?? ?? ? ?? ????? ???? ???? ???? ? ?????. ?? ???? onMessage ???? ???? ??? ? ??? ???? ??? ?? ????.

3. ?? ?? ??

??? ??? ??? ??? ???? ?, ?????? ??? ?? ??? ?? ??? ??? ???. ??? ??? ????.

var socket = new WebSocket('ws://localhost:2346');

socket.onopen = function (event) {
    console.log('WebSocket connected.');
    socket.send('Hello Socket!');
};

socket.onmessage = function (event) {
    console.log('Received message from server:', event.data);
};

socket.onclose = function (event) {
    console.log('WebSocket disconnected.');
};

???? ??? WebScoket ??? ???? ?? WebSocket ??? ?????. WebSocket ??, ???, ?? ? ?? ???? onopen, onmessage, onclose ? ?? ??? ???? ?? ????? ? ????.

4. ??? ?? ?? ??

WebSocket?? ??? ?? ? ??? ???? ??? ????? ???? ???. ?? ????? ??? ??? ?? ??? ???? ???. ??? ??? ????.

public function push()
{
    $server =     hinkacadeEnv::get('websocket.server');// 獲取Server實例
    // 接收客戶端傳輸?shù)臄?shù)據(jù)
    $data    = $server->frame->data;
    $ssid = $server->connections;// 返回全部連接
    foreach ($ssid as $v){
        // 給指定用戶發(fā)消息
        $server->push($v, $data);
    }
}

??? ThinkPHP6? ?? ???? Env ???? ???? WebSocket ??? ????? ?? foreach ??? ?? ?? ??? ?????. ? ??? ?? ???? ????. ??? ???? ??? ?? ??? ?? ??? ? ????. ?? ?? ??? ID? ???? ???? ??? ? ????.

3. ?? ???

?? ??? ??? WebSocket ???? ???? ??? ????? ????? ????? ???. ???? ?? ??? ?????:

php think worker:server

? ??? WebSocket ???? ???? ?? ?? 2346?? ?? ?????. ?? ????? ?? http://localhost:8000/push? ???? ??? ?? ??? ????? ? ????.

??

? ???? ThinkPHP6 ?????? ???? ??? ?? ??? ???? ??? ?????. ???? ?? ?? ??? ?????.

1. ??: PHP ??, MySQL ??????, ??? ? ?? ?? ??, ?????? ? ??? ?? ???? ??? ?? ThinkPHP6 ?????? ?????.

2. ?? ??: ?? ????? ???? WebSocket ???? ??? ? JavaScript? ?? ??? ?? ??? ?? ??? ?? ??? ?????.

3. ??? ??: WebSocket ???? ???? ????? ?? ??????.

? ??? ??? ?? ???? ?? ThinkPHP6 ?????? ???? ??? ?? ??? ???? ??? ???? ???? ?? ?? ??? ??? ??? ? ??? ????.

? ??? ThinkPHP6? ???? ??? ?? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!