# 在php-fpm或apache中使用swoole
swoole中绝大部分的模块只能用于CLI命令行环境，只有同步阻塞的swoole_client可以用于php-fpm或apache环境。
[TOC=2,3]
## **同步swoole_client**
~~~php
$client = new swoole_client(SWOOLE_SOCK_TCP); //同步阻塞
$client->connect('127.0.0.1', 9501) or die("connect failed\n");
$client->send(str_repeat("A", 600));
$data = $client->recv(700, 0) or die("recv failed\n");
echo "recv: " . $data . "\n";
~~~
## **在php-fpm/apache中创建长连接**
~~~php
$cli = new swoole_client(SWOOLE_TCP | SWOOLE_KEEP);
~~~
加入SWOOLE_KEEP标志后，创建的TCP连接在PHP请求结束或者调用`$cli->close`时并不会关闭。下一次执行connect调用时会复用上一次创建的连接。长连接保存的方式默认是以ServerHost:ServerPort为key的。可以再第3个参数内指定key。
* SWOOLE_KEEP只允许用于同步客户端
* $swoole_client->close(true)用于关闭长连接
> swoole_client在unset时会自动调用close方法关闭socket
> SWOOLE_KEEP长连接模式在1.6.12后可用，长连接的$key参数在1.7.5后增加
## **在php-fpm/apache中使用task功能**
AsyncTask是swoole提供一套生产者消费者模型，可以方便地将一个慢速任务投递到队列，由进程池异步地执行。task功能目前只能在swoole_server中使用。1.9.0版本提供了RedisServer框架，可以基于RedisServer和Task实现一个Server程序，在php-fpm或apache中直接调用Redis扩展就可以使用swoole的task功能了。
创建RedisServer
~~~
use Swoole\Redis\Server;
$server = new Server("127.0.0.1", 9501, SWOOLE_BASE);
$server->set(array(
'task_worker_num' => 32,
'worker_num' => 1,
));
$server->setHandler('LPUSH', function ($fd, $data) use ($server) {
$taskId = $server->task($data);
if ($taskId === false)
{
return Server::format(Server::ERROR);
}
else
{
return Server::format(Server::INT, $taskId);
}
});
$server->on('Finish', function() {
});
$server->on('Task', function ($serv, $taskId, $workerId, $data) {
//处理任务
});
$server->start();
~~~
* 如果是本机调用可以监听UnixSocket，局域网内调用需要使用IP:PORT
* Task中$data就是客户端投递的数据
* 其他语言也可以使用Redis客户端投递任务
* 可以根据Task任务执行的速度调节task_worker_num控制启动的进程数量，这些进程是由swoole底层负责管理的，在发生致命错误或进程退出后底层会重新创建新的任务进程
**投递任务**
php-fpm/apache中投递任务
~~~php
$redis = new Redis;
$redis->connect('127.0.0.1', 9501);
$taskId = $redis->lpush("myqueue", json_encode(array("hello", "swoole")));
~~~
注意这个RedisServer并不是一台真正的Redis服务器，它只支持LPUSH一个指令。
## **在php-fpm/apache中使用swoole_client_select实现并行处理**
swoole_client的并行处理中用了select来做IO事件循环。
函数原型：
~~~
int swoole_client_select(array &$read, array &$write, array &$error, float $timeout);
~~~
* swoole_client_select接受4个参数，$read, $write, $error 分别是可读/可写/错误的文件描述符。
* 这3个参数必须是数组变量的引用。数组的元素必须为swoole_client对象。 1.8.6或更高版本可以支持swoole_process对象
* $timeout参数是select的超时时间，单位为秒，接受浮点数。
* 调用成功后，会返回事件的数量，并修改$read/$write/$error数组。使用foreach遍历数组，然后执行$item->recv/$item->send来收发数据。或者调用$item->close()或unset($item)来关闭socket。
* swoole_client_select返回0表示在规定的时间内，没有任何IO可用，select调用已超时。
swoole_client用法
~~~php
$clients = array();
for($i=0; $i< 20; $i++)
{
$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC); //同步阻塞
$ret = $client->connect('127.0.0.1', 9501, 0.5, 0);
if(!$ret)
{
echo "Connect Server fail.errCode=".$client->errCode;
}
else
{
$client->send("HELLO WORLD\n");
$clients[$client->sock] = $client;
}
}
while (!empty($clients))
{
$write = $error = array();
$read = array_values($clients);
$n = swoole_client_select($read, $write, $error, 0.6);
if ($n > 0)
{
foreach ($read as $index => $c)
{
echo "Recv #{$c->sock}: " . $c->recv() . "\n";
unset($clients[$c->sock]);
}
}
}
~~~
- swoole简介
- swoole功能概述
- 序章
- 开发必读
- 1 环境搭建
- 1.1 环境搭建
- 1.2 搭建Echo服务器
- 2 初识Swoole
- 2.1 Worker进程
- 2.2 TaskWorker进程
- 2.3 Timer定时器
- 2.4 Process进程
- 2.5 Table内存表
- 2.6 多端口监听
- 2.7 sendfile文件支持
- 2.8 SSL支持
- 2.9 热重启
- 2.10 http_server
- 附录*server配置
- 附录*server函数
- 附录*server属性
- 附录*server回调函数
- 附录*server高级特性
- 心跳检测
- 3 Swoole协议
- 3.1 EOF协议
- 3.2 固定包头协议
- 3.3 Http协议
- 3.4 WebSocket协议
- 3.5 MTQQ协议
- 内置http_server
- 内置websocket_server
- Swoole\Redis\Server
- 4 Swoole异步IO
- 4.1 AsyncIO
- 异步文件系统IO
- swoole_async_readfile
- swoole_async_writefile
- swoole_async_read
- swoole_async_write
- 5 swoole异步客户端
- ws_client
- http_client
- mysql_client
- redis_client
- tcp_client
- http2_client
- 6 swoole协程
- Swoole\Coroutine\Http\Client
- Swoole\Coroutine\MySQL
- Swoole\Coroutine\Redis
- Coroutine\PostgreSQL
- Swoole\Coroutine\Client
- Swoole\Coroutine\Socket
- Swoole\Coroutine\Channel
- Coroutine
- Swoole\Coroutine::create
- Swoole\Coroutine::resume
- Swoole\Coroutine::suspend
- Swoole\Coroutine::sleep
- Coroutine::getaddrinfo
- Coroutine::gethostbyname
- swoole_async_dns_lookup_coro
- Swoole\Coroutine::getuid
- getDefer
- setDefer
- recv
- Coroutine::stats
- Coroutine::fread
- Coroutine::fget
- Coroutine::fwrite
- Coroutine::readFIle
- Coroutine::writeFIle
- Coroutine::exec
- 7 swoole_process
- process::construct
- process::start
- process::name
- process::signal
- process::setaffinity
- process::exit
- process::kill
- process::daemon
- process->exec
- process::wait
- process::alarm
- 8 swoole定时器
- swoole_timer_tick
- swoole_timer_after
- swoole_timer_clear
- 9 swoole_event
- swoole_event_add
- swoole_event_set
- swoole_event_del
- swoole_event_wait
- swoole_event_defer
- swoole_event_write
- swoole_event_exit
- swoole提供的function
- 常见问题
- 客户端链接失败原因
- 如何设置进程数
- 如何实现异步任务
- 如何选择swoole三种模式
- php中哪些函数是阻塞的
- 是否可以共用1个redis或mysql连接
- 如何在回调函数中访问外部的变量
- 为什么不要send完后立即close
- 不同的Server程序实例间如何通信
- MySQL的连接池、异步、断线重连
- 在php-fpm或apache中使用swoole
- 学习Swoole需要掌握哪些基础知识
- 在phpinfo中有在php-m中没有
- 同步阻塞与异步非阻塞选择
- CURL发送POST请求服务器端超时
- 附录
- 预定义常量
- 内核参数调优
- php四种回调写法
- 守护进程程序常用数据结构
- swoole生命周期
- swoole_server中内存管理机制
- 使用jemalloc优化swoole内存分配性能
- Reactor、Worker、Task的关系
- Manager进程
- Swoole的实现
- Reactor线程
- 安装扩展
- swoole-worker手册
- swoole相关开源项目
- 写在后面的话
- 版本更新记录
- 4.0