[PHP] 被swoole坑哭的PHP程序员 | IT知识库
-& 正文阅读
[PHP]被swoole坑哭的PHP程序员
被swoole坑哭的PHP程序员
& & 本文主要记录一下学习swoole的过程、填过的坑以及swoole究竟有多么强大！& &&首先说一下对swoole的理解：披着PHP外衣的C程序。很多PHPer朋友看到swoole提供的强大功能、外界对其的崇拜便跃跃欲试的安装、调试其demo、编写新功能，然后兴奋的奔走相告。没过几天当你按照自己的理解继续用swoole时，发现代码并没有按照自己的预期运行，然后开始破口大骂，什么破东西呀，代码跟demo基本一样，为啥运行不通呢？什么狗屁work、task、共享内存、ipcs、异步，各种问题涌现，然后迅速去查官方文档，发现文档中竟然对这些并没有提及，只是简单的介绍怎么使用，此时几乎对swoole丧失希望。遇到的几点问题：
1：关于phper常用的全局变量（global）为什么在onRequest函数中不能使用。因为swoole是多线程编程，global是不能在多个进程间共享的。例global $i = 0;function onRequest() {& & echo $i++;}如果在swoole中写一个上面的程序，并不会每次访问输出一个递增的数字。如果要实现预期的效果，需要使用swoole_table的相关函数。2：什么是异步、什么是回高对于phper来说，对异步、回调的理解估计就是ajax。当看到swoole里面对异步、回调的解释，貌似很简单的样子，就这样在没有任何多线程编辑经验的时候贸然用了swoole，结果被坑的偷偷撸代码好几个通宵来填自己的坑。3：为什么onReceive收到的数据这么大客户端发送的多次请求，服务端是可以一次性接收的。并不是客户端发送一次，服务端接收一次4：自制httpserve写一个http服务端，然后通过浏览器访问这个自制的服务器，刷新一次浏览器，服务端为什么为接收到两次请求？这个问题估计困饶了好多初次用swoole写httpserver的朋友。因为浏览器会多发一个favicon.ico请求。原因出现这种情况的原因其实很简单，大部分phper都只会php这一种语言，主要用途就是做web，写业务逻辑。很少去了解服务器程序的开发。有一次一个朋友用swoole写了一个简单的服务端，一个客户端，跑过来问我为什么都启动了却都收不到数据，我简单看了下代码，所有连接确实都成功了，两端都设置了onReceive回调，代码没问题，看到最后才发现他的服务端、客户端都设置了接到消息的回调函数，但是两端都没有向对方发消息，两端处于僵持状态。然后swoole官方对于这种常识问题没有给出说明，只是说如何设置回调、如何发消息，如何这样，如何那样。对于有服务端开发经验的同学来说，肯定不会遇到这种问题，swoole文档也不需要指明需要这样做，因为这是常识。但对于phper来说，指明这一点是非常重要的，因为如上面所说phper是没有这方面认知的，只有服务端开发经验的程序员有才会有。swoole的特色：网络通信框架、异步、多线程。这些特性正是php所不完善的功能（虽然官方提供很多基础函数可以实现这些功能，然后缺少中文文档，很少有人用php来实现这部分功能），普通的phper也不具备这些特性的基础认知，所以贸然使用swoole难免会遇到一些根本在swoole官方查不到的常识问题。使用swoole必须要掌握的技能
多线程编程
进程间通信
网络协议TCP/UDP的认知
PHP的各项基本技能
个人学习swoole的经历在很久之前我也是一个只会php的程序员，后来一次偶然机会需要用httpsqs，用了一段时间后发现有一些个性的需求，于是就开始看源码。这真是不看不知道，一看吓一跳，httpsqs只是一层简单的包装，内部是一个Tokyo Cabinet数据库，印象中封装的代码也就一百多行。主要思路就是用C语言的libevent做了一个http服务器，接收请求读写tokyo cabinet数据库，当时按照这种思路做出来的程序确实不少。后来我就突发奇想，既然C语言可以用libevent函数，那PHP肯定也可以用libevent监听网络，接收请求后读写数据库做队列服务。后来经过查php官方文档，PHP确实提供一系统完整的函数来完成这些功能，甚至多线程的全套函数都有提供，但中文文档太少，网上也很少搜索到成熟的代码。在逼不得已的情况下，补习了linux-C多线程开发的基本原理，进程间通信的常用方法，也用来做了一些简单的demo。唯一的感觉就是写一个简单的功能，设计起来还真复杂。就在快要放弃的时候，swoole出现了。swoole所提供的功能正是php所缺失的功能，简直是太棒了。swoole做为一种网络通信框架，只需要简单的几行设置，一个服务器就搭建起来了，以后就是不断的去完善业务代码。之前在libevent交流群中得知swoole的设计在c\c++中并不是最好的框架设计，但其亮点就是把基本功能用C封装好，业务功能留给世界上最好的语言PHP来编写。自此便开始了swoole的填坑之旅。总结swoole并不是一个简单的PHP框架，正如swoole官方首页的第一句话&重新定义PHP&，千万不要用旧有php的思想来写swoole代码！swoole重新激活了PHP，php成就了swoole!
加: 16:00:42&
更: 15:20:03&
&&网站联系: qq: email:&Swoole实例
swoole是什么？Swoole是一个PHP的C扩展，可用来开发PHP的高性能高并发TCP/UDP Server。Swoole的网络IO部分基于epoll/kqueue事件循环，是全异步非阻塞的。 业务逻辑部分使用多进程同步阻塞方式来运行。这样既保证了Server能够应对高并发和大量TCP连接。又保证业务代码仍然可以简单的编写。Swoole1.6.2之后增加了异步支持，应用程序也可以像node.js一样写异步回调。Swoole与Node.js相比更强大，支持同步/异步、多进程并行，Swoole提供了进程生命周期管理、内存保护机制，开发者无需考虑底层细节，专注于业务逻辑和功能的开发。Swoole底层内置了异步非阻塞、多线程的网络IO服务器。PHP程序员仅需处理事件回调即可，无需关心底层。与Nginx/Tornado/Node.js等全异步的框架不同，Swoole既支持全异步，也支持同步。Swoole从2.0版本开始支持了内置协程，可以使用完全同步的代码实现异步程序。PHP代码无需额外增加任何关键词，底层自动进行协程调度，实现异步。Swoole是开源免费的自由软件，授权协议是Apache2.0。企业和开发者均可免费使用Swoole的代码，并且在Swoole之上所作的修改无需开源。Swoole官网地址：优势纯C编写性能极强简单易用开发效率高事件驱动异步非阻塞并发百万TCP连接TCP/UDP/UnixSock服务器端/客户端全异步/半异步半同步支持多进程/多线程CPU亲和性/守护进程支持IPv4/IPv6网络Swoole&HttpServer实现示例：$serv = new Swoole\Http\Server("127.0.0.1", 9502);
$serv-&on('Request', function($request, $response) {
var_dump($request-&get);
var_dump($request-&post);
var_dump($request-&cookie);
var_dump($request-&files);
var_dump($request-&header);
var_dump($request-&server);
$response-&cookie("User", "Swoole");
$response-&header("X-Server", "Swoole");
$response-&end("&h1&Hello Swoole!&/h1&");
$serv-&start();Swoole WebSocket Server实现示例：$serv = new Swoole\Websocket\Server("127.0.0.1", 9502);
$serv-&on('Open', function($server, $req) {
echo "connection open: ".$req-&
$serv-&on('Message', function($server, $frame) {
echo "message: ".$frame-&
$server-&push($frame-&fd, json_encode(["hello", "world"]));
$serv-&on('Close', function($server, $fd) {
echo "connection close: ".$
$serv-&start();Swoole&TCP Server实现示例：$serv = new Swoole\Server("127.0.0.1", 9501);
$serv-&set(array(
'worker_num' =& 8,
//工作进程数量
'daemonize' =& true, //是否作为守护进程
$serv-&on('connect', function ($serv, $fd){
echo "Client:Connect.\n";
$serv-&on('receive', function ($serv, $fd, $from_id, $data) {
$serv-&send($fd, 'Swoole: '.$data);
$serv-&close($fd);
$serv-&on('close', function ($serv, $fd) {
echo "Client: Close.\n";
$serv-&start();Swoole&TCP Client实现示例：$client = new Swoole\Client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
//设置事件回调函数
$client-&on("connect", function($cli) {
$cli-&send("hello world\n");
$client-&on("receive", function($cli, $data){
echo "Received: ".$data."\n";
$client-&on("error", function($cli){
echo "Connect failed\n";
$client-&on("close", function($cli){
echo "Connection close\n";
//发起网络连接
$client-&connect('127.0.0.1', );Swoole&异步MySQL实现示例$db = new Swoole\MySQL;
$server = array(
'host' =& '127.0.0.1',
'user' =& 'test',
'password' =& 'test',
'database' =& 'test',
$db-&connect($server, function ($db, $result) {
$db-&query("show tables", function (Swoole\MySQL $db, $result) {
if ($result === false) {
var_dump($db-&error, $db-&errno);
} elseif ($result === true) {
var_dump($db-&affected_rows, $db-&insert_id);
var_dump($result);
$db-&close();
});Swoole&异步Redis/异步Http客户端实现示例$redis = new Swoole\R
$redis-&connect('127.0.0.1', 6379, function ($redis, $result) {
$redis-&set('test_key', 'value', function ($redis, $result) {
$redis-&get('test_key', function ($redis, $result) {
var_dump($result);
$cli = new Swoole\Http\Client('127.0.0.1', 80);
$cli-&setHeaders(array('User-Agent' =& 'swoole-http-client'));
$cli-&setCookies(array('test' =& 'value'));
$cli-&post('/dump.php', array("test" =& 'abc'), function ($cli) {
var_dump($cli-&body);
$cli-&get('/index.php', function ($cli) {
var_dump($cli-&cookies);
var_dump($cli-&headers);
});Swoole&Async-IO实现示例$fp = stream_socket_client("tcp://127.0.0.1:80", $code, $msg, 3);
$http_request = "GET /index.html HTTP/1.1\r\n\r\n";
fwrite($fp, $http_request);
Swoole\Event::add($fp, function($fp){
echo fread($fp, 8192);
swoole_event_del($fp);
fclose($fp);
Swoole\Timer::after(2000, function() {
echo "2000ms timeout\n";
Swoole\Timer::tick(1000, function() {
echo "1000ms interval\n";
});Swoole 异步任务实现示例：$serv = new Swoole\Server("127.0.0.1", 9502);
$serv-&set(array('task_worker_num' =& 4));
$serv-&on('Receive', function($serv, $fd, $from_id, $data) {
$task_id = $serv-&task("Async");
echo "Dispath AsyncTask: id=$task_id\n";
$serv-&on('Task', function ($serv, $task_id, $from_id, $data) {
echo "New AsyncTask[id=$task_id]".PHP_EOL;
$serv-&finish("$data -& OK");
$serv-&on('Finish', function ($serv, $task_id, $data) {
echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;
$serv-&start();案例swoole目前已被多家移动互联网、物联网、网络游戏、手机游戏企业使用，替代了C++、Java等复杂编程语言来实现网络服务器程序。 使用PHP+Swoole，开发效率可以大大提升。官方提供了基于swoole扩展开发的， 支持Http，FastCGI，WebSocket，FTP，SMTP，等网络协议&swoole在美国，英国，法国，印度等国家都有用户分布，在国内的&、、阿里巴巴、YY语音等多家知名互联网公司均有使用。
更新记录：
常见问题：
微信号：w3cschoolcn
意见反馈：
联系方式：主题信息（必填）
主题描述（最多限制在50个字符）
申请人信息（必填）
申请信息已提交审核，请注意查收邮件，我们会尽快给您反馈。
如有疑问，请联系
Coding.net 让开发更简单！
主要从事PHP开发工作，个人网址：
Java开发工程师
学习PHP前需要掌握的基础知识 你可准备好了吗？请使用过swoole的同学讲讲swoole酷炫叼炸天的性能和用途_问答_ThinkSAAS
请使用过swoole的同学讲讲swoole酷炫叼炸天的性能和用途
请使用过swoole的同学讲讲swoole酷炫叼炸天的性能和用途
如题，请同学们踊跃回答，最好答案中能附带实例代码或者数据说明
补充:我说的是swoole扩展，不是swoole-framework
毫秒定时器，异步MySQL，内置的Task队列服务，异步的TCP/UDP客户端。这个说起来太多了。
doc很详细！现在在关注 workerman
swoole 框架和 swoole 扩展是不一样的。
swoole 框架也可以脱离 swoole 扩展来使用。
swoole 扩展将进程管理，tcp 监听这些工作在 C 里面做了，以扩展的形式提供给 PHP 一些接口来调用。
workerman 就是原生的使用 php stream 相关的函数来监听 tcp，进行进程管理。
如果你想学习 PHP 开发 tcp 的原理建议看 workerman 的源码，如果你只是想使用，用 swoole 就 OK 了。
实例代码去官网啊，官网有。
你要什么样的数据说明啊，也去官网上看啊，能干什么写得很清楚的。
可以让大型变量常驻内存，避免每次访问重复加载的耗时
刚好写了个关键词过滤的例子，
添加你想要问的问题
PHP开发框架
开发工具/编程工具
服务器环境Swoole源码学习记录（十四）——Server模块详解（下）
1.swServer函数分析
swServer_addListener
该函数用于在swServer中添加一个需要监听的host及port。函数原型如下：
// Server.h 438h
int swServer_addListener(swServer *serv, int type, char *host,int port);
swServer *serv
swServer对象
创建的socket类型，见枚举swSocket_type
char* host
函数核心：
// Server.c 900~943h
swListenList_node *listen_host = SwooleG.memory_pool-&alloc(SwooleG.memory_pool, sizeof(swListenList_node));
listen_host-&type =
listen_host-&port =
listen_host-&sock = 0;
listen_host-&ssl = 0;
bzero(listen_host-&host, SW_HOST_MAXSIZE);
strncpy(listen_host-&host, host, SW_HOST_MAXSIZE);
LL_APPEND(serv-&listen_list, listen_host);
//UDP需要提前创建好
if (type == SW_SOCK_UDP || type == SW_SOCK_UDP6 || type == SW_SOCK_UNIX_DGRAM)
int sock = swSocket_listen(type, listen_host-&host, port, serv-&backlog);
if (sock & 0)
return SW_ERR;
//设置UDP缓存区尺寸，高并发UDP服务器必须设置
int bufsize = serv-&udp_sock_buffer_
setsockopt(sock, SOL_SOCKET, SO_SNDBUF, &bufsize, sizeof(bufsize));
setsockopt(sock, SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize));
listen_host-&sock =
serv-&have_udp_sock = 1;
if (type & SW_SOCK_SSL)
type = type & (~SW_SOCK_SSL);
listen_host-&type =
listen_host-&ssl = 1;
if (type != SW_SOCK_UNIX_STREAM && port &= 0)
swError(listen port must greater than 0.);
return SW_ERR;
serv-&have_tcp_sock = 1;
return SW_OK;
源码解释：
在SwooleG的共享内存池中创建一个swListenList_node，并设置type等相关参数，并将该node添加进swServer的listen_list。随后，判定type类型。如果是UDP类型的socket，需要直接调用swSocket_listen进行监听，并根据swServer的udp_sock_buffer_size设置socket的缓存区大小；如果是TCP类型的socket，只针对两种特别的type类型做判定（SSL类型要设置ssl开关，非Unix Sock类型要保证监听端口大于0）。
swServer_listen
该函数用于开始监听swServer中全部的TCP类型的socket。函数原型如下：
// Server.h 440h
int swServer_listen(swServer *serv, swReactor *reactor);
swServer *serv
swServer对象
swReactor *reactor
Reactor对象，监听实际的Listen事件
函数核心源码：
// Server.c 949-998h
LL_FOREACH(serv-&listen_list, listen_host)
if (listen_host-&type == SW_SOCK_UDP || listen_host-&type == SW_SOCK_UDP6 || listen_host-&type == SW_SOCK_UNIX_DGRAM)
sock = swSocket_listen(listen_host-&type, listen_host-&host, listen_host-&port, serv-&backlog);
if (sock & 0)
LL_DELETE(serv-&listen_list, listen_host);
return SW_ERR;
if (reactor!=NULL)
reactor-&add(reactor, sock, SW_FD_LISTEN);
#ifdef TCP_DEFER_ACCEPT
if (serv-&tcp_defer_accept & 0)
sockopt = serv-&tcp_defer_
setsockopt(sock, IPPROTO_TCP, TCP_DEFER_ACCEPT, &sockopt, sizeof(sockopt));
listen_host-&sock =
//将server socket也放置到connection_list中
serv-&connection_list[sock].fd =
serv-&connection_list[sock].addr.sin_port = listen_host-&
//save listen_host object
serv-&connection_list[sock].object = listen_
//将最后一个fd作为minfd和maxfd
if (sock &= 0)
swServer_set_minfd(serv, sock);
swServer_set_maxfd(serv, sock);
源码解释：
遍历listen_list列表，对所有TCP类型的socket，调用swSocket_listen函数启动监听，并将socket添加到reactor中。如果设置了TCP_DEFER_ACCEPT属性，则设置相应的socket option。最后，将监听的socket加入swServer的connection_list,并设置swServer的minfd和maxfd为最后一个待监听的server socket。
swServer_addTimer
该函数用于在swServer中添加一个定时器。函数原型如下：
// Server.h 443h
int swServer_addTimer(swServer *serv, int interval);
swServer *serv
swServer对象
int interval
Timer的时间间隔
函数核心源码：
// Server.c 263-293h
if (serv-&onTimer == NULL)
swWarn(onTimer is null. Can not use timer.);
return SW_ERR;
//timer no init
if (SwooleG.timer.fd == 0)
if (swTimer_create(&SwooleG.timer, interval, SwooleG.use_timer_pipe) & 0)
return SW_ERR;
if (swIsMaster())
serv-&connection_list[SW_SERVER_TIMER_FD_INDEX].fd = SwooleG.timer.
if (SwooleG.use_timer_pipe)
SwooleG.main_reactor-&setHandle(SwooleG.main_reactor, SW_FD_TIMER, swTimer_event_handler);
SwooleG.main_reactor-&add(SwooleG.main_reactor, SwooleG.timer.fd, SW_FD_TIMER);
SwooleG.timer.onTimer = swServer_onT
return swTimer_add(&SwooleG.timer, interval);
源码解释： 首先判定是否有onTimer回调，如果没有则返回一个Error。随后，如果没有初始化timer计时器，则调用swTimer_create函数创建计时器。如果当前进程是master进程，将timer的fd添加到connection_list中。如果timer指定使用了pipe管道，则将timer的fd添加到SwooleG的main_reactor中。最后，调用swTimer_add添加timer。
swServer_tcp_send
该函数用于发送TCP数据。函数原型如下：
// Server.h 443h
int swServer_tcp_send(swServer *serv, int fd, void *data, int length);
swServer *serv
swServer对象
发送的socket描述符
void *data
需要发送的数据
int length
函数核心源码：
// Server.c 788-858h
swSendData _
swFactory *factory = &(serv-&factory);
#ifndef SW_WORKER_SEND_CHUNK
* More than the output buffer
if (length &= serv-&buffer_output_size)
swWarn(More than the output buffer size[%d], please use the sendfile., serv-&buffer_output_size);
return SW_ERR;
_.type = SW_EVENT_TCP;
_send.data =
if (length &= SW_BUFFER_SIZE)
_send.length =
_send.length = 0;
return factory-&finish(factory, &_send);
char buffer[SW_BUFFER_SIZE];
int trunk_num = (length / SW_BUFFER_SIZE) + 1;
int send_n = 0, i,
swConnection *conn = swServer_connection_get(serv, fd);
if (conn == NULL || conn-&active == 0)
swWarn(Connection[%d] has been closed., fd);
return SW_ERR;
for (i = 0; i & trunk_ i++)
//last chunk
if (i == (trunk_num - 1))
send_n = length % SW_BUFFER_SIZE;
if (send_n == 0)
send_n = SW_BUFFER_SIZE;
memcpy(buffer, data + SW_BUFFER_SIZE * i, send_n);
_.len = send_n;
ret = factory-&finish(factory, &_send);
#ifdef SW_WORKER_SENDTO_YIELD
if ((i % SW_WORKER_SENDTO_YIELD) == (SW_WORKER_SENDTO_YIELD - 1))
swYield();
源码解释： 如果没有定义SW_WORKER_SEND_CHUNK宏，执行如下操作： 如果数据长度大于swServer的输出缓存大小，则报错。否则，设置swSendData的相关属性，调用swServer中的factory的finish函数将数据发出。 如果定义了SW_WORKER_SEND_CHUNK宏，执行如下操作： 首先根据数据长度length计算出需要多少个trunk。随后，获取fd对应的swConnecton，如果找不到connection或者connection已经关闭，则报错。随后，将数据划分为一个个trunk的长度，放进swSendData中后调用swServer中的factory的finish函数将数据发出。
swServer_reload
该函数用于通知Manager进程重启全部的Worker进程。函数原型如下：
// Server.h 443h
int swServer_reload(swServer *serv);
swServer *serv
swServer对象
函数核心源码：
// Server.c h
int manager_pid = swServer_get_manager_pid(serv);
if (manager_pid & 0)
return kill(manager_pid, SIGUSR1);
return SW_ERR;
源码解释： 通过kill函数向Manager进程发送SIGUSR1信号，该信号的行为是杀死并重启全部的Worker。
剩下的swServer的操作函数较为简单，在此不再贴出源码进行分析。
2.Server相关结构体分析
下面分析一些声明在Server.h中的结构体。
该结构体已被swEventData替代。
swPackage_task
// Server.h 420-424h
typedef struct
char tmpfile[sizeof(SW_TASK_TMP_FILE)];
} swPackage_
int length
char tmpfile[sizeof(SW_TASK_TMP_FILE)]
临时文件的文件名
说明： swPackage_task用于封装内容较大的task包（超过8K），tmpfile指向一个由mkstemp函数（如果开启了HAVE_MKOSTEMP选项，则为mkostemp函数）创造的临时文件，所有的数据会被暂时存放在这个文件里。
swPackage_response
// Server.h 426-430h
typedef struct
int worker_
} swPackage_
int length
int worker_id
用于接收该应答的Worker ID
说明： swPackage_response结构体用于Factory回应Reactor，主要作用是通知Reactor响应数据的实际长度以及是由哪个worker处理的，然后会根据是否为Big Response决定是否从worker的共享内存中读取数据。（参考ReactorThread的swReactorThread_onPipeReceive函数以及FactoryProcess的swFactoryProcess_finish函数）