关键词:
WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。
WebSocket 使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。
在 WebSocket API 中,浏览器和服务器只需要完成一次握手的动作,浏览器和服务器之间就形成了一条快速通道创建持久性的连接,两者之间就直接可以数据互相传送。(长连接,循环连接的不算)
现在,很多网站为了实现推送技术,所用的技术都是 Ajax 轮询。轮询是在特定的的时间间隔(如每1秒),由浏览器对服务器发出HTTP请求,然后由服务器返回最新的数据给客户端的浏览器。
这种传统的模式带来很明显的缺点,即浏览器需要不断的向服务器发出请求,然而HTTP请求可能包含较长的头部,其中真正有效的数据可能只是很小的一部分,显然这样会浪费很多的带宽等资源。
php应用实现webSocket更多使用workerman或swoole框架.
简单实现webSocket(demo)
serverSocket.php文件
1 <?php 2 3 class SocketService 4 5 private $address; 6 private $port; 7 private $_sockets; 8 public function __construct($address = ‘‘, $port=‘‘) 9 10 if(!empty($address)) 11 $this->address = $address; 12 13 if(!empty($port)) 14 $this->port = $port; 15 16 17 18 public function service() 19 //获取tcp协议号码。 20 $tcp = getprotobyname("tcp"); 21 $sock = socket_create(AF_INET, SOCK_STREAM, $tcp); 22 socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1); 23 if($sock < 0) 24 25 throw new Exception("failed to create socket: ".socket_strerror($sock)." "); 26 27 socket_bind($sock, $this->address, $this->port); 28 socket_listen($sock, $this->port); 29 echo "listen on $this->address $this->port ... "; 30 $this->_sockets = $sock; 31 32 33 public function run() 34 $this->service(); 35 $clients[] = $this->_sockets; 36 while (true) 37 $changes = $clients; 38 $write = NULL; 39 $except = NULL; 40 socket_select($changes, $write, $except, NULL); 41 foreach ($changes as $key => $_sock) 42 if($this->_sockets == $_sock) //判断是不是新接入的socket 43 if(($newClient = socket_accept($_sock)) === false) 44 die(‘failed to accept socket: ‘.socket_strerror($_sock)." "); 45 46 $line = trim(socket_read($newClient, 1024)); 47 $this->handshaking($newClient, $line); 48 //获取client ip 49 socket_getpeername ($newClient, $ip); 50 $clients[$ip] = $newClient; 51 echo "Client ip:$ip "; 52 echo "Client msg:$line "; 53 else 54 socket_recv($_sock, $buffer, 2048, 0); 55 $msg = $this->message($buffer); 56 //在这里业务代码 57 echo "$key clinet msg:",$msg," "; 58 fwrite(STDOUT, ‘Please input a argument:‘); 59 $response = trim(fgets(STDIN)); 60 $this->send($_sock, $response); 61 echo "$key response to Client:".$response," "; 62 63 64 65 66 67 /** 68 * 握手处理 69 * @param $newClient socket 70 * @return int 接收到的信息 71 */ 72 public function handshaking($newClient, $line) 73 74 $headers = array(); 75 $lines = preg_split("/ /", $line); 76 foreach($lines as $line) 77 78 $line = chop($line); 79 if(preg_match(‘/A(S+): (.*)z/‘, $line, $matches)) 80 81 $headers[$matches[1]] = $matches[2]; 82 83 84 $secKey = $headers[‘Sec-WebSocket-Key‘]; 85 $secAccept = base64_encode(pack(‘H*‘, sha1($secKey . ‘258EAFA5-E914-47DA-95CA-C5AB0DC85B11‘))); 86 $upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake " . 87 "Upgrade: websocket " . 88 "Connection: Upgrade " . 89 "WebSocket-Origin: $this->address " . 90 "WebSocket-Location: ws://$this->address:$this->port/websocket/websocket ". 91 "Sec-WebSocket-Accept:$secAccept "; 92 return socket_write($newClient, $upgrade, strlen($upgrade)); 93 94 95 /** 96 * 解析接收数据 97 * @param $buffer 98 * @return null|string 99 */ 100 public function message($buffer) 101 $len = $masks = $data = $decoded = null; 102 $len = ord($buffer[1]) & 127; 103 if ($len === 126) 104 $masks = substr($buffer, 4, 4); 105 $data = substr($buffer, 8); 106 else if ($len === 127) 107 $masks = substr($buffer, 10, 4); 108 $data = substr($buffer, 14); 109 else 110 $masks = substr($buffer, 2, 4); 111 $data = substr($buffer, 6); 112 113 for ($index = 0; $index < strlen($data); $index++) 114 $decoded .= $data[$index] ^ $masks[$index % 4]; 115 116 return $decoded; 117 118 119 /** 120 * 发送数据 121 * @param $newClinet 新接入的socket 122 * @param $msg 要发送的数据 123 * @return int|string 124 */ 125 public function send($newClinet, $msg) 126 $msg = $this->frame($msg); 127 socket_write($newClinet, $msg, strlen($msg)); 128 129 130 public function frame($s) 131 $a = str_split($s, 125); 132 if (count($a) == 1) 133 return "x81" . chr(strlen($a[0])) . $a[0]; 134 135 $ns = ""; 136 foreach ($a as $o) 137 $ns .= "x81" . chr(strlen($o)) . $o; 138 139 return $ns; 140 141 142 /** 143 * 关闭socket 144 */ 145 public function close() 146 return socket_close($this->_sockets); 147 148 149 150 $sock = new SocketService(‘127.0.0.1‘,‘9000‘); 151 $sock->run();
web.html 文件
1 <!doctype html> 2 <html lang="en"> 3 <head> 4 <meta charset="UTF-8"> 5 <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, user-scalable=no"> 6 <title>websocket</title> 7 </head> 8 <body> 9 <input id="text" value=""> 10 <input type="submit" value="send" onclick="start()"> 11 <input type="submit" value="close" onclick="close()"> 12 <div id="msg"></div> 13 <script> 14 /** 15 *0:未连接 16 *1:连接成功,可通讯 17 *2:正在关闭 18 *3:连接已关闭或无法打开 19 */ 20 //创建一个webSocket 实例 21 var webSocket = new WebSocket("ws://127.0.0.1:9000"); 22 23 24 webSocket.onerror = function (event) 25 onError(event); 26 ; 27 28 // 打开websocket 29 webSocket.onopen = function (event) 30 onOpen(event); 31 ; 32 33 //监听消息 34 webSocket.onmessage = function (event) 35 onMessage(event); 36 ; 37 38 39 webSocket.onclose = function (event) 40 onClose(event); 41 42 43 //关闭监听websocket 44 function onError(event) 45 document.getElementById("msg").innerHTML = "<p>close</p>"; 46 console.log("error"+event.data); 47 ; 48 49 function onOpen(event) 50 console.log("open:"+sockState()); 51 document.getElementById("msg").innerHTML = "<p>Connect to Service</p>"; 52 ; 53 54 function onMessage(event) 55 console.log("onMessage"); 56 document.getElementById("msg").innerHTML += "<p>response:"+event.data+"</p>" 57 ; 58 59 function onClose(event) 60 document.getElementById("msg").innerHTML = "<p>close</p>"; 61 console.log("close:"+sockState()); 62 webSocket.close(); 63 64 65 function sockState() 66 var status = [‘未连接‘,‘连接成功,可通讯‘,‘正在关闭‘,‘连接已关闭或无法打开‘]; 67 return status[webSocket.readyState]; 68 69 70 function start(event) 71 console.log(webSocket); 72 var msg = document.getElementById(‘text‘).value; 73 document.getElementById(‘text‘).value = ‘‘; 74 console.log("send:"+sockState()); 75 console.log("msg="+msg); 76 webSocket.send("msg="+msg); 77 document.getElementById("msg").innerHTML += "<p>request"+msg+"</p>" 78 ; 79 80 function close(event) 81 webSocket.close(); 82 83 </script> 84 </body> 85 </html>
运行结果:
准备工作开启扩展: php需要打开websocket的配置,在php安装目录下的php.ini extension=php_sockets.dll
先执行脚本 例如: php -q serverSocket.php
后执行页面 例如: http://web.html
php开启websocket服务,php实现简单的websocket服务(代码片段)
...用嵌套在任何一个框架都可以使用首先有一个空目录php-websocket在该目录下有一个test.php文件在该目录下下载依赖模块workermancomposerrequireworkerman/workerman在test.php编写代码<?phprequire_once__DIR__.'/vendor/autoload.php';// 查看详情
安装composer,tp5.0和workerman整合实现websocket通信demo(代码片段)
1.通过phpstudy安装composer2.全局配制composer:把改路径D:myDevphpstudyphpstudy_proExtensionscomposer1.8.5下的composer.bat和composer.phar复制到对应版本的php路径下。 并修改composer.bat中的内容为 @php"%~dp0composer.phar"%*3.把对应版本的php.exe配置到... 查看详情
使用websocket实现消息推送(下)(代码片段)
0x00WebSocket上一篇使用Java-WebSocket写了一套WebSocket的Demo,这一篇着重分析下WebSocket的一些实现细节,更加详细的协议细节可参考RFC6455。0x01WebSocket协议WebSocket协议:可参考RFC6455抓包工具:Charles和WireShark测试代码:参... 查看详情
简单的 php websocket 示例
】简单的phpwebsocket示例【英文标题】:simplephpwebsocketexample【发布时间】:2011-02-0920:31:45【问题描述】:谁能给我简单的websocket代码。我正在创建websocket示例,但它不能正常工作,我不知道是什么问题。谢谢。示例:server-side和cli... 查看详情
基于websocket协议的研究demo
1、日志推送 websocket在线测试WebSocket在线测试工具物联网http://www.websocket-test.com/2、Springboot+vue的聊天:Springboot+websocket+vue的web聊天项目https://gitee.com/xzlmk/spring_boot_vue_chat 3、实时通信 4、基于C#net4.5实现最简单的websocket... 查看详情
vue+websocket<简单实现聊天功能>(代码片段)
效果图:聊天室此篇文章是针对Websocket的简单了解和应用,利用Nodejs简单搭建一个服务器加以实现。首先创建一个vue项目然后再创建一个server文件夹,在终端上打开该文件夹,输入vueinit(一直敲"回车"键... 查看详情
websocket简单实现(代码片段)
...连接的情况,服务端处理http请求往往占用大量资源,而websocket则能使web端和服务端维持长连接。除此之外,建立长连接亦可以使服务端主动向web端推送消息,从而为项目提供更加丰富的功能。本文面向初次使用go开发web服务端的... 查看详情
php简单实现邮件发送
初中目的是为了学习WEBSOCKET,所以写了一个简单发送邮件的例子,为后面打下基础。代码如下: classMail { private$host; private$port; private$user; & 查看详情
wpf实现主题更换的简单demo(代码片段)
WPF实现主题更换的简单DEMO实现主题更换功能主要是三个知识点:动态资源(DynamicResource)INotifyPropertyChanged接口界面元素与数据模型的绑定(MVVM中的ViewModel)Demo代码地址:GITHUB下面开门见山,直奔主题一、准备主题资源在项目(怎么建... 查看详情
websocket的简单入门使用(代码片段)
WebSocketWebSocket介绍Java整合WebSocketSpringBoot整合WebSocketWebSocket介绍1)什么是WebSocket?WebSocket是HTML5一种新的协议。它实现了浏览器与服务器全双工通信(full-duplex)。一开始的握手需要借助HTTP请求完成。WebSocket是真正实现了全双工... 查看详情
springboot整合websocket实现简单聊天室(代码片段)
项目结构:效果展示:实现步骤步骤一:添加依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-thymeleaf</artifactId></dependency> 查看详情
springboot——springboot集成websocket实现简单的多人聊天室(代码片段)
文章目录:1.什么是WebSocket?2.Java中的WebSocketAPI2.1WebSocket开发中的相关注解及API方法2.2前端技术对WebSocket的支持3.多人聊天室的实现源码3.1pom文件中添加相关依赖2.2在核心配置文件中配置视图解析器2.3加入相关静态资源文... 查看详情
基于websocket实现网页版聊天室(代码片段)
WebSocket,HTML5开始提供的一种在单个TCP连接上进行全双工通讯的协议,其使用简单,应用场景也广泛,不同开发语言都用种类繁多的实现,仅Java体系中,Tomcat,Jetty,Spring等都提供了对WS的API支持。本篇不做理论探究,仅自娱... 查看详情
java语言通过websocket实现实时系统通知,以后再也不能装作没看到老板的通知了~~(代码片段)
📞文章简介:WebSocket实时通知Demo💡创作目的:因为公司正在从零搭建CRM,其中有一个需求是系统通知管理,老板发布通知给员工。简单的用数据库实现感觉缺少一些实时性,不是那么生动。于是想到... 查看详情
基于websocket实现一个简单的网站在线客服聊天室案例(代码片段)
...一个聊天室,进行客服解答功能,本节我们使用websocket实现一个简单的网站在线客服聊天功能,效果如下:正文后端引入websocket的pom依赖<dependency> <groupId>org.springframewor 查看详情
简单的ocr识别验证码demo|keras实现(代码片段)
HowtoimplementanOCRmodelusingCNNs,RNNs,andCTCloss.ThisexampledemonstratesasimpleOCRmodelbuiltwiththeFunctionalAPI.ApartfromcombiningCNNandRNN,italsoillustrateshowyoucaninstantiateanewlayeranduseitasan 查看详情
springbootwebsocket+webrtc实现点对点视频通话功能demo(代码片段)
...建SpringBoot项目1.1、创建一个空项目:传送门1.2、添加websocket引用<!--websocket--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId></dependency>1.3、添加WebSocketConfig配... 查看详情
go语言实战基于websocket+mongodb的im即时聊天demo(代码片段)
文章目录写在前面1.WebSocket原理2.具体流程2.1定义类型2.2进行连接2.2.1服务器监听连接2.2.2服务器监听断开连接2.2.3用户连接服务器2.3写入2.3.1定义类型2.3.2读取数据2.3.3接受消息2.3.3获取历史消息2.4读取2.5插入与查询2.5.1插入数据2.5.... 查看详情