socket编程 123

1. 预备知识

一直以来很少看到有多少人使用php的socket模块来做一些事情，大概大家都把它定位在脚本语言的范畴内吧，但是其实php的socket模块可以做很多事情，包括做ftplist,http post提交，smtp提交，组包并进行特殊报文的交互（如smpp协议），whois查询。这些都是比较常见的查询。

特别是php的socket扩展库可以做的事情简直不会比c差多少。
php的socket连接函数
1、集成于内核的socket
这个系列的函数仅仅只能做主动连接无法实现端口监听相关的功能。而且在4.3.0之前所有socket连接只能工作在阻塞模式下。
此系列函数包括
fsockopen，pfsockopen
这两个函数的具体信息可以查询php.net的用户手册
他们均会返回一个资源编号对于这个资源可以使用几乎所有对文件操作的函数对其进行操作如fgets(),fwrite(), fclose()等单注意的是所有函数遵循这些函数面对网络信息流时的规律，例如：
fread() 从文件指针 handle 读取最多 length 个字节。 该函数在读取完 length 个字节数，或到达 EOF 的时候，或（对于网络流）当一个包可用时就会停止读取文件，视乎先碰到哪种情况。 
可以看出对于网络流就必须注意取到的是一个完整的包就停止。
2、php扩展模块带有的socket功能。
php4.x 以后有这么一个模块extension=php_sockets.dll，Linux上是一个extension=php_sockets.so。
当打开这个此模块以后就意味着php拥有了强大的socket功能，包括listen端口，阻塞及非阻塞模式的切换，multi-client 交互式处理等
这个系列的函数列表参看http://www.php.net/manual/en/ref.sockets.php
看过这个列表觉得是不是非常丰富呢？不过非常遗憾这个模块还非常年轻还有很多地方不成熟，相关的参考文档也非常少：（
我也正在研究中，因此暂时不具体讨论它，仅给大家一个参考文章

http://www.zend.com/pecl/tutorials/sockets.php

2. 使用PHP socket扩展

