登录
首页 >  数据库 >  MySQL

基于Web实现远程与硬件交互

来源:SegmentFault

时间:2023-01-26 08:36:10 258浏览 收藏

IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《基于Web实现远程与硬件交互》,聊聊MySQL、Linux、PHP,我们一起来看看吧!

基于Web实现远程与硬件交互

项目背景:

最近在做一个类似“速递柜”的项目,项目需求大概如下:
1.用户使用微信扫描二维码
2.后台匹配相关数据,并存储用户信息,最终返回给用户当前柜子当前状态
3.用户选择“开柜”指令,进行存取物品

需求分析

1.实现跟硬件进行数据交互,使用TCP/IP 长连接,意味着,我们要有一个TCP服务器,TCP服务器一方面接受用户发过来的相关请求指令,另一方面完成发送指令给指定硬件这一操作。
2.除了TCP 服务器我们还需要一个 Websocket 服务器,也有两个功能,一方面接受客户端发送的指令,另一方面处理转发用户指令给TCP服务器。

功能实现

TCP 服务器,Websocket 服务器 使用相对成熟的 Workman 实现。

Workerman是一款纯PHP开发的开源高性能的PHP socket 服务器框架。被广泛的用于手机app、移动通讯,微信小程序,手游服务端、网络游戏、PHP聊天室、硬件通讯、智能家居、车联网、物联网等领域的开发。 支持TCP长连接,支持Websocket、HTTP等协议,支持自定义协议。拥有异步Mysql、异步Redis、异步Http、异步消息队列等众多高性能组件。

GatewayWorker 目录结构

// register 必须是text协议
$register = new Register('text://0.0.0.0:1238');

2.修改

start_gateway.php

// gateway 进程,这里使用 TCP 协议,可以用telnet测试
$gateway = new Gateway("tcp://0.0.0.0:8282");
// gateway名称,status方便查看
$gateway->name = 'TcpGateway';
// gateway进程数
$gateway->count = 4;
// 本机ip,分布式部署时使用内网ip
$gateway->lanIp = '127.0.0.1';
// 内部通讯起始端口,假如$gateway->count=4,起始端口为4000
// 则一般会使用4000 4001 4002 4003 4个端口作为内部通讯端口 
$gateway->startPort = 2900;
// 服务注册地址
$gateway->registerAddress = '127.0.0.1:1238';

3.修改

start_businessworker.php

// bussinessWorker 进程
$worker = new BusinessWorker();
// worker名称
$worker->name = 'TcpBusinessWorker';
// bussinessWorker进程数量
$worker->count = 4;
// 服务注册地址
$worker->registerAddress = '127.0.0.1:1238';

4.根据上面的操作,我们修改

WSServer
目录下的文件,这个修改跟上面一样的,但是要注意的是,两个应用应该是不用的端口,所以需要修改的地方有两个,
start_gateway
下的端口,还有
start_register
端口。!!!! 两个应用下register 和 Gateway 端口一定不一致!!!

好了,到目前为止,我们已经完成了两个服务器的创建,那么我们两个服务器之间如何数据共享呢?答案很简单,我们在ws服务下创建一个tcp 客户端即可,让tcp 客户端与我们tcp 服务器连接就可以,然后通过tcp 客户端直接发送相关数据给tcp服务器就可以,当然并不是所有数据都是通过这样的方式共享的,我们其他信息还是通过共用一个数据库来共享的。相关代码如下:

  public static function onConnect($client_id)
    {
        // 向所有人发送
        $host = "127.0.0.1";
        $port = 8282;
        global $socket;
        if (empty($socket)) {
            $socket = TcpClient::getInstace()->connect($host, $port);
        Gateway::sendToClient($client_id, "$client_id welcome\n\r");
        }
    }


    public static function onMessage($client_id, $message)
    {
        if ($GLOBALS['socket']) {
            // 数据指令解包
            $message_arr = str_split(str_replace(' ', '', trim($message)), 2);
            $cmd=null;
            for ($j = 0; $j 

好了,截止目前我们就完成了服务端工作,当然客户端只是简单的创建一个ws连接就好。

本篇关于《基于Web实现远程与硬件交互》的介绍就到此结束啦,但是学无止境,想要了解学习更多关于数据库的相关知识,请关注golang学习网公众号!

声明:本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>