workerman实现tcp和http双向连接的方法介绍

下面给大家介绍一下workerman实现tcp和http双向连接的方法介绍。有一定的参考价值,有需要的朋友可以参考一下,希望对大家有所帮助。

workerman实现tcp和http双向连接的方法介绍

相关推荐:《workerman教程》

workerman实现tcp和http双向连接

本来想采用GatewayWorker来完成的,最后还是想写简单一点。用workerman进行和智能设备的tcp长连接和http的短连接。
场景需求。小程序端传给服务器开启设备或调节温度等操作。服务器和小程序http短连接,拿到信息后与设备进行tcp长连接。

1、建立tcp连接

protected $socket = 'tcp://0.0.0.0:2346';protected $processes = 1;protected $uidConnections = array();

2、在onWorkerStart建立http连接

global $ws_worker;    // 监听5678端口,协议websocket/http    $ws_worker = new Work('http://0.0.0.0:5678');    // 网页ws发来数据的时候的处理,可根据需要做处理,这里省略    $ws_worker->onMessage = function($ws_connection, $data){    $redis = new Redis();        //获取http发过来的http值        $data = $data['get'];        if(empty($data['type'])){            $ws_connection->send("type为空");        }elseif($data['type'] == 1){            //开机            //拿mac去redis验证是否存在,然后拿拿到http进行访问请求开机。做个定时器。到期自动请求设备关机            $mac = $redis->hGet('facility',$data['mac']);            if(!$mac){                $ws_connection->send("mac地址错误");            }            $status = $this->sendMessageByUid($mac,'开机');//像指定用户发送消息            if($status == 1){//回调码,判断是否成功                $ws_connection->send("开机成功");            }else{                $ws_connection->send("发生错误");            }        }elseif($data['type'] == 2){            //关机            //拿mac去redis验证是否存在,然后拿拿到http进行访问请求关机。            $mac = $redis->hGet('facility',$data['mac']);            if(!$mac){                $ws_connection->send("mac地址错误");            }              $status = $this->sendMessageByUid($mac,'关机');//像指定用户发送消息            if($status == 1){//回调码,判断是否成功                $ws_connection->send("关机成功");            }else{                $ws_connection->send("发生错误");            }        }    };    $ws_worker->listen();}

上面代码为demo案例。下面做点连接的测试,业务代码自行参考

3、tcp连接与http连接

法语写作助手 法语写作助手

法语助手旗下的AI智能写作平台,支持语法、拼写自动纠错,一键改写、润色你的法语作文。

法语写作助手 31 查看详情 法语写作助手

 /** * 当连接建立时触发的回调函数 * @param $connection */public function onConnect($connection){  $connection->send(“tcp连接\n");    echo 'tcp连接';    }

我们做一个客户端的tcp连接请求。

'123456','ip'=>'1.2.3.4');socket_write($socket, json_encode($mac)) or die("Write failed\n");while ($buff = socket_read($socket, 1024, PHP_NORMAL_READ)) {    echo '1';    echo("Response was:" . $buff . "\n");    echo("input what you want to say to the server:\n");    $text = fgets(STDIN);    socket_write($socket, $text);}socket_close($socket);

我们在终端运行这个php文件和server文件,当建立了连接时。服务端会输出tcp连接(此时已是长连接)

注:当用tcp连接发送消息的时候,注意粘包问题。每个消息后加”\n”代表换行

在这里插入图片描述
我们在试一下http连接,http连接就简单多了。url访问就可以了

global $ws_worker;$ws_worker = new Work('http://0.0.0.0:5678');$ws_worker->onMessage = function($ws_connection, $data){        echo "http连接";}

在这里插入图片描述
这个简单的例子应该都懂。接下来就差业务代码了,就看自己发挥了。

更多编程相关知识,请访问:编程教学!!

以上就是workerman实现tcp和http双向连接的方法介绍的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/350484.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年11月5日 22:03:55
下一篇 2025年11月5日 22:05:01

相关推荐

发表回复

登录后才能评论
关注微信