使用TCP服务网关接入设备

本文档使用Packet SenderTCP透传方式接入设备 - 图1 (opens new window)工具模拟tcp客户端接入平台。

创建协议

请参考创建协议

TIP

本文使用到协议仅作为演示,请根据实际情况参照协议实现.在设备未确定协议的情况下,建议使用mqtt方式接入.

创建产品

  1. 选择 设备管理-->产品--> 点击新建按钮。

设备型号新增

  1. 在操作列点击查看,选择功能定义,点击添加按钮添加属性和事件。
    i. 属性定义
    属性定义
    ii. 事件定义
    事件定义

    json对象-经度:
    事件定义

    json对象-维度:
    事件定义

    json对象-点位:
    事件定义

  2. 在操作列点击发布按钮,发布新增的型号。

设备型号发布

创建设备

  1. 选择 设备管理-->设备--> 点击添加设备按钮。

设备新增

  1. 在操作列点击激活按钮,激活新增的设备实例。

设备发布

创建TCP服务网络组件

  1. 选择 设备接入-->网络组件--> 点击新增组件按钮。
    insert-mqtt-client

注意

本文档使用javascript自定义脚本的方式解析消息。用于处理tcp的粘拆包。

自定义脚本:

  1. var BytesUtils = org.jetlinks.core.utils.BytesUtils;
  2. parser.fixed(5) //1. 固定5字节为报文头,0字节为类型,1-4字节为消息长度(低字节位在前).
  3. .handler(function(buffer){
  4. var len = BytesUtils.leToInt(buffer.getBytes(),1,4);//2. 获取消息长度.
  5. parser
  6. .fixed(len)//3. 设置下一个包要读取固定长度的数据.
  7. .result(buffer); //4. 设置当前解析的结果
  8. })
  9. .handler(function(buffer){
  10. parser.result(buffer) //5. 收到了新的包,则为消息体,设置到结果中,完成后将与步骤4的数据合并为完整的数据包.
  11. .complete(); //6. 完成解析(消息将进入协议中进行解析(DemoTcpMessageCodec)),重置解析器,下一个数据包将从步骤1开始解析.
  12. });
  1. 在创建完成的模块上点击启动按钮。
    mqtt-client-start

创建TCP服务设备网关

  1. 选择 设备接入-->设备网关--> 点击新建按钮。 insert-mqtt-gateway

注意

和MQTT服务设备网关不同的是,TCP必须指定消息协议,因为无法通过消息识别出对应的设备标识. 在消息解码时也无法通过上下文(MessageDecodeContext)获取到设备操作接口(DeviceOperator). 此处使用demo协议.

  1. 在操作列点击启动按钮启动网关。
    mqtt-gateway-start

使用tcp工具接入

  1. 下载并安装Packet SenderTCP透传方式接入设备 - 图15 (opens new window)

注意

TCP协议以二进制的数据包传输数据,此处使用Packet Sender工具将发送的消息先转成十六进制, 再通过该工具自动转换成二进制发送到平台。

  1. 生成所需的十六进制字符串。
    i. 检出协议代码TCP透传方式接入设备 - 图16 (opens new window)
    ii. 执行测试包org.jetlinks.demo.protocol.tcp下DemoTcpMessageTest的test方法生成设备认证所需的十六进制字符串
    代码如下:
  1. @Test
  2. void test() {
  3. DemoTcpMessage message = DemoTcpMessage.of(MessageType.AUTH_REQ, AuthRequest.of(1000, "admin"));
  4. byte[] data = message.toBytes();
  5. System.out.println(Hex.encodeHexString(data));
  6. DemoTcpMessage decode = DemoTcpMessage.of(data);
  7. System.out.println(decode);
  8. Assertions.assertEquals(message.getType(), decode.getType());
  9. Assertions.assertArrayEquals(message.getData().toBytes(), decode.getData().toBytes());
  10. }

结果:000d000000e80300000000000061646d696e

注意

AuthRequest.of(deviceId,key) 第一个参数为设备id,第二参数为设备型号中配置的TCP认证配置。

iii. 在测试类中执行如下代码生成事件上报所需的十六进制字符串:

  1. @Test
  2. void encodeEvent() {
  3. DemoTcpMessage demoTcpMessage = DemoTcpMessage.of(MessageType.FIRE_ALARM,
  4. FireAlarm.builder()
  5. .point(ThreadLocalRandom.current().nextInt())
  6. .lat(36.5F)
  7. .lnt(122.3F)
  8. .deviceId(1000)
  9. .build());
  10. byte[] data = demoTcpMessage.toBytes();
  11. System.out.println(demoTcpMessage);
  12. System.out.println(Hex.encodeHexString(data));
  13. }

结果:0614000000e8030000000000009a99f4420000124222b7c94c

  1. 设置参数

    i. 设置基本信息 tcp基本信息设置

    参数说明
    Name输入您的自定义名称。
    ASCIIASCII码,输入下方十六进制字符串后会自动生成。
    HEX十六进制。
    AddressTCP服务地址。
    PortTCP服务端口。
    Persistent TCP勾选之后可保持长连接。

    注意

    设置参数时,请确保参数值中或参数值的前后均没有空格。

    模式选择TCP。
    模式选择

    分别保存上线参数以及事件上报参数。
    设备上线:
    参数1
    事件上报:
    参数2

  2. 模拟设备上下线

单击packetsender工具上Send按钮发起请求。
online-send

平台中设备状态变为上线即为连接成功

设备上线

在设备日志模块可以看到设备上线日志

设备上线日志

勾选Persistent TCPpacketsender上请求成功后会打开一个新的已连接页面。

persistent-tcp

关闭这个新的已连接页面即可断开设备与平台的连接

disconnect-persistent-tcp

平台中设备状态变为离线即为断开连接成功

设备离线

在设备日志模块可以看到设备离线日志

设备离线日志

  1. 模拟设备上报事件

    i. 在第4.步,设备上线成功后打开的新的已连接页面上选择第3.步保存的事件上报参数。

    事件上报请求

    ii. 上报成功后,在页面可以查看到。

    事件上报内容

    事件上报内容1

    iii. 事件上报设备日志

    事件上报设备日志

    事件上报设备日志1