PHP 编写基本的 Socket 程序

告诫年轻人

空想是没有用的,个人的能力来源于每一天的努力,而不是一步登天,不要畏惧任何新的知识,水滴石穿,总有一天会柳暗花明。

我的目的

因为在以后的学习中,我可能会用到网络方面的内容,但同时很多写PHP的coder都没写过socket程序,但是肯定听说过它,也肯定听说过网络编程这个词,所以为了今后的学习,我打算在这里先简单的讲解下相关知识,本篇博文自带实例程序,代码托管在码云php-socket-base-code),你只需要下载下来,配置好相关环境,按照说明即可运行,如果无法运行,请联系我。

环境配置

socket编程需要开启php的socket扩展,我用的电脑是windows,所以这里你只需要打开php.ini文件,找到这一行去掉注释就可以了

extension=sockets

官方文档

php的socket编程的官方地址为:php socket

服务端编程

socket编程遵循一定的编程步骤,这几个步骤缺一不可,客户端和服务端编程有所区别,我们首先来看一下服务端。

PHP编写基本的Socket程序

创建套接字

套接字属于系统资源,我们首先调用socket_create方法(参考官方文档:https://www.php.net/manual/en/function.socket-create.php),调用如下:

$this->socket_handle = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if (!$this->socket_handle) {
      //创建失败抛出异常,socket_last_error获取最后一次socket操作错误码,socket_strerror打印出对应错误码所对应的可读性描述
     throw new Exception(socket_strerror(socket_last_error($this->socket_handle)));
} else {
          echo "create socket successful\n";
}

第一个参数指定了,当前套接字是采用ipv4还是ipv6,如果是前者的话,那么传递AF_INET,否则AF_INET6,当然还有一种类型,就是AF_UNIX,这个暂时不讨论,我们一般选择AF_INET(ipv6不是很普及)。
第二个参数,指定了协议的类型,一般选择TCP或者是UDP,TCP是可靠的流传输(生活当中用的最为广泛,保证了可靠性和安全性),UDP则不是,这个参数一般选择TCP。
第三个如果你之前选择了TCP,那么它就是SOL_TCP,否则就是SOL_UDP。

绑定地址和端口号

因为一台主机可能存在多个ip地址,所以你需要指定你的socket监听的是哪一个,常用的值为127.0.0.1,或者是监听所有地址0.0.0.0,那么这里可能有人不明白了,127.0.0.1和0.0.0.0有啥区别呢?127.0.0.1只是一个回环地址,只能用于本机访问,说白了就是自己玩自己的,因为这个ip不对外部开放,所以别人也就无法访问这个地址,所以如果你的服务器地址设置为127.0.0.1,别人想要访问,只能去屎吧。
0.0.0.0严格来说不算是一个ip地址,它的意思是本机的所有IP地址,都是我的,哈哈。
PHP编写基本的Socket程序

明白了上面这个,我们来看这个调用的代码

if (!socket_bind($this->socket_handle, $this->addr, $this->port)) {
         throw new Exception(socket_strerror(socket_last_error($this->socket_handle)));
    } else {
         echo "bind addr successful\n";
 }

是不是很简单,第一个参数就是socket_create返回的结果,第二个参数就是地址了,上面已经说过了,第三个参数是端口号。

监听套接字

经过上面的这些步骤,我们只是创建了一个套接字并且给它绑定了端口号和地址,但是系统怎么知道它是监听套接字呢?所以呢,我们的事情还没有做完,所以我们得告诉它啊,别告诉我你和系统心有灵犀啊!!!

if (!socket_listen($this->socket_handle, $this->back_log)) {
      throw new Exception(socket_strerror(socket_last_error($this->socket_handle)));
  } else {
      echo "socket  listen successful\n";
 }

第二个参数值得说明一哈,请听我细细道来,对于linux系统中的每一个进程而言,系统都维护着待处理套接字的队列(先进先出,总得讲个先来后到吧),上层程序处理业务逻辑总得需要时间吧,所以让你你等着你就等着呗。那么这个队列的大小设置为多大呢?它的值就是这第二个参数,那么我是不是可以设置的很大呢?骚年,你想多了吧?不同的系统这个值有所不同,别说我忽悠你,看下面。

The maximum number passed to the backlog parameter highly depends on the underlying platform. On Linux, it is silently truncated to SOMAXCONN. On win32, if passed SOMAXCONN, the underlying service provider responsible for the socket will set the backlog to a maximum reasonable value. There is no standard provision to find out the actual backlog value on this platform.

你也不必关心这个值精确的数据,没有什么意义。

万事俱备,只欠东风

经过上面的一通操作之后,我们可以开始接受来自客户端的连接了,这个函数就更简单了

$client_socket_handle = socket_accept($this->socket_handle);

这个函数的返回值也是一个套接字句柄,所以你可以对它进行读写操作,在当前的实例程序中,我们做的事情很简单,简单到你可以怀疑人生了。

 $client_socket_handle = socket_accept($this->socket_handle);
        if (!$client_socket_handle) {
            echo "socket_accept call failed\n";
            exit(1);
        } else {
            while (true) {
                $bytes_num = socket_recv($client_socket_handle, $buffer, 100, 0);
                if (!$bytes_num) {
                    echo "socket_recv  failed\n";
                    exit(1);
                } else {
                    echo "content from client:" . $buffer . "\n";
                }
            }
        }

读取套接字

以上面的例子为例,我们使用socket_recv读取来自客户端的内容,这个函数很简单,函数原型如下

socket_recv ( resource $socket , string &$buf , int $len , int $flags ) : int

读取的内容会在第二个参数返回,第三个参数传递我们想要读取的字符数,第四个参数可以直接设置为0,该函数的返回值为实际读取的字节数。

客户端编程

客户端相对于服务端来说,就很简单了,流程如下

PHP编写基本的Socket程序

创建套接字前面已经讲过了,不再详述,客户端只需要连接服务器即可,函数为socket_create,我们来看一哈在当前的例子中,我们是如何调用的。

if (!socket_connect($this->socket_handle, $this->server_addr, $this->server_port)) {
            echo socket_strerror(socket_last_error($this->socket_handle)) . "\n";
            exit(1);
        } else {
            while (true) {
                $data = fgets(STDIN);
                //如果用户输入quit,那么退出程序
                if (strcmp($data, "quit".PHP_EOL) == 0) { //这里匹配用户输入quit表示退出的时候需要加上PHP_EOL预定义常量换行符
                    break;
                }
                socket_write($this->socket_handle, $data);
            }
        }

该函数只需要指定服务器的地址和端口号即可,参数是不是很简单

练习实例

在讲解基本函数调用的时候,我就把自带程序的核心部分,复制出来了,如果要完整的程序,这里是地址(php-socket-base-code),代码非常简单,再次提醒,这些代码完全是用于给大家讲解基本的socket变成操作,为大家以后的学习打下基础,那么如何使用这个例子程序呢?

进入到命令行,开启服务器程序
php TcpServer.php,
打开另外一个命令行界面,
php TcpClient.php,
在客户端界面,输入任何文本,再输入回车,再切换到服务器界面,您将会看到客户端输入的内容

在笔者的电脑上操作实例截图如下:

PHP编写基本的Socket程序

交流

喜欢编程的小伙伴,可以加一下这个qq群,我会给大家深入的讲解Laravel的源代码,和其它的编程知识。

PHP 编写基本的 Socket 程序

本作品采用《CC 协议》,转载必须注明作者和本文链接
微信:okayGoHome
本帖由系统于 4年前 自动加精
Dennis_Ritchie
《L04 微信小程序从零到发布》
从小程序个人账户申请开始,带你一步步进行开发一个微信小程序,直到提交微信控制台上线发布。
《L02 从零构建论坛系统》
以构建论坛项目 LaraBBS 为线索,展开对 Laravel 框架的全面学习。应用程序架构思路贴近 Laravel 框架的设计哲学。
讨论数量: 25

nice work!

4年前 评论

file
不错,就是这边判断输出quit会不成功,没法执行break。也就断不开连接

4年前 评论
curd-boy 3年前

file
加个换行符可以退出了

4年前 评论

看不懂,但是还是想点个赞

4年前 评论
gutao123

这是个单进程单连接的server吧。。。

4年前 评论
Dennis_Ritchie (楼主) 4年前
UKNOW

file

file

我在客户端输入 内容 回车 然后就断掉了 服务端显示失败

4年前 评论
UKNOW (作者) 4年前
three_xtie 3年前
bestcyt

老哥,这个不能开多个客户端的吗

4年前 评论

composer require swoole

4年前 评论
看上隔壁小花了啦 4年前

简单明了.

4年前 评论

如何做到异步不阻塞呢 :unamused: :unamused: :unamused:?

2年前 评论

我是用socket_read这个来读取内容,没有使用socket_recv

2年前 评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!