简单理解php的socket编程
happyxyb
8年前
<p>php 的 socket 编程算是比较难以理解的东西吧，不过，我们只要理解 socket 几个函数之间的关系，以及它们所扮演的角色，那么理解起来应该不是很难了，在笔者看来， socket 编程，其实就是建立一个网络服务的客户端和服务端，这和 mysql 的客户端和服务端是一样的，你只要理解 mysql 的客户端和服务端是怎么一回事，你就应该能够理解下面我要讲的东西吧。</p> <p>关于 socket 编程所涉及到的网络协议，什么 TCP 啊， UDP 啊，什么 socket 三次握手等等，这些网络协议网上有很详细的解释，这里不讲，只截个 socket 建立套接的过程图让你瞧瞧：</p> <p style="text-align:center"><img src="https://simg.open-open.com/show/da402a736f306df7391f98d0fe93c930.png"></p> <p>这个图是我辛辛苦苦从别人那里盗截过来的，你一定要好好看啊，同时，在这里我也向那个被我盗截图的笔者表示感谢，本人对自己盗取你的图案表示歉意，还望你大人大量不要计较啊。本人实在太懒了，懒得画图，（其实是对自己的画图技术表示不自信，呵呵）。</p> <p>socket 是怎么建立连接的呢？上面已经提到过了，它建立连接的过程是与 mysql 的客户端和服务端的连接本质是一样的。而它与 mysql 不同的是， mysql 的服务端和客户端都已经为我们编辑好了，我们只要应用就行了。但是，关键时刻来啦， socket 它什么东西都没有提供给我们，唯一提供给我们的就是：几十个 socket 函数。</p> <p>这言外之意就是说， socket 编程就是要我们自己创建服务端和客户端，也就是说， ``socket 编程 ``—— 就是要我们自己建立一个类似于 mysql 的服务端和客户端的应用。</p> <p>说到这里，我想问一句，你说这 socket 让人头疼不？它既不建立个服务端，也不建立个客户端给我们应用，非要让我们自己去应用 socket 的函数，创建一个属于我们自己的网络协议套接应用，这是不是很让你头疼呢？头疼也没办法，要是你需要自己的应用，你还是不得不跟 socket 打交道。呵呵，这只是题外话，不多说，下面进入正题。</p> <p>在你没有被 socket 编程搞蒙之前，我还是让你看看 socket 的几个关键函数，先给你解释一下它们各自的作用。不然，要是对 socket 编程一点基础都没有的人看到了，我怕你看了之后，就果断跳过这篇文章，从此对 socket 产生恐惧症了。呵呵，又多说了。</p> <p>socket 的关键函数 1 ：</p> <p>socket_create($net 参数 1 ， $stream 参数 2 ， $protocol 参数 3)</p> <p>作用：创建一个 socket 套接 字 ，说白了 ，就是一个网络数据流 。</p> <p>返回值：一个套接字，或者是false ，参数错误发出 E_WARNING 警告</p> <p>php 的在线手册那里说得更清楚：</p> <p>socket_create 创建并返回一个套接字，也称作一个通讯节点。一个典型的网络连接由 2 个套接字构成，一个运行在客户端，另一个运行在服务器端。</p> <p>上面一句话是从 php 在线手册那里复制过来的。看到没有，这里说得意思是不是和我上面反反复复提到的客户端与服务端一模一样？呵呵。</p> <p>参数 1 是：网络协议，</p> <p>网络协议有哪些？它的选择项就下面这三个：</p> <p>AF_INET ： IPv4 网络协议。 TCP 和 UDP 都可使用此协议。一般都用这个，你懂的。</p> <p>AF_INET6 ： IPv6 网络协议。 TCP 和 UDP 都可使用此协议。</p> <p>AF_UNIX: 本地通讯协议。具有高性能和低成本的 IPC （进程间通讯）。</p> <p>参数 2 ：套接字流，选项有：</p> <p>SOCK_STREAM SOCK_DGRAM SOCK_SEQPACKET SOCK_RAW SOCK_RDM 。</p> <p>这里只对前两个进行解释：</p> <p>SOCK_STREAM TCP 协议套接字。</p> <p>SOCK_DGRAM UDP 协议套接字。</p> <p>欲了解更多请链接这里： http://php.net/manual/zh/function.socket-create.php</p> <p>参数 3 ： protocol 协议，选项有：</p> <p>SOL_TCP ： TCP 协议。</p> <p>SOL_UDP ： UDP 协议。</p> <p>从这里可以看出，其实 socket_create 函数的第二个参数和第三个参数是相关联的。</p> <p>比如，假如你第一个参数应用 IPv4 协议： AF_INET ，然后，第二个参数应用的是 TCP 套接字： SOCK_STREAM ，</p> <p>那么第三个参数必须要用 SOL_TCP ， 这个应该不难理解。</p> <p>TCP 协议套接字嘛，当然只能用 TCP 协议了，是不是？如果你应用 UDP 套接字，那么第三个参数该怎么选择我就不说了，呵呵，你懂的。</p> <p>关键函数 2 ：</p> <p>socket_connect($socket 参数 1,$ip 参数 2,$port 参数 3)</p> <p>作用：连接一个套接字，返回值为 true 或者 false</p> <p>参数 1 ： socket_create 的函数返回值</p> <p>参数 2 ： ip 地址</p> <p>参数 3 ：端口号</p> <p>关键函数 3 ：</p> <p>socket_bind($socket 参数 1,$ip 参数 2,$port 参数 3)</p> <p>作用：绑定一个套接字，返回值为 true 或者 false</p> <p>参数 1 ： socket_create 的函数返回值</p> <p>参数 2 ： ip 地址</p> <p>参数 3 ：端口号</p> <p>关键函数 4 ：</p> <p>socket_listen($socket 参数 1,$backlog 参数 2)</p> <p>作用：监听一个套接字，返回值为 true 或者 false</p> <p>参数 1 ： socket_create 的函数返回值</p> <p>参数 2 ： 最大监听套接字个数</p> <p>关键函数 5 ：</p> <p>socket_accept($socket)</p> <p>作用：接收套接字的资源信息，成功返回套接字的信息资源，失败为 false</p> <p>参数： socket_create 的函数返回值</p> <p>关键函数 6 ：</p> <p>socket_read($socket)</p> <p>作用：读取套接字的资源信息，</p> <p>返回值：成功把套接字的资源转化为字符串信息，失败为 false</p> <p>参数： socket_create 或者 socket_accept 的函数返回值</p> <p>关键函数 7 ：</p> <p>socket_write($socket 参数 1 ， $msg 参数 2 ， $strlen 参数 3 )</p> <p>作用：把数据写入套接字中</p> <p>返回值：成功返回字符串的字节长度，失败为 false</p> <p>参数： socket_create 或者 socket_accept 的函数返回值</p> <p>关键函数 8 ：</p> <p>socket_close($socket)</p> <p>作用：关闭套接字</p> <p>返回值：成功返回 true ，失败为 false</p> <p>参数： socket_create 或者 socket_accept 的函数返回值</p> <p>这八个函数是 socket 的核心函数，下面列举两个个比较重要的函数</p> <p>socket_last_error($socket) ，参数为 socket_create 的返回值，作用是获取套接字的最后一条错误码号，返回值套接字 code</p> <p>socket_strerror($code) ，参数为 socket_last_error 函数的返回值,获取 code 的字符串信息,返回值也就是套接字的错误信息</p> <p>这两个函数在 socket 编程中还是很重要的，在写 socket 编程的时候，我觉得你还是得利用起来，特别是新手，可以当做调试用</p> <p>下面就是代码了，注意注意，请认真看我的注释，注释很重要，注释很重要，注释很重要，重要的事情要大喊三遍，呵呵。</p> <p>服务端脚本，D:\vhost\test\socket\server_socket.php</p> <pre> <code class="language-php"><?php //创建服务端的socket套接流,net协议为IPv4，protocol协议为TCP $socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP); /*绑定接收的套接流主机和端口,与客户端相对应*/ if(socket_bind($socket,'127.0.0.1',8888) == false){ echo 'server bind fail:'.socket_strerror(socket_last_error()); /*这里的127.0.0.1是在本地主机测试，你如果有多台电脑，可以写IP地址*/ } //监听套接流 if(socket_listen($socket,4)==false){ echo 'server listen fail:'.socket_strerror(socket_last_error()); } //让服务器无限获取客户端传过来的信息 do{ /*接收客户端传过来的信息*/ $accept_resource = socket_accept($socket); /*socket_accept的作用就是接受socket_bind()所绑定的主机发过来的套接流*/ if($accept_resource !== false){ /*读取客户端传过来的资源，并转化为字符串*/ $string = socket_read($accept_resource,1024); /*socket_read的作用就是读出socket_accept()的资源并把它转化为字符串*/ echo 'server receive is :'.$string.PHP_EOL;//PHP_EOL为php的换行预定义常量 if($string != false){ $return_client = 'server receive is : '.$string.PHP_EOL; /*向socket_accept的套接流写入信息，也就是回馈信息给socket_bind()所绑定的主机客户端*/ socket_write($accept_resource,$return_client,strlen($return_client)); /*socket_write的作用是向socket_create的套接流写入信息，或者向socket_accept的套接流写入信息*/ }else{ echo 'socket_read is fail'; } /*socket_close的作用是关闭socket_create()或者socket_accept()所建立的套接流*/ socket_close($accept_resource); } }while(true); socket_close($socket); </code></pre> <p>客户端脚本,D:\vhost\test\socket\client_socket.php</p> <pre> <code class="language-php"><?php //创建一个socket套接流 $socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP); /****************设置socket连接选项，这两个步骤你可以省略*************/ //接收套接流的最大超时时间1秒，后面是微秒单位超时时间，设置为零，表示不管它 socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, array("sec" => 1, "usec" => 0)); //发送套接流的最大超时时间为6秒 socket_set_option($socket, SOL_SOCKET, SO_SNDTIMEO, array("sec" => 6, "usec" => 0)); /****************设置socket连接选项，这两个步骤你可以省略*************/ //连接服务端的套接流，这一步就是使客户端与服务器端的套接流建立联系 if(socket_connect($socket,'127.0.0.1',8888) == false){ echo 'connect fail massege:'.socket_strerror(socket_last_error()); }else{ $message = 'l love you 我爱你 socket'; //转为GBK编码，处理乱码问题，这要看你的编码情况而定，每个人的编码都不同 $message = mb_convert_encoding($message,'GBK','UTF-8'); //向服务端写入字符串信息 if(socket_write($socket,$message,strlen($message)) == false){ echo 'fail to write'.socket_strerror(socket_last_error()); }else{ echo 'client write success'.PHP_EOL; //读取服务端返回来的套接流信息 while($callback = socket_read($socket,1024)){ echo 'server return message is:'.PHP_EOL.$callback; } } } socket_close($socket);//工作完毕，关闭套接流 </code></pre> <p>怎么测试这两个脚本呢？</p> <p>首先打开windows的dos窗口，就是cmd黑窗口，然后，运行php D:\vhost\test\socket\server_socket.php，</p> <p>让服务端的的黑窗口持续运行的，</p> <p>其次，php的客户端脚本可以通过浏览器运行，也可以再开一个cmd黑窗口运行</p> <p>php D:\vhost\test\socket\client_socket.php</p> <p>在这里请注意：php这个运行命名必须加入windows的环境变量中，假如不知道怎么加，</p> <p>请进入php运行命令目录用绝对命令运行，也可以百度把php命令加入环境变量中</p> <p>这里是我的情况，你的文件地址可能和我不一样，请按照你的地址情况来操作，否则，后果自负，呵呵</p> <p>上面已经说过了，socket编程必须要有服务端才能交流，所以服务端的黑窗口是必须让它持续开着的。</p> <p>后记补充：</p> <p>socket_set_option ($socket 参数 1 ， $level 参数 2 ， $optname 参数 3 ， $optval 参数 4)</p> <p>这个函数的作用是给套接字设置数据流选项，还是一个很重要的函数。</p> <p>参数 1 ： socket_create 或者 socket_accept 的函数返回值</p> <p>参数 2 ： SOL_SOCKET ，好像只有这个选项</p> <p>参数 3 与参数 4 是相关联的，</p> <p>参数 3 可为： SO_REUSEADDR SO_RCVTIMEO S0_SNDTIMEO</p> <p>解释一下：</p> <p>SO_REUSEADDR 是让套接字端口释放后立即就可以被再次使用</p> <p>参数 3 假如是这个，则参数 4 可以为 true 或者 false</p> <p>SO_RCVTIMEO 是套接字的接收资源的最大超时时间</p> <p>SO_SNDTIMEO 是套接字的发送资源的最大超时时间</p> <p>参数 3 假如是这两个，则参数 4 是一个这样的数组 array('sec'=>1,'usec'=>500000)</p> <p>数组里面都是设置超时的最大时间，不过，一个是秒为单位，一个是微秒单位，作用都一样</p> <p> </p> <p>来自：http://www.cnblogs.com/loveyoume/p/6076101.html</p> <p> </p>