crc高位补零，ByteBuf异常处理

README.md

 # 下发控制6x6大屏
 
+#### 启动：
+
+​		NettyApplication.java    主程序入口，运行即启动
+
+```
+//NettyApplication.java  文件路径: /src/main/java/com/gemho/netty/NettyApplication.java
+	
+	public static void main(String[] args) {
+        SpringApplication.run(NettyApplication.class, args);
+        new nettyServer(9999);    // 设备连接端口，可以根据自身情况进行修改
+    }
+```
+
+
+
+​		application.yml文件中
+
+```
+// application.yml 文件路径: /src/main/resource/application.yml
+
+	server:
+      port: 9998                   // http请求端口，可以根据自身情况进行修改
+```
+
+
+
+
+
 #### 服务端：
 
 ​		监听端口: 9999
@@ -18,13 +46,17 @@
 
 | 参数名称 | 参数值                                       |
 | -------- | -------------------------------------------- |
-| key      | 313233343536373839383736353433（hex string） |
+| key      | 864333042029678（string） |
 | code     | 03 (string)                                  |
-| x        | 54（hex string）                             |
-| y        | 5 （hex string）                             |
+| x        | 54（string）                             |
+| y        | 5 （string）                             |
 | font     | 30  (string)                                 |
 | content  | 温度 (string)                                |
 
+完整接口格式:
+
+http://localhost:9998/display?key=864333042029678&code=01&x=12&y=15&font=31&content=温 度:33.5℃
+
 
 
 ##### 清屏指令
@@ -32,7 +64,8 @@
 ##### url:  http://192.168.1.49:9998/clear
 
 | 参数名称 | 参数值                    |
-| -------- | -------------------------------------------- |
-| key      | 313233343536373839383736353433（hex string） |
+| -------- | ------------------------- |
+| key      | 864333042029678（string） |
 | code     | 03(string)                |
 
+完整接口格式:http://localhost:9998/clear?key=864333042029678&code=01

netty.iml

@@ -4,16 +4,6 @@
     <facet type="Spring" name="Spring">
       <configuration />
     </facet>
-    <facet type="jpa" name="JPA">
-      <configuration>
-        <setting name="validation-enabled" value="true" />
-        <setting name="provider-name" value="Hibernate" />
-        <datasource-mapping>
-          <factory-entry name="entityManagerFactory" />
-        </datasource-mapping>
-        <naming-strategy-map />
-      </configuration>
-    </facet>
     <facet type="web" name="Web">
       <configuration>
         <webroots />
@@ -33,7 +23,7 @@
       <sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
       <excludeFolder url="file://$MODULE_DIR$/target" />
     </content>
-    <orderEntry type="jdk" jdkName="1.8" jdkType="JavaSDK" />
+    <orderEntry type="inheritedJdk" />
     <orderEntry type="sourceFolder" forTests="false" />
     <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter:2.3.3.RELEASE" level="project" />
     <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot:2.3.3.RELEASE" level="project" />

src/main/java/com/gemho/netty/NettyApplication.java

@@ -3,8 +3,10 @@ package com.gemho.netty;
 import com.gemho.netty.controller.nettyServer;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration;
 
