高平做网站,宁波大型网站推广服务,彩票网站用什么软件做,wordpress 免费自媒体workerman是纯PHP开发的开源PHP 应用容器#xff0c;可以通过composer安装#xff0c;目前因为要用到客户端与服务器实时通信#xff0c;故使用了workerman中的websocket模块功能
服务器端#xff1a;
1.建一个目录#xff0c;创建start.php文件#xff0c;文件名随意 …workerman是纯PHP开发的开源PHP 应用容器可以通过composer安装目前因为要用到客户端与服务器实时通信故使用了workerman中的websocket模块功能
服务器端
1.建一个目录创建start.php文件文件名随意
2.composer安装workerman
composer require workerman/workerman
3.根据worker示例编写代码
简单的开发示例-workerman手册
?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . /vendor/autoload.php;// 创建一个Worker监听2345端口使用websocket协议通讯
// 不要把websocket写成了tcp或者http
$http_worker new Worker(websocket://0.0.0.0:6789);// 启动4个进程对外提供服务
$http_worker-count 4;$http_worker-onConnect function(TcpConnection $connection)
{echo connected:\n;//var_dump($connection);echo new connection from ip . $connection-getRemoteIp() . \n;
};// 接收到浏览器发送的数据时回复hello world给浏览器
$http_worker-onMessage function(TcpConnection $connection, $data)
{echo get message:\n;var_dump($data);//var_dump($request);// 向浏览器发送hello world// Connection::send(mixed $data [,$raw false])// 第二个参数是raw发送的数据只是第一个参数不要搞错了// https://www.workerman.net/doc/workerman/tcp-connection/send.html$connection-send(hello world . $data);
};$http_worker-onClose function(TcpConnection $connection)
{echo connection closed\n;
};// 运行worker
Worker::runAll();
4.配置nginx
workerman默认是可以直接监听端口的但是因为开发环境、防火墙、安全、其他项目等因素js直接连服务器ip端口连不上所以采用了nginx代理转发server模块中添加如下location
location /websocket {proxy_pass http://127.0.0.1:6789;#js前端ws new WebSocket(wss://www.example.com/websocket);#workerman里面$http_worker new Worker(websocket://0.0.0.0:6789);#这里就是代理转发到本地的6789端口proxy_http_version 1.1;proxy_set_header Upgrade $http_upgrade;proxy_set_header Connection Upgrade;proxy_set_header Host $host;
}前端
1.编写js代码
// 创建 WebSocket 对象并建立连接
var ws null;try{ws new WebSocket(wss://www.haoqi100.com/websocket);
}catch(e){console.log(new socket catch, e)
}
console.log(get websocket:, ws)
console.log(init event:)
// 打开连接时触发的事件
ws.onopen function(event) {console.log(WebSocket 已连接);// onopen里面send会断开连接应该是因为打乱了握手顺序setTimeout((){ws.send(i am ok)// 发送心跳不然时间长了会断开heartBeat()}, 1)
};// 接收到消息时触发的事件
ws.onmessage function(event) {console.log(接收到服务器的消息, event.data);
};// 发生错误时触发的事件
ws.onerror function(error) {console.error(WebSocket 错误, error);
};// 关闭连接时触发的事件
ws.onclose function(event) {console.log(WebSocket 已关闭, event);ws null
};function heartBeat(){var heartInterval setInterval((){if(ws){ws.send(ping)}else{clearInterval(heartInterval)console.log(heartBeat finish)}}, 10000)
}
注意事项
1.前端js里面ws.onopen不要马上send可能会打乱握手顺序
2.服务端的send有两个参数第二个可选参数不会当成数据发送不要搞错了
3.注意自己实现一个心跳以免长时间没有收发数据导致连接断开