服务器端代码：

  1. <?php
  2. /**
  3. * File name server.php
  4. * 服务器端代码
  5. *
  6. * @author guisu.huang
  7. * @since 2012-04-11
  8. *
  9. */
  10. //确保在连接客户端时不会超时
  11. set_time_limit(0);
  12. //设置IP和端口号
  13. $address = "127.0.0.1";
  14. $port = 2046; //调试的时候，可以多换端口来测试程序！
  15. /**
  16. * 创建一个SOCKET
  17. * AF_INET=是ipv4 如果用ipv6，则参数为 AF_INET6
  18. * SOCK_STREAM为socket的tcp类型，如果是UDP则使用SOCK_DGRAM
  19. */
  20. $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
  21. //阻塞模式
  22. socket_set_block($sock) or die("socket_set_block() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
  23. //绑定到socket端口
  24. $result = socket_bind($sock, $address, $port) or die("socket_bind() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
  25. //开始监听
  26. $result = socket_listen($sock, 4) or die("socket_listen() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
  27. echo "OK\nBinding the socket on $address:$port ... ";
  28. echo "OK\nNow ready to accept connections.\nListening on the socket ... \n";
  29. do { // never stop the daemon
  30. //它接收连接请求并调用一个子连接Socket来处理客户端和服务器间的信息
  31. $msgsock = socket_accept($sock) or  die("socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "/n");
  32. //读取客户端数据
  33. echo "Read client data \n";
  34. //socket_read函数会一直读取客户端数据,直到遇见\n,\t或者\0字符.PHP脚本把这写字符看做是输入的结束符.
  35. $buf = socket_read($msgsock, 8192);
  36. echo "Received msg: $buf   \n";
  37. //数据传送 向客户端写入返回结果
  38. $msg = "welcome \n";
  39. socket_write($msgsock, $msg, strlen($msg)) or die("socket_write() failed: reason: " . socket_strerror(socket_last_error()) ."/n");
  40. //一旦输出被返回到客户端,父/子socket都应通过socket_close($msgsock)函数来终止
  41. socket_close($msgsock);
  42. } while (true);
  43. socket_close($sock);

客户端代码：

  1. <?php
  2. /**
  3. * File name:client.php
  4. * 客户端代码
  5. *
  6. * @author guisu.huang
  7. * @since 2012-04-11
  8. */
  9. set_time_limit(0);
  10. $host = "127.0.0.1";
  11. $port = 2046;
  12. $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create  socket\n"); // 创建一个Socket
  13. $connection = socket_connect($socket, $host, $port) or die("Could not connet server\n");    //  连接
  14. socket_write($socket, "hello socket") or die("Write failed\n"); // 数据传送 向服务器发送消息
  15. while ($buff = socket_read($socket, 1024, PHP_NORMAL_READ)) {
  16. echo("Response was:" . $buff . "\n");
  17. }
  18. socket_close($socket);

使用cli方式启动server：

php server.php

这里注意socket_read函数：

可选的类型参数是一个命名的常数：
PHP_BINARY_READ - 使用系统recv（）函数。用于读取二进制数据的安全。 （在PHP>“默认= 4.1.0）
PHP_NORMAL_READ - 读停在\ n或\r（在PHP <= 4.0.6默认）

针对参数PHP_NORMAL_READ ，如果服务器的响应结果没有\ n。造成socket_read(): unable to read from socket

3. PHP socket内部源码

从PHP内部源码来看，PHP提供的socket编程是在socket，bind,listen等函数外添加了一个层，让其更加简单和方便调用。但是一些业务逻辑的程序还是需要程序员自己去实现。
下面我们以socket_create的源码实现来说明PHP的内部实现。
前面我们有说到php的socket是以扩展的方式实现的。在源码的ext目录，我们找到sockets目录。这个目录存放了PHP对于socket的实现。直接搜索PHP_FUNCTION(socket_create)，在sockets.c文件中找到了此函数的实现。如下所示代码：

  1. /* {{{ proto resource socket_create(int domain, int type, int protocol) U
  2. Creates an endpoint for communication in the domain specified by domain, of type specified by type */
  3. PHP_FUNCTION(socket_create)
  4. {
  5. long            arg1, arg2, arg3;
  6. php_socket      *php_sock = (php_socket*)emalloc(sizeof(php_socket));
  7. if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "lll", &arg1, &arg2, &arg3) == FAILURE) {
  8. efree(php_sock);
  9. return;
  10. }
  11. if (arg1 != AF_UNIX
  12. #if HAVE_IPV6
  13. && arg1 != AF_INET6
  14. #endif
  15. && arg1 != AF_INET) {
  16. php_error_docref(NULL TSRMLS_CC, E_WARNING, "invalid socket domain [%ld] specified for argument 1, assuming AF_INET", arg1);
  17. arg1 = AF_INET;
  18. }
  19. if (arg2 > 10) {
  20. php_error_docref(NULL TSRMLS_CC, E_WARNING, "invalid socket type [%ld] specified for argument 2, assuming SOCK_STREAM", arg2);
  21. arg2 = SOCK_STREAM;
  22. }
  23. php_sock->bsd_socket = socket(arg1, arg2, arg3);
  24. php_sock->type = arg1;
  25. if (IS_INVALID_SOCKET(php_sock)) {
  26. SOCKETS_G(last_error) = errno;
  27. php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to create socket [%d]: %s", errno, php_strerror(errno TSRMLS_CC));
  28. efree(php_sock);
  29. RETURN_FALSE;
  30. }
  31. php_sock->error = 0;
  32. php_sock->blocking = 1;
  33. 1257,1-8      61%
  34. ZEND_REGISTER_RESOURCE(return_value, php_sock, le_socket);
  35. }
  36. /* }}} */

Zend API实际对c函数socket做了包装，供PHP使用。 而在c的socket编程中，我们使用如下方式初始化socket。

  1. //初始化Socket
  2. if( (socket_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1 ){
  3. printf("create socket error: %s(errno: %d)\n",strerror(errno),errno);
  4. exit(0);
  5. }

4. socket函数

函数名 描述
socket_accept() 接受一个Socket连接
socket_bind() 把socket绑定在一个IP地址和端口上
socket_clear_error() 清除socket的错误或最后的错误代码
socket_close() 关闭一个socket资源
socket_connect() 开始一个socket连接
socket_create_listen() 在指定端口打开一个socket监听
socket_create_pair() 产生一对没有差别的socket到一个数组里
socket_create() 产生一个socket，相当于产生一个socket的数据结构
socket_get_option() 获取socket选项
socket_getpeername() 获取远程类似主机的ip地址
socket_getsockname() 获取本地socket的ip地址
socket_iovec_add() 添加一个新的向量到一个分散/聚合的数组
socket_iovec_alloc() 这个函数创建一个能够发送接收读写的iovec数据结构
socket_iovec_delete() 删除一个已分配的iovec
socket_iovec_fetch() 返回指定的iovec资源的数据
socket_iovec_free() 释放一个iovec资源
socket_iovec_set() 设置iovec的数据新值
socket_last_error() 获取当前socket的最后错误代码
socket_listen() 监听由指定socket的所有连接
socket_read() 读取指定长度的数据
socket_readv() 读取从分散/聚合数组过来的数据
socket_recv() 从socket里结束数据到缓存
socket_recvfrom() 接受数据从指定的socket，如果没有指定则默认当前socket
socket_recvmsg() 从iovec里接受消息
socket_select() 多路选择
socket_send() 这个函数发送数据到已连接的socket
socket_sendmsg() 发送消息到socket
socket_sendto() 发送消息到指定地址的socket
socket_set_block() 在socket里设置为块模式
socket_set_nonblock() socket里设置为非块模式
socket_set_option() 设置socket选项
socket_shutdown() 这个函数允许你关闭读、写、或指定的socket
socket_strerror() 返回指定错误号的周详错误
socket_write() 写数据到socket缓存
socket_writev() 写数据到分散/聚合数组

5. PHP Socket模拟请求

我们使用stream_socket来模拟：

  1. /**
  2. *
  3. * @param $data= array=array(‘key‘=>value)
  4. */
  5. function post_contents($data = array()) {
  6. $post = $data ? http_build_query($data) : ‘‘;
  7. $header = "POST /test/ HTTP/1.1" . "\n";
  8. $header .= "User-Agent: Mozilla/4.0+(compatible;+MSIE+6.0;+Windows+NT+5.1;+SV1)" . "\n";
  9. $header .= "Host: localhost" . "\n";
  10. $header .= "Accept: */*" . "\n";
  11. $header .= "Referer: http://localhost/test/" . "\n";
  12. $header .= "Content-Length: ". strlen($post) . "\n";
  13. $header .= "Content-Type: application/x-www-form-urlencoded" . "\n";
  14. $header .= "\r\n";
  15. $ddd = $header . $post;
  16. $fp = stream_socket_client("tcp://localhost:80", $errno, $errstr, 30);
  17. $response = ‘‘;
  18. if (!$fp) {
  19. echo "$errstr ($errno)<br />\n";
  20. } else {
  21. fwrite($fp, $ddd);
  22. $i = 1;
  23. while ( !feof($fp) ) {
  24. $r = fgets($fp, 1024);
  25. $response .= $r;
  26. //处理这一行
  27. }
  28. }
  29. fclose($fp);
  30. return $response;
  31. }

注意，以上程序可能会进入死循环；

这个PHP的feof($fp) 需要注意的地方了，我们来分析为什么进入死循环。

  1. while ( !feof($fp) ) {
  2. $r = fgets($fp, 1024);
  3. $response .= $r;
  4. }

实际上，feof是可靠的，但是结合fgets函数一块使用的时候，必须要小心了。一个常见的做法是：

  1. $fp = fopen("myfile.txt", "r");
  2. while (!feof($fp)) {
  3. $current_line = fgets($fp);
  4. //对结果做进一步处理,防止进入死循环
  5. }

当处理纯文本的时候，fgets获取最后一行字符后，foef函数返回的结果并不是TRUE。实际的运算过程如下：

1) while（）继续循环。

2) fgets 获取倒数第二行的字符串

3) feof返回false，进入下一次循环

