什么是Workerman
Workerman是一款纯PHP开发的开源高性能的PHP socket 服务器框架。被广泛的用于手机app、手游服务端、网络游戏服务器、聊天室服务器、硬件通讯服务器、智能家居、车联网、物联网等领域的开发。
支持TCP长连接，支持Websocket、HTTP等协议，支持自定义协议。基于workerman开发者可以更专注于业务逻辑开发，不必再为PHP Socket底层开发而烦恼。
技术交流群:
Workerman支持的特性
纯PHP开发，多进程支持，支持php7，支持hhvm
支持TCP/UDP，单机可支持数百万以上TCP长连接
支持分布式部署，集群能支持数百万甚至更高的并发TCP连接
支持libevent事件触发网络库
支持热更新及服务器平滑重启
支持守护进程化和统计监控模块
基于高性能的libevent事件网络库，单机可支持百万的并发连接，长连接吞吐量高达36W/S。PHP数据库等对象可以常驻内存，减少解析编译及网络开销。
已被多家公司证实其高可用性，这些公司不乏日营业额过亿的电子商务公司用于服务器后台的开发，以及知名网游公司用于游戏后台的开发。
接口简单，并已经有很多成熟的网络应用，只要你会PHP，你就可以在这些应用的基础上快速的开发出自己的Socket应用服务。
workerman相关应用
一个出色的视频直播，包含Web端、安卓客户端和iphone客户端。
主要功能包括主播系统，礼物系统，游戏系统，道具系统，代理功能，排行榜，充值系统，个人中心，守护系统等。即时通讯采用workerman，视频流采用rtmp协议利用fms或者cdn分发。
(此需要，)
+Workerman开发的即时通讯项目，支持群聊、私聊、表情、传图、传文件、离线消息、历史消息记录等功能，非常强大。支持分布式部署、支持万人在线。
+Workerman开发的客服系统，任何站点引入一段js即可接入，接入成本极低。支持表情、离线消息，支持多站点，支持分布式部署、支持万人在线。
一个可扩展的php socket的聊天室，服务端采用GatewayWorker作为socket服务器框架，支持万人在线，采用web-socket-js作为前端websocket库，支持多浏览器。同样可以用作app聊天室开发。
web消息推送系统，能够通过socket 长连接实时推送消息给所有用户，基于PHPSocketIO开发，客户端使用socket.io客户端，支持各种浏览器。
使用HTML5+WebSocket+GatewayWorker实时推送技术开发的小蝌蚪聊天室，聊天室中玩家们化身为小蝌蚪，可以自由游动，并且可以实时聊天，非常有趣。
BrowserQuest是Mozilla发布的一款2D图形的MMO（大型多人在线）游戏，玩家可以聊天、打怪、升级、寻宝、获得成就。这里基于WorkerMan框架重写了BrowserQuest服务端nodejs部分，浏览器与后端同样是基于websocket协议通讯。
PHPSocket.IO是Socket.IO的PHP 服务端版本。PHP版socket.io可用来替代传统nodejs版本socket.io服务端，并且接口与其一致，可用于开发跨浏览器或者安卓、ios等移动端即时通讯应用。
一个php写的socks5代理，基于workerman开发。socks5代理不关心应用层协议，是一种通用的代理服务器，可用于做游戏代理、http代理等等。
基于workerman开发的一个http代理。源码仅有几十行，性能强悍。
phptty是一个基于浏览器的Linux终端模拟器，可以在浏览器里面控制Linux终端程序。服务端基于workerman开发。phptty可以实现很多有意思的功能，例如利用htop命令查看服务器负载，tail -f 实时服务器错误日志等等。
一个通过浏览器查看vmstat命令的工具，以更友好的方式实时展示服务器cpu、内存、IO等情况
利用浏览器HTML5捕获摄像头视频并转换成ascii码流，并利用workerman实时转发给其它浏览器展示
网页HTML5调用摄像头，利用websocket将摄像头视频流实时传输给workerman，并实时转发给其它浏览器展示
易联云平台是依托移动互联网的超远程打印解决方案，包含了设备管理中心、互联网API等模块。能够有效的实现易联云和应用之间的对接，帮助用户和开发者方便的使用超远程打印的构架和功能。
一款有趣的手机app，后端基于workerman开发
基于workerman开发的一款手机游戏
多人在线版flappy bird，游戏中你可以看到无数玩家同时控制小鸟前赴后继地向前送死的壮烈(搞笑)场面。
Workerman和Thrift框架相结合，目的是解决异构系统与PHP通信的问题，使你的服务更方便的被其它语言调用。
使用json数据格式通讯的远程调用系统，通讯格式简单明了，方便其它语言调用，并集成了监控模块。
基于php socket开发的一款分布式统计监控系统，udp数据上报，分布式统计，结果自动汇总展示。纯PHP开发、无需安装Mysql、Nginx、Apache等软件。
GatewayWorker是基于Workerman开发的一个可分布式部署的TCP长连接框架，专门用于快速开发TCP长连接应用，例如app推送服务端、即时IM服务端、游戏服务端、物联网、智能家居等等
一个简单的消息队列demo，基于Linux sysv 队列实现，需要开启sysvmsg扩展
基于订阅的进程间通讯组件，事件的订阅发布机制，使用方法简单，能够方便的实现进程间及服务器集群间通讯。
进程间数据共享组件，用于分布式数据共享。服务端基于Workerman。客户端可用于任何PHP项目。
phptty发布
分布式进程间通讯组件Channel发布
GatewayWorker2.0发布
web-msg-sender(web消息推送)改版
phpsocket.io发布
workerman3.x windows版本 发布
摄像头视频流直播demo发布
摄像头视频流转ascii码流实时传输demo发布
web vmstat工具发布
BrowserQuest php版本发布
workerman-3.0 发布
workerman-MT多线程版本发布，同时支持Linux Windows平台
聊天室支持分房间等功能
workerman 手册发布
workerman windows 平台多线程测试版本发布
社区功能上线
flappy bird 多人在线版发布
PHP小蝌蚪游戏发布
聊天室发布
分布式监控系统发布
Thrif Rpc框架发布
Json Rpc 框架发布
workerman 框架发布
免费QQ群：
&VIPQQ群：
商务合作联系QQ：
10.0?匿名微信
12.22?佳少支付宝
500.0?ㄔ余 赤赤微信
50.0?匿名微信
1.0?你长得好丑支付宝
11.11?匿名微信
28.0?Wilson支付宝
1.0?选择没有对OR错QQ钱包
2.0?匿名微信
0.80?匿名微信
2.0?匿名微信
19.0?匿名微信
5.20?Joinsen微信
5.0?匿名微信
3.0?匿名微信
0.27?JDbone支付宝
1.0?匿名微信
20.0?匿名微信
1.0?秋色支付宝
0.88?匿名微信
5.0?匿名微信
0.88? 雪走。QQ钱包
8.8?九牛微信
1.0?匿名微信
1.0?钱来发发软件工作室QQ钱包
5.0?匿名微信
1.0?匿名微信
10.0?白影支付宝
20.0?匿名微信
50.0?超支付宝
1.88?他会笑QQ钱包
5.0?爱晕车QQ钱包
1.0?Eba支付宝
27.0?冰和支付宝
20.0?世发支付宝
0.01?BambooQQ钱包
10.0?家斌支付宝
100.0?叮当Q版微信
5.0￥大森林支付宝
0.01?匿名微信
8.0?匿名微信
200.0￥Mrzeta支付宝
1.85?匿名微信
2.0?匿名微信
0.01?匿名微信
10.0?Awin微信
1.29?匿名微信
50.0￥孙裕支付宝
5.0￥国焌支付宝
10.0￥匿名微信
1.0￥匿名微信
1.0￥匿名微信
捐赠账号(walkor) ：
Powered by
QQ群1：00人已满)
QQ群2：00人已满)
QQ群3：0人已满)
QQ群4：00人)
商务合作联系QQ：workerman源码分析之启动过程
PHP一直以来以草根示人，它简单，易学，被大量应用于web开发，非常可惜的是大部分开发都在简单的增删改查，或者加上pdo，redis等客户端甚至分布式，以及规避语言本身的缺陷。然而这实在太委屈PHP了。记得有一次问walker，PHP能做什么？他说：什么都能做啊！当时我就震惊了，这怎么可能。。。直到后来一直看workerman源码，发现PHP原来有很多不为大家所知的诸多用法，包括多进程（还有线程）、信号处理、namespace等等一大堆特点。而workerman正是这些很少被使用特性（或者说扩展）的集大成者，如果非要说它的缺点，那就是PHP的缺点了，当然PHP的优点它全占了~而且PHP7发布在即，workerman必将得到更多的优化，搭配HHVM更是叼的不行。
版本：3.1.8（linux）
模型：GatewayWorker（Worker模型可与之类比）
注：只贴出讲解部分代码，出处以文件名形式给出，大家可自行查看
workerman最初只开发了Linux版本，win是后来增加的，基于 命令行模式运行(cli） 。
多进程模型
工作进程，Master、Gateway和Worker，Gateway主要用于处理IO事件，保存客户端链接状态，将数据处理请求发送给Worker等工作，Worker则是完全的业务逻辑处理，前者为IO密集型，后者为计算密集型，它们之间通过网络通信，Gateway和Worker两两间注册通信地址，所以非常方便的进行分布式部署，如果业务处理量大可以单纯的增加Worker服务。
它们有一个负责监听的父进程（Master），监听子进程状态，发送 signal 给子进程，接受来自终端的命令、信号等工作。父进程可以说是整个系统启动后的入口。
启动命令解析
既然以命令模式（cli）运行（注意与 fpm 的区别，后者处理来自网页端的请求），就必然有一个启动脚本解析命令，譬如说3.x版本（之前默认为daemon）新增一个 -d 参数，以表示守护进程运行，解析到该参数设置 self::$daemon = true, 随后fork子进程以脱离当前进程组，设置进程组组长等工作。这里有两个非常重要的参数 $argc 和 $argc，前者表示参数个数，后者为一个数组，保存有命令的所有参数，比如：sudo php start.php start -d，$argv就是 array( [0]=&start.php, [1]=&start, [2]=&-d )，而解析主要用到$argv。
启动主要执行下面步骤：
包含 自动加载器 Autoloader ，加载各 Application 下启动文件;
设置_appInitPath 根目录；
解析，初始化参数，执行相应命令。
下面是具体实现（workerman/worker.php）:
public static function parseCommand() 2
// 检查运行命令的参数 4
global $ 5
$start_file = $argv[0];
$command = trim($argv[1]); 9
// 子命令，目前只支持-d11
$command2 = isset($argv[2]) ? $argv[2] : '';12
// 检查主进程是否在运行14
$master_pid = @file_get_contents(self::$pidFile);15
$master_is_alive = $master_pid && @posix_kill($master_pid, 0);16
if($master_is_alive)17
if($command === 'start')19
self::log(&Workerman[$start_file] is running&);21
elseif($command !== 'start' && $command !== 'restart')24
self::log(&Workerman[$start_file] not run&);26
// 根据命令做相应处理29
switch($command)30
// 启动 workerman32
case 'start':33
if($command2 === '-d')34
Worker::$daemonize =36
// 显示 workerman 运行状态39
case 'status':40
exit(0);41
// 重启 workerman42
case 'restart':43
// 停止 workeran44
case 'stop':45
// 想主进程发送SIGINT信号，主进程会向所有子进程发送SIGINT信号46
$master_pid && posix_kill($master_pid, SIGINT);47
// 如果 $timeout 秒后主进程没有退出则展示失败界面48
$timeout = 5;49
$start_time = time();50
while(1)51
// 检查主进程是否存活53
$master_is_alive = $master_pid && posix_kill($master_pid, 0);54
if($master_is_alive)55
// 检查是否超过$timeout时间57
if(time() - $start_time &= $timeout)58
self::log(&Workerman[$start_file] stop fail&);60
usleep(10000);63
self::log(&Workerman[$start_file] stop success&);66
// 是restart命令67
if($command === 'stop')68
exit(0);70
// -d 说明是以守护进程的方式启动72
if($command2 === '-d')73
Worker::$daemonize =75
// 平滑重启 workerman80
case 'reload':81 82
walker代码注释已经非常详尽，下面有几点细节处：
检查主进程是否存活：17行的逻辑与操作，如果主进程PID存在情况下，向该进程发送信号0，实际上并没有发送任何信息，只是检测该进程（或进程组）是否存活，同时也检测当前用户是否有权限发送系统信号；
为什么主进程PID会保存？系统启动后脱离当前terminal运行，如果要执行关闭或者其他命令，此时是以另外的一个进程执行该命令，如果我们连进程PID都不知道，那该向谁发信号呢？！所以主进程PID必须保存起来，而且主进程负责监听其他子进程，所以它是我们继续操作的入口。
Worker::runAll()
php的socket编程其实和C差不多，后者对socket进行了再包裹，并提供接口给php，在php下网络编程步骤大大减少。譬如： stream_socket_server 和 stream_socket_client 直接创建了server/client socke（php有两套socket操作函数）。wm则大量使用了前者，启动过程如下（注释已经非常详尽）：
public static function runAll() 2
// 初始化环境变量 4
self::init(); 5
// 解析命令 6
self::parseCommand(); 7
// 尝试以守护进程模式运行 8
self::daemonize(); 9
// 初始化所有worker实例，主要是监听端口10
self::initWorkers();11
初始化所有信号处理函数12
self::installSignal();13
// 保存主进程pid14
self::saveMasterPid();15
// 创建子进程（worker进程）并运行16
self::forkWorkers();17
// 展示启动界面18
self::displayUI();19
// 尝试重定向标准输入输出20
self::resetStd();21
// 监控所有子进程（worker进程）22
self::monitorWorkers();23
下面还是只说该过程的关键点：
初始化环境变量，例如设置主进程名称、日志路径，初始化定时器等等；
解析命令行参数，主要用到 $argc 和 $argc 用法同C语言；
生成守护进程，以脱离当前终端（两年前大部分认为PHP无法做daemon，其实这是个误区！其实PHP在linux的进程模型很稳定，现在wm在商业的应用已经非常成熟，国内某公司每天处理几亿的连接，用于订单、支付调用，大家可以打消顾虑了）；
初始化所有worker实例（注意，这里是在主进程做的，只是生成了一堆 server 并没有设置监听，多进程模型是在子进程做的监听，即IO复用）；
为主进程注册信号处理函数；
保存主进程PID，当系统运行后，我们在终端查看系统状态或者执行关闭、重启命令，是通过主进程进行通信，所以需要知道主进程PID，我们知道在终端下敲入一个可执行命令，实则是在当前终端下新建一个子进程来执行，所以我们需要得知主进程PID，以向WM主进程发送SIGNAL，这时信号处理函数捕获该信号，并通过回调方式执行。
创建子进程，设置当前进程用户(root)。在多进程模型中，两给子进程，分别监听不同的server地址，我们在主进程只是创建server并没有设置监听，也没有生成指定数目的server，原因在于，我们在一个进程多次创建同一个 socket， woker数目其实就是 socket 数量，也就是该 socket 的子进程数目，否则会报错；
在子进程中，将 server socket 注册监听事件，用到一个扩展 Event ，可以实现IO复用，并注册数据读取回调，同时也可注册socket连接事件回调；
输入输出重定向；
主进程监听子进程状态，在一个无限循环中调用 pcntl_signal_dispatch() 函数，用于捕获子进程退出状态，该函数会一直阻塞，直到有子进程退出时才触发；
至此，一个完整的启动过程大致处理完成，然后 server 会一直运行，一直等待 socket 连接事件，等待数据可读可写事件，通过事先注册的处理函数，就能完整的处理整个网络过程。
其实网络编程过程大致都差不多，这些都有标准答案，每个语言实现的大致过程基本相同，当然类似 golang 的 goroutine 另说。。。需要了解应用层协议(如果可能，需要手动解包和封包)，网络模型，TCP/UDP，进程间通信，IO复用等等，当然最重要的是会 debug。。。自己动手尝试写一个简单的 server 就会遇到很多无法遇见的坑，所以纸上得来终觉浅，绝知此事要躬行。
最新教程周点击榜
微信扫一扫PHP（399）
什么是Workerman
Workerman是一款纯PHP开发的开源的高性能的PHP
socket 异步框架。被广泛的用于移动通讯、手游服务端、网络游戏服务器、聊天室服务器、硬件通讯服务器、智能家居、车联网、物联网等领域的开发。 支持Websocket、HTTP等协议，支持自定义协议。基于workerman开发者可以更专注于业务逻辑开发，不必再为PHP Socket底层开发而烦恼。
&&&下载12765次
Workerman支持的特性
纯PHP开发，多进程支持，支持hhvm支持TCP/UDP，单机可支持数百万以上TCP长连接支持分布式，集群能支持数百万甚至更高的并发TCP连接支持libevent事件触发网络库支持热更新及服务器平滑重启支持守护进程化和统计监控模块
The&Workerman&Framework
基于高性能的libevent事件网络库，单机可支持百万的并发连接，长连接吞吐量高达36W/S。PHP数据库等对象可以常驻内存，减少解析编译及网络开销。
已被多家公司证实其高可用性，这些公司不乏日营业额过亿的电子商务公司用于服务器后台的开发，以及知名网游公司用于游戏后台的开发。
接口简单，并已经有很多成熟的网络应用，只要你会PHP，你就可以在这些应用的基础上快速的开发出自己的Socket应用服务。
使用HTML5+WebSocket+Workerman实时推送技术开发的蝌蚪小游戏，游戏中玩家们可以实时互动，并且可以实时聊天，非常有趣。&
BrowserQuest是Mozilla发布的一款2D图形的MMO（大型多人在线）游戏，玩家可以聊天、打怪、升级、寻宝、获得成就。这里基于WorkerMan框架重写了BrowserQuest服务端nodejs部分，浏览器与后端同样是基于websocket协议通讯。&
一个可扩展的基于Websocket协议的聊天室，服务端采用workerman作为Socket服务器框架，客户端支持多浏览器统一接口，支持浏览器原生Websocket同时支持Flash实现的Websocket。&
轻量级科学上网姿势，改变您的生活体验！&
一个通过浏览器查看vmstat命令的工具，以更友好的方式实时展示服务器cpu、内存、IO等情况&
利用HTML5将摄像头视频流转换成ascii码流，通过websocket实时传输workerman，workerman实时转发给其它浏览器展示&
HTML5调用摄像头，利用websocket将摄像头视频流实时传输workerman，workerman实时转发给其它浏览器展示&
基于websocket+workerman的web消息推送系统，能够通过网页实时推送消息给所有用户，支持各种浏览器（需要浏览器支持html5或者flash）&
易联云平台是依托移动互联网的超远程打印解决方案，包含了设备管理中心、互联网API等模块。能够有效的实现易联云和应用之间的对接，帮助用户和开发者方便的使用超远程打印的构架和功能。
“萌Mark是什么？图片社交？漫画工具？表情工具？”
　　“no，都不是。”
　　我眼里的萌Mark是什么？
《精灵危机》的游戏带玩家进入一个由昆虫们组成的魔法大陆，他们依靠火，水，风，光，暗的魔法能量工作和生活。而有一天，能量的平衡被打破了，玩家必须帮助这个世界的人们，守卫能量的平衡，拯救这个岌岌可危的世界并揭露幕后的阴谋。&
在线斗兽棋:斗兽棋是中国一种棋类游戏,80后儿时的玩具,双方有八只棋子，依大小顺序为象、狮、虎、豹、犬、狼、猫、鼠。较大的可吃较小的，同类可以互吃，而鼠则可吃象，象不能吃鼠。动物走一格，前后左右都可以，极具趣味性。
使用HTML5+WebSocket+Workerman实时推送技术开发的多人在线版flappy bird，游戏中你可以看到无数玩家同时控制小鸟前赴后继地向前送死的壮烈(搞笑)场面。&
Workerman和Thrift框架相结合，目的是解决异构系统与PHP通信的问题，使你的服务更方便的被其它语言调用。&
使用json数据格式通讯的远程调用系统，通讯格式简单明了，方便其它语言调用，并集成了监控模块。&
基于workerman socket框架开发的一款分布式统计监控系统，纯PHP开发、无需安装Mysql、Nginx、Apache等软件。&
参考知识库
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：724442次
积分：8604
积分：8604
排名：第1673名
原创：55篇
转载：615篇
评论：78条
(1)(6)(2)(7)(1)(1)(5)(15)(15)(1)(5)(4)(7)(5)(3)(4)(1)(3)(11)(19)(37)(11)(10)(47)(139)(53)(98)(72)(9)(6)(1)(1)(1)(1)(4)(8)(7)(6)(33)(3)(9)(2)输入关键字进行搜索
var login_data = JSON.stringify({&type&:&login&,&client_name&:name,&room_id&:&?php echo isset($_GET['room_id']) ? $_GET['room_id'] : 1?>});
console.log(&websocket握手成功，发送登录数据:&+login_data);
ws.send(login_data);
reconnect =
这是chat首页登录的逻辑。这里我想在login_data中增加一项例如userid:12345，并用这个userid生成对应的client_id，请问ws.send(login_data)后我该如何处理？后端如何获取ws发送的内容？
// 全局唯一client_id
$global_client_id = $this->createGlobalClientId();
$this->clientConnMap[$global_client_id] = $
$this->connClientMap[$fd] = $global_client_
这个是默认的client_id生成逻辑。如何获取ws发送的userid呢？？？求指导
登录时想向workerman-chat传递任何数据，在login_data加即可。
js调用 ws.send
发送的数据都在workerman/applications/Chat/Event.php中的onMessage方法里面接收，login_data也是在这里接收解析。
workerman-chat默认没有userid概念，全部以client_id作为客户端标记相互发送数据。client_id可以看做Web开发中的session_id，每个网页的连接的client_id都不一样（类似Web程序中每次用户登录session_id都不一样）。
如果想让workerman-chat中的用户与现有其他项目中的用户关联起来，可以在workerman-chat登录发送给workerman的login_data加入用户识别信息（例如你说的userid，实际上这样不安全，容易被伪造。比较安全的做法是login_data中放入登录用户的Web程序的session_id，workerman收到Web程序的session_id来验证用户，识别方法一般是Web登录时保存session_id与用户信息的关系），当workerman-chat识别当前用户后，可以使用workerman提供的$_SESSION机制（和Web的$_SESSION类似）记录当前用户用户的信息，例如$_SESSION['userid']=$_SESSION['username']=...，当需要当前用户的信息时直接从$_SESSION中取即可，非常方便。
如果想通过userid来获得client_id，你需要一个存储来记录userid和client_id的对应关系，可以限制一对一或者一对多（根据自己业务情况确定）。
GatewayWorker 增加了bindUid 和 sendToUid方法，可以直接使用，参见手册
要回复问题请先或
浏览: 2682
关注: 2 人
Powered by