Skip to content

E
environment_demo_down
Commit 979cc658 authored by shiyubin's avatar shiyubin 🌼
Browse files
Options

环境监测6x6大屏下发指令

parents
Pipeline #129 failed with stages
      Expand all Hide whitespace changes
      Inline Side-by-side
      Showing with 956 additions and 0 deletions
      HELP.md 0 → 100644
      View file @ 979cc658
      # Getting Started
      ### Reference Documentation
      For further reference, please consider the following sections:
      * [Official Apache Maven documentation](https://maven.apache.org/guides/index.html)
      * [Spring Boot Maven Plugin Reference Guide](https://docs.spring.io/spring-boot/docs/2.3.3.RELEASE/maven-plugin/reference/html/)
      * [Create an OCI image](https://docs.spring.io/spring-boot/docs/2.3.3.RELEASE/maven-plugin/reference/html/#build-image)
      README.md 0 → 100644
      View file @ 979cc658
      # 下发控制6x6大屏
      #### 服务端：
      ​ 监听端口: 9999
      ​ 连接方式: 192.168.1.49:9999
      #### 请求接口 （程序启动占用9998端口）：
      ##### 下发到大屏数据
      ##### url: http://192.168.1.49:9998/display
      | 参数名称 | 参数值 |
      | -------- | -------------------------------------------- |
      | key | 313233343536373839383736353433（hex string） |
      | code | 03 (string) |
      | x | 54（hex string） |
      | y | 5 （hex string） |
      | font | 30 (string) |
      | content | 温度 (string) |
      ##### 清屏指令
      ##### url: http://192.168.1.49:9998/clear
      | 参数名称 | 参数值 |
      | -------- | -------------------------------------------- |
      | key | 313233343536373839383736353433（hex string） |
      | code | 03(string) |
      mvnw 0 → 100755
      View file @ 979cc658
      This diff is collapsed.
      mvnw.cmd 0 → 100644
      View file @ 979cc658
      @REM ----------------------------------------------------------------------------
      @REM Licensed to the Apache Software Foundation (ASF) under one
      @REM or more contributor license agreements. See the NOTICE file
      @REM distributed with this work for additional information
      @REM regarding copyright ownership. The ASF licenses this file
      @REM to you under the Apache License, Version 2.0 (the
      @REM "License"); you may not use this file except in compliance
      @REM with the License. You may obtain a copy of the License at
      @REM
      @REM https://www.apache.org/licenses/LICENSE-2.0
      @REM
      @REM Unless required by applicable law or agreed to in writing,
      @REM software distributed under the License is distributed on an
      @REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
      @REM KIND, either express or implied. See the License for the
      @REM specific language governing permissions and limitations
      @REM under the License.
      @REM ----------------------------------------------------------------------------
      @REM ----------------------------------------------------------------------------
      @REM Maven Start Up Batch script
      @REM
      @REM Required ENV vars:
      @REM JAVA_HOME - location of a JDK home dir
      @REM
      @REM Optional ENV vars
      @REM M2_HOME - location of maven2's installed home dir
      @REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
      @REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
      @REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
      @REM e.g. to debug Maven itself, use
      @REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
      @REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
      @REM ----------------------------------------------------------------------------
      @REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
      @echo off
      @REM set title of command window
      title %0
      @REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
      @if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
      @REM set %HOME% to equivalent of $HOME
      if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
      @REM Execute a user defined script before this one
      if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
      @REM check for pre script, once with legacy .bat ending and once with .cmd ending
      if exist "%HOME%\mavenrc_pre.bat" call "%HOME%\mavenrc_pre.bat"
      if exist "%HOME%\mavenrc_pre.cmd" call "%HOME%\mavenrc_pre.cmd"
      :skipRcPre
      @setlocal
      set ERROR_CODE=0
      @REM To isolate internal variables from possible post scripts, we use another setlocal
      @setlocal
      @REM ==== START VALIDATION ====
      if not "%JAVA_HOME%" == "" goto OkJHome
      echo.
      echo Error: JAVA_HOME not found in your environment. >&2
      echo Please set the JAVA_HOME variable in your environment to match the >&2
      echo location of your Java installation. >&2
      echo.
      goto error
      :OkJHome
      if exist "%JAVA_HOME%\bin\java.exe" goto init
      echo.
      echo Error: JAVA_HOME is set to an invalid directory. >&2
      echo JAVA_HOME = "%JAVA_HOME%" >&2
      echo Please set the JAVA_HOME variable in your environment to match the >&2
      echo location of your Java installation. >&2
      echo.
      goto error
      @REM ==== END VALIDATION ====
      :init
      @REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
      @REM Fallback to current working directory if not found.
      set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
      IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
      set EXEC_DIR=%CD%
      set WDIR=%EXEC_DIR%
      :findBaseDir
      IF EXIST "%WDIR%"\.mvn goto baseDirFound
      cd ..
      IF "%WDIR%"=="%CD%" goto baseDirNotFound
      set WDIR=%CD%
      goto findBaseDir
      :baseDirFound
      set MAVEN_PROJECTBASEDIR=%WDIR%
      cd "%EXEC_DIR%"
      goto endDetectBaseDir
      :baseDirNotFound
      set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
      cd "%EXEC_DIR%"
      :endDetectBaseDir
      IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
      @setlocal EnableExtensions EnableDelayedExpansion
      for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
      @endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
      :endReadAdditionalConfig
      SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
      set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
      set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
      set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar"
      FOR /F "tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
      IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
      )
      @REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
      @REM This allows using the maven wrapper in projects that prohibit checking in binary data.
      if exist %WRAPPER_JAR% (
      if "%MVNW_VERBOSE%" == "true" (
      echo Found %WRAPPER_JAR%
      )
      ) else (
      if not "%MVNW_REPOURL%" == "" (
      SET DOWNLOAD_URL="%MVNW_REPOURL%/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar"
      )
      if "%MVNW_VERBOSE%" == "true" (
      echo Couldn't find %WRAPPER_JAR%, downloading it ...
      echo Downloading from: %DOWNLOAD_URL%
      )
      powershell -Command "&{"^
      "$webclient = new-object System.Net.WebClient;"^
      "if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
      "$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
      "}"^
      "[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
      "}"
      if "%MVNW_VERBOSE%" == "true" (
      echo Finished downloading %WRAPPER_JAR%
      )
      )
      @REM End of extension
      @REM Provide a "standardized" way to retrieve the CLI args that will
      @REM work with both Windows and non-Windows executions.
      set MAVEN_CMD_LINE_ARGS=%*
      %MAVEN_JAVA_EXE% %JVM_CONFIG_MAVEN_PROPS% %MAVEN_OPTS% %MAVEN_DEBUG_OPTS% -classpath %WRAPPER_JAR% "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
      if ERRORLEVEL 1 goto error
      goto end
      :error
      set ERROR_CODE=1
      :end
      @endlocal & set ERROR_CODE=%ERROR_CODE%
      if not "%MAVEN_SKIP_RC%" == "" goto skipRcPost
      @REM check for post script, once with legacy .bat ending and once with .cmd ending
      if exist "%HOME%\mavenrc_post.bat" call "%HOME%\mavenrc_post.bat"
      if exist "%HOME%\mavenrc_post.cmd" call "%HOME%\mavenrc_post.cmd"
      :skipRcPost
      @REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
      if "%MAVEN_BATCH_PAUSE%" == "on" pause
      if "%MAVEN_TERMINATE_CMD%" == "on" exit %ERROR_CODE%
      exit /B %ERROR_CODE%
      netty.iml 0 → 100644
      View file @ 979cc658
      This diff is collapsed.
      pom.xml 0 → 100644
      View file @ 979cc658
      <?xml version="1.0" encoding="UTF-8"?>
      <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
      <parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>2.3.3.RELEASE</version>
      <relativePath/> <!-- lookup parent from repository -->
      </parent>
      <groupId>com.gemho</groupId>
      <artifactId>netty</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <name>netty</name>
      <description>Demo project for Spring Boot</description>
      <properties>
      <java.version>1.8</java.version>
      </properties>
      <dependencies>
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter</artifactId>
      </dependency>
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-jpa</artifactId>
      </dependency>
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
      </dependency>
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
      <exclusions>
      <exclusion>
      <groupId>org.junit.vintage</groupId>
      <artifactId>junit-vintage-engine</artifactId>
      </exclusion>
      </exclusions>
      </dependency>
      <!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
      <dependency>
      <groupId>io.netty</groupId>
      <artifactId>netty-all</artifactId>
      <version>4.1.43.Final</version>
      </dependency>
      <dependency>
      <groupId>cn.hutool</groupId>
      <artifactId>hutool-all</artifactId>
      <version>5.4.0</version>
      </dependency>
      <!-- https://mvnrepository.com/artifact/org.postgresql/postgresql -->
      <dependency>
      <groupId>org.postgresql</groupId>
      <artifactId>postgresql</artifactId>
      <version>42.2.12</version>
      </dependency>
      </dependencies>
      <build>
      <plugins>
      <plugin>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
      </plugins>
      </build>
      </project>
      src/main/java/com/gemho/netty/NettyApplication.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty;
      import com.gemho.netty.controller.nettyServer;
      import org.springframework.boot.SpringApplication;
      import org.springframework.boot.autoconfigure.SpringBootApplication;
      @SpringBootApplication
      public class NettyApplication {
      public static void main(String[] args) {
      SpringApplication.run(NettyApplication.class, args);
      new nettyServer(9999);
      }
      }
      src/main/java/com/gemho/netty/controller/SocketController.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty.controller;
      import cn.hutool.json.JSONUtil;
      import com.gemho.netty.util.CRC16Util;
      import com.gemho.netty.util.MapUtils;
      import com.gemho.netty.util.ParamUtil;
      import com.gemho.netty.util.StringUtil;
      import io.netty.buffer.ByteBuf;
      import io.netty.buffer.Unpooled;
      import io.netty.channel.Channel;
      import org.springframework.web.bind.annotation.RequestMapping;
      import org.springframework.web.bind.annotation.RestController;
      import java.util.LinkedHashMap;
      import java.util.Map;
      @RestController
      public class SocketController {
      private static String CLEAR_CODE = "0000000400000650";
      private static String DISPLAY_CODE = "0001";
      // key:313233343536373839383736353433 16进制DTU码
      // code: 03
      @RequestMapping("/clear")
      public String clearDiaplay(String key, String code) {
      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();
      // 内容封装
      ByteBuf bufff = Unpooled.buffer();
      // bufff.clear();
      bufff.writeBytes(StringUtil.hexString2Bytes(code));
      // 获取通道
      Channel mapChannel = MapUtils.getMapChannel(key);
      mapChannel.writeAndFlush(bufff);
      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) {
      try{
      // 指令处理
      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);
      lenHex = StringUtil.hightAddZero(lenHex);
      code = code + DISPLAY_CODE + lenHex + xHex + yHex + font + StringUtil.bytesToHexString(contentB);
      code = code + StringUtil.encodeHEX(CRC16Util.calcCrc16(StringUtil.hexString2Bytes(code)));
      System.out.println("下发指令==============" + code.toUpperCase());
      // 数据封装
      ByteBuf bufff = Unpooled.buffer();
      bufff.writeBytes(StringUtil.hexString2Bytes(code));
      // 获取通道
      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);
      }
      return "success";
      }catch(Exception e) {
      e.printStackTrace();
      return null;
      }
      }
      }
      src/main/java/com/gemho/netty/controller/nettyHandler.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty.controller;
      import cn.hutool.json.JSONUtil;
      import com.gemho.netty.util.*;
      import io.netty.buffer.ByteBuf;
      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 {
      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()))));
      if (msg.toString().length() == 30) {
      MapUtils.addMap(msg.toString(), ctx.channel());
      }else {
      byte[] bys = StringUtil.hexString2Bytes(msg.toString());
      int i = CRC16Util.calcCrc16(bys, 0, 6);
      if (StringUtil.hightAddZero(Integer.toHexString(i).toUpperCase()).equals(StringUtil.bytesToHexString(bys).substring(12))){
      System.out.println("CRC校验通过!");
      /*src：byte源数组
      srcPos：截取源byte数组起始位置（0位置有效）
      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("正常. 大屏接收到数据");
      } 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);
      }
      }
      }
      }
      // System.out.println(ctx.channel().remoteAddress() + "错误. 大屏未接收到数据");
      }
      }else {
      System.out.println("CRC校验失败！");
      }
      }
      }
      @Override
      public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
      System.out.println("异常信息:" + cause.getMessage());
      }
      // 心跳处理
      @Override
      public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
      }
      }
      \ No newline at end of file
      src/main/java/com/gemho/netty/controller/nettyServer.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty.controller;
      import com.gemho.netty.util.DecodeUtil;
      import io.netty.bootstrap.ServerBootstrap;
      import io.netty.channel.ChannelInitializer;
      import io.netty.channel.ChannelOption;
      import io.netty.channel.nio.NioEventLoopGroup;
      import io.netty.channel.socket.SocketChannel;
      import io.netty.channel.socket.nio.NioServerSocketChannel;
      import io.netty.handler.codec.string.StringEncoder;
      import io.netty.util.CharsetUtil;
      public class nettyServer {
      public nettyServer(int port) {
      this.start(port);
      }
      public void start(int port) {
      System.out.println("启动成功, 当前监听: " + port);
      ServerBootstrap b = new ServerBootstrap();
      NioEventLoopGroup group = new NioEventLoopGroup();
      b.group(group)
      .channel(NioServerSocketChannel.class)
      .childHandler(new ChannelInitializer<SocketChannel>() {
      @Override
      public void initChannel(SocketChannel ch)
      throws Exception {
      System.out.println("initChannel ch:" + ch);
      ch.pipeline()
      .addLast("decoder", new DecodeUtil())
      .addLast("encoder", new StringEncoder(CharsetUtil.UTF_8))
      .addLast("handler", new nettyHandler());
      }
      })
      .option(ChannelOption.SO_BACKLOG, 128) // determining the number of connections queued
      .childOption(ChannelOption.SO_KEEPALIVE, Boolean.TRUE);
      try{
      b.bind(port).sync();
      }catch(Exception e) {
      e.printStackTrace();
      }
      }
      }
      src/main/java/com/gemho/netty/util/CRC16Util.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty.util;
      /**
      * @Author: liujing
      * @Date: 2019/10/24 16:49
      * @Version: 1.0
      */
      public class CRC16Util {
      static byte[] crc16_tab_h = { (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0,
      (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1,
      (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,
      (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,
      (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40 };
      static byte[] crc16_tab_l = { (byte) 0x00, (byte) 0xC0, (byte) 0xC1, (byte) 0x01, (byte) 0xC3, (byte) 0x03, (byte) 0x02, (byte) 0xC2, (byte) 0xC6, (byte) 0x06, (byte) 0x07, (byte) 0xC7, (byte) 0x05, (byte) 0xC5, (byte) 0xC4, (byte) 0x04, (byte) 0xCC, (byte) 0x0C, (byte) 0x0D, (byte) 0xCD, (byte) 0x0F, (byte) 0xCF, (byte) 0xCE, (byte) 0x0E, (byte) 0x0A, (byte) 0xCA, (byte) 0xCB, (byte) 0x0B, (byte) 0xC9, (byte) 0x09, (byte) 0x08, (byte) 0xC8, (byte) 0xD8, (byte) 0x18, (byte) 0x19, (byte) 0xD9, (byte) 0x1B, (byte) 0xDB, (byte) 0xDA, (byte) 0x1A, (byte) 0x1E, (byte) 0xDE, (byte) 0xDF, (byte) 0x1F, (byte) 0xDD, (byte) 0x1D, (byte) 0x1C, (byte) 0xDC, (byte) 0x14, (byte) 0xD4, (byte) 0xD5, (byte) 0x15, (byte) 0xD7, (byte) 0x17, (byte) 0x16, (byte) 0xD6, (byte) 0xD2, (byte) 0x12,
      (byte) 0x13, (byte) 0xD3, (byte) 0x11, (byte) 0xD1, (byte) 0xD0, (byte) 0x10, (byte) 0xF0, (byte) 0x30, (byte) 0x31, (byte) 0xF1, (byte) 0x33, (byte) 0xF3, (byte) 0xF2, (byte) 0x32, (byte) 0x36, (byte) 0xF6, (byte) 0xF7, (byte) 0x37, (byte) 0xF5, (byte) 0x35, (byte) 0x34, (byte) 0xF4, (byte) 0x3C, (byte) 0xFC, (byte) 0xFD, (byte) 0x3D, (byte) 0xFF, (byte) 0x3F, (byte) 0x3E, (byte) 0xFE, (byte) 0xFA, (byte) 0x3A, (byte) 0x3B, (byte) 0xFB, (byte) 0x39, (byte) 0xF9, (byte) 0xF8, (byte) 0x38, (byte) 0x28, (byte) 0xE8, (byte) 0xE9, (byte) 0x29, (byte) 0xEB, (byte) 0x2B, (byte) 0x2A, (byte) 0xEA, (byte) 0xEE, (byte) 0x2E, (byte) 0x2F, (byte) 0xEF, (byte) 0x2D, (byte) 0xED, (byte) 0xEC, (byte) 0x2C, (byte) 0xE4, (byte) 0x24, (byte) 0x25, (byte) 0xE5, (byte) 0x27, (byte) 0xE7,
      (byte) 0xE6, (byte) 0x26, (byte) 0x22, (byte) 0xE2, (byte) 0xE3, (byte) 0x23, (byte) 0xE1, (byte) 0x21, (byte) 0x20, (byte) 0xE0, (byte) 0xA0, (byte) 0x60, (byte) 0x61, (byte) 0xA1, (byte) 0x63, (byte) 0xA3, (byte) 0xA2, (byte) 0x62, (byte) 0x66, (byte) 0xA6, (byte) 0xA7, (byte) 0x67, (byte) 0xA5, (byte) 0x65, (byte) 0x64, (byte) 0xA4, (byte) 0x6C, (byte) 0xAC, (byte) 0xAD, (byte) 0x6D, (byte) 0xAF, (byte) 0x6F, (byte) 0x6E, (byte) 0xAE, (byte) 0xAA, (byte) 0x6A, (byte) 0x6B, (byte) 0xAB, (byte) 0x69, (byte) 0xA9, (byte) 0xA8, (byte) 0x68, (byte) 0x78, (byte) 0xB8, (byte) 0xB9, (byte) 0x79, (byte) 0xBB, (byte) 0x7B, (byte) 0x7A, (byte) 0xBA, (byte) 0xBE, (byte) 0x7E, (byte) 0x7F, (byte) 0xBF, (byte) 0x7D, (byte) 0xBD, (byte) 0xBC, (byte) 0x7C, (byte) 0xB4, (byte) 0x74,
      (byte) 0x75, (byte) 0xB5, (byte) 0x77, (byte) 0xB7, (byte) 0xB6, (byte) 0x76, (byte) 0x72, (byte) 0xB2, (byte) 0xB3, (byte) 0x73, (byte) 0xB1, (byte) 0x71, (byte) 0x70, (byte) 0xB0, (byte) 0x50, (byte) 0x90, (byte) 0x91, (byte) 0x51, (byte) 0x93, (byte) 0x53, (byte) 0x52, (byte) 0x92, (byte) 0x96, (byte) 0x56, (byte) 0x57, (byte) 0x97, (byte) 0x55, (byte) 0x95, (byte) 0x94, (byte) 0x54, (byte) 0x9C, (byte) 0x5C, (byte) 0x5D, (byte) 0x9D, (byte) 0x5F, (byte) 0x9F, (byte) 0x9E, (byte) 0x5E, (byte) 0x5A, (byte) 0x9A, (byte) 0x9B, (byte) 0x5B, (byte) 0x99, (byte) 0x59, (byte) 0x58, (byte) 0x98, (byte) 0x88, (byte) 0x48, (byte) 0x49, (byte) 0x89, (byte) 0x4B, (byte) 0x8B, (byte) 0x8A, (byte) 0x4A, (byte) 0x4E, (byte) 0x8E, (byte) 0x8F, (byte) 0x4F, (byte) 0x8D, (byte) 0x4D,
      (byte) 0x4C, (byte) 0x8C, (byte) 0x44, (byte) 0x84, (byte) 0x85, (byte) 0x45, (byte) 0x87, (byte) 0x47, (byte) 0x46, (byte) 0x86, (byte) 0x82, (byte) 0x42, (byte) 0x43, (byte) 0x83, (byte) 0x41, (byte) 0x81, (byte) 0x80, (byte) 0x40 };
      /**
      * 计算CRC16校验
      *
      * @param data
      * 需要计算的数组
      * @return CRC16校验值
      */
      public static int calcCrc16(byte[] data) {
      return calcCrc16(data, 0, data.length);
      }
      /**
      * 计算CRC16校验
      *
      * @param data
      * 需要计算的数组
      * @param offset
      * 起始位置
      * @param len
      * 长度
      * @return CRC16校验值
      */
      public static int calcCrc16(byte[] data, int offset, int len) {
      return calcCrc16(data, offset, len, 0xffff);
      }
      /**
      * 计算CRC16校验
      *
      * @param data
      * 需要计算的数组
      * @param offset
      * 起始位置
      * @param len
      * 长度
      * @param preval
      * 之前的校验值
      * @return CRC16校验值
      */
      public static int calcCrc16(byte[] data, int offset, int len, int preval) {
      int ucCRCHi = (preval & 0xff00) >> 8;
      int ucCRCLo = preval & 0x00ff;
      int iIndex;
      for (int i = 0; i < len; ++i) {
      iIndex = (ucCRCLo ^ data[offset + i]) & 0x00ff;
      ucCRCLo = ucCRCHi ^ crc16_tab_h[iIndex];
      ucCRCHi = crc16_tab_l[iIndex];
      }
      return ((ucCRCLo & 0x00ff) << 8) | (ucCRCHi & 0x00ff) & 0xffff;
      }
      }
      src/main/java/com/gemho/netty/util/DecodeUtil.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty.util;
      import io.netty.buffer.ByteBuf;
      import io.netty.channel.ChannelHandlerContext;
      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);
      final StringBuilder hex = new StringBuilder(2 * req.length);
      for (int i = 0; i < req.length; i++) {
      byte b = req[i];
      hex.append(HEXES.charAt((b & 0xF0) >> 4))
      .append(HEXES.charAt((b & 0x0F)));
      }
      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 0 → 100644
      View file @ 979cc658
      package com.gemho.netty.util;
      import io.netty.channel.Channel;
      import java.util.LinkedHashMap;
      import java.util.Map;
      import java.util.concurrent.locks.ReentrantLock;
      public class MapUtils {
      private static ReentrantLock lock = new ReentrantLock();
      private static Map<String, Channel> map = new LinkedHashMap<>();
      public static void addMap(String key, Channel channel) {
      lock.lock();
      map.put(key, channel);
      lock.unlock();
      }
      public static void removeMap(String key){
      lock.lock();
      map.remove(key);
      lock.unlock();
      }
      public static Channel getMapChannel(String key) {
      try{
      lock.lock();
      return map.get(key);
      }finally {
      lock.unlock();
      }
      }
      }
      src/main/java/com/gemho/netty/util/ParamUtil.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty.util;
      import io.netty.buffer.ByteBuf;
      import java.net.SocketAddress;
      import java.util.LinkedHashMap;
      import java.util.Map;
      import java.util.concurrent.locks.ReentrantLock;
      public class ParamUtil {
      private static ReentrantLock lock = new ReentrantLock();
      private static Map<SocketAddress, Map<Integer, ByteBuf>> PARAM_MAP = new LinkedHashMap<>();
      public static void addMap(SocketAddress key, Map<Integer, ByteBuf> map) {
      lock.lock();
      PARAM_MAP.put(key, map);
      lock.unlock();
      }
      public static void updateMap(SocketAddress key, Map<Integer, ByteBuf> map) {
      lock.lock();
      PARAM_MAP.replace(key, map);
      lock.unlock();
      }
      public static void removeMap(SocketAddress key) {
      lock.lock();
      PARAM_MAP.remove(key);
      lock.unlock();
      }
      public static Map<Integer, ByteBuf> findMap(SocketAddress key) {
      lock.lock();
      try{
      return PARAM_MAP.get(key);
      }catch(Exception e) {
      e.printStackTrace();
      return null;
      } finally {
      lock.unlock();
      }
      }
      }
      src/main/java/com/gemho/netty/util/StringUtil.java 0 → 100755
      View file @ 979cc658
      /*
      * Copyright Notice:
      * Copyright 1998-2008, Huawei Technologies Co., Ltd. ALL Rights Reserved.
      *
      * Warning: This computer software sourcecode is protected by copyright law
      * and international treaties. Unauthorized reproduction or distribution
      * of this sourcecode, or any portion of it, may result in severe civil and
      * criminal penalties, and will be prosecuted to the maximum extent
      * possible under the law.
      */
      package com.gemho.netty.util;
      import java.math.BigInteger;
      public class StringUtil {
      public static boolean strIsNullOrEmpty(String s) {
      return (null == s || s.trim().length() < 1);
      }
      public static byte[] stringToAscii(String value)
      {
      char[] chars = value.toCharArray();
      byte[] b = new byte[chars.length];
      for (int i = 0; i < chars.length; i++) {
      b[i] = (byte) chars[i];
      }
      return b;
      }
      public static 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();
      }
      /**
      * @Title:hexString2Bytes
      * @Description:16进制字符串转字节数组
      * @param src 16进制字符串
      * @return 字节数组
      */
      public static byte[] hexString2Bytes(String src) {
      int l = src.length() / 2;
      byte[] ret = new byte[l];
      for (int i = 0; i < l; i++) {
      ret[i] = (byte) Integer
      .valueOf(src.substring(i * 2, i * 2 + 2), 16).byteValue();
      }
      return ret;
      }
      public static String encodeHEX(Integer numb){
      String hex= Integer.toHexString(numb);
      return hex;
      }
      public static int decodeHEX(String hexs) {
      BigInteger bigint = new BigInteger(hexs, 16);
      int numb = bigint.intValue();
      return numb;
      }
      /**
      * 高位补零
      */
      public static String splitString(String hexcode) {
      StringBuffer sb = new StringBuffer();
      int len = 24 - hexcode.length();
      for (int i = 0; i < len; i++) {
      sb.append(0);
      }
      return sb.toString() + hexcode;
      }
      /**
      * 十六进制字符串转十进制
      *
      * @param hex
      * 十六进制字符串
      * @return 十进制数值
      */
      public static int hexStringToAlgorism(String hex) {
      hex = hex.toUpperCase();
      int max = hex.length();
      int result = 0;
      for (int i = max; i > 0; i--) {
      char c = hex.charAt(i - 1);
      int algorism = 0;
      if (c >= '0' && c <= '9') {
      algorism = c - '0';
      } else {
      algorism = c - 55;
      }
      result += Math.pow(16, max - i) * algorism;
      }
      return result;
      }
      /**
      * 将汉字转换车16进制字符串
      * @param str
      * @return st
      */
      public static String enUnicode(String str) {// 将汉字转换为16进制数
      String st = "";
      try {
      //这里要非常的注意,在将字符串转换成字节数组的时候一定要明确是什么格式的,这里使用的是gb2312格式的,还有utf-8,ISO-8859-1等格式
      byte[] by = str.getBytes("gb2312");
      for (int i = 0; i < by.length; i++) {
      String strs = Integer.toHexString(by[i]);
      if (strs.length() > 2){
      strs = strs.substring(strs.length() - 2);
      }
      st += strs;
      }
      } catch (Exception e) {
      e.printStackTrace();
      }
      return st;
      }
      /**
      * 数据补零
      * @param str
      * @return
      */
      public static String hightAddZero(String str) {
      if (str.length() == 1) {
      return "000" +str;
      }else if(str.length() == 2) {
      return "00" +str;
      }else if(str.length() == 3) {
      return "0" +str;
      }else {
      return str;
      }
      }
      /**
      * Ascii转换为字符串
      * @param value
      * @return
      */
      public static String asciiToString(String value)
      {
      StringBuffer sbu = new StringBuffer();
      String[] chars = value.split(",");
      for (int i = 0; i < chars.length; i++) {
      sbu.append((char) Integer.parseInt(chars[i]));
      }
      return sbu.toString();
      }
      }
      src/main/resources/application.yml 0 → 100644
      View file @ 979cc658
      server:
      port: 9998
      spring:
      datasource:
      driver-class-name: org.postgresql.Driver
      url: jdbc:postgresql://localhost:5432/postgres
      username: postgres
      password: red___
      src/test/java/com/gemho/netty/NettyApplicationTests.java 0 → 100644
      View file @ 979cc658
      package com.gemho.netty;
      import org.junit.jupiter.api.Test;
      import org.springframework.boot.test.context.SpringBootTest;
      @SpringBootTest
      class NettyApplicationTests {
      @Test
      void contextLoads() {
      }
      }
      target/classes/application.yml 0 → 100644
      View file @ 979cc658
      server:
      port: 9998
      spring:
      datasource:
      driver-class-name: org.postgresql.Driver
      url: jdbc:postgresql://localhost:5432/postgres
      username: postgres
      password: red___
      Markdown is supported
      0% or
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment