提交海兰信原始数据解析与导出代码

protobuf_hlx/pom.xml

@@ -0,0 +1,114 @@
+<?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>
+        <artifactId>es-track-analysis</artifactId>
+        <groupId>cn.com.taiji</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <artifactId>protobuf_hlx</artifactId>
+    <name>protobuf_hlx</name>
+    <description>protobuf_hlx</description>
+    <properties>
+        <java.version>8</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+            <version>2.7.6</version>
+        </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>2.2.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.5.1</version>
+        </dependency>
+        <!--  protobuf 支持 Java 核心包-->
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java</artifactId>
+            <version>3.17.0</version>
+        </dependency>
+        <!--  proto 与 Json 互转会用到-->
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java-util</artifactId>
+            <version>3.17.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+            <version>1.2.6</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>easyexcel</artifactId>
+            <version>2.2.8</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>easyexcel</artifactId>
+            <version>3.0.3</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>easyexcel</artifactId>
+            <version>3.0.3</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.kafka</groupId>
+            <artifactId>spring-kafka</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.kafka</groupId>
+            <artifactId>spring-kafka</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.60</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.60</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>2.2.6.RELEASE</version>
+                <configuration>
+                    <classifier>exec</classifier>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

protobuf_hlx/src/main/java/cn/com/taiji/ProtobufHlxApplication.java

@@ -0,0 +1,13 @@
+package cn.com.taiji;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ProtobufHlxApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ProtobufHlxApplication.class, args);
+    }
+
+}

protobuf_hlx/src/main/java/cn/com/taiji/consumer/HlxAisConsumer.java

@@ -0,0 +1,95 @@
+package cn.com.taiji.consumer;
+
+import cn.com.taiji.model.HlxAisPackage;
+import cn.com.taiji.model.HlxHead;
+import cn.com.taiji.model.HlxRadarPackage;
+import cn.com.taiji.protobuf.Target;
+import cn.com.taiji.service.HlxAisService;
+import cn.com.taiji.utils.ByteArrayUtils;
+import com.alibaba.fastjson.JSON;
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.util.JsonFormat;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.kafka.support.Acknowledgment;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Optional;
+
+/**
+ * @author kok20
+ * @date 2023/3/3
+ */
+@Component
+public class HlxAisConsumer {
+
+    @Autowired
+    HlxAisService hlxAisService;
+
+    @KafkaListener(topics = "hlx_ax_original_ais", groupId = "20230303yougi")
+    public void aisConsumer(List<ConsumerRecord<byte[],byte[]>> records, Acknowledgment ack) {
+        for (ConsumerRecord<byte[],byte[]> record : records) {
+            Optional<byte[]> kafkaMessage = Optional.ofNullable(record.value());
+            kafkaMessage.ifPresent(result -> {
+                byte[] head = new byte[21];
+                byte[] entry = new byte[result.length-21];
+//                System.out.println("protobuf数据bytes[]:" + ByteArrayUtils.bytes2hexDisplayHex(result));
+//                System.out.println("protobuf序列化大小: " + result.length);
+                System.arraycopy(result,0,head,0,21);
+                System.arraycopy(result,21,entry,0,result.length-21);
+
+                Target.TargetAisList list = null;
+                try {
+                    HlxHead hlxHead = hlxAisService.getHeadFromByte(head);
+//                    System.out.println("hlxHead:\n" + JSON.toJSONString(hlxHead));
+                    list = Target.TargetAisList.parseFrom(entry);
+                    String jsonObject = JsonFormat.printer().print(list);
+//                    System.out.println("Json格式化结果:\n" + jsonObject);
+//                    System.out.println("Json格式化数据大小: " + jsonObject.getBytes().length);
+                    HlxAisPackage pack = new HlxAisPackage();
+                    pack.setHead(JSON.toJSONString(hlxHead));
+                    pack.setAisList(jsonObject);
+                    hlxAisService.putAisList(pack);
+                } catch (InvalidProtocolBufferException e) {
+//                    e.printStackTrace();
+                }
+            });
+
+        }
+        ack.acknowledge();
+    }
+
+    @KafkaListener(topics = "hlx_ax_original_radar", groupId = "20230303yougi")
+    public void radarConsumer(List<ConsumerRecord<byte[],byte[]>> records, Acknowledgment ack) {
+        for (ConsumerRecord<byte[],byte[]> record : records) {
+            Optional<byte[]> kafkaMessage = Optional.ofNullable(record.value());
+            kafkaMessage.ifPresent(result -> {
+                byte[] head = new byte[21];
+                byte[] entry = new byte[result.length-21];
+                System.arraycopy(result,0,head,0,21);
+                System.arraycopy(result,21,entry,0,result.length-21);
+                System.out.println("protobuf数据bytes[]:" + ByteArrayUtils.bytes2hexDisplayHex(result));
+                System.out.println("protobuf序列化大小: " + result.length);
+
+                Target.TargetRadarList list = null;
+                try {
+                    HlxHead hlxHead = hlxAisService.getHeadFromByte(head);
+                    list = Target.TargetRadarList.parseFrom(entry);
+                    String jsonObject = JsonFormat.printer().print(list);
+                    System.out.println("Json格式化结果:\n" + jsonObject);
+                    System.out.println("Json格式化数据大小: " + jsonObject.getBytes().length);
+                    HlxRadarPackage pack = new HlxRadarPackage();
+                    pack.setHead(JSON.toJSONString(hlxHead));
+                    pack.setRadarList(jsonObject);
+                    hlxAisService.putRadarList(pack);
+                } catch (InvalidProtocolBufferException e) {
+                    e.printStackTrace();
+                }
+            });
+
+        }
+        ack.acknowledge();
+    }
+}

