IG网关上禁止某些终端设备通过网关上网，造成无用的流量损失。

打开网关配置页面-->网络-->防火墙-->访问控制列表-->添加策略之后应用到所在出口网络上。

一．蜂窝网和以太网（以太网为主）

1.在确保以太网和蜂窝网都正常连接的情况下点击高级功能

2. 输入登录网关的用户名密码

3. 配置SLA

4. 配置Track模块

5. 配置接口备份

6. 配置静态路由

7. 配置完成检查路由状态

8. 配置完成，此时若以太网没有网络，蜂窝网连接

二．蜂窝网和WiFi（WiFi为主）

1. 配置SLA

2. 配置Track标识

3. 配置接口备份

4. 静态路由配置

5. 配置完成

6. 此时若WiFi关闭，蜂窝网自动连接

三．以太网和WiFi（以太网为主）

1.配置SLA

2.配置Track标识

3. 配置接口备份

4. 配置静态路由

5. 配置完成

6. 此时若有线没网络，自动切换WiFi

网关毫秒采集配置

（注：目前设备支持的毫秒采集协议modbus、opc ua。最低毫秒采集周期100ms）

准备工作

映翰通网关；PC；网线；谷歌浏览器；modbus、opc ua模拟软件或者PLC等真实设备

操作步骤：

1、PC或者PLC设备通过网线连接。通过PC登陆设备管理配置页面

2、打开
边缘计算→启用边缘计算SDK环境→启用APP

3、进入
设备监控→测点监控→添加控制器及点位信息。数据正常采集

（在添加控制器时启用毫秒采集选项，添加测点时需要毫秒采集的点位开启毫秒采集开关）

4、点击云服务连接mqtt平台，等mqtt平台连接成功

5、点击自定义快函数，新增快函数

（注意添加本地订阅触发，触发主题为：“ds2/eventbus/south/upload/msec/data/\{controllerName\}”
，\{controllerName\最后的这个字段为前面添加的控制器名称。如示例为TCP-test）

6、添加脚本

7、脚本示例

# Enter your python code.

import json

from common.Logger import logger

from quickfaas.remotebus import publish

def main(message):

    logger.info(json.dumps(message))

    publish("inhand",json.dumps(message),1,cloud_name="default")

8、通过mqtt客户端订阅验证

IG902默认桥接情况下修改连接外网方式

一：确保连接外网的网线连接至GE 0/1的接口上；连接PC的网线连接至GE0/2（Console）的接口上。

二：通过WEB界面 192.168.2.1 进入设备配置。

https://192.168.2.1

三：如何将默认桥接口关闭。（查看设备是否启用桥接口如下）

打开GE0/1的DHCP服务后，将连接PC的接口转换连接至GE0/1并通过 192.168.3.1 来访问设备控制界面。

登录进入后点击高级功能进入配置界面：

四：如何设定GE0/1为WAN口，并设定固定IP或DHCP自动获取。（需完成桥接口的删除操作后，PC连接GE0/2的接口来做配置）

五：如何判断设备正常连接。

设备支持三种联网方式：

有线连接、SIM卡连接、WiFi连接（产品类型需支持）。

一：有线连接根据设备标注的提示连接WAN口，并设定WAN口的IP（DHCP获取居多）；

二：SIM卡界面选择启用数据连接，如使用专网卡等（根据特定的APN、用户验证方式）设定信息来确保正常连接至特定的网络；

（支持双SIM卡的设备）启用双SIM卡机制，设备检测到当前SIM卡故障无法通讯时即可自动切换至副卡。

同时可以启用ICMP链路侦测功能确保通讯信号的时效性。

三：WiFi模式设定为STA后重启设备，设定并扫描需要连接的WiFi输入密码，应用连接。以上连接均可以在IG设备主页或IR设备网络连接的页面下查看到实时状态。

四：设定SIM卡或网口、无线三者的链路备份，既可以通过SIM卡连接也可以通过网口连接也可以通过WiFi的方式接入网络。

1.登录跳转进入高级功能设定模块：

2、选择链路备份下的-接口备份模块。

3、选择主接口以及备份接口等数据参数；设定完成后添加即生效。（Dot11radio 1代表WLAN接口）

通过这样设定即可实现链路备份的基础功能设定：

1、电脑网口连接网关的GE0/2口，打开浏览器登录默认地址192.168.2.1进入路由器的配置页面

输入用户名：adm

密码：123456

2、找到系统管理--管理工具--启用telnet 提交更改。

电脑打开CMD

输入telnet 192.168.2.1

用户名：adm

密码：123456

显示如下：

1、添加设备，PLC协议选择ISO-on-TCP，设置IP地址和端口102，模式选择TSAP。客户端TSAP：02.00，服务器TSAP：02.01

2、添加变量，寄存器类型选择V，填写地址，选择数据类型。

3、成功读取寄存器V5000的数据。

1.电脑通过网线连接设备,访问192.168.2.1,使用默认用户adm,密码123456登录设备.

2.导航栏 选择网络 >>WLAN.

3.启用wifi 功能

4.点击扫描按钮,搜索网络中的无线信号. 选择需要连接的无线网络,输入认证密码.点击提交按钮.

5.配置默认路由

选择网络>路由>静态路由

点击编辑图标修改默认路由,修改为如图所示

6.测试 导航栏选择 系统管理>>工具

ping 功能主机处输入8.8.8.8 点击ping按钮

返回如下结果表示配置正确,设备联网正常.

本实验是做的采集数据上传云平台保留原先的断点续传并且可以将数据暂存到路由器的存储里，暂时设置暂存3天，第5天文件创建会删除第一天的文件，脚本可以根据需要修改上传和修改机制。

查看生成的日志文件，

如有错误欢迎指出，欢迎交流！

#**********************************以下是脚本解析*********************************

#以下是写数据到网关的脚本：

from common.Logger import logger
import json,os
import logging
import datetime 
def vars_cache_test(data_collect, wizard_api): 
    value_list = [] 
    utc_time = datetime.datetime.utcfromtimestamp(data_collect["timestamp"]+28800) 
for device, val_dict in data_collect['values'].items(): 
        value_dict = { 
"deviceID": device,
"timestamp": utc_time.strftime('%Y-%m-%dT%H:%M:%S.%fZ'),
"fields": {   }
                      }
for id, val in val_dict.items(): 
            value_dict["fields"][id] = val["raw_data"]
        value_list.append(value_dict)

    name=datetime.datetime.now().strftime("%Y%m%d")
    namedel=(datetime.datetime.now()+datetime.timedelta(days=-3)).strftime("%Y%m%d")
if os.path.isfile("/var/user/log/"+namedel+".log"):
        os.remove("/var/user/log/"+namedel+".log")
    tim=datetime.datetime.now().strftime('%Y-%m-%d-%H:%M:%S')
    path='/var/user/log/'+name+".log"
    tex=open(path,"a",encoding="utf8" )
    tex.write("%s数据%s\n" %(tim,value_list) )
    tex.close()
    logging.info(value_list)
return value_list

1. 下载一个电脑安装的OPC UA Cliet 工具UaExpert，协助我们查找Server的变量

https://wiki.freeioe.org/doku.php?id=opcua:uaexport

uaexpert-bin-win32-x86-vs2008sp1-v1.5.0-319.zip

2. 读取到变量之后，可以通过网线链接PLC和网关，在边缘计算APP中添加PLC

3. 添加PLC寄存器，以下面变量为例子：

添加更多工业协议设备，访问 http://app.ig.inhand.com.cn

1.进入设备web管理界面,运行device_supervisor app程序,选择 设备监控->云服务.

2.配置 发布功能(需要明白mqtt协议的组概念,同一组中可以接收数据,及A发布主题 为topic_A,B 和 c 同时订阅 topic_A,则B和C能同时收到数据)

定义发布主题为jieshou, Qos 为1.

3.添加采集数据的相关信息

4.模拟客户自行开发的APP实现与device_supervisor 通讯.

4.1 开启IG网关 调试模式.

4.2 通过ssh 222端口连接 设备用户名密码 如上图

3.3 编写测试代码

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code: " + str(rc))

def on_message(client, userdata, msg):
    print(msg.topic + " " + str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect('127.0.0.1', 9009, 600) 
client.subscribe('jieshou', qos=1)
client.loop_forever() 

4.3运行py文件,查看接收数据

注意:IG 里面开启 9009 只对设备本机内部APP互访数据有效， 不对外提供服务(外部通过IG地址加端口访问).

 EMQX 是全球领先的开源物联网MQTT 5.0服务器,高并发、低延时,内置强大的规则引擎,支持边缘及云端部署,是5G时代大型物联网应用首选技术方案。IG902边缘计算网关，可以通过MQTT协议接入EMQ服务器，帮助您快速搭建IIoT计算方案。   

1. IG902初始化配置

1）开启边缘计算安装相应APP device_supervisor并启动APP。

2）添加设备选择右侧栏目设备监控-》设备列表右上角操作中的“ ”号添加设备。

3）添加变量

2.模拟传感器数据上传：

1）使用软件modbus Slave

   2） 添加模拟数据

3）启动数据发送connection-》connect

3.配置设备云服务及搭建EMQ服务器

1）在IG Web端查看接收数据

 4.搭建EMQ服务器

1）下载链接 https://www.emqx.io/cn/downloads#enterprise

2）以Linux系统为例注册账户下载免费的license 文件，替换etc目录下的对应文件。

3）安装目录bin目录下启动系统 通过./empx start命令启动。

  4）浏览器访问http://服务器地址:18083/#/login  输入用户名和密码用户名admin 密码public登录管理页面

5.EMQ平台配置用户名认证

1）关闭匿名登录

配置匿名认证开关：

# 修改etc/emqx.conf

## Value: true | false

allow_anonymous=false

方式一：

修改etc/plugins文件夹下的

emqx_auth_username.conf文件

# etc/plugins/emqx_auth_username.conf

auth.user.password_hash = plain

## 第一组认证数据

auth.user.1.username = admin

auth.user.1.password = public

## 第二组认证数据

auth.user.2.username = test

auth.user.2.password = test

启动认证服务

./emqx_ctlplugins loademqx_auth_username或在web界面开启服务

重启emqx服务

./bin/emqx stop

./bin/emqx start

查看运行状态

./bin/emqx_ctlstatus

方式二： 1）安装mysql 数据库

mysql安装

检查系统本身是否有预装的mysql

rpm -qa | grep mysql #检查是否安装了mysql

rpm -qa | grep mariadb #检查是否安装了mariadb

rpm -e xxx#一般使用此命令即可卸载成功

rpm -e --nodeps xxx #卸载不成功时使用此命令强制卸载)

安装

wget -i -c http://dev.mysql.com/get/mysql57-community-release-el7-10.noarch.rpm

//下载mysql的rpm的包

yum -y installmysql57-community-release-el7-10.noarch.rpm

yum -y installmysql-community-server

2）创建相关表格：

>mysql –u root –p

createdatabase mqtt;

CREATETABLE`mqtt_user`(

`id`int(11) unsignedNOTNULLAUTO_INCREMENT,

`username`varchar(100) DEFAULTNULL,

`password`varchar(100) DEFAULTNULL,

`salt`varchar(35) DEFAULTNULL,

`is_superuser`tinyint(1) DEFAULT0,

`created`datetime DEFAULTNULL,

PRIMARY KEY(`id`),

UNIQUEKEY`mqtt_username`(`username`)

) ENGINE=InnoDBDEFAULTCHARSET=utf8mb4;

3) 修改文件

# etc/plugins/emqx_auth_mysql.conf

## 服务器地址

auth.mysql.server = 127.0.0.1:3306

## 连接池大小

auth.mysql.pool = 8

auth.mysql.username = mysql数据库名

auth.mysql.password = 数据库密码

auth.mysql.database = mqtt数据库

auth.mysql.query_timeout = 5s

4）启动服务mysql认证服务emqx_ctl plugins load emqx_auth_mysql   或通过web管理端插件开启

注意：如果服务未启动查看报错内容解决。1.配置文件出错（检查后修改）。2.mysql未开启远程管理权限

5）添加测试用户

mysql -u root -p

usemysql;

updateusersethost=’%’ whereuser=‘root’ andhost=‘localhost’;

添加认证用户test密码test

INSERTINTO`mqtt_user`( `username`, `password`, `salt`)

VALUES

('test', ' f2ca1bb6c7e907d06dafe4687e579fce76b37e4e93b7605022da52e6ccc26fd2', NULL);

密码采用sha256加密

6）客户端测试使用软件MQTTX  链接:https://mqttx.app/cn/

7）点击connect,提示连接成功

8）IG连接需要添加用户名密码

9)编辑发布脚本

