本文主要是介绍workerman 实现推送实时数据到前端，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
首先要说明一下，实时推送是有两个socket服务端和两个socket的客户端
我们分别起名叫做
外层服务端 （开启服务主进程 创建一个 websoket 连接）ws://
内层服务端 （在开户主进程的时候，内部又创建的一个 socket）text://
外层客户端 (这是由前端的用户端 使用js 创建的一个 websocket 客户端)
内层客户端 （这是php 使用 stream_socket_client 创建的一个客户端）
上代码（说明在代码的注释中）
服务端代码 （websocket 的创建）
- 安装 workerman (因为使用的是 tp框架，所以安装的 topthink/think-worker ，它已经包含了 workerman)
composer install topthink/think-worker
这个服务端是一个 挂起的操作， 所以不需要过 tp 的入口文件，直接使用 php 命令行运行就可以了
本人在 app\worker\Testworker.php 新建了这个服务端的文件
require __DIR__ . '/../../vendor/autoload.php'; //因为是独立运行的，所以要引入 autoload.php
use Workerman\Worker;
$worker = new Worker("websocket://0.0.0.0:2345"); //创建了一个 websocket 的服务端，端口是 2345 （记得打开阿里云 或 宝塔的 2345端口）
$worker->count=1; //count属性windows中的配置就写1 linux中可以配多个$worker->uidConnections = []; //自定义了一个空数组，用来存放所有的 连接对象//当连接成功时
$worker->onConnect = function($connection){dump($connection);//这里只是显示一下连接是否成功，没有什么作用
};//workerman 收到消息时的监听，前端可能发过来不同种类的消息，所以消息上都带有type字段，根据 type 类型的不同做相应的处理
//参数 $connection 表示 这个 websocket连接的资源操作符 是一个非常有用的数据后续我们是在保存起来的
//参数 $msg 就是前端发过来的数据 格式是 {type:"bind",uid:1},自已定义就可以了 我这里bind就是绑定用户的意思
$worker->onMessage = function($connection,$msg) use ($worker){$msg = json_decode($msg,true);if($msg["type"] == "bind"){//如果前端传来的消息类型是 bind 就是绑定用户的消息类型if(!isset($connection->uid)){$connection->uid = $msg["uid"]; //我们给 $connection对象加上一个uid属性 这一步用户不太大}$worker->uidConnections[$connection->uid] = $connection; //这里把所有客户端的连接放入一个数组中， 并使用 用户的uid 做为键名，当要发送信息的时候，就通过 uid 得到用户相对应的 connection }else if($msg["type"] == "logout"){//如果前端传来的消息类型是 logout 就从uidConnections中删除 相应的connectionunset($worker->uidConnections[$msg["uid"]]);}//这里根据消息类型的不同可以写很多的 if 分支
};//当服务端关闭的时候，给每一个客户端发送 服务器下线的通知
$worker->onClose = function() use ($worker){foreach($worker->uidConnections as $uidConnection){$uidConnection->send("服务器下线了");}
};//当服务启动时
$worker->onWorkerStart = function($worker){
//当服务启动时， 我们在内部开启一个socket 也就是上面说的 内层服务端 端口是2346 记得打开（阿里云或宝塔的端口）
//这里的 innerSocket是给 php 开启的 socket 的客户端来使用的$innerSocket = new Worker("text://0.0.0.0:2346");$innerSocket->onMessage = function($connection,$innermsg) use($worker){//在innermesg 中包含的有数据 {type:"notify",uids:[1,2,4,5],data:{.....}} 类型和要接收通知的用户的id$innermsgArr = json_decode($innermsg,true);if($innermsgArr["type"] == "notify"){//如果消息类型是 notify ，就从 $worker->uidConnections中取出相对应用户的连接对象，使用send方法把数据发送给前端foreach($innermsgArr["uids"] as $uid){$worker->uidConnections[$uid]->send($innermsgArr["data"]);}}}//workerman允许在服务运行过程中调用new Worker实例化Worker建立监听其它端口。此时因为已经在运行，所以不需要调用run方法，直接调用listen方法，将新的监听add到EventLoop中即可。$innserSocket->listen(); //上面解释了这里为什么要使用 listen方法
}Worker::runAll(); //这是workerman 启动服务的方法
以上就是 服务端的代码， 使用时 在命令行中 php Testwroker.php就可以了， 它是一个挂起的窗口，我们实际上线时可以让它在后台运行就可以了
前端（用户端） 客户端 socket的使用 这里我使用的是vue3 不用安装就直接使用js 原生的websocket ，开发工具写的时候可能为 自动给你添加了别了 websocket类，注意把开发工具添加的 import …websocket 这行给删除掉
上代码
<template><div class="wrapper"><h5>这是一个websocket 的测试的例子</h5><div>{{backdata}}</div></div>
</template><script setup>import {onMounted, ref} from "vue";let websocket = ref();let backdata = ref("xxxxx"); //后端发回过来的数据onMounted(()=>{//前端创建一个websocket客户端，并建接到 外层服务端 2345 的端口websocket.value = new WebSocket("ws://127.0.0.1:2345")websocket.value.onopen = ()=> {console.log("建立连接");//当连接建立成功之后， 就给服务端发送一个绑定的消息，其中 uid 是用户登录的时候就已经获取到的， 样例这里我是写死的 为1websocket.value.send(JSON.stringify({type:"bind",uid:1}))}//当后端给前端发送消息时websocket.value.onmessage = (event) =>{console.log(event);console.log(event.data); //这里的data 也可以 分为不同的类型， 也就是说在服务端返回数据的时候加上 type 自定义一下就可以了，根据类型的不同来前端显示不同的数据backdata.value = event.data;}websocket.value.onclose = ()=> {console.log("连接关闭")}})</script>
php 的创建的客户端的用法
当我们后端改动数据库之后， 给前端发送一个信息
我们在 自已的业务中 api 添加一个接口
<?php
namespace app\api\controller;use app\common\controller\Frontend;
use utils\WechatUtil;
class Order extends Frontend{protected array $noNeedPermission = ["*"];protected array $noNeedLogin = ["*"];//我们的 api 测度接口public function workerMantest(){/*** 这里有一些修改数据库的代码 根据业务的不同写上就可以了* 完成了数据库的操作之后* 下面要用 php 新建一个 socket的客户端，去连接 innerworker 的服务端，并传输一些数据*///这里使用 stream_socket_client创建了一个 socket 的资源， 为什么要用它，后面再说$client = stream_socket_client("tcp://127.0.0.1:2346",$error,$errmsg,10);if(!$client){echo $errmsg; //如果报错返回错误信息}else{$result = ["type"=>"notify","uids"=>[1], // 这里是 哪些用户需要被推送消息"data"=>"这里是想发送给 用户客户端的一些数据"];$resultjson = json_encode($result); //2346 socket开的是 text:// 协议 text协议，要求在文本最后加上 \n 为结束标记fwrite($client, $resultjson."\n");//fread($client,strlen($resultjson."\n")); 这里的 fread就不需要了， 没用，而耗时fclose($client); //完成关闭资源}return $this->succcess("订单修改成功");}
}
最后在这里说明一下， 为什么 在 php 客户端中使用的是 stream_socket_client 函数创建的，而不是用 workerman 来创建客户端， 我们知道 workerman 也可以创建客户端，也可以创建服务端， 那么我们为什么没有 在 api 接口中，使用workerman 创建客户端呢？？？
主要是因为 api接口和 workerman 运行的环境不同
api接口，我们是运行在 php-fpm 的环境中的
workerman 是运行在 命令行中的，不能在 php-fpm 中使用
退一步想，我们 api接口运行完成，就返回数据了， 如果在其中使用 workerman的话，这个接口就会一直挂起
所以 我们 使用了 stream_socket_client 创建了 php 端的 socket
这篇关于workerman 实现推送实时数据到前端的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
