其他分享
首页 > 其他分享> > workman 搭建tcp服务器,和websocket互相通信

workman 搭建tcp服务器,和websocket互相通信

作者:互联网

前一段时间需要做一个小demo,把温湿度传感器采集到的数据同步显示在浏览器网页上。抽了点时间把demo做了出来,虽然是个小demo,功能也比较简单,但是做的时候还是踩了一些坑,记录一下流程。

参考链接:https://www.cnblogs.com/zjfree/p/6491740.html

1. 下载安装workman

workman:官网地址
workman开发文档:官网文档地址

根据文档所说:

WorkerMan实际上就是一个PHP代码包,如果你的PHP环境已经装好,只需要把WorkerMan源代码或者demo下载下来即可运行。

这里我选择用composer安装

composer require workerman/workerman

安装成功

2. 代码实现

<?php
use Workerman\Worker;

require_once __DIR__ . '\Workman\Autoloader.php';

// 设置时区
date_default_timezone_set("PRC");

// websocket 协议的worker
$ws_worker = new Worker('Websocket://0.0.0.0:5678');
// 这里只能写1
$ws_worker->count = 1;
// websocket server 启动后在当前进程增加一个socket监听
$ws_worker->onWorkerStart = function($ws_worker)
{
    // 增加一个Socket端口的监听设备发来的数据
    $socket_worker = new Worker('tcp://0.0.0.0:1236');
    // 当设备发来数据时如何处理
    $socket_worker->onMessage = function($connection, $data)
    {
        // 这里处理设备发来的数据 $data
        // 比如像这样给所有的WebSocket连接转发数据
        global $ws_worker;
        if ($data === FALSE) return;
        foreach($ws_worker->connections as $ws_con)
        {
           $data = json_encode(['code'=>666,'data'=>$data]);
           $ws_con->send($data);
        }
    };
    // 给ws_worker添加一个属性保存socket_worker,方便获取
    // 之前ws接收的数据一直推送不到tcp,问题就在这里,这里要保存一下
    $ws_worker->socketWorker = $socket_worker;
    // 执行监听
    $socket_worker->listen();
};

// websocket协议也就是浏览器发来数据时
$ws_worker->onMessage = function($connection, $data)
{
    // 假设需要转发给所有的设备
    global $ws_worker;
    foreach($ws_worker->socketWorker->connections as $socket_con)
    {
    	// 处理业务代码
    }
};

Worker::runAll();

其中遇到的问题就是,websocket端接收到的数据无法发送到tcp,直到看到

$ws_worker->socketWorker = $socket_worker;

把socket_worker保存在ws_worker里,再ws推送信息时,循环数组,达到推送所有设备的目的。

3. 前端代码实现

<script>
    var wsObj = new WebSocket("ws://ip:port");   //建立连接
    wsObj.onopen = function(){ 
        var ms = {code:200,msg:"success"};
        wsObj.send(JSON.stringify(ms));
    };
    wsObj.onmessage = function(ev){  //获取后端响应
        var msg=eval("("+ev.data+")");
        // 格式化json数据
        if (msg['code'] == 666) {
            var data = msg['data']
            var res = eval("("+ data +")")
            // 处理数据
        }
    };
    wsObj.onclose = function(ev){
    	// 断开连接
         alert("close");
    };
    wsObj.onerror = function(ev){
    	// 连接出错
        alert("error");
    };
</script>

具体的业务代码就不上了。

4. 小结

wokerman还是比较好用的,这个demo没有选择使用原生socket服务,也是为了节约时间和成本,快速实现开发目的。

标签:function,wsObj,websocket,socket,workman,worker,tcp,ws,data
来源: https://blog.csdn.net/qq_36142158/article/details/116660963