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

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

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

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

// 啟動(dòng)4個(gè)進(jìn)程對(duì)外提供服務(wù)
$ws_worker->count = 1;

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

// 當(dāng)收到客戶端發(fā)來(lái)的數(shù)據(jù)后返回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);

};

// 運(yùn)行worker
Worker::runAll();

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

官網(wǎng)的是http協(xié)議，你的是websocket協(xié)議

恍然大明白 謝謝大佬