PHP-Socket服务端客户端发送接收通讯实例详解

时间 2019-11-20

标签 php socket 服务客户端发送接收通讯实例详解栏目 PHP 繁體版

原文原文链接

原创做品，容许转载，转载时请务必以超连接形式标明文章原始出处、做者信息和本声明。不然将追究法律责任。 http://fighter.blog.51cto.com/1318618/1533957

Socket介绍
php

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

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

Socket链接过程缓存

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

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

（2）客户端请求：是指由客户端的套接字提出链接请求，要链接的目标是服务器端的套接字。为此，客户端的套接字必须首先描述它要链接的服务器的套接字，指出服务器端套接字的地址和端口号，而后就向服务器端套接字提出链接请求。数据结构

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

socket百科：http://baike.baidu.com/view/13870.htm tcp

一、测试环境：函数

服务器ip：192.168.150.1

客户端ip：192.168.150.2

二、测试过程：

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

三、服务端文件内容：

 
        #server.php 
       
        <?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" 
        );  
       
        }  
       
        ?>

 
        四、客户端文件内容： 
       
        client.php 
       
        <?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" 
        ;  
       
        }         
       
        }  
       
        }  
       
        ?>

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

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

Interactive mode enabled

六、服务端启动后查看启动的进程及端口。

#netstat -tnlp |grep 10008
tcp 0 0 192.168.150.13:10008 0.0.0.0:* LISTEN 28892/php

七、在客户端（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

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

#/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!

九、参考资料

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