-@SpringBootApplication
+@SpringBootApplication(exclude={DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class})
 public class NettyApplication {
 
     public static void main(String[] args) {

src/main/java/com/gemho/netty/controller/SocketController.java

 package com.gemho.netty.controller;
 
-import cn.hutool.json.JSONUtil;
+import cn.hutool.core.util.URLUtil;
+import cn.hutool.http.HttpUtil;
+import com.gemho.netty.model.ResultModel;
 import com.gemho.netty.util.CRC16Util;
 import com.gemho.netty.util.MapUtils;
 import com.gemho.netty.util.ParamUtil;
@@ -8,58 +10,75 @@ import com.gemho.netty.util.StringUtil;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.Channel;
+import io.netty.channel.ChannelFuture;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.LinkedHashMap;
-import java.util.Map;
+import java.net.URLEncoder;
 
 @RestController
 public class SocketController {
 
-
-    private static String CLEAR_CODE = "0000000400000650";
-
-    private static String DISPLAY_CODE = "0001";
-
-    // key:313233343536373839383736353433   16进制DTU码
-    // code: 03
-    @RequestMapping("/clear")
+    /**
+     *
+     * @param key  313233343536373839383736353433   16进制DTU码
+     * @param code  01
+     * @return String
+     */
+    @GetMapping("/clear")
     public String clearDiaplay(String key, String code) {
+        String CLEAR_CODE = "0000000400006050";
         code = code + CLEAR_CODE;
         int i = CRC16Util.calcCrc16(StringUtil.hexString2Bytes(code));
-        System.out.println("=============" + StringUtil.encodeHEX(i));
-        System.out.println("=============" + StringUtil.hexString2Bytes((code + StringUtil.encodeHEX(i)).toUpperCase()));
-        code = (code + StringUtil.encodeHEX(i)).toUpperCase();
+        code = (code + StringUtil.hightAddZero(StringUtil.encodeHEX(i))).toUpperCase();
         // 内容封装
         ByteBuf bufff = Unpooled.buffer();
         //  bufff.clear();
+        System.out.println("============send:" + code);
         bufff.writeBytes(StringUtil.hexString2Bytes(code));
         // 获取通道
         Channel mapChannel = MapUtils.getMapChannel(key);
+        bufff.retain();
         mapChannel.writeAndFlush(bufff);
+        // bufff.retain();
+
+        // 返回失败指令时使用
+        if (!ParamUtil.findMapContainerKey("clear" + mapChannel.remoteAddress().toString())) {
+            ResultModel model = new ResultModel();
+            model.setCount(1);
+            model.setHexCodeByte(StringUtil.hexString2Bytes(code));
+            ParamUtil.addMap("clear" + mapChannel.remoteAddress().toString(), model);
+        }
         return "success";
     }
 
-    // 01 00 01 00 0E 36 05 30 CE C2 B6 C8 B7 38
-    // key:313233343536373839383736353433   16进制DTU码
-    // code: 03
-    // x: 54  16进制
-    // y: 5   16禁止
-    // font:  30字体大小
-    // content: 温度
-    @RequestMapping("/display")
-    public String display(String key, String code, Integer x, Integer y, String font, String content) {
+
+    /**
+     *
+     * @param key          313233343536373839383736353433   16进制DTU码
+     * @param code         01
+     * @param x            54  16进制
+     * @param y            5   16禁止
+     * @param font         31字体大小
+     * @param content      温度
+     * @return String
+     */
+    @GetMapping("/display")
+    public String display(String key, String code, Integer x, Integer y, String font,String content) {
         try{
+            String DISPLAY_CODE = "0001";
             // 指令处理
             String xHex = Integer.toHexString(x).length() == 1? "0"+ Integer.toHexString(x) : Integer.toHexString(x);
             String yHex = Integer.toHexString(y).length() == 1? "0"+ Integer.toHexString(y) : Integer.toHexString(y);
             String contentByte = StringUtil.enUnicode(content);
             byte[] contentB = StringUtil.hexString2Bytes(contentByte);
-            String lenHex = StringUtil.encodeHEX(contentB.length + 10);
+            String lenHex = StringUtil.encodeHEX(contentB.length + 3);
             lenHex = StringUtil.hightAddZero(lenHex);
             code = code + DISPLAY_CODE + lenHex + xHex + yHex + font + StringUtil.bytesToHexString(contentB);
-            code = code + StringUtil.encodeHEX(CRC16Util.calcCrc16(StringUtil.hexString2Bytes(code)));
+            code = code + StringUtil.hightAddZero(StringUtil.encodeHEX(CRC16Util.calcCrc16(StringUtil.hexString2Bytes(code))));
             System.out.println("下发指令==============" + code.toUpperCase());
             // 数据封装
             ByteBuf bufff = Unpooled.buffer();
@@ -67,11 +86,14 @@ public class SocketController {
             // 获取通道
             Channel mapChannel = MapUtils.getMapChannel(key);
             mapChannel.writeAndFlush(bufff);
-            // 执行失败使用
-            if (ParamUtil.findMap(mapChannel.remoteAddress()) == null) {
-                Map<Integer, ByteBuf> map = new LinkedHashMap<>();
-                map.put(1, bufff.retain());
-                ParamUtil.addMap(mapChannel.remoteAddress(), map);
+
+            // bufff.retain();
+            // 返回失败指令时使用
+            if (!ParamUtil.findMapContainerKey("display" + mapChannel.remoteAddress().toString())) {
+                ResultModel model = new ResultModel();
+                model.setCount(1);
+                model.setHexCodeByte(StringUtil.hexString2Bytes(code));
+                ParamUtil.addMap("display" + mapChannel.remoteAddress().toString(), model);
             }
             return "success";
         }catch(Exception e) {
@@ -79,5 +101,13 @@ public class SocketController {
             return null;
         }
     }
-
+    @GetMapping("/test")
+    public void test(String key) throws Exception{
+        System.out.println(key + "=======================");
+        String body = HttpUtil.createGet("http://localhost:9998/display?key=864333042029678&code=01&x=0&y=12&font=31&content=温 度:33.5℃").execute().body();
+        // Thread.sleep(500);
+        String body1 = HttpUtil.createGet("http://localhost:9998/display?key=864333042029678&code=01&x=0&y=24&font=31&content=湿 度:33.5%RH").execute().body();
+        // Thread.sleep(500);
+        String body2 = HttpUtil.createGet("http://localhost:9998/display?key=864333042029678&code=01&x=0&y=36&font=31&content=CO2:450ppm").execute().body();
+    }
 }

src/main/java/com/gemho/netty/controller/nettyHandler.java

 package com.gemho.netty.controller;
 
-import cn.hutool.json.JSONUtil;
+import com.gemho.netty.model.ResultModel;
 import com.gemho.netty.util.*;
 import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 
-import java.util.Map;
-import java.util.Set;
 
 public class nettyHandler extends ChannelInboundHandlerAdapter {
 
     @Override
-    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+    public void channelActive(ChannelHandlerContext ctx) {
         System.out.println("当前连接信息:" + ctx.channel().remoteAddress());
     }
 
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-        /*System.out.println(msg.toString() + "========================");
-        if (msg.toString().length() == 8) {
-            System.out.println("=====================1");
-            msg = StringUtil.bytesToHexString(msg.toString().getBytes());
-        }else {
-            System.out.println("=====================2");
-            msg = msg.toString();
-        }*/
-        System.out.println("=================" + StringUtil.bytesToHexString(StringUtil.hexString2Bytes(StringUtil.splitString(msg.toString()))));
+        System.out.println("返回指令===========" + msg.toString());
         if (msg.toString().length() == 30) {
-            MapUtils.addMap(msg.toString(), ctx.channel());
+            String IMEICode = new String(StringUtil.hexString2Bytes(msg.toString()));
+            System.out.println("连接的IMEI码:" + IMEICode);
+            if (MapUtils.judgeChannel(IMEICode)) {
+                // 有重复的IMEI连接
+                MapUtils.replaceChannel(IMEICode, ctx.channel());
+            } else {
+                // 无重复连接
+                MapUtils.addMap(IMEICode, ctx.channel());
+            }
         }else {
             byte[] bys = StringUtil.hexString2Bytes(msg.toString());
             int i = CRC16Util.calcCrc16(bys, 0, 6);
@@ -39,34 +38,20 @@ public class nettyHandler extends ChannelInboundHandlerAdapter {
                 dest,：byte目的数组（截取后存放的数组）
                 destPos：截取后存放的数组起始位置（0位置有效）
                 length：截取的数据长度*/
-                byte[] newBys = new byte[2];
-                System.arraycopy(bys, 3, newBys, 0, 2);
-                if ("0001".equals(StringUtil.bytesToHexString(newBys))) {
-                    System.out.println("正常. 大屏接收到数据");
+                byte[] newBys = new byte[1];
+                System.arraycopy(bys, 5, newBys, 0, 1);
+                System.out.println("==============result:" + StringUtil.bytesToHexString(newBys));
+                if ("00".equals(StringUtil.bytesToHexString(newBys))) {
+                    System.out.println("正常:大屏接收到数据");
                 } else {
-                    // 执行失败
-                    Map<Integer, ByteBuf> map = ParamUtil.findMap(ctx.channel().remoteAddress());
-                    if (map != null) {
-                        Set<Integer> integers = map.keySet();
-                        for (Integer key : integers) {
-                            for (int j = 0; j < 4 - key; j++) {
-                                if (key == 3) {
-                                    ParamUtil.removeMap(ctx.channel().remoteAddress());
-                                    System.out.println(ctx.channel().remoteAddress() + "错误. 大屏未接收到数据");
-                                    return ;
-                                }else {
-                                    ByteBuf byteBuf = map.get(key);
-                                    System.out.println("发送数据==============" + JSONUtil.toJsonStr(byteBuf));
-                                    ctx.channel().write(byteBuf.retain());
-                                    map.put(key+1, map.get(key).retain());
-                                    map.remove(ctx.channel().remoteAddress());
-                                    ParamUtil.updateMap(ctx.channel().remoteAddress(), map);
-                                    System.out.println("repeat......." + key);
-                                }
-                            }
-                        }
+                    byte[] typeByte = new byte[2];
+                    System.arraycopy(bys, 1, typeByte, 0, 2);
+                    System.out.println("0000:清屏异常==0001:屏幕显示异常============返回异常信息指令:" + StringUtil.bytesToHexString(typeByte));
+                    if ("0001".equals(StringUtil.bytesToHexString(typeByte))) {
+                        this.processResult("display" + ctx.channel().remoteAddress().toString(), ctx);
+                    } else {
+                        this.processResult("clear" + ctx.channel().remoteAddress().toString(), ctx);
                     }
-                   // System.out.println(ctx.channel().remoteAddress() + "错误. 大屏未接收到数据");
                 }
             }else {
                 System.out.println("CRC校验失败！");
@@ -77,15 +62,45 @@ public class nettyHandler extends ChannelInboundHandlerAdapter {
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
         System.out.println("异常信息:" + cause.getMessage());
+        ctx.channel().closeFuture().sync();
     }
 
-    // 心跳处理
+    /**
+     *
+     * @param ctx 连接通道
+     * @param evt 事件
+     */
     @Override
-    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
+    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
 
     }
 
-
-
+    /**
+     *
+     * @param Key clear-address
+     * @param ctx 通道
+     * @throws Exception 异常
+     */
+    private void processResult(String Key, ChannelHandlerContext ctx) throws Exception{
+        ResultModel map = ParamUtil.findMap(Key);
+        if (map != null) {
+            int count = map.getCount();
+            for (int j = 0; j < 4 - map.getCount(); j++) {
+                if (count == 3) {
+                    System.out.println(Key + "错误:大屏未接收到数据, 连接关闭！");
+                    ParamUtil.removeMap(Key);
+                    ctx.channel().close().sync();
+                    return;
+                } else {
+                    byte[] hexCodeByte = map.getHexCodeByte();
+                    ByteBuf byteBuf = Unpooled.buffer();
+                    byteBuf.writeBytes(hexCodeByte);
+                    ctx.writeAndFlush(byteBuf);
+                    count += 1;
+                    System.out.println("repeat send......." + count);
+                }
+            }
+        }
+    }
 
 }

src/main/java/com/gemho/netty/controller/nettyServer.java

@@ -18,7 +18,7 @@ public class nettyServer {
 
 
 
-    public void start(int port)  {
+    private void start(int port)  {
         System.out.println("启动成功, 当前监听: " + port);
         ServerBootstrap b = new ServerBootstrap();
         NioEventLoopGroup group = new NioEventLoopGroup();
@@ -26,8 +26,7 @@ public class nettyServer {
                 .channel(NioServerSocketChannel.class)
                 .childHandler(new ChannelInitializer<SocketChannel>() {
                     @Override
-                    public void initChannel(SocketChannel ch)
-                            throws Exception {
+                    public void initChannel(SocketChannel ch) {
                         System.out.println("initChannel ch:" + ch);
                         ch.pipeline()
                                 .addLast("decoder", new DecodeUtil())

src/main/java/com/gemho/netty/model/ResultModel.java

+package com.gemho.netty.model;
+
+public class ResultModel {
+
+    private int count;
+    private byte[] hexCodeByte;
+
+    public ResultModel() {
+
+    }
+
+    public int getCount() {
+        return count;
+    }
+
+    public void setCount(int count) {
+        this.count = count;
+    }
+
+    public byte[] getHexCodeByte() {
+        return hexCodeByte;
+    }
+
+    public void setHexCodeByte(byte[] hexCodeByte) {
+        this.hexCodeByte = hexCodeByte;
+    }
+
+}

src/main/java/com/gemho/netty/util/DecodeUtil.java

@@ -7,18 +7,9 @@ import io.netty.handler.codec.ByteToMessageDecoder;
 import java.util.List;
 
 public class DecodeUtil extends ByteToMessageDecoder {
+
     @Override
     protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception {
-        /*//创建字节数组,buffer.readableBytes可读字节长度
-        byte[] b = new byte[buffer.readableBytes()];
-        //复制内容到字节数组b
-        buffer.readBytes(b);
-        //字节数组转字符串
-        String str = new String(b);
-
-        System.out.println("======decode:" + str);
-
-        out.add(bytesToHexString(b));*/
         String HEXES = "0123456789ABCDEF";
         byte[] req = new byte[buffer.readableBytes()];
         buffer.readBytes(req);
@@ -32,32 +23,4 @@ public class DecodeUtil extends ByteToMessageDecoder {
         out.add(hex.toString());
     }
 
-    public String bytesToHexString(byte[] bArray) {
-        StringBuffer sb = new StringBuffer(bArray.length);
-        String sTemp;
-        for (int i = 0; i < bArray.length; i++) {
-            sTemp = Integer.toHexString(0xFF & bArray[i]);
-            if (sTemp.length() < 2)
-                sb.append(0);
-            sb.append(sTemp.toUpperCase());
-        }
-        return sb.toString();
-    }
-
-    public static String toHexString1(byte[] b) {
-        StringBuffer buffer = new StringBuffer();
-        for (int i = 0; i < b.length; ++i) {
-            buffer.append(toHexString1(b[i]));
-        }
-        return buffer.toString();
-    }
-
-    public static String toHexString1(byte b) {
-        String s = Integer.toHexString(b & 0xFF);
-        if (s.length() == 1) {
-            return "0" + s;
-        } else {
-            return s;
-        }
-    }
 }

src/main/java/com/gemho/netty/util/MapUtils.java

@@ -13,18 +13,29 @@ public class MapUtils {
 
     private static Map<String, Channel> map = new LinkedHashMap<>();
 
+    /**
+     * 添加建立的连接
+     * @param key 标识
+     * @param channel 通道
+     */
     public static void addMap(String key, Channel channel) {
         lock.lock();
         map.put(key, channel);
         lock.unlock();
     }
 
-    public static void removeMap(String key){
+
+    /*public static void removeMap(String key){
         lock.lock();
         map.remove(key);
         lock.unlock();
-    }
+    }*/
 
+    /**
+     * 根据IMEI码，查询管道
+     * @param key 标识
+     * @return Channel
+     */
     public static Channel getMapChannel(String key) {
         try{
             lock.lock();
@@ -34,4 +45,29 @@ public class MapUtils {
         }
     }
 
+    /**
+     * 查询是否重复连接
+     * @param key 标识
+     * @return channel
+     */
+    public static boolean judgeChannel(String key) {
+        try{
+            lock.lock();
+            return map.containsKey(key);
+        }finally {
+            lock.unlock();
+        }
+    }
+
+    /**
+     * 替换掉当前IMEI码的通道
+     * @param key 标识
+     * @param channel 通道
+     */
+    public static void replaceChannel(String key , Channel channel) {
+        lock.lock();
+        map.replace(key, channel);
+        lock.unlock();
+    }
+
 }

src/main/java/com/gemho/netty/util/ParamUtil.java

 package com.gemho.netty.util;
 
-import io.netty.buffer.ByteBuf;
-
-import java.net.SocketAddress;
+import com.gemho.netty.model.ResultModel;
 import java.util.LinkedHashMap;
 import java.util.Map;
 import java.util.concurrent.locks.ReentrantLock;
@@ -11,27 +9,27 @@ public class ParamUtil {
 
     private static ReentrantLock lock = new ReentrantLock();
 
-    private static Map<SocketAddress, Map<Integer, ByteBuf>> PARAM_MAP = new LinkedHashMap<>();
+    private static Map<String, ResultModel> PARAM_MAP = new LinkedHashMap<>();
 
-    public static void addMap(SocketAddress key,  Map<Integer, ByteBuf> map) {
+    public static void addMap(String key, ResultModel model) {
         lock.lock();
-        PARAM_MAP.put(key, map);
+        PARAM_MAP.put(key, model);
         lock.unlock();
     }
 
-    public static void updateMap(SocketAddress key, Map<Integer, ByteBuf> map) {
+/*    public static void updateMap(String key, ResultModel model) {
         lock.lock();
-        PARAM_MAP.replace(key, map);
+        PARAM_MAP.replace(key, model);
         lock.unlock();
-    }
+    }*/
 
-    public static void removeMap(SocketAddress key) {
+    public static void removeMap(String key) {
         lock.lock();
         PARAM_MAP.remove(key);
         lock.unlock();
     }
 
-    public static Map<Integer, ByteBuf> findMap(SocketAddress key) {
+    public static ResultModel findMap(String key) {
         lock.lock();
         try{
             return PARAM_MAP.get(key);
@@ -43,4 +41,14 @@ public class ParamUtil {
         }
     }
 
+
+    public static boolean findMapContainerKey(String key) {
+        try{
+            lock.lock();
+            return PARAM_MAP.containsKey(key);
+        }finally {
+            lock.unlock();
+        }
+    }
+
 }

src/main/resources/application.yml

 server:
   port: 9998
-
-spring:
-  datasource:
-    driver-class-name: org.postgresql.Driver
-    url: jdbc:postgresql://localhost:5432/postgres
-    username: postgres
-    password: red___

target/classes/application.yml

 server:
   port: 9998
-
-spring:
-  datasource:
-    driver-class-name: org.postgresql.Driver
-    url: jdbc:postgresql://localhost:5432/postgres
-    username: postgres
-    password: red___