在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，开始贴代码~

--------------分割线

服务端代码：

1. <?php 
2. class WS { 
3.  var $master; 
4.  var $sockets = array(); 
5.  var $debug = false;//true为调试模式，输出log日志 
6.  var $handshake = array(); 
7.  function __construct($address, $port){ 
8.  $this->master=socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() failed"); 
9.  socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) or die("socket_option() failed"); 
10.  socket_bind($this->master, $address, $port)  or die("socket_bind() failed"); 
11.  socket_listen($this->master,20)  or die("socket_listen() failed"); 
12.    
13.  $this->sockets[] = $this->master; 
14.  $this->say("Server Started : ".date('Y-m-d H:i:s')); 
15.  $this->say("Listening on : ".$address." port ".$port); 
16.  $this->say("Master socket : ".$this->master."\n"); 
17.    
18.  while(true){ 
19.  $socketArr = $this->sockets; 
20.  $write = NULL; 
21.  $except = NULL; 
22.  socket_select($socketArr, $write, $except, NULL); //自动选择来消息的socket 如果是握手 自动选择主机 
23.  foreach ($socketArr as $socket){ 
24.  if ($socket == $this->master){ //主机 
25.   $client = socket_accept($this->master); 
26.   if ($client < 0){ 
27.   $this->log("socket_accept() failed"); 
28.   continue; 
29.   } else{ 
30.   $this->connect($client); 
31.   } 
32.  } else { 
33.   $bytes = @socket_recv($socket,$buffer,2048,0); 
34.   if ($bytes == 0){ 
35.   $this->disConnect($socket); 
36.   } 
37.   else{ 
38.   $key = array_search($socket, $this->sockets); 
39.   if (emptyempty($this->handshake) || !isset($this->handshake[$key]) || !$this->handshake[$key]){ 
40.   $this->doHandShake($socket, $buffer, $key); 
41.   } 
42.   else{ 
43.   $buffer = $this->decode($buffer); 
44.   echo $buffer.PHP_EOL; 
45.   $key = array_search($socket, $this->sockets); 
46.   $arr = $this->sockets; 
47.   array_shift($arr); 
48.   foreach ($arr as $s){ 
49.   $this->send($s, $buffer); 
50.   } 
51.   } 
52.   } 
53.  } 
54.  } 
55.  } 
56.  } 
57.    
58.  function send($client, $msg){ 
59.  $msg = $this->frame($msg); 
60.  socket_write($client, $msg, strlen($msg)); 
61.  } 
62.  function connect($socket){ 
63.  array_push($this->sockets, $socket); 
64.  $this->say("\n" . $socket . " CONNECTED!"); 
65.  $this->say(date("Y-n-d H:i:s")); 
66.  } 
67.  function disConnect($socket){ 
68.  $index = array_search($socket, $this->sockets); 
69.  socket_close($socket); 
70.  $this->say($socket . " DISCONNECTED!"); 
71.  if ($index >= 0){ 
72.  echo 'unset index is:'.PHP_EOL; 
73.  unset($this->sockets[$index]); 
74.  } 
75.  } 
76.  function doHandShake($socket, $buffer, $handKey){ 
77.  $this->log("\nRequesting handshake..."); 
78.  $this->log($buffer); 
79.  list($resource, $host, $origin, $key) = $this->getHeaders($buffer); 
80.  $this->log("Handshaking..."); 
81.  $upgrade = "HTTP/1.1 101 Switching Protocol\r\n" . 
82.   "Upgrade: websocket\r\n" . 
83.   "Connection: Upgrade\r\n" . 
84.   "Sec-WebSocket-Accept: " . $this->calcKey($key) . "\r\n\r\n"; //必须以两个回车结尾 
85.  $this->log($upgrade); 
86.  $sent = socket_write($socket, $upgrade, strlen($upgrade)); 
87.  $this->handshake[$handKey]=true; 
88.  $this->log("Done handshaking..."); 
89.  return true; 
90.  } 
91.  function getHeaders($req){ 
92.  $r = $h = $o = $key = null; 
93.  if (preg_match("/GET (.*) HTTP/" ,$req,$match)) { $r = $match[1]; } 
94.  if (preg_match("/Host: (.*)\r\n/" ,$req,$match)) { $h = $match[1]; } 
95.  if (preg_match("/Origin: (.*)\r\n/" ,$req,$match)) { $o = $match[1]; } 
96.  if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/",$req,$match)) { $key = $match[1]; } 
97.  return array($r, $h, $o, $key); 
98.  } 
99.  function calcKey($key){ 
100.  //基于websocket version 13 
101.  $accept = base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)); 
102.  return $accept; 
103.  } 
104.  function decode($buffer) { 
105.  $len = $masks = $data = $decoded = null; 
106.  $len = ord($buffer[1]) & 127; 
107.  if ($len === 126) { 
108.  $masks = substr($buffer, 4, 4); 
109.  $data = substr($buffer, 8); 
110.  }  
111.  else if ($len === 127) { 
112.  $masks = substr($buffer, 10, 4); 
113.  $data = substr($buffer, 14); 
114.  }  
115.  else { 
116.  $masks = substr($buffer, 2, 4); 
117.  $data = substr($buffer, 6); 
118.  } 
119.  for ($index = 0; $index < strlen($data); $index++) { 
120.  $decoded .= $data[$index] ^ $masks[$index % 4]; 
121.  } 
122.  return $decoded; 
123.  } 
124.  function frame($s){ 
125.  $a = str_split($s, 125); 
126.  if (count($a) == 1){ 
127.  return "\x81" . chr(strlen($a[0])) . $a[0]; 
128.  } 
129.  $ns = ""; 
130.  foreach ($a as $o){ 
131.  $ns .= "\x81" . chr(strlen($o)) . $o; 
132.  } 
133.  return $ns; 
134.  } 
135.    
136.  function say($msg = ""){ 
137.  echo $msg . "\n"; 
138.  } 
139.  function log($msg = ""){ 
140.  if ($this->debug){ 
141.  echo $msg . "\n"; 
142.  } //phpfensi.com 
143.  } 
144. } 
145.    
146. new WS('localhost', 4000); 

客户端代码（H5）：

1. <html> 
2.  <head> 
3.  <title>demo</title> 
4.  <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> 
5.  </head> 
6.  <body> 
7.  <input type="text" id="content"> 
8.  <input type="button" value="send" id="send"> 
9.  <script type="text/javascript"> 
10.   var ws = new WebSocket("ws://localhost:4000"); 
11.   ws.onopen = function(){ 
12.   console.log("握手成功"); 
13.   } 
14.   ws.onmessage = function(e){ 
15.   console.log("message:" + e.data); 
16.   } 
17.   ws.onerror = function(){ 
18.   console.log("error"); 
19.   } 
20.   $("#send").click(function(){ 
21.   content = $("#content").val(); 
22.   console.log(content); 
23.   ws.send(content); 
24.   }) 
25.  </script> 
26.  </body> 
27. </html> 

Tags: php推送 socket推送

分享到：