Workerman的使用

CRMEB -
Workerman的使用

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同级目录

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

发送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不胜感激 !

特别申明:本文内容来源网络,版权归原作者所有,如有侵权请立即与我们联系(cy198701067573@163.com),我们将及时处理。

php介绍

PHP即“超文本预处理器”,是一种通用开源脚本语言。PHP是在服务器端执行的脚本语言,与C语言类似,是常用的网站编程语言。PHP独特的语法混合了C、Java、Perl以及 PHP 自创的语法。利于学习,使用广泛,主要适用于Web开发领域。
下一篇: php签名

Tags 标签

php前端

扩展阅读

加个好友,技术交流

1628738909466805.jpg