4）fgets获取最后一行数据

5)  一旦fegets函数被调用，feof函数仍然返回的是false。所以继续执行循环

6) fget试图获取另外一行，但实际结果是空的。实际代码没有意识到这一点，试图处理另外根本不存在的一行，但fgets被调用了，feof放回的结果仍然是false

7)    .....

8) 进入死循环

时间： 2024-08-26 11:35:25

socket编程 123的相关文章

（转）Java Socket编程

原文出自:http://www.cnblogs.com/rocomp/p/4790340.html Socket是网络驱动层提供给应用程序编程接口和一种机制.可以把Socket比喻成一个港口码头,应用程序只要把货物放到港口码头上,就算完成了货物的运送.对于接收方应用程序也要创建一个港口码头,只需等待货物到达码头后将货物取走. InetAddress          InetAddress类用于标识网络上的硬件资源,标识互联网协议(IP)地址.           该类没有构造方法       

使用libevent进行多线程socket编程demo

最近要对一个用libevent写的C/C++项目进行修改,要改成多线程的,故做了一些学习和研究. libevent是一个用C语言写的开源的一个库.它对socket编程里的epoll/select等功能进行了封装,并且使用了一些设计模式(比如反应堆模式),用事件机制来简化了socket编程.libevent的好处网上有很多,但是初学者往往都看不懂.我打个比方吧,1)假设有N个客户端同时往服务端通过socket写数据,用了libevent之后,你的server程序里就不用再使用epoll或是sele

