安卓应用-媒体影音-海豚tv手机版 v2.1.2.zip

package com.qq.taf.jce; import java.io.UnsupportedEncodingException; import java.lang.reflect.Array; import java.lang.reflect.Constructor; import java.nio.BufferUnderflowException; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; /** * 数据读取流 * @author meteorchen * */ public final class JceInputStream { private ByteBuffer bs; // 缓冲区 /** * 头数据 * @author meteorchen * */ public static class HeadData { public byte type; public int tag; public void clear() { type = 0 ; tag = 0 ; } } public JceInputStream() { } public JceInputStream(ByteBuffer bs) { this.bs = bs; } public JceInputStream(byte[] bs) { this.bs = ByteBuffer.wrap(bs); } public JceInputStream(byte[] bs, int pos) { this.bs = ByteBuffer.wrap(bs); this.bs.position(pos); } /** * 拼写错误 * @deprecated use wrap instead */ public void warp(byte[] bs) { wrap(bs); } public void wrap(byte[] bs) { this.bs = ByteBuffer.wrap(bs); } /** * 读取数据头 * @param hd 读取到的头信息 * @param bb 缓冲 * @return 读取的字节数 */ public static int readHead(HeadData hd, ByteBuffer bb) { byte b = bb.get(); hd.type = (byte) (b & 15); hd.tag = ((b & (15 << 4)) >> 4); if (hd.tag == 15) { hd.tag = (bb.get()&0x00ff); return 2; } return 1; } public void readHead(HeadData hd) { readHead(hd, bs); } // 读取头信息，但不移动缓冲区的当前偏移 private int peakHead(HeadData hd) { return readHead(hd, bs.duplicate()); } // 跳过若干字节 private void skip(int len) { bs.position(bs.position() + len); } // 跳到指定的tag的数据之前 public boolean skipToTag(int tag) { try { HeadData hd = new HeadData(); while (true) { int len = peakHead(hd); if (hd.type == JceStruct.STRUCT_END) { return false; } if (tag <= hd.tag) return tag == hd.tag; skip(len); skipField(hd.type); } } catch (JceDecodeException e) { } catch (BufferUnderflowException e) { } return false; } // 跳到当前结构的结束位置 public void skipToStructEnd() { HeadData hd = new HeadData(); do { readHead(hd); skipField(hd.type); } while (hd.type != JceStruct.STRUCT_END); } // 跳过一个字段 private void skipField() { HeadData hd = new HeadData(); readHead(hd); skipField(hd.type); } private void skipField(byte type) { switch (type) { case JceStruct.BYTE: skip(1); break; case JceStruct.SHORT: skip(2); break; case JceStruct.INT: skip(4); break; case JceStruct.LONG: skip(8); break; case JceStruct.FLOAT: skip(4); break; case JceStruct.DOUBLE: skip(8); break; case JceStruct.STRING1: { int len = bs.get(); if (len < 0) len += 256; skip(len); break; } case JceStruct.STRING4: { skip(bs.getInt()); break; } case JceStruct.MAP: { int size = read(0, 0, true); for (int i = 0; i < size * 2; ++i) skipField(); break; } case JceStruct.LIST: { int size = read(0, 0, true); for (int i = 0; i < size; ++i) skipField(); break; } case JceStruct.SIMPLE_LIST: { HeadData hd = new HeadData(); readHead(hd); if(hd.type != JceStruct.BYTE){ throw new JceDecodeException("skipField with invalid type, type value: " + type + ", " + hd.type); } int size = read(0, 0, true); skip(size); break; } case JceStruct.STRUCT_BEGIN: skipToStructEnd(); break; case JceStruct.STRUCT_END: case JceStruct.ZERO_TAG: break; default: throw new JceDecodeException("invalid type."); } } public boolean read(boolean b, int tag, boolean isRequire) { byte c = read((byte) 0x0, tag, isRequire); return c != 0; } public byte read(byte c, int tag, boolean isRequire) { if (skipToTag(tag)) { HeadData hd = new HeadData(); readHead(hd); switch (hd.type) { case JceStruct.ZERO_TAG: c = 0x0; break; case JceStruct.BYTE: c = bs.get(); break; default: throw new JceDecodeException("type mismatch."); } } else if (isRequire) { throw new JceDecodeException("require field not exist."); } return c; } public short read(short n, int tag, boolean isRequire) { if (skipToTag(tag)) { HeadData hd = new HeadData(); readHead(hd); switch (hd.type) { case JceStruct.ZERO_TAG: n = 0; break; case JceStruct.BYTE: n = (short) bs.get(); break; case JceStruct.SHORT: n = bs.getShort(); break; default: throw new JceDecodeException("type mismatch."); } } else if (isRequire) { throw new JceDecodeException("require field not exist."); } return n; } public int read(int n, int tag, boolean isRequire) { if (skipToTag(tag)) { HeadData hd = new HeadData(); readHead(hd); switch (hd.type) { case JceStruct.ZERO_TAG: n = 0; break; case JceStruct.BYTE: n = bs.get(); break; case JceStruct.SHORT: n = bs.getShort(); break; case JceStruct.INT: n = bs.getInt(); break; default: throw new JceDecodeException("type mismatch."); } } else if (isRequire) { throw new JceDecodeException("require field not exist."); } return n; } public long read(long n, int tag, boolean isRequire) { if (skipToTag(tag)) { HeadData hd = new HeadData(); readHead(hd); switch (hd.type) { case JceStruct.ZERO_TAG: n = 0; break; case JceStruct.BYTE: n = bs.get(); break; case JceStruct.SHORT: n = bs.getShort(); break; case JceStruct.INT: n = bs.getInt(); break; case JceStruct.LONG: n = bs.getLong(); break; default: throw new JceDecodeException("type mismatch."); } } else if (isRequire) { throw new JceDecodeException("require field not exist."); } return n; } public float read(float n, int tag, boolean isRequire) { if (skipToTag(tag)) { HeadData hd = new HeadData(); readHead(hd); switch (hd.type) { case JceStruct.ZERO_TAG: n = 0; break; case JceStruct.FLOAT: n = bs.getFloat(); break; default: throw new JceDecodeException("type mismatch."); } } else if (isRequire) { throw new JceDecodeException("require field not exist."); } return n; } public double read(double n, int tag, boolean isRequire) { if (skipToTag(tag)) { HeadData hd = new HeadData(); readHead(hd); switch (hd.type) { case JceStruct.ZERO_TAG: n = 0; break; case JceStruct.FLOAT: n = bs.getFloat(); break; case JceStruct.DOUBLE: n = bs.getDouble(); break; default: throw new JceDecodeException("type mismatch."); } } else if (isRequire) { throw new JceDecodeException("require field not exist."); } return n; } public String readByteString(String s, int tag, boolean isRequire) { if (skipToTag(tag)) { HeadData hd = new HeadData(); readHead(hd); switch (hd.type) { case JceStruct.STRING1: { int len = bs.get(); if (len < 0) len += 256; byte[] ss = new byte[len]; bs.get(ss); s = HexUtil.bytes2HexStr(ss); } break; case JceStruct.STRING4: { int len = bs.getInt(); if (len > JceStruct.JCE_MAX_STRING_LENGTH || len < 0 || len > bs.capacity()) throw new JceDecodeException("String too long: " + len); byte[] ss = new byte[len]; bs.get(ss); s = HexUtil.bytes2HexStr(ss); } break; default: throw new JceDecodeException("type mismatch."); } } else if (isRequire) { throw n