protobuf_hlx/src/main/java/cn/com/taiji/controller/protobufController.java

@@ -0,0 +1,63 @@
+package cn.com.taiji.controller;
+
+import cn.com.taiji.model.HlxAisPackage;
+import cn.com.taiji.model.HlxRadarPackage;
+import cn.com.taiji.protobuf.Target;
+import cn.com.taiji.service.HlxAisService;
+import com.alibaba.excel.EasyExcel;
+import org.springframework.beans.factory.annotation.Autowired;
+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 javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.net.URLEncoder;
+import java.text.ParseException;
+import java.util.List;
+
+/**
+ * @author kok20
+ * @date 2023/3/3
+ */
+@RequestMapping("/protobuf")
+@RestController
+public class protobufController {
+    @Autowired
+    HlxAisService hlxAisService;
+
+    @PostMapping("/hlxais/excel")
+    public void hlxAisExcel(HttpServletResponse response) throws IOException, ParseException {
+        try {
+            List<HlxAisPackage> list = hlxAisService.getAisList();
+            System.out.println("导出海兰信AIS原始数据");
+            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
+            response.setCharacterEncoding("utf-8");
+            String fileName = URLEncoder.encode("海兰信AIS原始数据", "UTF-8");
+            response.setHeader("Content-Disposition", "attachment;filename=" + fileName + ".xlsx");
+            EasyExcel.write(response.getOutputStream(), HlxAisPackage.class).sheet("海兰信AIS原始数据")
+                    .doWrite(list);
+        } catch (Exception e) {
+            // 重置response
+            System.out.println("导出海兰信AIS原始数据excel失败：{}" + e.getMessage() + e);
+        }
+    }
+
+    @PostMapping("/hlxradar/excel")
+    public void hlxRadarExcel(HttpServletResponse response) throws IOException, ParseException {
+        try {
+            List<HlxRadarPackage> list = hlxAisService.getRadarList();
+            System.out.println("导出海兰信雷达原始数据");
+            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
+            response.setCharacterEncoding("utf-8");
+            String fileName = URLEncoder.encode("海兰信雷达原始数据", "UTF-8");
+            response.setHeader("Content-Disposition", "attachment;filename=" + fileName + ".xlsx");
+            EasyExcel.write(response.getOutputStream(), HlxRadarPackage.class).sheet("海兰信雷达原始数据")
+                    .doWrite(list);
+        } catch (Exception e) {
+            // 重置response
+            System.out.println("导出海兰信雷达原始数据excel失败：{}" + e.getMessage() + e);
+        }
+    }
+}