相关发布脚本参考链接:

https://read-ts-en.readthedocs.io/en/latest/PLC%20Supervisor%E7%94%A8%E6%88%B7%E6%89%8B%E5%86%8C.html#mqtt

6.配置客户端数据存储到Mysql

1）手动新建数据表，或根据附件mqtt.sql导入数据库。

修改文件emqx_backend_mysql.conf

# etc/plugins/emqx_backend_mysql.conf

## 服务器地址

auth.mysql.server=127.0.0.1:3306

## 连接池大小

auth.mysql.pool=8

auth.mysql.username=mysql数据库名

auth.mysql.password=数据库密码

auth.mysql.database=mqtt数据库

auth.mysql.query_timeout=5s

2）建立相关表格MySQL设备在线状态表

mqtt_client 存储设备在线状态:

DROPTABLEIFEXISTS`mqtt_client`;

CREATETABLE`mqtt_client`(

`id`int(11) unsignedNOTNULLAUTO_INCREMENT,

`clientid`varchar(64) DEFAULTNULL,

`state`varchar(3) DEFAULTNULL,

`node`varchar(64) DEFAULTNULL,

`online_at`datetime DEFAULTNULL,

`offline_at`datetime DEFAULTNULL,

`created`timestampNULLDEFAULTCURRENT_TIMESTAMP,

PRIMARY KEY(`id`),

KEY`mqtt_client_idx`(`clientid`),

UNIQUEKEY`mqtt_client_key`(`clientid`),

INDEXtopic_index(`id`, `clientid`)

) ENGINE=InnoDBDEFAULTCHARSET=utf8MB4;

