kafka转发iot数据,适用于iot-project和iot-collect无法直接TCP连接的情况,通过iot-transfer进行转发通信,目前招商适用

wuwenjun 82513417c6 日志增加offset 2 anni fa
.mvn db0ef15424 初始化提交 3 anni fa
src 82513417c6 日志增加offset 2 anni fa
.gitignore db0ef15424 初始化提交 3 anni fa
README.md 0a478d0235 增加描述信息 3 anni fa
iot-transfer.yml 9bbde956c0 增加配置描述 3 anni fa
mvnw db0ef15424 初始化提交 3 anni fa
mvnw.cmd db0ef15424 初始化提交 3 anni fa
pom.xml bbc540557e 复制kafka认证文件 3 anni fa

README.md

iot-transfer

  • kafka转发iot数据,适用于iot-project和iot-collect无法直接TCP连接的情况,通过iot-transfer进行转发通信,目前招商适用;
  • 程序一式两份,一份部署在云端,一份部署在边缘端,一式两份之间通过kafka通讯,实现内外网之间的iot数据通讯,
  • iot-transfer通过模拟iot-collect/iot-control给iot-project提供服务,同时需要配置iot-collect/iot-control的地址实现转发数据到云端,
  • 一式两份之间配置相同,通过配置文件中的iot.type.cloud和iot.type.edge来设置是部署在哪一侧;

测试服务启动状态

http://127.0.0.1:8863/test/

接口描述


post请求

参数例子

{}

成功示例

hello world!

测试给kafka发送消息

http://127.0.0.1:8863/test/sendKafka

接口描述

/隔开的参数n选1

post请求

参数例子

{
    "topic": "iot.edge2collect/iot.edge2control/iot.collect2edge/iot.control2edge",
    "packetEntity": {
        "address": "",
        "projectId": "4403050019",
        "type": "tcpControl/tcpCollect(边缘都到云端发送消息的时候需要指定)",
        "content": {
            "packetString": "3201130004;1;report;20210418000145;5864;30000;1;10101;6.06"
        }
    }
}

成功示例

发送数据的长度