服务端：

require_once "../vendor/autoload.php";

use Workerman\Worker;

$worker = new Worker(‘websocket://0.0.0.0:2345‘);

$worker->count = 1;

$worker->onWorkerStart = function($data){

echo "连接开始\n";

};

$worker->onConnect = function($data){

echo "连接完成\n";

};

$worker->onMessage = function($con,$data) use ($worker){

echo "接收消息：{$data}\n";

foreach($worker->connections as $id=>$connection){

$connection->send($id.‘:‘.$data);

}

};

$worker->onClose = function($data){

echo "关闭连接\n";

};

$worker->onError = function($data){

echo "遇到错误\n";

};

Worker::runAll();

客户端：

Document

var ws = new WebSocket(‘ws://192.168.8.81:2345‘)

ws.onopen = function(data) {

console.log(‘连接开始\n‘)

}

ws.onmessage = function(data) {

console.log(‘接收消息：‘+data.data)

}

ws.onclose = function(data) {

console.log(‘关闭连接\n‘)

}

ws.onerror = function(data) {

console.log(‘遇到错误\n‘)

}

var text = document.getElementsByTagName(‘input‘)[0]

var button = document.getElementsByTagName(‘input‘)[1]

button.onclick = function(){

var val = text.value

ws.send(val)

}

效果：