1 rows in set(0.00sec)

MySQL主题订阅表

mqtt_sub 存储设备的主题订阅关系:

DROPTABLEIFEXISTS`mqtt_sub`;

CREATETABLE`mqtt_sub`(

`id`int(11) unsignedNOTNULLAUTO_INCREMENT,

`clientid`varchar(64) DEFAULTNULL,

`topic`varchar(180) DEFAULTNULL,

`qos`tinyint(1) DEFAULTNULL,

`created`timestampNULLDEFAULTCURRENT_TIMESTAMP,

PRIMARY KEY(`id`),

KEY`mqtt_sub_idx`(`clientid`,`topic`,`qos`),

UNIQUEKEY`mqtt_sub_key`(`clientid`,`topic`),

INDEXtopic_index(`id`, `topic`)

) ENGINE=InnoDBDEFAULTCHARSET=utf8MB4;

MySQL消息存储表

mqtt_msg 存储MQTT 消息:

DROPTABLEIFEXISTS`mqtt_msg`;

CREATETABLE`mqtt_msg`(

`id`int(11) unsignedNOTNULLAUTO_INCREMENT,

`msgid`varchar(64) DEFAULTNULL,

`topic`varchar(180) NOTNULL,

`sender`varchar(64) DEFAULTNULL,

`node`varchar(64) DEFAULTNULL,

`qos`tinyint(1) NOTNULLDEFAULT'0',

`retain`tinyint(1) DEFAULTNULL,

`payload`blob,

`arrived`datetime NOTNULL,

PRIMARY KEY(`id`),

INDEXtopic_index(`id`, `topic`)

) ENGINE=InnoDBDEFAULTCHARSET=utf8MB4;

MySQL保留消息表

mqtt_retain 存储retain 消息:

DROPTABLEIFEXISTS`mqtt_retain`;

CREATETABLE`mqtt_retain`(

`id`int(11) unsignedNOTNULLAUTO_INCREMENT,

`topic`varchar(180) DEFAULTNULL,

`msgid`varchar(64) DEFAULTNULL,

`sender`varchar(64) DEFAULTNULL,

`node`varchar(64) DEFAULTNULL,

`qos`tinyint(1) DEFAULTNULL,

`payload`blob,

`arrived`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,

PRIMARY KEY(`id`),

UNIQUEKEY`mqtt_retain_key`(`topic`),

INDEXtopic_index(`id`, `topic`)

) ENGINE=InnoDBDEFAULTCHARSET=utf8MB4;

select* frommqtt_retain wheretopic = "retain";

MySQL消息确认表

mqtt_acked 存储客户端消息确认:

DROPTABLEIFEXISTS`mqtt_acked`;

CREATETABLE`mqtt_acked`(

`id`int(11) unsignedNOTNULLAUTO_INCREMENT,

`clientid`varchar(64) DEFAULTNULL,

`topic`varchar(180) DEFAULTNULL,

`mid`int(11) unsignedDEFAULTNULL,

`created`timestampNULLDEFAULTNULL,

PRIMARY KEY(`id`),

UNIQUEKEY`mqtt_acked_key`(`clientid`,`topic`),

INDEXtopic_index(`id`, `topic`)

) ENGINE=InnoDBDEFAULTCHARSET=utf8MB4;

3）启动服务mysql存储方法一：emqx_ctl plugins load emqx_backend_mysql方法二：通过插件启动对应插件emqx_backend_mysql

4）通过mysql查看客户端发送数据

EMQ配置文档https://docs.emqx.io/enterprise/latest/cn/

7.数据显示通过软件Grafana

1）下载链接：https://grafana.com/grafana/download安装完成后访问服务器地址：3000进入管理界面，此处访问10.5.20.245:3000

2）设置相关参数

3）测试连接mysql是否可以连接

4）创建视图表格

5）编辑表格

6）设置数据库及查询语句。

      8.尝试修改上传值

