一、Swoole 安装
下载源码编译安装( pecl install swoole安装易失败)：
#下载源码
git clone https://github.com/swoole/swoole-src.git
#如果clone不下来可以选择： git clone ttps://gitee.com/swoole/swoole.git
#进入源码目录并选择最新tag
cd swoole-src
git checkout v4.3.3
#或 cd swoole
#git checkout v4.3.2
phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make && make install
#配置php.ini 添加：
extension=swoole.so
#执行php -m 查看拓展是否安装成功
二、Swoole 搭建Http服务器
1、简单服务搭建
//(1)创建swool的http服务器对象
$serv = new swoole_http_server('0.0.0.0',8000);
//(2)当浏览器链接点这个http服务器的时候,向浏览器发送helloworld
$serv->on('request',function($request,$response){
//(2.1)$request包含这个请求的所有信息，比如参数
//(2.2)$response包含返回给浏览器的所有信息，比如helloworld
var_dump($request);
var_dump($response);
//(2.3)向浏览器发送helloworld
$response->end("hello world");
});
//(3)启动http服务器
$serv->start();
?>
#执行测试
php sw_http.php
curl http://127.0.0.1:8000
2、原理解析
启动swoole的时候会启动Manager进程和Master进程。对于Manager进程，用于管理Worker进程(我们业务层的逻辑代码一般放在这里)和Task进程(用于在某个特定的时间或者条件下执行的代码)。对于Master进程，用于底层的开发，后面详细介绍.如下图：
线程和进程的模型
1. 在这个swoole服务器启动后，会创建三个进程
* Manager
* Worker
* Task
2.这个Manager进程是Worker进程的守护进程，在这个Worker进程意外结束后，这个Manager进程会重新启动Workder进程，Manager进程只有一个，而这个Worker可以有多个。
3.Worker进程通过给这个Task进程发送任务，可以把一些计算量大的任务转移到Task进程，这样我们的Worker进程就可以高速处理客户端的请求，提高并发量。
4.reactor线程是swoole底层处理高并发，最大限度的调用底层资源。
swoole执行过程
image.png
3、简单的swoole http 服务器实例
use Swoole\Http\Server as http_server;
$setting = [
'reactor_num' => 1,
'worker_num' => 2,
'max_request' => 1000,
'task_worker_num' => 1,
'task_tmpdir' => '/tmp',
'daemonize' => 0,
'log_file' => __DIR__.'/swlog.txt',
'pid_file' => __DIR__.'/swhttpserver.pid',
];
function startSwHttpServer($setting){
$webserver = new http_server('0.0.0.0', '8881', SWOOLE_PROCESS, SWOOLE_SOCK_TCP);//如果ssl SWOOLE_SOCK_TCP | SWOOLE_SSL
$webserver->set($setting);
$webserver->on('Start', function(http_server $server) {
echo 'Start...',"\n";
// 重新设置进程名称
swoole_set_process_name('swhttp-master');
});
$webserver->on('ManagerStart', function(http_server $server) {
echo 'manager start...',"\n";
// 重新设置进程名称
swoole_set_process_name('swhttp-manager');
});
$webserver->on('ManagerStop', function(http_server $server) {
echo 'manager stop...',"\n";
});
$webserver->on('WorkerStart', function(http_server $server, $worker_id) use($setting) {
// 设置worker的进程
if($worker_id >= $setting['worker_num']) {
swoole_set_process_name("swhttp-task".$worker_id);
}else {
swoole_set_process_name("swhttp-worker".$worker_id);
}
// 延迟绑定
onWorkerStart($server, $worker_id);
});
$webserver->on('WorkerStop', function(http_server $server, $worker_id) {
echo 'worker stop...',"\n";
});
$webserver->on('request', function(Request $request, Response $response) {
try{
onRequest($request, $response);
return true;
}catch(\Exception $e) {
echo $e;
}
});
$webserver->on('task', function(http_server $server, $task_id, $from_worker_id, $data) {
try{
$task_data = unserialize($data);
onTask($server, $task_id, $from_worker_id, $task_data);
}catch(\Exception $e) {
echo $e;
}
});
$webserver->start();
}
//请求处理即传统web/MVC框架启动处
function onRequest($request, $response){
echo 'onRequest...',"\n";
}
function onWorkerStart($server, $worker_id){
echo 'onWorkerStart...',"\n";
}
function onTask($server, $task_id, $from_worker_id, $task_data){
echo 'onTask...',"\n";
}
startSwHttpServer($setting);
//在onRequest方法中启动执行MVC框架
4、接入Slim框架
1、composer create-project slim/slim-skeleton ss
2、cd ss
3、创建脚本SlimSwooleHttpServier.php 脚本如下：
use Slim\Http\Environment;
class SlimSwooleHttpServier{
public $host='0.0.0.0';
public $port=6666;
public $http="";
public function __construct()
{
$this->http = new Swoole\Http\Server($this->host, $this->port);
$this->http->set([
//'daemonize'=>1,
'worker_num'=>4
]);
$this->http->on('Start',[$this,'MasterStart']);
$this->http->on('ManagerStart',[$this,'ManagerStart']);
$this->http->on('WorkerStart',[$this,'WorkerStart']);
$this->http->on('request',[$this,'request']);
$this->http->start();
}
public function MasterStart(){
swoole_set_process_name('sshttp-master');
}
public function ManagerStart(){
swoole_set_process_name('sshttp-manager');
}
public function WorkerStart($server,$worker_id){
define("ROOT",__DIR__);
define('APP', ROOT . '/src');
swoole_set_process_name('sshttp-worker');
require ROOT . '/vendor/autoload.php';
echo $worker_id."\n";
}
public function request($request,$response){
$config = require APP . '/settings.php';
$config['environment'] = function () use($request) {
$_SERVER = [];
foreach ($request->server as $key => $value) {
$_SERVER[strtoupper($key)] = $value;
}
return new Environment($_SERVER);
};
$_GET=[];
if(isset($request->get)){
$_GET = $request->get;
}
$_POST=[];
if(isset($request->post)){
$_POST = $request->post;
}
$app = new \Slim\App($config);
require APP . '/dependencies.php';
require APP . '/routes.php';
// Register middleware
$middleware = require APP . '/middleware.php';
$middleware($app);
// Register routes
$routes = require APP . '/routes.php';
$routes($app);
// Run app
$slimResponse = $app->run(true);
$headers = $slimResponse->getHeaders();
foreach ($headers as $name => $values) {
$response->header($name, implode(", ", $values));
}
$response->header("X-Powered-By", "Salamander");
$response->end($slimResponse->getBody());
}
}
new SlimSwooleHttpServier();
?>
4、添加路由：vim src/routes.php 添加路由：
$app->get('/hello/{name}', function (Request $request, Response $response, array $args) {
$name = $args['name'];
$response->getBody()->write("Hello, $name\n");
return $response;
});
5、执行php SlimSwooleHttpServier.php
6、测试：curl -i http://127.0.0.1:6666/hello/123
HTTP/1.1 200 OK
Content-Type: text/html; charset=UTF-8
X-Powered-By: Salamander
Server: swoole-http-server
Connection: keep-alive
Date: Tue, 21 May 2019 01:31:46 GMT
Content-Length: 10
Hello, 123