composer require workerman/gateway-worker<?php require_once "vendor/autoload.php"; use Workerman\Worker; use GatewayWorker\Gateway as gate; use GatewayWorker\BusinessWorker; use GatewayWorker\Register; use GatewayWorker\Lib\Gateway; use Medoo\Medoo; $gateway = new gate("websocket://0.0.0.0:2345"); $gateway->startPort = 30000; $gateway->count = 4; $gateway->name = 'gateway'; $gateway->registerAddress = '127.0.0.1:1234'; $business = new BusinessWorker(); $business->count = 4; $business->registerAddress = '127.0.0.1:1234'; $register = new Register('text://0.0.0.0:1234'); $register->name = 'register'; class Events{ public static function onConnect($client_id){ $arr = array( 'remote_ip'=>$_SERVER['REMOTE_ADDR'], 'remote_port'=>$_SERVER['REMOTE_PORT'], 'gate_ip'=>$_SERVER['GATEWAY_ADDR'], 'gate_port'=>$_SERVER['GATEWAY_PORT'], 'client_id'=>$_SERVER['GATEWAY_CLIENT_ID'] ); $ret = json_encode($arr); return GateWay::sendToCurrentClient($ret); } public static function onMessage($client_id, $message){ return GateWay::sendToCurrentClient($message); } public static function onClose($client_id){ GateWay::sendToAll("client[$client_id] logout\n"); } } Worker::runAll();<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Document</title> </head> <body> <input type="text"> <br> <input type="button" value="提交"> <script> 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) } </script> </body> </html>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
