全部代碼
<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;

require_once __DIR__ . '/../vendor/autoload.php';

// 注意：這里與上個例子不同，使用的是websocket協議
$ws_worker = new Worker("websocket://0.0.0.0:2000");

$ws_worker->onWorkerStart = function($ws_worker)
{
// 將db實例存儲在全局變量中(也可以存儲在某類的靜態(tài)成員中)
global $db;
$db = new \Workerman\MySQL\Connection('localhost', '3306', 'tp6', 'ERFYFsaLKSa62dKc', 'tp6');
};

// 啟動4個進程對外提供服務
$ws_worker->count = 1;

$ws_worker->onConnect = function(TcpConnection $connection)
{
$connection->id='進程id'.rand(10,999).$connection->id;
$data = array(
'user'=>'鏈接成功',
'message'=>$connection->id
);
$connection->send(json_encode($data));
};

// 當收到客戶端發(fā)來的數據后返回hello $data給客戶端
$ws_worker->onMessage = function(TcpConnection $connection, Request $request)
{
global $db;
$all_tables = $db->query("select * from think_message_list");

// 向客戶端發(fā)送hello $data
foreach($connection->worker->connections as $con)
{
    //var_dump($con->id);
    if($con->id !=$connection->id){
        $datal = array(
                'user'=>$connection->id.';'.$con->id,
                'message'=>$data
            );
        $con->send(json_encode($datal));
    }

}

//$cookie = $request->cookie();
//var_dump($cookie);

};

// 運行worker
Worker::runAll();

官網的例子就是這樣寫的http://wtbis.cn/doc/workerman/http/request.html

官網的是http協議，你的是websocket協議

恍然大明白 謝謝大佬