php完成socket推送技术的示例
发布时间：2022-02-24 14:29:09 所属栏目：PHP教程 来源：互联网
导读：在socket出现之前已经有ajax定时请求、长轮询等方案，但都不能满足需求，socket就应用而生了。 socket基本函数socket 总结下常用的socket函数 服务端：socket_create 创建socket设置基本参数 socket_bind 绑定ip和端口号 socket_listen 监听 socket_accept
|
在socket出现之前已经有ajax定时请求、长轮询等方案，但都不能满足需求，socket就应用而生了。 socket基本函数socket 总结下常用的socket函数 服务端：socket_create 创建socket设置基本参数 socket_bind 绑定ip和端口号 socket_listen 监听 socket_accept 客户端的连接 socket_read 读取客户端的数据 socket_write 给单独客户端发送数据 socket_close 关闭连接 客户端：socket_create 创建socket设置基本参数 socket_connect 连接socket socket_write 给服务端发送数据 socket_read 读取服务端数据 socket_close 关闭连接 H5websocket不多说了，上链接 OK，开始贴代码~ --------------分割线 服务端代码： <?php class WS { var $master; var $sockets = array(); var $debug = false;//true为调试模式，输出log日志 var $handshake = array(); function __construct($address, $port){ $this->master=socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() failed"); socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) or die("socket_option() failed"); socket_bind($this->master, $address, $port) or die("socket_bind() failed"); socket_listen($this->master,20) or die("socket_listen() failed"); $this->sockets[] = $this->master; $this->say("Server Started : ".date('Y-m-d H:i:s')); $this->say("Listening on : ".$address." port ".$port); $this->say("Master socket : ".$this->master."/n"); while(true){ $socketArr = $this->sockets; $write = NULL; $except = NULL; socket_select($socketArr, $write, $except, NULL); //自动选择来消息的socket 如果是握手 自动选择主机 foreach ($socketArr as $socket){ if ($socket == $this->master){ //主机 $client = socket_accept($this->master); if ($client < 0){ $this->log("socket_accept() failed"); continue; } else{ $this->connect($client); } } else { $bytes = @socket_recv($socket,$buffer,2048,0); if ($bytes == 0){ $this->disConnect($socket); } else{ $key = array_search($socket, $this->sockets); if (emptyempty($this->handshake) || !isset($this->handshake[$key]) || !$this->handshake[$key]){ $this->doHandShake($socket, $buffer, $key); } else{ $buffer = $this->decode($buffer); echo $buffer.PHP_EOL; $key = array_search($socket, $this->sockets); $arr = $this->sockets; array_shift($arr); foreach ($arr as $s){ $this->send($s, $buffer); } } } } } } } new WS('localhost', 4000); 客户端代码（H5）： <html> <head> <title>demo</title> <script src="https://cdn.boot<a href="http://www.111cn.net/cssdiv/css.html" class="anchor" target="_blank">css</a>.com/jquery/1.9.1/jquery.min.js"></script> </head> <body> <input type="text" id="content"> <input type="button" value="send" id="send"> <script type="text/javascript"> var ws = new WebSocket("ws://localhost:4000"); ws.onopen = function(){ console.log("握手成功"); } ws.onmessage = function(e){ console.log("message:" + e.data); } ws.onerror = function(){ console.log("error"); } $("#send").click(function(){ content = $("#content").val(); console.log(content); ws.send(content); }) </script> </body> </html> 然后执行php demo.php 开启socket（从运维那偷学一招，linux下执行nohup php demo.php &可以在后台执行），浏览器打开多个index.html，就能建立通讯了。 代码解析： 1.属性$sockets数组保存每个accept连接（不知道这么描述对不对）; 2.属性$handshake数组保存连接是否在连接状态。 （编辑：昌吉站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
站长推荐