protobuf_hlx/src/main/java/cn/com/taiji/enetity/HlxAis.java

@@ -0,0 +1,20 @@
+package cn.com.taiji.enetity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import com.baomidou.mybatisplus.annotation.TableName;
+/**
+ * @author kok20
+ * @date 2023/3/3
+ */
+@TableName("hlx_ax_original_ais")
+public class HlxAis {
+    private byte[] value;
+    public byte[] getValue() {
+        return value;
+    }
+    public void setValue(byte[] value) {
+        this.value = value;
+    }
+}

protobuf_hlx/src/main/java/cn/com/taiji/mapper/HlxAisMapper.java

@@ -0,0 +1,13 @@
+package cn.com.taiji.mapper;
+
+import cn.com.taiji.enetity.HlxAis;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+/**
+ * @author kok20
+ * @date 2023/3/3
+ */
+@Mapper
+public interface HlxAisMapper extends BaseMapper<HlxAis> {
+}

protobuf_hlx/src/main/java/cn/com/taiji/model/HlxAisPackage.java

@@ -0,0 +1,29 @@
+package cn.com.taiji.model;
+
+import cn.com.taiji.protobuf.Target;
+
+/**
+ * @author kok20
+ * @date 2023/3/4
+ */
+public class HlxAisPackage {
+    String head;
+
+    String aisList;
+
+    public String getHead() {
+        return head;
+    }
+
+    public void setHead(String head) {
+        this.head = head;
+    }
+
+    public String getAisList() {
+        return aisList;
+    }
+
+    public void setAisList(String aisList) {
+        this.aisList = aisList;
+    }
+}

protobuf_hlx/src/main/java/cn/com/taiji/model/HlxHead.java

@@ -0,0 +1,44 @@
+package cn.com.taiji.model;
+
+/**
+ * @author kok20
+ * @date 2023/3/4
+ */
+public class HlxHead {
+    Long num;
+    String timestamp;
+    Integer type;
+    Integer length;
+
+    public String getTimestamp() {
+        return timestamp;
+    }
+
+    public void setTimestamp(String timestamp) {
+        this.timestamp = timestamp;
+    }
+
+    public Integer getType() {
+        return type;
+    }
+
+    public void setType(Integer type) {
+        this.type = type;
+    }
+
+    public Integer getLength() {
+        return length;
+    }
+
+    public void setLength(Integer length) {
+        this.length = length;
+    }
+
+    public Long getNum() {
+        return num;
+    }
+
+    public void setNum(Long num) {
+        this.num = num;
+    }
+}

protobuf_hlx/src/main/java/cn/com/taiji/model/HlxRadarPackage.java

@@ -0,0 +1,27 @@
+package cn.com.taiji.model;
+
+/**
+ * @author kok20
+ * @date 2023/3/4
+ */
+public class HlxRadarPackage {
+    String head;
+
+    String radarList;
+
+    public String getHead() {
+        return head;
+    }
+
+    public void setHead(String head) {
+        this.head = head;
+    }
+
+    public String getRadarList() {
+        return radarList;
+    }
+
+    public void setRadarList(String radarList) {
+        this.radarList = radarList;
+    }
+}

protobuf_hlx/src/main/java/cn/com/taiji/service/HlxAisService.java

@@ -0,0 +1,26 @@
+package cn.com.taiji.service;
+
+import cn.com.taiji.enetity.HlxAis;
+import cn.com.taiji.model.HlxAisPackage;
+import cn.com.taiji.model.HlxHead;
+import cn.com.taiji.model.HlxRadarPackage;
+import cn.com.taiji.protobuf.Target;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.List;
+
+/**
+ * @author kok20
+ * @date 2023/3/3
+ */
+public interface HlxAisService extends IService<HlxAis> {
+    void putAisList(HlxAisPackage p);
+
+    List<HlxAisPackage> getAisList();
+
+    void putRadarList(HlxRadarPackage p);
+
+    List<HlxRadarPackage> getRadarList();
+
+    HlxHead getHeadFromByte(byte[] head);
+}