查看传输的数据

   9.EMQ平台下发数据到客户端

1）编辑订阅

相关程序参考https://read-ts-en.readthedocs.io/en/latest/PLC%20Supervisor%E7%94%A8%E6%88%B7%E6%89%8B%E5%86%8C.html#id19

2）填写代码

import logging

import json

defctl_test(topic, payload, wizard_api): #定义订阅主函数

logging.info(topic) #打印订阅主题,假定topic为write/plc

logging.info(payload) #打印订阅数据,假定payload数据为{"method":"setValue", "TagName":"SP1", "TagValue":12.3}

payload = json.loads(payload) #反序列化订阅数据

ifpayload["method"] == "setValue": #检测是否为写入数据

message = {payload["TagName"]:payload["TagValue"]} #定义下发消息，包括下发的变量名称和变量值

wizard_api.write_plc_values(message) #调用wizard_api模块中的write_plc_values方法，将message字典中的数据下发至指定变量

3）EMQ服务器端连接websocket

4）发布信息到客户端，填写对应客户端订阅主题，及修改字段{"method":"setValue", "TagName":"字段名", "TagValue":修改值为}此处修改客户端字段temperature修改值为12.3此处输入{"method":"setValue", "TagName":"temperature", "TagValue":12.3}  点击发布按钮

查看值是否修改（modbus中值和变量列表中值都被修改）

相关日志

扩展 python实现对数据的修改

import paho.mqtt.client as mqtt

# 连接成功回调

defon_connect(client, userdata, flags, rc):

print('Connected with result code 'str(rc))

client.subscribe('to_service')

# 消息接收回调

defon_message(client, userdata, msg):

print(msg.topic " "str(msg.payload))

client = mqtt.Client()

# 指定回调函数

client.on_connect = on_connect

client.on_message = on_message

# 建立连接

client.username_pw_set('用户名','密码')

client.connect('服务器地址', 1883, 60)

# 发布消息修改对象修改值

client.publish('to_client',payload='{"method":"setValue", "TagName":"T1", "TagValue":12}',qos=1)

client.loop_forever()

   Python paho-mqtt 模块使用   https://www.jianshu.com/p/ef546f476322  

运行程序查看数据变化

其它：

相关启动命令

启动mysql：  systemctl start mysqld

启动EMQ：   ./emqx/bin/emqx start

启动grafana：service grafana-server start

如果访问服务器IP：端口无法访问的情况

1.检查服务是否开启

2.centos下防火墙开启相关接口

查看命令

开启相关端口例：开启tcp协议端口3306 firewall-cmd --permanent --add-port=3306/tcp

1.访问EMQ 平台的MQTT测试信息页面 网址：https://www.emqx.io/cn/mqtt/public-mqtt5-broker

2.访问IG902的web管理界面，进入“边缘计算”，启动APP。

3.配置设备列表，配置读取的设备协议及寄存器地址。

4.使用Modbus Slave 模拟数据。

5.查看 IG设备读取状态

6.选择“设备管理>>云服务”，配置MQTT连接。

7.配置脚本将数据上传至云端。

1）选择“云服务”，点击发布中的“+”。

2）配置相关的发布设置。

3）配置订阅脚本。

代码：

import logging

import json
def ctl_test(topic, payload, wizard_api): #定义订阅主函数
    logging.info(topic) #打印订阅主题,假定topic为write/plc
    logging.info(payload) #打印订阅数据,假定payload数据为{"method":"setValue", "TagName":"SP1", "TagValue":12.3}
    payload = json.loads(payload) #反序列化订阅数据
if payload["method"] == "setValue": #检测是否为写入数据
        message = {payload["TagName"]:payload["TagValue"]} #定义下发消息，包括下发的变量名称和变量值
        wizard_api.write_plc_values(message) #调用wizard_api模块中的write_plc_values方法，将message字典中的数据下发至指定变量

相关脚本程序参考http://app.ig.inhand.com.cn/   

8.PC端使用MQTT客户端订阅相同的Topic，接收IG设备发送的数据。

1）使用MQTTBox 充当MQTT协议的客户端2。

2）订阅IG设备的发布主题。

3）查看数据

4）测试下发数据到IG。

发布信息到客户端，填写对应客户端订阅主题，及修改字段 {"method":"setValue", "TagName":"字段名", "TagValue":修改值为} 此处修改客户端字段 temperature 修改值为12.3 此处输入{"method":"setValue", "TagName":" temperature ", "TagValue":12.3} 点击发布按钮 .

5)查看数据是否下发成功。注：如果下发未成功，1.确定该变量允许写入。2.根据日志查找其它原因。