《当 Swoole 遇上 ThinkPHP5》电子书全集(一)

Swoole简介:

Swoole 是一种PHP高级Web开发框架,框架不是为了提升网站的性能,是为了提升网站的开发效率。最少的性能损耗,换取最大的开发效率。利用 Swoole 框架,开发一个复杂的 Web 功能,可以在很短的时间内完成! Swoole 不是一个像 Zend Framework、CakePHP、Yii、symfony、ThinkPHP 等一样的框架,也不是一个向WordPress、Drupal、Discuz、UChome等开源产品看齐的项目。 Swoole 的目标是向 Java 框架、Ruby On Rails、Python DjangoPylons 等一流框架发起挑战。 运行环境:Linux Windows Mac FreeBSD Unix PHP版本支持:PHP5.3+ 支持的数据库:MS SQL Server、MySQL、IBM DB2、Oracle、Interbase 、SQLite、PostgreSQL、ODBC 支持的运行方式:Web、Cli 命令行脚本、PHP-GTK GUI。

环境要求:

ThinkPHP5 环境要求

ThinkPHP5 支持 Windows,Linux,FreeBSD,MacOS等操作系统,PHP 版本要求 5.4.0 以上版本,ThinkPHP5 无需安装过程,简单来说直接把源码下载下来,直接放到 WEB 目录即可正常使用,但是推荐使用 Composer 来安装 ThinkPHP5,目前 ThinkPHP 最新稳定版本是 5.0.5。

Swoole 环境要求

Swoole 目前仅支持Linux,FreeBSD,MacOS,3类操作系统,Swoole 官方建议使用Ubuntu14/CentOS7 或更高版本的操作系统,PHP 版本要求 PHP5.3.10 以上版本,并且支持PHP7。目前 Swoole 最新稳定版本是 1.9.3。

最佳环境

使用 think-swoole 环境,综合 Swoole 扩展和 ThinkPHP 框架的环境要求来看,目前最低要求是使用 PHP 5.4 版本以上的 Linux 发行版本,笔者推荐使用 PHP 5.6 版本和 CentOS 7.2 64位操作系统。笔者有两套 Swoole 线上项目运行在这个组合的环境下,运行很稳定。笔者也有一个活动项目运行在 PHP 7.0.7 和 CentOS 7.2 下,在运行了10天之后,完成任务而下线。高性能出色的完成了任务。

名称 操作系统 PHP版本
ThinkPHP5 Windows,Linux,FreeBSD,MacOS 5.4+
Swoole Linux,FreeBSD,MacOS 5.3.10 +
最低要求 *nux 5.4+
最佳实践 Linux (Ubuntu14+/CentOS7+) 7.0/7.1

Hello,Swoole

本文假设你已经有了 Linux 操作系统的 PHP 环境,并且符合上一篇文章的环境要求,强烈推荐使用 Vagrant 来搭建开发环境

安装 Swoole PECL 拓展

可以通过 pecl 命令或者通过源码包编译安装,本文采用 pecl 命令来安装 Swoole
在命令行输入

$ > pecl install swoole

安装 Swoole PECL 拓展,执行命令后通过php -m命令来检查 Swoole 是否安装成功,如果返回的拓展列表中包含swoole则表明已经安装成功,也可以通过phpinfo来检查 Swoole 是否安装成功。

安装 ThinkPHP5 框架

1.安装 Composer

如果已经安装了 Composer 可以跳过本步骤,但是请确定通过composer self-update命令来确保已经使用了最新版本的 Composer
使用以下命令可以直接通过 Composer 官网下载 Composer.phar 并自动安装到/usr/local/bin/目录下

$ > php -r "readfile('https://getcomposer.org/installer');" | php -- --install-dir=/usr/local/bin/ --filename=composer
$ > composer self-update

如果以上安装过程极慢的话,可以尝试用以下方式通过 Composer 国内镜像来安装。

$ > php -r "readfile('http://install.phpcomposer.com/installer');" | php -- --install-dir=/usr/local/bin/ --filename=composer
$ > composer config -g repo.packagist composer https://packagist.phpcomposer.com
$ > composer self-update

2.安装 ThinkPHP5 框架

使用以下命令把最新版本的 ThinkPHP5 框架安装到当前目录下的 thinkSwooleFirst 文件夹中

$ > composer create-project topthink/think thinkSwooleFirst  --prefer-dist

安装 think-swoole Composer 包

把命令行目录切换到 thinkSwooleFirst 目录,通过 Composer 安装 think-swoole

$ > composer require topthink/think-swoole

安装 think-swoole Composer 包之前必须先安装好 Swoole PECL 拓展

HelloSwoole

当环境全部搭建完成后,我们在application/index/controller目录下建立Demon.php文件,用来书写 Swoole 与 ThinkPHP5 的 TCP 服务器的 Hello World

<?php
namespace app\index\controller;

// 必须 use 并继承 \think\swoole\Server 类
use think\swoole\Server;

class Demon extends Server
{
    // 监听所有地址
    protected $host = '0.0.0.0';
    // 监听 9501 端口
    protected $port = 9501;
    // 指定运行模式为多进程
    protected $mode = SWOOLE_PROCESS;
    // 指定 socket 的类型为 ipv4 的 tcp socket
    protected $sockType = SWOOLE_SOCK_TCP;
    // 配置项
    protected $option = [
        /** 
         *  设置启动的worker进程数
         *  业务代码是全异步非阻塞的,这里设置为CPU的1-4倍最合理
         *  业务代码为同步阻塞,需要根据请求响应时间和系统负载来调整
         */
        'worker_num' => 4,
        // 守护进程化
        'daemonize'  => true,
        // 监听队列的长度
        'backlog'    => 128
    ];

