Workerman是一款纯PHP开拓的开源高性能的PHP socket 做事框架。
Workerman不是重复造轮子，它不是一个MVC框架，而是一个更底层更通用的socket做事框架，你可以用它开拓tcp代理、梯子代理、做游戏做事器、邮件做事器、ftp做事器、乃至开拓一个php版本的redis、php版本的数据库、php版本的nginx、php版本的php-fpm等等。Workerman可以说是PHP领域的一次创新，让开发者彻底摆脱了PHP只能做WEB的束缚。实际上Workerman类似一个PHP版本的nginx，核心也是多进程+Epoll+非壅塞IO。Workerman每个进程能坚持上万并发连接。由于本身常住内存，不依赖Apache、nginx、php-fpm这些容器，拥有超高的性能。同时支持TCP、UDP、UNIXSOCKET，支持长连接，支持Websocket、HTTP、WSS、HTTPS等通讯协议以及各种自定义协议。拥有定时器、异步socket客户端、异步Mysql、异步Redis、异步Http、异队伍列等浩瀚高性能组件。
Workerman的一些运用方向
Workerman不同于传统MVC框架，Workerman不仅可以用于Web开拓，同时还有更广阔的运用领域，例如即时通讯类、物联网、游戏、做事管理、其它做事器或者中间件，这无疑大大提高了PHP开拓者的视野。目前这些领域的PHP开拓者奇缺，如果想在PHP领域有自己的技能上风，不知足于每天的增编削查事情，或者想向架构师方向或者技能大牛的方向发展，Workerman都是非常值得学习的框架。建议开拓者不仅会用，而且能基于Workerman开拓出属于自己的开源项目，提升技能增加自己的影响力，比如Beanbun多进程网络爬虫框架便是一个很好的例子，刚刚上线不久就得到浩瀚好评。
Workerman的一些运用方向如下：
1、即时通讯类例如网页即时谈天、即时推送、微信小程序、手机app推送、PC软件推送等等
[示例 workerman-chat谈天室 、 web推送 、 小蝌蚪谈天室]
2、物联网类例如Workerman与打印机通讯、与单片机通讯、智好手环、智能家居、共享单车等等。
[客户案例如 易联云、易泊时期等]
3、游戏做事器类例如棋牌游戏、MMORPG游戏等等。[示例 browserquest-php]
4、HTTP做事例如 写高性能HTTP接口、高性能网站。如果想要做HTTP干系的做事或者站点强烈推举 webman
5、SOA做事化利用Workerman将现有业务不同功能单元封装起来，以做事的形式对外供应统一的接口，达到系统松耦合、易掩护、高可用、易伸缩。[示例 workerman-json-rpc、 workerman-thrift]
6、其它做事器软件例如 GatewayWorker，PHPSocket.IO，http代理，sock5代理，分布式通讯组件，分布式变量共享组件，行列步队、DNS做事器、WebServer、CDN做事器、FTP做事器等等
7、中间件例如异步MySQL组件，异步redis组件，异步http组件，异队伍列组件，异步dns组件，文件监控组件，还有很多第三方开拓的组件框架等等
显然传统的mvc框架很难实现以上的功能，以是也便是workerman出身的缘故原由。
下面利用workerman建立websocket连接，实现一个大略的谈天事例。
下载workerman源码包
在start.php中引入源码，将源码包vendor目录放在与start.php同级目录
1. start.php 代码如下：
<?php
require_once 'vendor/autoload.php';
use Workerman\Worker;
/
多端口，多协议
/
// 利用websocket协议
$ws_worker = new Worker("websocket://0.0.0.0:10086");
// 启动进程对外做事。如果进程启动后建立一个内部通讯端口，则进程数必须为1$ws_worker->count = 1;
// 连接事宜,阻断造孽连接
$ws_worker->onConnect = function ($connection) use ($domains){
};
// 进程启动后建立一个内部通讯端口
$ws_worker->onWorkerStart = function ($ws_worker){
$inner_text_worker = new Worker("Text://0.0.0.0:10087");
$inner_text_worker->onMessage = function ($connection, $buffer) use ($ws_worker)
{
$data = json_decode($buffer, true);
$id = $data['id'];
// 通过workerman向id的页面推送数据
$ret = sendMessageById($id, $buffer);
// 返回推送结果
$connection->send($ret ? 'ok' : 'fail');
};
$inner_text_worker->listen();
$inner_text_worker = new Worker("http://0.0.0.0:10087");
$inner_text_worker->onMessage = function ($http) use ($ws_worker)
{
$id = $_POST['id'];
$status = $_POST['status'];
// 通过workerman向id的页面推送数据
$ret = sendMessageById($id, ['id', 'status' => $status]);
// 返回推送结果
$http->send($ret ? 'ok' : 'fail');
};
$inner_text_worker->listen();};
// 增加一个属性，用来保存uid到connection的映射
$ws_worker->uidConnetions = [];// 客户端发送时回调
$ws_worker->onMessage = function ($connection, $data) use ($ws_worker){
// 判断当前客户端是否已履历证过
if (!isset($connection->uid)) {
$connection->uid = $data;
$ws_worker->uidConnetions[$connection->uid] = $connection;
return;
}};
// 当客户端连接断开时
$ws_worker->onClose = function ($connection) use ($ws_worker){
if (isset($connection->uid)) {
unset($ws_worker->uidConnetions[$connection->uid]);
}};
/
sendMessageById 向指定的客户端推送数据
@param mixed $id
@param mixed $message
@access public
@return bool
/
function sendMessageById($id, $message){
if (is_array($message))
$message = json_encode($message);
global $ws_worker;
if (isset($ws_worker->uidConnetions[$id])) {
$connection = $ws_worker->uidConnetions[$id];
$connection->send($message);
return true;
}
return false;}
/
broadcast 向所有用户推送数据
@param mixed $message
@access public
@return void
/
function broadcast($message){
global $ws_worker;
foreach ($ws_worker->uidConnetions as $connection) {
$connection->send($message);
} }
Worker::runAll();
2.开启做事进程：php start.php start
3. 发送http要求到对应的端口,代码如下：
function post($url, $data = [], $timeout = 3){
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout); //设置超时
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
$result = curl_exec($ch);
curl_close($ch);
return $result;}
}
// 发送http要求到http做事
$data['id'] = 100;$data['status'] = 6;
// 你的IP地址+端口号
$url = 'http://192.168.16.101:10087';
$result = post($url, $data);echo $result . "\n";
4.客户端连接代码：
<!DOCTYPE html>
<html lang="en"><head>
<meta charset="UTF-8">
<title>WebSocket_client</title>
<script>
//创建一个socket实例
ws = new WebSocket("ws://192.168.16.101:10086");
ws.onopen = function () {
console.log("连接成功");
ws.send(100);
//console.log("发送数据：tom")
};
ws.onmessage = function (e) {
console.log("收到做事端信息：" + e.data);
};
</script>
</head>
<body>
</body>
</html>
crmeb知识付费系统的直播功能便是利用了workerman+websocket功能实现的，application\push\controller\Push.php文件便是workerman的初始文件。public/wap/first/zsff/js/Websocket.js为websocket功能文件。如果须要二开直播间互动功能，可以通过这两个文件修正。
如果你以为这篇文章对你有点用的话，麻烦请给我们的开源项目点点star: http://github.crmeb.net/u/defu不胜感激 ！
