Workerman的使用

一时失言乱红尘 2023-10-10 00:53 7阅读 0赞

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

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>

<title>WebSocket\_client</title>

//创建一个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功能文件。如果需要二开直播间互动功能，可以通过这两个文件修改。