Java Socket编程----通信是这样炼成的

Java最初是作为网络编程语言出现的,其对网络提供了高度的支持,使得客户端和服务器的沟通变成了现实,而在网络编程中,使用最多的就是Socket.像大家熟悉的QQ.MSN都使用了Socket相关的技术.下面就让我们一起揭开Socket的神秘面纱. Socket编程 一.网络基础知识(参考计算机网络)            关于计算机网络部分可以参考相关博客:           <TCP/IP协议栈及OSI参考模型详解> http://wangdy.blog.51cto.com/3845563/

Linux socket编程 DNS查询IP地址

本来是一次计算机网络的实验,但是还没有完全写好,DNS的响应请求报文的冗余信息太多了,不只有IP地址.所以这次的实验主要就是解析DNS报文.同时也需要正确的填充请求报文.如果代码有什么bug,欢迎指正啊.代码排版有点乱... 本文有以下内容 DNS报文的填充和解析 利用socket API传输信息 一.填充DNS请求报文 随便百度一下,就可以知道DNS报文的格式.所以这里只介绍如何填充DNS报文. 首先是填充报文首部: ? 1 2 3 4 5 6 7 8 9 /* 填充首部的格式大致相同,下面的

socket编程初级

什么是socket 定义 socket通常也称作套接字,用于描述IP地址和端口,是一个通信链的句柄,应用程序通常通过套接字向网络发出请求或者应答网络请求. socket起源于Unix,而Unix/Linux基本哲学之一就是"一切皆文件",对于文件用[打开][读写][关闭]模式来操作.socket就是该模式的一个实现,socket即是一种特殊的文件,一些socket函数就是对其进行的操作(读/写IO.打开.关闭) socket和file的区别: file模块是针对某个指定文件进行[打开]

winsock教程- windows下的socket编程（c语言实现）

winsock教程- windows下的socket编程(c语言实现) 使用winsock进行socket 编程 这是一个学习windows下socket编程(c语言)的快速指南.这是因为一下代码片段只能运行在windows下.windows API中的socket编程部分叫做winsock. 你电脑上做出的任何网络通信背后基本上都有socket,它是一个网络的基本组成部分.举个例子说当你在浏览器键入www.google.com的时候,socket连接到google.com并且取回那个页面然后才

TCP之socket编程

socket(套接字):IP地址+端口号,唯一标识网络中的一个进程 socket编程中建立连接的两个进程都有一个socket来标识唯一一个连接. 网络字节序:网络数据流有大小端之分,发送主机通常将发送缓冲区中的数据按内存地址从低到高的顺序发出,接收主机把从网络上接到的字节依次保存在接收缓冲区中,也是按内存地址从低到高的顺序保存,网络数据流的地址规定:先发出的数据是低地址,后发出的数据是 地址. TCP/IP协议规定,网络数据流应采用大端字节序,即低地址高字节. 例:如果端口号是1000(0x3e

socket编程，简单多线程服务端测试程序

socket编程,简单多线程服务端测试程序 前些天重温了MSDN关于socket编程的WSAStartup.WSACleanup.socket.closesocket.bind.listen.accept.recv.send等函数的介绍,今天写了一个CUI界面的测试程序(依赖MFC)作为补充.程序功能简介如下: 1:一个线程做监听用. 2:监听线程收到客户端连接后,创建新线程接收客户端数据.所有对客户端线程将加入容器,以便管理. 3:服务端打印所有客户端发来的信息. 4:服务端CUI界面输入数字

基于TCP协议下的socket编程

socket: TCP/IP协议中一个端口号和一个IP地址绑定在一起就生成一个socket就表示了网络中唯一的一个进程,它是全双工的工作方式. 基于TCP的socket编程 函数的使用: 1.socket()         #include <sys/types.h>          /* See NOTES */        #include <sys/socket.h>        int socket(int domain, int type, int protoco