赵工的个人空间

要用PHP进行Socket编程，需要加载PHP扩展，Socket库。一般安装包内的扩展库已经包括php_sockets.dll，在windows下加载Socket库很简单，只需要在PHP配置文件php.ini中找到：
;extension=php_sockets.dll
将其改为：
extension=php_sockets.dll
即可。即把这条语句前面的注释去掉。然后重启Apache，运行phpinfo()，看看有没有Socket库说明，可以知道是否成功加载了Socket库。

2.Socket原理：

Socket不过是一个数据结构，可以用此去开始一个客户端和服务器之间的会话。会话中的服务器会一直监听网络，随时准备产生一个新的会话。如果有客户端连接请求并且服务器端接受了客户端的连接请求，那么就开始进行会话。这时，如果客户端能够发生信息到服务器，服务器也能发送信息给客户端。
要创建一个Socket，需要三个变量：一个协议、一个Socket类型和一个公共协议类型。
下表列出了Socket协议类型：

下表列出了Socket类型：

下表列出了可选择的公共协议类型：

3.Socket函数和用法：

可以在PHP中使用socket_create()函数来产生一个Socket，这个函数需要三个参数，运行成功返回一个包含Socket的资源类型，没有成功则返回false。语法格式：
resource socket_create(int protocol, int socketType, int commonProtocol);
然后，就能够使用操作Socket的内建函数。这些内建函数能够绑定Socket到一个IP，监听一个Socket的通信，接收一个Socket。示例：
<?php
  $commonProtocol=getprotobyname('tcp');
  $socket=socket_create(AF_INET, SOCK_STREAM, $commonProtocol);
  socket_bind($socket, 'localhost', 1337);
  socket_listen($socket);
  //其他Socket操作
?>
上面的代码产生了一个服务器端，其中getprotobyname()使用公共协议名字来获取一个协议类型，这里使用的是TCP公共协议。也可以使用：
  $socket=socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
来替代上述代码的前两行。后面的代码是产生一个Socket并且返回一个Socket资源，然后把Socket绑定到一个IP地址和某一个端口上，接着监听所有进来的Socket连接。
下表列出部分常用的PHP中的Socket内建函数：

4.Socket实例：

①简单Socket服务器simple_server.php：
<?php
  $commonProtocol=getprotobyname('tcp');
  $socket=socket_create(AF_INET, SOCK_STREAM, $commonProtocol);
  socket_bind($socket, 'localhost', 1234);
  socket_listen($socket);
  //接受连接
  $conn=socket_accept($socket);
  $msg="成功连接到socket……";
  $msg=iconv('utf-8', 'gbk', $msg);
  if ($conn) {
    socket_write($conn, "$msg\n\r");
  }
  //关闭连接
  socket_close($conn);
?>
应该使用命令提示符来运行上面的实例，因为这里将产生一个服务器，而不是一个网页。如果尝试使用Web浏览器来运行这个脚本，有可能运行时间会超过30秒的限时。当然，也可以设置一个无限的运行时间：
set_time_limit(0);
当然最好还是使用命令提示符来运行脚本：
php.exe simple_server.php
如果没有在系统的环境变量中设置php解释器的路径，就需要给php.exe指定详细的路径。当运行这个服务器端时，就能够通过远程登录Telnet的方式连接到端口1234来测试这个服务器。
telnet localhost 1234
需要注意，要在命令行下正确显示中文，需要把$msg改为gbk编码，因为windows命令行的字符编码是gbk。可以通过使用gbk编码来编写脚本，从而避免中文乱码。如果脚本不是gbk，就需要用iconv函数对$msg进行编码转换，这样才能看到正确的信息。
②交互式的服务器：
<?php
  //创建Socket
  $commonProtocol=getprotobyname('tcp');
  if ($socket=socket_create(AF_INET, SOCK_STREAM, $commonProtocol)===false) {
    echo "socket_create()错误：".socket_strerror(socket_last_error())."\n";
  }
  //绑定端口
  $addr='localhost';
  $port=1234;
  if (socket_bind($socket, $addr, $port)===false) {
    echo "socket_bind()错误：".socket_strerror(socket_last_error())."\n";
  }
  //监听
  if (socket_listen($socket)===false) {
    echo "socket_listen()错误：".socket_strerror(socket_last_error())."\n";
  }
  //设置欢迎信息
  $msg="欢迎连接PHP socket服务器。\r\n"."要退出连接可以输入'quit';\r\n"."要关闭服务器请输入'shutdown'.\r\n";
  //编码转换
  $msg=iconv('utf-8', 'gbk', $msg);
  while (true) {
    //接受所有的连接请求
    if ($conn=socket_accept($socket)===false) {
  echo "socket_accept()错误：".socket_strerror(socket_last_error())."\n";
  break;
    }
  //检查是否有欢迎信息，如果有则在客户连接后输出
    if ($msg!="") {
  socket_write($conn, "$msg\n\r");
    }
  //读取输入
    while (true) {
  //读取提示符
  $prompt='PHP Server>';
  socket_write($conn, $prompt);
      if (false===($buf=socket_read($conn, 2048, PHP_NORMAL_READ))) {
    echo "socket_read()错误：".socket_strerror(socket_last_error())."\n";
    break 2;
      }
  //剔除无意义的输入
      if (!($buf=trim($buf))) {
    continue;
      }
  //退出连接
      if ($buf=='quit') {
    break;
      }
  //关闭服务
      if ($buf=='shutdown') {
    //关闭连接并跳出循环
        socket_close($conn);
    break 2;
      }
  //反馈信息
  $talkback="接收到输入：";
  $talkback=iconv('utf-8', 'gbk', $talkback);
  $talkback.=$buf.”\r\n”;
  socket_write($conn, $talkback, strlen($talkback));
  //服务器端记录
  echo "$buf\n";
}
  //关闭连接
  socket_close($conn);
  echo iconv('utf-8', 'gbk', '关闭连接')."\r\n\r\n";
  }
//关闭服务
socket_close($socket);
?>
在使用“telnet localhost 1234”连接服务器后可以看到Socket服务端对输入的响应。