protobuf_hlx/src/main/java/cn/com/taiji/service/impl/HlxAisServiceImpl.java

@@ -0,0 +1,114 @@
+package cn.com.taiji.service.impl;
+
+import cn.com.taiji.enetity.HlxAis;
+import cn.com.taiji.mapper.HlxAisMapper;
+import cn.com.taiji.model.HlxAisPackage;
+import cn.com.taiji.model.HlxHead;
+import cn.com.taiji.model.HlxRadarPackage;
+import cn.com.taiji.service.HlxAisService;
+import cn.com.taiji.utils.ByteArrayUtils;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * @author kok20
+ * @date 2023/3/3
+ */@Service
+@Slf4j
+public class HlxAisServiceImpl extends ServiceImpl<HlxAisMapper, HlxAis> implements HlxAisService {
+    private Vector<HlxAisPackage> targetAis = new Vector<>();
+    private Vector<HlxRadarPackage> targetRadar = new Vector<>();
+
+    @Override
+    public void putAisList(HlxAisPackage p) {
+        targetAis.add(p);
+    }
+
+    @Override
+     public List<HlxAisPackage> getAisList() {
+        List<HlxAisPackage> result = new ArrayList<> (targetAis);
+        targetAis.clear();
+        return result;
+     }
+
+    @Override
+    public void putRadarList(HlxRadarPackage p) {
+        targetRadar.add(p);
+    }
+
+    @Override
+    public List<HlxRadarPackage> getRadarList() {
+        List<HlxRadarPackage> result = new ArrayList<> (targetRadar);
+        targetRadar.clear();
+        return result;
+    }
+
+    @Override
+    public HlxHead getHeadFromByte(byte[] head) {
+        HlxHead hlxHead = new HlxHead();
+        if(head.length == 21){
+            byte[] num = new byte[8];
+            System.arraycopy(head,0,num,0,8);
+            hlxHead.setNum(ByteArrayUtils.byteArray2Long_Little_Endian(num));
+            byte[] timestamp = new byte[8];
+            System.arraycopy(head,8,timestamp,0,8);
+            Long stamp = ByteArrayUtils.byteArray2Long_Little_Endian(timestamp);
+            Date time = new Date();
+            time.setTime(stamp);
+            hlxHead.setTimestamp(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
+                    .format(time));
+            byte[] type = new byte[1];
+            System.arraycopy(head,16,type,0,1);
+            int t = type[0]&255;
+            hlxHead.setType(t);
+            byte[] length = new byte[4];
+            System.arraycopy(head,17,length,0,4);
+            hlxHead.setLength(ByteArrayUtils.byteArray2Int_Little_Endian(length));
+        }
+        return hlxHead;
+    }
+
+    public static void main(String[] args) {
+
+        byte[] result = new byte[21];
+        result[0] = 0x69;
+        result[1] = 0x20;
+        result[2] = (byte) 0x91;
+        result[3] = 0x01;
+        result[4] = 0x00;
+        result[5] = 0x00;
+        result[6] = 0x00;
+        result[7] = 0x00;
+        result[8] = (byte) 0xFD;
+        result[9] = 0x1C;
+        result[10] = 0x0C;
+        result[11] = (byte) 0xA8;
+        result[12] = (byte) 0x86;
+        result[13] = (byte) 0x01;
+        result[14] = (byte) 0x00;
+        result[15] = (byte) 0x00;
+        result[16] = (byte) 0x02;
+        result[17] = (byte) 0x4E;
+        result[18] = (byte) 0x00;
+        result[19] = (byte) 0x00;
+        result[20] = (byte) 0x00;
+        System.out.println("protobuf数据bytes[]:" + ByteArrayUtils.bytes2hexDisplayHex(result));
+//        byte[] num = new byte[8];
+//        System.arraycopy(result,0,num,0,8);
+//        System.out.println("num:" + ByteArrayUtils.byteArray2Long_Little_Endian(num));
+//        byte[] timestamp = new byte[8];
+//        System.arraycopy(result,8,timestamp,0,8);
+//        System.out.println("timestamp:" + ByteArrayUtils.byteArray2Long_Little_Endian(timestamp));
+//        byte[] type = new byte[1];
+//        System.arraycopy(result,16,type,0,1);
+//        int i = type[0]&255;
+//        System.out.println("type:" + i);
+//        byte[] lenth = new byte[4];
+//        System.arraycopy(result,17,lenth,0,4);
+//        System.out.println("lenth:" + ByteArrayUtils.byteArray2Int_Little_Endian(lenth));
+    }
+}

