消息类型判断

src/main/java/com/cusc/adas/v2x/server/UdpServerHandler.java

@@ -44,6 +44,7 @@ public class UdpServerHandler extends SimpleChannelInboundHandler<DatagramPacket
         String body = new String(req, CharsetUtil.UTF_8);
         String hexString = Parse.byteToHexString(req);
        // byte[] bytes = HexStringToByteArray.hexStringToByteArray(body);
+        //车辆运行状态
         if(hexString.substring(10,12).equals("15")) {
 	        ByteBuf byteBuf = Unpooled.wrappedBuffer(req);
 	        VehicleMessage  vehicleMessage = Parse.parse(byteBuf,new VehicleMessage()); 
@@ -54,11 +55,13 @@ public class UdpServerHandler extends SimpleChannelInboundHandler<DatagramPacket
 	        System.out.println("Received message: " + vehicleBodyDto);
 	        
         }else if(hexString.substring(10,12).equals("36")) {
+        	//车辆功能订阅信息
        	 ByteBuf byteBuf = Unpooled.wrappedBuffer(req);
        	 VehicleSubscribeMessage  vehicleSubscribeMessage = Parse.parse(byteBuf,new VehicleSubscribeMessage()); 
 	     System.out.println("Received message: " + vehicleSubscribeMessage);
 
        }else if(hexString.substring(10,12).toUpperCase().equals("3C")) {
+    	   //实时决策建议
         	 ByteBuf byteBuf = Unpooled.wrappedBuffer(req);
         	 CloudDecisionMessage  cloudDecisionMessage = Parse.parse(byteBuf,new CloudDecisionMessage()); 
  	        System.out.println("Received message: " + cloudDecisionMessage);
@@ -66,10 +69,12 @@ public class UdpServerHandler extends SimpleChannelInboundHandler<DatagramPacket
 // 	        Parse.convoterBean(vehicleMessage.getVehicleMessageBody(), vehicleBodyDto);       
 // 	        System.out.println("Received message: " + vehicleBodyDto);
         }else if(hexString.substring(10,12).toUpperCase().equals("3E")) {
+        	//辅助功能
         	 ByteBuf byteBuf = Unpooled.wrappedBuffer(req);
         	 AssistMessage  assistMessage = Parse.parse(byteBuf,new AssistMessage()); 
  	        System.out.println("Received message: " + assistMessage);
         }else if(hexString.substring(10,12).toUpperCase().equals("5E")) {
+        	//下行自定义功能
        	 ByteBuf byteBuf = Unpooled.wrappedBuffer(req);
        	SelfDefineMessage  selfDefineMessage = Parse.parse(byteBuf,new SelfDefineMessage()); 
 	        System.out.println("Received message: " + selfDefineMessage);