    /**
     * 收到信息时回调函数
     * @param \swoole_server $serv swoole_server对象
     * @param $fd TCP客户端连接的文件描述符
     * @param $from_id TCP连接所在的Reactor线程ID
     * @param $data 收到的数据内容
     */
    public function onReceive(\swoole_server $server, $fd, $from_id, $data)
    {
        $server->send($fd, 'onReceive: ' . $data);
    }
}

以上代码即使用 ThinkPHP5 和 Swoole 完成了相对简单的 TCP 服务器,接下来就可以运行服务器
使用以下命令即可启动 TCP 服务器

$ > php public/index.php index/Demon/start

我们也可以通过修改配置项deamonize为false,让程序不使用守护进程,更方便我们的调试

使用守护进程方式我们也可以使用lsof工具来检测,端口是否处于正常状态

$ > lsof -i:9501

当确认程序正常运行后,使用telnet工具来连接 TCP 服务器,稍后的文章中我们也会讲述如果使用 swoole 的 TCP 客户端来连接 TCP 服务器

telnet 127.0.0.1 9501

输入hello后会得到以下结果

onReceive: hello

WebSocket PHP 即时通讯开发

PHP 在之前的某一段时间里是被认为无法处理好协议层面的,但是随着Workerman,Swoole 以及目前风头正上的 MEEPOPS 的出现,彻底打破了这一局面,让很多人发现原来 PHP 能做的事越来越多。

接下来本章将详细介绍如何用 swoole_websocket_server 和 ThinkPHP5 的命令行来建立 websocket 服务器。

本章没有使用think-swoole Composer 包。

创建 ThinkPHP5 自定义命令行

在 ThinkPHP5 中推荐使用命令行工具来管理运行不需要外部访问的程序,如 http 服务器启动程序,websocket 服务器启动程序,crontab(计划任务/定时器)等

1.创建命令行类

创建application/console/WebSocket.php文件

<?php
namespace app\Console;

use think\console\Command;
use think\console\Input;
use think\console\Output;

class WebSocket extends Command
{
    // 命令行配置函数
    protected function configure()
    {
        // setName 设置命令行名称
        // setDescription 设置命令行描述
        $this->setName('websocket:start')->setDescription('Start Web Socket Server!');
    }

    // 设置命令返回信息
    protected function execute(Input $input, Output $output)
    {
        $output->writeln("WebSocket: Start.\n");
    }
}

2.修改配置文件

文件所在 application/command.php

<?php
return [
    'app\console\WebSocket',
];

这时在项目根目录输入命令行就可以看到已经配置好的命令行类及描述

$ > php think

编写 Web Socket 逻辑代码

接下来我们就可以正式编写 web socket 服务器的代码了,Swoole 帮我们内置了 web socket 服务器支持,通过几行 PHP 代码就可以写出一个异步非阻塞多进程的 web scoket 服务器。
在application/console/WebSocket.php文件中继续编写代码

<?php
namespace app\Console;

use think\console\Command;
use think\console\Input;
use think\console\Output;

class WebSocket extends Command
{
    // Server 实例
    protected $server;

    protected function configure()
    {
        $this->setName('websocket:start')->setDescription('Start Web Socket Server!');
    }

    protected function execute(Input $input, Output $output)
    {
        // 监听所有地址,监听 10000 端口
        $this->server = new \swoole_websocket_server('0.0.0.0', 10000);

        // 设置 server 运行前各项参数
        // 调试的时候把守护进程关闭,部署到生产环境时再把注释取消
        // $this->server->set([
        //     'daemonize' => true,
        // ]);

        // 设置回调函数
        $this->server->on('Open', [$this, 'onOpen']);
        $this->server->on('Message', [$this, 'onMessage']);
        $this->server->on('Close', [$this, 'onClose']);

        $this->server->start();
        // $output->writeln("WebSocket: Start.\n");
    }

    // 建立连接时回调函数
    public function onOpen(\swoole_websocket_server $server, \swoole_http_request $request)
    {
        echo "server: handshake success with fd{$request->fd}\n";
    }

    // 收到数据时回调函数
    public function onMessage(\swoole_websocket_server $server, \swoole_websocket_frame $frame)
    {
        echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
        $server->push($frame->fd, "this is server");
    }

    // 连接关闭时回调函数
    public function onClose($server, $fd)
    {
        echo "client {$fd} closed\n";
    }
}

在命令行输入php think websocket:start启动 web socket 服务器

接下来我们使用 JavaScript 代码来测试 Web Socket 服务器是否正常运行,推荐使用 Chrome 来进行调试

<script>
var  websocket = new WebSocket('ws://localhost:10000'); 

websocket.onopen = function (evt) { onOpen(evt) }; 
websocket.onclose = function (evt) { onClose(evt) }; 
websocket.onmessage = function (evt) { onMessage(evt) }; 
websocket.onerror = function (evt) { onError(evt) }; 

function onOpen(evt) {
    console.log("Connected to WebSocket server."); 
} 
function onClose(evt) { 
    console.log("Disconnected"); 
}
function onMessage(evt) { 
    console.log('Retrieved data from server: ' + evt.data); 
} 
function onError(evt) { 
    console.log('Error occured: ' + evt.data); 
}
</script>

打开 Chrome 浏览器的调试工具,切换到 Console 选项卡下看到如下图结果,表示 web socket 连接成功

同时服务器端命令行下应该看到如下回执消息

server: handshake success with fd1
点赞

发表评论

电子邮件地址不会被公开。 必填项已用*标注