Socket介绍

什么是socket 所谓socket通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。

在Internet上的主机一般运行了多个服务软件，同时提供几种服务。每种服务都打开一个Socket，并绑定到一个端口上，不同的端口对应于不同的服务。

Socket连接过程

根据连接启动的方式以及本地套接字要连接的目标，套接字之间的连接过程可以分为三个步骤：服务器监听，客户端请求，连接确认。

(1)服务器监听：是服务器端套接字并不定位具体的客户端套接字，而是处于等待连接的状态，实时监控网络状态。

(2)客户端请求：是指由客户端的套接字提出连接请求，要连接的目标是服务器端的套接字。为此，客户端的套接字必须首先描述它要连接的服务器的套接字，指出服务器端套接字的地址和端口号，然后就向服务器端套接字提出连接请求。

(3)连接确认：是指当服务器端套接字监听到或者说接收到客户端套接字的连接请求，它就响应客户端套接字的请求，建立一个新的线程，把服务器端套接字的描述发给客户端，一旦客户端确认了此描述，连接就建立好了。而服务器端套接字继续处于监听状态，继续接收其他客户端套接字的连接请求

1、测试环境：

服务器ip：192.168.150.1

客户端ip：192.168.150.2

2、测试过程：

客户端服务器将在本机(192.168.150.2)通过socket发送数据到服务端(192.168.150.2)的socket服务器上，服务端接收到客户端发送的数据后返回一些信息给客户端。

3、服务端文件内容：#server.php

//获取tcp协议号码。

$tcp = getprotobyname("tcp");

// 建立server端socket ，创建并返回一个套接字，也称作一个通讯节点。一个典型的网络连接由 2 个套接字构成，一个运行在客户端，另一个运行在服务器端。

$socket = socket_create(AF_INET, SOCK_STREAM, $tcp);

//绑定要监听的ip和端口，这里绑定的ip一定要写局域网ip，写成127.0.0.1客户端将无法与服务端建议连接。

socket_bind($socket, '192.168.150.1', 10008);

//监听端口

socket_listen($socket);

//初始化一个数据，和客户端通信

$buffer = "connect";

while (true) {

// 接受客户端请求过来的一个socket连接

$connection = socket_accept($socket);

if(!$connection){

echo "connect faild";

}else{

echo "Socket connected\n";

// 向客户端传递一个信息数据

if ($buffer != "") {

echo "send data to client\n";

socket_write($connection, $buffer . "\n");

echo "Wrote to socket\n";

} else {

echo "no data in the buffer\n" ;

}

// 从客户端获取得的数据

while ($data = @socket_read($connection, 1024, PHP_NORMAL_READ)) {

printf("Buffer: " . $data . "\n");

//取得信息给客户端一个反馈, Thank you client, you data is  Received success发给客户端的回应信息。

socket_write($connection, "Thank you client, you data is  Received success\n");

}

}

//关闭 socket

socket_close($connection);

printf("Closed the socket\n");

}

?>

4、客户端文件内容：

client.php

// 建立客户端的socet连接

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

//连接服务器端socket

$connection = socket_connect($socket, '192.168.150.1', 10008);

//要发送到服务端的信息。

$send_data = "This data will Send to server!";

//客户端去连接服务端并接受服务端返回的数据，如果返回的数据保护not connect就提示不能连接。

while ($buffer = @socket_read($socket, 1024, PHP_NORMAL_READ)) {

if (preg_match("/not connect/",$buffer)) {

echo "don`t connect\n";

break;

} else {

//服务端传来的信息

echo "Buffer Data: " . $buffer . "\n";

echo "Writing to Socket\n";

// 将客户的信息写到通道中，传给服务器端

if (!socket_write($socket, "$send_data\n")) {

echo "Write failed\n";

}

//服务器端收到信息后，客户端接收服务端传给客户端的回应信息。

while ($buffer = socket_read($socket, 1024, PHP_NORMAL_READ)) {

echo "sent to server:$send_data\n response from server was:" . $buffer . "\n";

}

}

}

?>

5、在服务端socket服务启动进程。

#/usr/local/php/bin/php -a /home/server.php

Interactive mode enabled6、服务端启动后查看启动的进程及端口。

#netstat -tnlp |grep 10008

tcp        0      0 192.168.150.13:10008        0.0.0.0:*                   LISTEN      28892/php

7、在客户端(192.168.1.2)上执行传输

#/usr/local/php/bin/php -a  client.php

Interactive mode enabled

Buffer Data: connect

Writing to Socket

sent to server:This data will Send to server!

response from server was:Thank you client, you data Information Received

8、回到服务端上查看接收到的信息。

#/usr/local/php/bin/php -a /home/server.php

Interactive mode enabled

Socket connected

send data to client

Wrote to socket

Buffer: This data will Send to server!

9、参考资料

socket_create()函数需要三个参数：一个协议、一个socket类型、一个公共协议。socket_create()函数运行成功返回一个包含socket的资源类型，如果没有成功则返回false。

Socket函数

函数名      描述

socket_accept()    接受一个Socket连接

socket_bind()     把socket绑定在一个IP地址和端口上

socket_close()     关闭一个socket资源

socket_connect()    开始一个socket连接

socket_create()    产生一个socket，相当于产生一个socket的数据结构

socket_listen()     监听由指定socket的所有连接

socket_read()     读取指定长度的数据

socket_readv()     读取从分散/聚合数组过来的数据

socket_send()     这个函数发送数据到已连接的socket

socket_write()     写数据到socket缓存

socket_writev()    写数据到分散/聚合数组

参考文档：http://blog.51yip.com/php/673.html