README.md · 曾韬/iotos-soft-gateway_1

# 说明

本项目是 [氦氪](https://hekr.me/) [IoTOS](https://hekr.me/p-iotos.html) 的配套**专用**软网关开发 Java SDK，用来进行二次开发对接 IoTOS 平台的一套工具集合。
需要配合 IoTOS 平台的网关（开启远程配置）使用。

本 SDK 托管在 [gitee](https://gitee.com/geekhekr/iotos-soft-gateway) 以开源的方式提供给客户使用，使用 [MulanPSL-2.0](https://gitee.com/geekhekr/iotos-soft-gateway/blob/master/LICENSE) 方式授权。

# 背景

IoTOS 是一套先进的企业级物联网解决方案平台，提供了广泛的设备接入方式，但是因为设备的多样性，无法做到一一兼容，虽然提供了硬件 [边缘网关](https://hekr.me/p-edgeos.html) ，但是也无法满足多样的设备连接方式和多样复杂的协议的要求，所以IoTOS 平台提供了软网关的方式，方便用户自己快速接入设备。

目前有两类情况可能会导致设备或子系统无法连接至 IoTOS：

- IoTOS 目前支持 MQTT、CoAP、LwM2M、HTTP 这四种协议，且认证方式要符合 IoTOS 的规定，但很多存量设备或者子系统使用了 TCP、UDP 和 WS
  等协议，且认证方式多种多样，甚至连产品标识（对应 IoTOS 里的 PK）也有缺失；
- IoTOS 作为物联网中台对南向设备只有 Server 的角色，没有 Client 的角色，但很多子系统往往提供的是 Server，因此在 IoTOS 和子系统之间必须有一个程序充当 Client
  从子系统拉取数据并传到 IoTOS。
  
# 适用场景

本项目是一个快速开发软网关的**SDK**，作为 IoTOS 的配套组件，用户需要集成本 SDK 进行二次开发才能完成完整的设备接入流程。

软件网关可用于解决以下2类无法连接 IoTOS 的设备或子系统的情况：

- 基于 TCP、UDP 和 HTTP 等私有协议的设备或子系统；
- 自带上位机的软硬件一体系统，该类系统可能暴露如 HTTP、TCP、UDP、JDBC、ODBC 等各种接口对外提供数据。

## 环境要求

> 本项目所提供的 SDK 是基于 Java 开发，如果用户有其他语言要求，可以参考 [IoTOS平台文档](http://hy.hekr.me/iot-docs-test/web/index.html) 自行实现

- JDK 1.8及以上版本
- Maven（或者 Gradle）

# 简要设计说明

下图是软件网关的基本工作原理，包含三个主要环节：

![](pics/designInstruction.png)

1. 设备接入环节 软件网关中内置了 Server 能力，默认支持 TCP、UDP、HTTP 协议的接入。使用者需要自行实现上报数据的拆包/组包（当为 TCP 时）功能。

同时软件网关也内置了 Client 能力，默认支持向子系统发起 TCP、UDP、HTTP 请求，从而实现与子系统的交互。

开发者需要自行实现交互逻辑，还可以自行扩展实现更多协议的支持。

2. 数据转码环节 此环节需实现设备原始数据格式（即设备或子系统认识的数据格式）和 KLink （IoTOS 内置的标准数据格式，采用 JSON 标准）的互相转换，使用者需要自行实现
   encode（原始数据转 KLink） 和 decode（KLink 转原始数据）这两个 interface。

3. 与 IoTOS 交互环节 软件网关使用 MQTT 协议实现与 IoTOS 的交互，使用者只需配置相关参数即可。

IoTOS 与软件网关交互的数据中一定包含 PK 和 devID，若存量设备本身不含 PK 等标识信息，开发者则需自行完成映射。

例如，子设备发送亮度状态值 `light` 为90，软件网关发送给 IoTOS 的数据格式如下：

```json
{
  "action": "devSend",
  "msgId": 1,
  "pk": "3276aa89d25a46b789c7987421396e05",  // 子设备PK 
  "devId": "dev-001",//子设备ID
  "data": {
    "cmd": "report",
    "params": {
      "light": 90
    }
  }
}
```

更详细的设备通信协议参考 [网关介绍](http://hy.hekr.me/iot-docs-test/web/content/%E8%AE%BE%E5%A4%87%E7%AE%A1%E7%90%86/%E7%BD%91%E5%85%B3%E4%B8%8E%E5%AD%90%E8%AE%BE%E5%A4%87.html) 和 [Klink 协议](http://hy.hekr.me/iot-docs-test/web/content/%E8%AE%BE%E5%A4%87%E7%AE%A1%E7%90%86/KLink.html)

# 二次开发

## 项目结构

- `framework-core` 和 IoTOS 平台交互的主要代码
- `framework-network-common` 网络组件通用代码
- `framework-network-XX` 网络组件具体实现，比如 TCP，UDP 服务端和客户端，随着优化，会丰富网络组件
- `example` 示例代码，包含网络组件的使用方式使用的时候先启动对应的 server，再启动对应的 client

其中 core 是必须的， `framework-network-XX` 模块按需加载。

## 功能封装

框架(core 部分)封装了软网关设备和 IoTOS 平台的交互过程，包括：

- 网关登录
- 掉线自动重连
- 子设备注册和添加拓扑
- 命令发送和接收
- 远程配置，自动更新本地映射关系
- 集群模式

如果用户需要详细了解交互机制，可以查阅 `framework-core` 部分的代码，同时可以参考 [IoTOS文档](http://hy.hekr.me/iot-docs-test/web/content/%E8%AE%BE%E5%A4%87%E7%AE%A1%E7%90%86/%E7%BD%91%E5%85%B3%E4%B8%8E%E5%AD%90%E8%AE%BE%E5%A4%87.html)

## 功能开放

- IoTOS 平台交互： KlinkService 类
- mqtt 连接监听 MqttDisConnectListener 类
- mqtt 断开连接监听 MqttDisConnectListener 类
- server 消息回调，事件回调 *Listener
- client 自动重连，异步、同步消息处理 *Listener

## 基本使用

### 子设备登录、登出

调用 `KlinkService#devLogin` 方法可以使子设备在线；`devLogout` 则可以使子设备离线。

### 发送业务数据

发送的业务数据的字段需要在产品的[物模型](http://hy.hekr.me/iot-docs-test/web/content/%E8%AE%BE%E5%A4%87%E6%8E%A5%E5%85%A5/%E7%89%A9%E6%A8%A1%E5%9E%8B.html)中定义，并且定义相应的命令。

发送数据使用方法： `KlinkService#devSend`。该方法重载了几个方法：

- `public void devSend(String pk, String devId, String cmd)` 可以只发送命令
- `public void devSend(String pk, String devId, String cmd, Map<String, Object> params)` 发送命令和参数
- `public void devSend(DeviceMapper mapper, ModelData data)` 直接使用 DeviceMapper 发送数据

#### 设备映射

DeviceRemoteConfig 类做了设备映射关系；该关系是通过服务启动的时候自动获取远程配置或者主动更新远程配置来做映射的。

主要方法有：

- `public static Set<DeviceRemoteConfig> getAll()` 获取所有设备信息
- `public static Optional<DeviceRemoteConfig> getByPkAndDevId(String pk, String devId)` 根据 pk 和 devId
  获取设备信息
- `public static Optional<DeviceRemoteConfig> getBySubSystemProperties(Props p)` 根据子系统的设备属性获取设备信息
- `public static String getStatus()` 获取状态信息
- `public String getPk()` 获取设备的 pk
- `public String getDevId()` 获取设备的 devId
- `public String getDevName()` 获取设备的名字
- `public <T> T getProp(String prop)` 根据属性名字获取设备属性值，注意远程配置中数据类型

你还可以实现 `DeviceMapper` 接口，直接将属性绑定到接口上，这样就可以用类似 `devSend(DeviceMapper mapper, ModelData data)` 的方法进行发送数据，而无需每次都要手动匹配设备。

### 下发命令处理
框架封装了下发命令处理过程，只需要实现 `SubsystemCommandService` 接口并添加注解 `CloudSendCommand`。

cmd，type， gateway 是 与 的关系。

举例： <code>@CloudSendCommand(cmd={"cmdA","cmdB"}, type={"typeA", "typeB"})</code> 可以匹配设备类型为
typeA或者typeB的，下发命令是 cmdA 或者 cmdB的数据。

<p style="color: red">下面方法下个版本会删除，当前做了兼容处理</p>

>框架封装了下发命令处理过程，只需要实现 `SubsystemCommandService` 接口并根据要求定义成 Spring 的 bean 即可，Bean要求：
>
>1. 子设备只有1种类型，远程配置中可以不填写 deviceType 字段， 实现类要加 `@Service("{CMD}"+Constants.CMD_BEAN_SUFFIX)`，其中 `{CMD}` 为 IoTOS 物模型命令。
>1. 子设备多于1种类型，远程配置中必须填写 deviceType 字段， 实现类要加 `@Service("{CMD}#{deviceType}"+Constants.CMD_BEAN_SUFFIX)`，其中 `{CMD}` 为 IoTOS 物模型命令。

###### 比如设备类型是 A, 命令是 set，则 bean 的名字为 `"set#A"+Constants.CMD_BEAN_SUFFIX`。

实现方法 `void handle(DeviceRemoteConfig deviceRemoteConfig, ModelData data)`；参数 `deviceRemoteConfig` 是控制的设备， `data`
是物模型信息，实际需要参考子产品定义的物模型。

### 其他开发接口

- `MqttDisConnectListener` mqtt 连接监听，可以参考 `CoreMqttConnectedListenerImpl`
  实现；如果需要在软网关连接建立或者重连的时候进行业务处理，可以实现这个接口
- `MqttDisConnectListener` mqtt 断开连接监听，可以参考 `CoreMqttDisConnectListenerImpl`
  实现；如果需要在软网关连接断开的时候进行业务处理，可以实现这个接口
- `TcpMessageListener` tcp server 消息处理监听器
- `CommonMessageListener` tcp client, udp client, udp server 消息处理监听器
- `EventListener` 事件监听器

### 集群模式

默认是单机模式。如果要启用集群模式，需要配置`mqtt.connect.cluster.mode` ，可选的参数值有：

- standalone 单机模式，不允许多个客户端登录
- cluster 集群模式，允许多个客户端同时登录，但是下发的消息只有1个客户端可以收到
- broadcast 广播模式，允许多个客户端同时登录，下发的消息所有客户端可以收到

### 开发

SDK 已经发布到 maven 仓库中，https://mvnrepository.com/artifact/me.hekr.iotos.softgateway

[API 文档](https://apidoc.gitee.com/geekhekr/iotos-soft-gateway/)

添加必须依赖：

```xml
<dependency>
  <groupId>me.hekr.iotos.softgateway</groupId>
  <artifactId>${artifactId}</artifactId>
  <version>${version}</version>;
</dependency>
```

简化依赖配置，可以直接依赖parent 配置

```xml
<parent>
  <artifactId>iotos-soft-gateway</artifactId>
  <groupId>me.hekr.iotos.softgateway</groupId>
  <version>3.2.4</version>
</parent>
```

snapshot 版本 需要添加仓库：

```xml
<repositories>
  <repository>
    <id>hekr-iotos-soft-gateway-snapshot</id>
    <url>https://s01.oss.sonatype.org/content/repositories/snapshots/</url>
  </repository>
</repositories>
```

最新版本请关注 [发行版信息](https://gitee.com/geekhekr/iotos-soft-gateway/releases)
  
示例 demo 可以参考 [iotos-soft-gateway-demo](https://gitee.com/geekhekr/iotos-soft-gateway-demo) 项目。

### 远程配置

远程配置只能用于网关设备，并且在创建产品的时候，开启远程配置功能。

远程配置内容为json数据，每行一个json对象，格式为：

```json
{"pk":"","devId":"","devName":"","deviceType": ""}
```

其中 `pk` 是子设备在IoT平台的pk，`devId` 是子设备在IoT平台的devId，devName是设备在IoT平台的设备名字，deviceType 是自定义的设备类型，用于区分不同子设备类型，如果只有1种设备，可以不写。
其他的字段可以自行填写，比如子系统设备根据ip进行区分，则可以加配置，比如`"ip":"10.1.1.2"`。

### 配置参数

默认发送队列大小为1000

设置常规发送消息队列大小，包括登录，devSend等，根据设备发送频率设置。
队列只是暂时缓冲，频率高的话，最终队列也会满，队列设置最好不要超过10000.

超过会报错

-Diot.queue.general=1000

设置注册消息队列大小，根据远程配置的设备数量配置，保险可设置为1.5-2倍

-iot.queue.register=1000

设置注册消息队列大小，根据远程配置的设备数量配置，保险可设置为1.5-2倍

### 发布

修改deploy.sh 文件中的版本号，然后 执行

`./deploy.sh install` 安装到本地

`./deploy.sh remote` 发布到中央仓库（需要10分钟-2小时同步到中央仓库）（需要管理员执行）

[中央仓库地址](https://repo1.maven.org/maven2/me/hekr/iotos/softgateway/)

然后提交到 gitee 上，打上 tag。

曾韬/iotos-soft-gateway_1

简介

发行版

贡献者

近期动态

曾韬/iotos-soft-gateway_1 .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

曾韬/iotos-soft-gateway_1