protobuf_hlx/src/main/java/cn/com/taiji/utils/ByteArrayUtils.java

@@ -0,0 +1,355 @@
+package cn.com.taiji.utils;
+
+/**
+ * @author kok20
+ * @date 2023/3/3
+ */
+import java.io.*;
+import java.util.Arrays;
+import java.util.Optional;
+
+/**
+ * Created by Jason on 2017/1/3.
+ */
+public class ByteArrayUtils {
+
+    // byte 转 string (十进制)
+    public static String bytes2hexDisplayDec(byte[] bytes) {
+        return Arrays.toString(bytes);
+    }
+
+    // byte 转 string (十六进制)
+    public static String bytes2hexDisplayHex(byte[] bytes) {
+        StringBuilder sb = new StringBuilder();
+        String tmp;
+        sb.append("[");
+        for (byte b : bytes) {
+            // 将每个字节与0xFF进行与运算，然后转化为10进制，然后借助于Integer再转化为16进制
+            tmp = Integer.toHexString(0xFF & b);
+            if (tmp.length() == 1) {
+                tmp = "0" + tmp;//只有一位的前面补个0
+            }
+            sb.append(tmp).append(" ");//每个字节用空格断开
+        }
+        sb.delete(sb.length() - 1, sb.length());//删除最后一个字节后面对于的空格
+        sb.append("]");
+        return sb.toString();
+    }
+    /**
+     * 字节数组转 short，小端
+     */
+    public static short byteArray2Short_Little_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length > 2) {
+            return 0;
+        }
+
+        short value = 0;
+        for (int i = 0; i < array.length; i++) {
+            // & 0xff，除去符号位干扰
+            value |= ((array[i] & 0xff) << (i * 8));
+        }
+        return value;
+    }
+
+    /**
+     * 字节数组转 short，大端
+     */
+    public static short byteArray2Short_Big_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length > 2) {
+            return 0;
+        }
+
+        short value = 0;
+        for (int i = 0; i < array.length ; i++) {
+            value |= ((array[i] & 0xff) << ((array.length - i - 1) * 8));
+        }
+        return value;
+    }
+
+    /**
+     * 字节数组转 int，小端
+     */
+    public static int byteArray2Int_Little_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length > 4) {
+            return 0;
+        }
+
+        int value = 0;
+        for (int i = 0; i < array.length; i++) {
+            value |= ((array[i] & 0xff) << (i * 8));
+
+        }
+        return value;
+    }
+
+    /**
+     * 字节数组转 int，大端
+     */
+    public static int byteArray2Int_Big_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length > 4) {
+            return 0;
+        }
+
+        int value = 0;
+        for (int i = 0; i < array.length ; i++) {
+            value |= ((array[i] & 0xff) << ((array.length - i - 1) * 8));
+        }
+        return value;
+    }
+
+    /**
+     * 字节数组转 float，小端
+     */
+    public static float byteArray2Float_Little_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length != 4) {
+            return 0;
+        }
+
+        return Float.intBitsToFloat(byteArray2Int_Little_Endian(array));
+    }
+
+    /**
+     * 字节数组转 float，大端
+     */
+    public static float byteArray2Float_Big_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length > 4) {
+            return 0;
+        }
+
+        return Float.intBitsToFloat(byteArray2Int_Big_Endian(array));
+    }
+
+    /**
+     * 字节数组转 long，小端
+     */
+    public static long byteArray2Long_Little_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length != 8) {
+            return 0;
+        }
+
+        long value = 0;
+        for (int i = 0; i < array.length ; i++) {
+            // 需要转long再位移，否则int丢失精度
+            value |= ((long)(array[i]& 0xff) << (i * 8));
+        }
+        return value;
+    }
+
+    /**
+     * 字节数组转 long，大端
+     */
+    public static long byteArray2Long_Big_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length != 8) {
+            return 0;
+        }
+
+        long value = 0;
+        for (int i = 0; i < array.length ; i++) {
+            value |= ((long)(array[i] & 0xff) << ((array.length - i - 1) * 8));
+        }
+        return value;
+    }
+
+    /**
+     * 字节数组转 double，小端
+     */
+    public static double byteArray2Double_Little_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length != 8) {
+            return 0;
+        }
+
+        return Double.longBitsToDouble(byteArray2Long_Little_Endian(array));
+    }
+
+    /**
+     * 字节数组转 double，大端
+     */
+    public static double byteArray2Double_Big_Endian(byte[] array) {
+
+        // 数组长度有误
+        if (array.length != 8) {
+            return 0;
+        }
+
+        return Double.longBitsToDouble(byteArray2Long_Big_Endian(array));
+    }
+
+    /**
+     * 字节数组转 HexString
+     */
+    public static String byteArray2HexString(byte[] array) {
+
+        StringBuilder builder = new StringBuilder();
+        for (byte b : array) {
+
+            String s = Integer.toHexString(b & 0xff);
+            if (s.length() < 2) {
+                builder.append("0");
+            }
+            builder.append(s);
+        }
+
+        return builder.toString().toUpperCase();
+    }
+
+    //---------------------------------华丽的分割线-------------------------------------
+
+    /**
+     * short 转字节数组，小端
+     */
+    public static byte[] short2ByteArray_Little_Endian(short s) {
+
+        byte[] array = new byte[2];
+
+        for (int i = 0; i < array.length; i++) {
+            array[i] = (byte) (s >> (i * 8));
+        }
+        return array;
+    }
+
+    /**
+     * short 转字节数组，大端
+     */
+    public static byte[] short2ByteArray_Big_Endian(short s) {
+
+        byte[] array = new byte[2];
+
+        for (int i = 0; i < array.length; i++) {
+            array[array.length - 1 - i] = (byte) (s >> (i * 8));
+        }
+        return array;
+    }
+
+    /**
+     * int 转字节数组，小端
+     */
+    public static byte[] int2ByteArray_Little_Endian(int s) {
+
+        byte[] array = new byte[4];
+
+        for (int i = 0; i < array.length; i++) {
+            array[i] = (byte) (s >> (i * 8));
+        }
+        return array;
+    }
+
+    /**
+     * int 转字节数组，大端
+     */
+    public static byte[] int2ByteArray_Big_Endian(int s) {
+
+        byte[] array = new byte[4];
+
+        for (int i = 0; i < array.length; i++) {
+            array[array.length - 1 - i] = (byte) (s >> (i * 8));
+        }
+        return array;
+    }
+
+    /**
+     * float 转字节数组，小端
+     */
+    public static byte[] float2ByteArray_Little_Endian(float f) {
+
+        return int2ByteArray_Little_Endian(Float.floatToIntBits(f));
+    }
+
+    /**
+     * float 转字节数组，大端
+     */
+    public static byte[] float2ByteArray_Big_Endian(float f) {
+
+        return int2ByteArray_Big_Endian(Float.floatToIntBits(f));
+    }
+
+    /**
+     * long 转字节数组，小端
+     */
+    public static byte[] long2ByteArray_Little_Endian(long l) {
+
+        byte[] array = new byte[8];
+
+        for (int i = 0; i < array.length; i++) {
+            array[i] = (byte) (l >> (i * 8));
+        }
+        return array;
+    }
+
+    /**
+     * long 转字节数组，大端
+     */
+    public static byte[] long2ByteArray_Big_Endian(long l) {
+
+        byte[] array = new byte[8];
+
+        for (int i = 0; i < array.length; i++) {
+            array[array.length - 1 - i] = (byte) (l >> (i * 8));
+        }
+        return array;
+    }
+
+    /**
+     * double 转字节数组，小端
+     */
+    public static byte[] double2ByteArray_Little_Endian(double d) {
+
+        return long2ByteArray_Little_Endian(Double.doubleToLongBits(d));
+    }
+
+    /**
+     * double 转字节数组，大端
+     */
+    public static byte[] double2ByteArray_Big_Endian(double d) {
+
+        return long2ByteArray_Big_Endian(Double.doubleToLongBits(d));
+    }
+
+    /**
+     * HexString 转字节数组
+     */
+    public static byte[] hexString2ByteArray(String hexString) {
+
+        // 两个十六进制字符一个 byte，单数则有误
+        if (hexString.length() % 2 != 0) {
+            return null;
+        }
+
+        byte[] array = new byte[hexString.length() / 2];
+
+        int value = 0;
+        for (int i = 0; i < hexString.length(); i++) {
+
+            char s = hexString.charAt(i);
+
+            // 前半个字节
+            if (i % 2 == 0) {
+                value = Integer.parseInt(String.valueOf(s), 16) * 16;
+            } else {
+                // 后半个字节
+                value += Integer.parseInt(String.valueOf(s), 16);
+                array[i / 2] = (byte) value;
+                value = 0;
+            }
+        }
+
+        return array;
+    }
+}

