update mq

pom.xml

@@ -172,7 +172,7 @@
         <dependency>
             <groupId>org.apache.rocketmq</groupId>
             <artifactId>rocketmq-spring-boot-starter</artifactId>
-            <version>2.3.0</version>
+            <version>2.3.1</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>

src/main/java/com/qmth/exam/reserve/mq/MQConstants.java

@@ -0,0 +1,10 @@
+package com.qmth.exam.reserve.mq;
+
+public interface MQConstants {
+
+    /**
+     * MQ消息分类：考生预约
+     */
+    String TAG_STUDENT_APPLY = "student_apply";
+
+}

src/main/java/com/qmth/exam/reserve/util/JsonHelper.java

@@ -47,6 +47,21 @@ public class JsonHelper {
         }
     }
 
+    public static <T> T toObj(byte[] bytes, Class<T> clazz) {
+        if (bytes.length == 0) {
+            return null;
+        }
+
+        try {
+            ObjectMapper mapper = new ObjectMapper();
+            mapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
+            return mapper.readValue(bytes, clazz);
+        } catch (Exception e) {
+            log.error("JSON:{} ERR:{}", new String(bytes), e.getMessage());
+            throw new StatusException("JSON解析失败！", e);
+        }
+    }
+
     public static <T> List<T> toList(String jsonStr, Class<T> clazz) {
         if (StringUtils.isEmpty(jsonStr)) {
             return null;