diff --git a/app/Events.php b/app/Events.php index 575d5a7..3861e06 100644 --- a/app/Events.php +++ b/app/Events.php @@ -70,6 +70,8 @@ class Events echo "客服端发送的消息type无法处理...".PHP_EOL; Gateway::sendToCurrentClient("客服端发送的消息type无法处理"); } + + return GateWay::sendToAll($message); } /** diff --git a/app/start_gateway.php b/app/start_gateway.php index 3f5e494..4cd6f03 100644 --- a/app/start_gateway.php +++ b/app/start_gateway.php @@ -21,7 +21,7 @@ use \Workerman\Autoloader; require_once __DIR__ . '/../vendor/autoload.php'; // gateway 进程,这里使用Text协议,可以用telnet测试 -$gateway = new Gateway("websocket://0.0.0.0:8282"); +$gateway = new Gateway("Websocket://0.0.0.0:8282"); $gateway->transport = 'ssl'; // 启用 SSL // gateway名称,status方便查看 @@ -45,15 +45,9 @@ $gateway->pingData = '{"type":"pong "}'; // 当客户端连接上来时,设置连接的onWebSocketConnect,即在websocket握手时的回调 $gateway->onConnect = function($connection) { - $connection->onWebSocketConnect = function($connection , $http_header) + $connection->onWebSocketConnect = function($connection , $httpBuffer) { // 设置允许跨域 -// header('Access-Control-Allow-Origin: *' ); -// header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE, PATCH, OPTIONS'); -// header('Access-Control-Allow-Headers: Content-Type,Authorization,Accpet,Token,Language'); -// header('Access-Control-Max-Age: 86400'); -// header('Access-Control-Allow-Credentials: true'); - $connection->headers['Access-Control-Allow-Origin'] = '*'; $connection->headers['Access-Control-Allow-Methods'] = 'GET, POST, PUT, DELETE, PATCH, OPTIONS'; $connection->headers['Access-Control-Allow-Headers'] = 'Content-Type';