protobuf_hlx/src/main/resources/application-prod.yml

@@ -0,0 +1,53 @@
+server:
+  port: 9001
+spring:
+  datasource:
+    type: com.alibaba.druid.pool.DruidDataSource
+    driverClassName: com.mysql.cj.jdbc.Driver
+    url: jdbc:mysql://127.0.0.1:3306/hlx?hlx=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&rewriteBatchedStatements=true
+    username: root
+    password: root
+    # 初始连接数
+    initialSize: 5
+    # 最小连接池数量
+    minIdle: 10
+    # 最大连接池数量
+    maxActive: 20
+    # 配置获取连接等待超时的时间
+    maxWait: 60000
+    # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
+    timeBetweenEvictionRunsMillis: 60000
+    # 配置一个连接在池中最小生存的时间，单位是毫秒
+    minEvictableIdleTimeMillis: 300000
+    # 配置一个连接在池中最大生存的时间，单位是毫秒
+    maxEvictableIdleTimeMillis: 900000
+    # 配置检测连接是否有效
+    validationQuery: SELECT 1
+  kafka:
+    bootstrap-servers: app2833:9094,app2834:9094,app2835:9094,app2836:9094,app2837:9094
+    #bootstrap-servers: localhost:9092
+    consumer:
+      # 自动提交的时间间隔 在spring boot 2.X 版本中这里采用的是值的类型为Duration 需要符合特定的格式，如1S,1M,2H,5D
+      auto-commit-interval: 1S
+      # 该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理：
+      # latest（默认值）在偏移量无效的情况下，消费者将从最新的记录开始读取数据（在消费者启动之后生成的记录）
+      # earliest ：在偏移量无效的情况下，消费者将从起始位置读取分区的记录
+      auto-offset-reset: latest
+      # 是否自动提交偏移量，默认值是true,为了避免出现重复数据和数据丢失，可以把它设置为false,然后手动提交偏移量
+      enable-auto-commit: false
+      key-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer
+      value-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer
+    properties:
+      security:
+        protocol: SASL_PLAINTEXT
+      sasl:
+        mechanism: SCRAM-SHA-512
+        jaas:
+          config: 'org.apache.kafka.common.security.scram.ScramLoginModule required username="admin" password="admin-secret";'
+    listener:
+      # 在侦听器容器中运行的线程数。
+      concurrency: 5
+      #listner负责ack，每调用一次，就立即commit
+      ack-mode: manual_immediate
+      missing-topics-fatal: false
+      type: batch

protobuf_hlx/src/main/resources/application.yml

@@ -0,0 +1,3 @@
+spring:
+  profiles:
+    active: prod