1. package net.xdclass.util;
    3. import com.sun.xml.internal.ws.api.model.wsdl.WSDLOutput;
    4. import io.netty.buffer.ByteBuf;
    5. import io.netty.buffer.Unpooled;
    6. import io.netty.channel.ChannelHandlerContext;
    7. import io.netty.util.CharsetUtil;
    8. import net.xdclass.config.FrameConfig;
    10. import java.util.Arrays;
    11. import java.util.List;
    13. public class Test {
    15.     public static void testdecode(ByteBuf in) throws Exception {
    16.         System.out.println("进入编码器");
    17.         while (true) {
    18.             System.out.println("一开始得长度" + in.readableBytes());
    19.             if (in.readableBytes() == 0) {
    20.                 break;
    21.             }
    22.             int begin_index = in.readerIndex();
    23.             //记录一开始得读标识
    24.             in.markReaderIndex();//最开始得地方
    25.             byte a = in.readByte();
    26.             byte[] markbyte = new byte[19];
    27.             //读到&=开始校验，只有读到头部才会进行校验
    28.             if (a == 36) {
    29.                 System.out.println("读到$符号，进行头尾部验证");
    30.                 //先看看长度满不满足要求
    31.                 if (in.readableBytes() < 19) {
    32.                     System.out.println("【半包】长度不够，复原至此次原始buf头部，等待后部接收");
    33.                     in.resetReaderIndex();
    34.                     break;
    35.                 } else {
    36.                     //满足了则看看这个$是否是头部
    37.                     markbyte[0] = a;
    38.                     markbyte[1] = in.readByte();
    39.                     for (int i = 0; i < 17; i++) {
    40.                         markbyte[i + 2] = in.readByte();
    41.                     }
    42.                     if (isHeadOrTail(markbyte).equals("head")) {
    43.                         System.out.println("返回得in" + in.readableBytes());
    44.                         System.out.println("检测到头部标识");
    45.                         //此处进行msg读取
    46.                         byte[] msg = new byte[100];
    47.                         int index = 0;
    48.                         int msg_length=0;
    49.                         while (true) {
    50.                             byte b = in.readByte();
    51.                             //看看是不是$符号
    52.                             if (b == 36) {
    53.                                 System.out.println("检测到第二个符号");
    54.                                 byte[] tail = new byte[17];
    55.                                 tail[0]=b;
    56.                                 for (int i = 1; i < 17; i++) {
    57.                                     tail[i] = in.readByte();
    58.                                 }
    59.                                 if (isHeadOrTail(tail).equals("tail")){
    60.                                     System.out.println("尾部标识");
    61.                                 }
    62.                                 break;
    63.                             }
    64.                             msg[index] = b;
    65.                             msg_length++;
    66.                             index++;
    67.                         }
    68.                         System.out.println(Arrays.toString(msg));
    69.                     } else {
    70.                         System.out.println("不是头部标识，");
    71.                         in.resetReaderIndex();
    72.                         //不是头部，因为长度满足且不是头部则这个$符号肯定不是头部。复原至$后面一个字节等待后续读
    73.                         //前面得逻辑正确得话，大概率是误码了
    74.                     }
    76.                 }
    77.             }
    79.         }
    81.     }
    83.     public static String isHeadOrTail(byte[] markbyte) {
    84. //        System.out.println("判断方法里得in" + in.readableBytes());
    85.         System.out.println(Arrays.toString(markbyte));
    86.         boolean head = true;
    87.         boolean tail = true;
    88.         if (!Arrays.equals(markbyte, FrameConfig.head_strb)) {
    89.             head = false;
    90.         }
    91.         if (!Arrays.equals(markbyte, FrameConfig.tail_strb)) {
    92.             tail = false;
    93.         }
    94.         if (head) {
    95.             return "head";
    96.         } else if (tail) {
    97.             return "tail";
    98.         } else {
    99.             return "no";
    100.         }
    101.     }
    103.     public static void main(String[] args) throws Exception {
    104.         ByteBuf byteBuf = Unpooled.copiedBuffer("$===+++start+++===$\" + msg + \"$===+++end+++===$", CharsetUtil.UTF_8);
    105.         ByteBuf byteBuf2 = Unpooled.copiedBuffer("$===+++start+++===$", CharsetUtil.UTF_8);
    106. //        System.out.println(byteBuf2.readableBytes());
    107.         String tail = "$===+++end+++===$";
    108.         System.out.println(Arrays.toString(tail.getBytes()));
    109.         System.out.println(Arrays.toString("$===+++start+++===$\" + msg + \"$===+++end+++===$".getBytes()));
    110.         System.out.println(Arrays.toString(FrameConfig.head_strb));
    111.         testdecode(byteBuf);
    112.     }
    113. }