V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
HHAO2019
V2EX  ›  物联网

物联网的技术方案都有哪些?刚入行

  •  
  •   HHAO2019 · 148 天前 · 801 次点击
    这是一个创建于 148 天前的主题,其中的信息可能已经有所发展或是发生改变。

    我们目前设备不多。数据流程如下:

    • 1 硬件设备使用 485 线连接通讯设备(DTU),使用 4G 网络传输数据
    • 2 通讯设备吧数据传输到 EMQX
    • 3 Java 程序订阅 EMQX 主题,接受 16 进制数据,并做解析 /告警校验等,录入 Influxdb

    遇到的问题是:java 程序挂掉,数据就丢失了,这里如何做高可用?

    第 1 条附言  ·  146 天前
    仔细看了一下 emqx 的文档,使用规则引擎把数据通过 http 请求接口的形式解决了 java 客户端订阅总是断开的问题。
    12 条回复    2022-04-07 22:58:55 +08:00
    villivateur
        1
    villivateur  
       148 天前 via Android
    你不如去解决下为什么 Java 会挂掉。

    另外物联网设备自己可以在本地做缓存
    cat007
        2
    cat007  
       148 天前
    做高可用就不会挂掉了
    HHAO2019
        3
    HHAO2019  
    OP
       148 天前
    @villivateur java 用的库是这个 Eclipse Paho Java Client ,经常 mqtt 断连 。重连机制一直在调试,最近几天好点了
    HHAO2019
        4
    HHAO2019  
    OP
       148 天前
    @villivateur 我看挺多同行都自己研发了个通讯管理机做边缘计算,感觉那样会更稳
    HHAO2019
        5
    HHAO2019  
    OP
       148 天前
    @cat007 主要是 java 服务订阅一个主题,如果订阅连接断了,重连也失败了,如何做高可用?我试过 system.exit 然后触发 docker 重启。
    mlhorizon
        6
    mlhorizon  
       148 天前
    高可用就是不让这个程序挂掉。
    物联网设备本地缓存一般只对断网情况做缓存,它是没法知道数据消费者挂掉的。
    HHAO2019
        7
    HHAO2019  
    OP
       148 天前
    @mlhorizon 是的 ,我可能说错了,我的意思是如何让消费者的连接断了能快速回复。或者我目前做的是不是错的方法?在物联网行业中如何保证录入数据的高可用性?
    cat007
        8
    cat007  
       148 天前
    @HHAO2019 应该解决订阅为什么会断掉吧,如:网络不稳定、被别的客户端挤下线了
    paradoxs
        9
    paradoxs  
       148 天前
    呵呵,既然你的 java 程序经常要挂,那我推荐你把 Influxdb 的数据持久化。
    HHAO2019
        10
    HHAO2019  
    OP
       148 天前
    @paradoxs java 程序做解析,然后就直接 influxdb 持久化了。 我说错了,不是程序挂了,是订阅 emqx 的连接挂了,不好意思。我也不知道业内的逻辑是怎么样的,所以上来问问看我目前做的是不是有更好的解决方案
    paradoxs
        11
    paradoxs  
       147 天前   ❤️ 1
    打开 emq 后台,找到插件,然后把 emqx_web_hook EMQ X WebHook Plugin 这个打开。

    vim etc/plugins/emqx_web_hook.conf , 把里面的链接换成你 java 程序监听的地址。

    重启一下 emqx ,然后在 java 里面就可以监听到断链的消息。

    后面再操作一下重新链接
    IfEles
        12
    IfEles  
       125 天前   ❤️ 1
    @HHAO2019 mqtt 断开,有几种可能,你设备端的 clientId 重复,还有可能是你的 java 程序消费没有生产的速度快,导致 mq 队列积压阻塞,然后 mqtt 会断开,你可以排查一下程序经常断开的原因
    关于   ·   帮助文档   ·   API   ·   FAQ   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   2857 人在线   最高记录 5497   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 24ms · UTC 11:28 · PVG 19:28 · LAX 04:28 · JFK 07:28
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.