终端参数上报后，平台通过tcp协议接收到相应数据并处理。

终端将终端参数以json格式的数据发送至平台。终端上电后上报，可以不认证直接上报。

实现流程如下。

1.设置终端参数上报的协议类型，例如：0x0000。

public static final int CMD_UP_PARAM = 0x0000;

2.侦听tcp服务

public void startServer() {
        log.info("startServer begin,tcp port={}", port);
        //处理接收accept连接的线程池
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        //处理tcp接收到的数据的线程池
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
            b.childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);// 关键是这句
            b.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch)
                                throws Exception {
                            
                            InetSocketAddress insocket = (InetSocketAddress)ch.localAddress();
                            // 注册OutboundHandler，执行顺序为注册顺序的逆序
                            ch.pipeline().addLast(new ProtocolEncoder());
                            // 注册InboundHandler，执行顺序为注册顺序
                            //tcp连接始终  120秒 没收到数据 300毫秒未发送数据
                            ch.pipeline().addLast(new IdleStateHandler(120000, 0, 0, TimeUnit.MILLISECONDS));
                            //根据不同的侦听端口，采用不同的解码类
                            ch.pipeline().addLast(new ProtocolDecoder());
                            ch.pipeline().addLast(new DiffChannelLogin());
                            ch.pipeline().addLast(new DealProtocolData());

                        }

                    }).option(ChannelOption.SO_BACKLOG, 128)
                    .childOption(ChannelOption.SO_KEEPALIVE, true);
            log.info("startServer bind,tcp port={}", port);
            ChannelFuture f = b.bind(port).sync();
            f.channel().closeFuture().sync();
        } catch (InterruptedException e) {
            log.error("InterruptedException e={}", e);
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
            log.info("startServer end,tcp port={}", port);
        }
    }

3.处理接收到的tcp数据，该数据是登录认证后的数据。

处理完成后，将结果响应给终端。4位处理代码。

ProtDataApi diffProtocol(ChnlData chl, ProtDataApi protData) {
        if (protData instanceof ProtDataString) {//instanceof通过返回一个布尔值来指出，这个对象是否是这个特定类或者是它的子类的一个实例。
            return diffProtocolString(chl, protData);
        }
        
        ProtData data = (ProtData) protData; 
        //log.info("diffProtocol,json={}", data.jsontext);
        JSONObject json = JSON.parseObject(data.jsontext);
        JSONObject res = null;
        
        if (data.getCmd() == DeviceProtCmd.CMD_UP_LOGIN) {
            res = service.logIn(chl, json);
            if (res == null) {
                chl.close();
                return null;
            }
        } else if(data.getCmd() == DeviceProtCmd.CMD_UP_PARAM){
            
        } else if (chl.getData() instanceof DeviceData == false){
            chl.close();
            return null;
        } 
        
        long context = json.getLongValue("context");
        if (context > 0) {
            
        }
        
        taskDao.recvDevTaskData(data.getCmd(), json);
        
        DeviceData dev = (DeviceData) chl.getData();
        if (dev != null) {
            ProtDataApi d = dao.updateTaskFlag(dev.getId(), json);
            if (d != null) {
                return d;
            }
        }
switch (data.getCmd()) {
case DeviceProtCmd.CMD_UP_PARAM:
            res = service.uploadParam(chl, json);
            break;
default:
            break;
        }
        
        if (res == null) {
            return null;
        }
        
        return new ProtData(data.getCmd(), data.getSessionId(), res.toJSONString(), chl.getEncoding());
    }

4.平台处理接收到的终端参数，并更新入库，响应结果。

public JSONObject uploadParam(JSONObject json) throws Exception {
        String identity = json.getString("identity");// ”:”设备序列号”, 
        int id = dataDao.getDeviceId(identity);
        if (id == -1) {
            log.error("该设备,identity={},不存在！", identity);
            return JsonUtils.getErrorJson(ErrorCode.ERR_NORECORD);
        }
        
        String modelno = json.getString("modelno");//":"KCC(1A)", //设备型号
        String devtype = json.getString("devtype");//":"1011", //设备类型
        String hardver = json.getString("hardver");//":"硬件版本",
        String softver = json.getString("softver");//":"软件版本",
        String serverip = json.getString("serverip");//":"平台ip",
        String serverport = json.getString("serverport");//":"平台端口号",
        String sql = "update info_terminal set devModel=?,devicetypeid=?,hardver=?"
                + ",softver=?,platform_ip=?,platform_port=? where id=?";
        JSONObject res;
        try {
            jt.update(sql, modelno,devtype,hardver,softver,serverip,serverport,id);
            res = JsonUtils.getErrorJson(ErrorCode.ERR_SUCCESS);
        } catch (DataAccessException e) {
            log.error("更新参数失败，sql={},json={},exception={}", sql, json.toJSONString(), e);
            res = JsonUtils.getErrorJson(ErrorCode.ERR_SAVE);
        }        
        return res;
    }

5.回应终端数据处理

public short head;//协议头
    public int cmd;//协议类型
    public int sessID;//会话id
    public short pkgID;//包号
    public short pkgCount;//总包数
    public short keyID;//密钥id
    public short datalen;//单包数据长途
    public int totalLen;//数据总长度
    public byte[] data;//数据
    private ChannelHandlerContext ctx;
    public String jsontext;//json字符串
    private String encoding;

public ProtData(int cmd, int sessID, String jsontext, String encoding){
        this.encoding = encoding;
        this.head = 0x2324;
        this.cmd = cmd;

        this.sessID = sessID;
        pkgCount = 1;
        pkgID = 0;
        keyID = (short) DeskeyConfig.getKeyId();
        datalen = 0;
        data = new byte[datalen];
        DecryptionMode jm = DecryptionMode3DesImp.getDecryptionMode();
        data = jm.getDecryption(data, sessID, keyID);
        this.jsontext = jsontext;
    }

 6.附上协议。

json格式如下：
{
"identity":"设备序列号", 
"modelno":"kcc(1a)", //设备型号
"devtype":1011, //设备类型
"hardver":"硬件版本",
"softver":"软件版本",
"serverip":"平台ip",
"serverport":平台端口号
}
应答：
字段名    长度    备注
json    n    json格式的数据
        
json格式如下：
{
    "errcode":错误码
}