Workerman是什么？
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

  1. 发送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不胜感激 ！