From 28d7bb243606a80db5a13ea20ffb22dfc771a29a Mon Sep 17 00:00:00 2001 From: free will <2647778488@qq.com> Date: Tue, 9 Mar 2021 11:32:37 +0800 Subject: [PATCH] finished first component: TTL --- src/main/java/component/InitialAble.java | 19 ++++ src/main/java/component/TTL.java | 101 ++++++++++++++++++ src/main/java/component/TlvComponentBase.java | 12 +++ src/main/java/encoding/Encoder.java | 40 +++++++ src/main/java/encoding/IEncodingAble.java | 27 +++++ src/main/java/encoding/TLV.java | 27 ++++- src/test/java/others/Animal.java | 15 +++ src/test/java/others/God.java | 13 +++ src/test/java/others/HumanImpl.java | 26 +++++ 9 files changed, 279 insertions(+), 1 deletion(-) create mode 100644 src/main/java/component/InitialAble.java create mode 100644 src/main/java/component/TTL.java create mode 100644 src/main/java/component/TlvComponentBase.java create mode 100644 src/main/java/encoding/IEncodingAble.java create mode 100644 src/test/java/others/Animal.java create mode 100644 src/test/java/others/God.java create mode 100644 src/test/java/others/HumanImpl.java diff --git a/src/main/java/component/InitialAble.java b/src/main/java/component/InitialAble.java new file mode 100644 index 0000000..c62e95f --- /dev/null +++ b/src/main/java/component/InitialAble.java @@ -0,0 +1,19 @@ +package component; + +/* + * @Author: Wang Feng + * @Description: 指示当前组件是否有初始化，如果没有初始化，且组件是可选组件，则无需编码 + * @Version: 1.0.0 + * @Date: 10:15 2021/3/9 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public interface InitialAble { + // 指示当前组件是否有初始化，如果没有初始化，且组件是可选组件，则无需编码 + boolean initial = false; + + // 将组件标记为已初始化 + public void doInitial(); + + // 判断当前组件是否已经初始化 + public boolean isInitial(); +} diff --git a/src/main/java/component/TTL.java b/src/main/java/component/TTL.java new file mode 100644 index 0000000..7a1bb50 --- /dev/null +++ b/src/main/java/component/TTL.java @@ -0,0 +1,101 @@ +package component; + +import encoding.*; + +/* + * @Author: Wang Feng + * @Description: + * @Version: 1.0.0 + * @Date: 10:20 2021/3/9 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public class TTL implements IEncodingAble { + /** + * 表示一个 TTL Tlv + * todo: 后台使用的uint64，故这里用long表示，则理论上可能越界 + * // @Description: + * 1. 格式如下： + * TTL = TTL-TYPE TLV-LENGTH NonNegativeInteger + */ + private long ttl; + + public TTL(Block block){ + buildTTLByBlock(block); + } + + /** + * 根据 TLV Block 初始化一个 TTL + * @param block + * @return + */ + public boolean buildTTLByBlock(Block block){ + return this.wireDecode(block); + } + + /** + * 获取 TTL 值 + * @return + */ + public long ttl(){ + return this.ttl; + } + + /** + * 设置 TTL 值 + * @param ttl + */ + public void setTtl(long ttl){ + this.ttl=ttl; + } + + /** + * 将 TTL 线速编码为一个 TLV + * @param encoder + * @return + */ + @Override + public int wireEncode(Encoder encoder) { + int totalLength=0; + // 编码 TLV-VALUE + int tmpLen=encoder.prependNonNegativeInteger(this.ttl); + if(tmpLen==0){ + return 0; + } + totalLength+=tmpLen; + + // 编码 TLV-LENGTH + tmpLen=encoder.prependVarNumber(new VlInt(totalLength)); + if(tmpLen==0){ + return 0; + } + totalLength+=tmpLen; + + // 编码 TLV-TYPE + tmpLen=encoder.prependVarNumber(new VlInt(TLV.TlvTTL)); + if(tmpLen==0){ + return 0; + } + totalLength+=tmpLen; + + return totalLength; + } + + /** + * 从 TLV Block 中解码出一个 TTL + * @param block + * @return + */ + @Override + public boolean wireDecode(Block block) { + // 检查Type是否正确 + if(!TLV.expectType(block.getTlvType(),new VlInt(TLV.TlvTTL))){ + return false; + } + long value=TLV.readNonNegativeInteger(block.getValue(),0,block.getLength().getVlIntValue2Int()); + if(value==0){ + return false; + } + this.ttl=value; + return true; + } +} diff --git a/src/main/java/component/TlvComponentBase.java b/src/main/java/component/TlvComponentBase.java new file mode 100644 index 0000000..b866156 --- /dev/null +++ b/src/main/java/component/TlvComponentBase.java @@ -0,0 +1,12 @@ +package component; + +/* + * @Author: Wang Feng + * @Description: 实现所有 TLV 组件需要的一些通用功能 + * @Version: 1.0.0 + * @Date: 21:49 2021/3/6 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public interface TlvComponentBase { + +} diff --git a/src/main/java/encoding/Encoder.java b/src/main/java/encoding/Encoder.java index 4c1463b..0a2f870 100644 --- a/src/main/java/encoding/Encoder.java +++ b/src/main/java/encoding/Encoder.java @@ -122,6 +122,46 @@ public class Encoder { } + /** + * 编码一个非负整数到一个数组当中 + * todo: 越界问题 + * @param uint64 + * @return + */ + public byte[] buildNonNegativeIntegerArr(long uint64){ + VlInt vlInt=new VlInt(uint64); + int len=vlInt.getVlIntBytes().length; + if(len==1){ + return vlInt.getVlIntBytes(); + }else { + byte[] res = new byte[len - 1]; + System.arraycopy(vlInt.getVlIntBytes(),1,res,0,len-1); + return res; + } + } + + /** + * 在前向插入一个非负整数，最大为 uint64::Max + * todo: 越界问题 + * @param uint64_value + * @return + */ + public int prependNonNegativeInteger(long uint64_value){ + byte[] bytes=buildNonNegativeIntegerArr(uint64_value); + return this.prependByteArray(bytes,new SizeT(bytes.length)); + } + + /** + * 在后向插入一个非负整数，最大为 uint64::Max + * todo: 越界问题 + * @param uint64_value + * @return + */ + public int appendNonNegativeInteger(long uint64_value){ + byte[] bytes=buildNonNegativeIntegerArr(uint64_value); + return this.appendByteArray(bytes,new SizeT(bytes.length)); + } + /** * @param array * @param size diff --git a/src/main/java/encoding/IEncodingAble.java b/src/main/java/encoding/IEncodingAble.java new file mode 100644 index 0000000..d1a23d5 --- /dev/null +++ b/src/main/java/encoding/IEncodingAble.java @@ -0,0 +1,27 @@ +package encoding; + +/* + * @Author: Wang Feng + * @Description: + * @Version: 1.0.0 + * @Date: 21:06 2021/3/7 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public interface IEncodingAble { + /** + * 线速编码，将一个包编码成网络可传输的格式 + * @Description: + * 1. 可以使用 Encoder.getBuffer() 获取编码的结果 + * @param encoder + * @return + */ + public int wireEncode(Encoder encoder); + + /** + * 线速解码，将一个TLV解码成一个网络包 + * @param block + * @return + */ + public boolean wireDecode(Block block); + +} diff --git a/src/main/java/encoding/TLV.java b/src/main/java/encoding/TLV.java index c6d89d0..0b059ac 100644 --- a/src/main/java/encoding/TLV.java +++ b/src/main/java/encoding/TLV.java @@ -117,7 +117,32 @@ public class TLV { return tlvType; } - // todo:从字节数组的指定位置中读取一个非负整型 + /** + * 从字节数组的指定位置中读取一个非负整型 + * todo: 越界问题 + */ + public static long readNonNegativeInteger(byte[] buffer,int start,int end){ + if(start==end){ + return 0; + } + if((start<0)||(end>buffer.length)){ + return 0; + } + int len=end-start; + byte[] bytes=new byte[len]; + System.arraycopy(buffer,start,bytes,0,len); + if(len==1){ + return ByteHelper.uint8ToLong(buffer[start]); + }else if(len==2){ + return ByteHelper.uint16ToLong(bytes); + }else if(len==4){ + return ByteHelper.uint32ToLong(bytes); + }else if(len==8){ + return ByteHelper.uint64ToLong(bytes); + }else{ + return 0; + } + } /** * 检查某个type值是否是指定的 TLV-TYPE diff --git a/src/test/java/others/Animal.java b/src/test/java/others/Animal.java new file mode 100644 index 0000000..528dbce --- /dev/null +++ b/src/test/java/others/Animal.java @@ -0,0 +1,15 @@ +package others; + +/* + * @Author: Wang Feng + * @Description: + * @Version: 1.0.0 + * @Date: 9:15 2021/3/9 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +interface Animal { +// private String name="灵长类动物"; + + + public void sayHi(); +} diff --git a/src/test/java/others/God.java b/src/test/java/others/God.java new file mode 100644 index 0000000..3db3f9b --- /dev/null +++ b/src/test/java/others/God.java @@ -0,0 +1,13 @@ +package others; + +/* + * @Author: Wang Feng + * @Description: + * @Version: 1.0.0 + * @Date: 9:15 2021/3/9 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +interface God { + + public void makeWorld(); +} diff --git a/src/test/java/others/HumanImpl.java b/src/test/java/others/HumanImpl.java new file mode 100644 index 0000000..4385ccb --- /dev/null +++ b/src/test/java/others/HumanImpl.java @@ -0,0 +1,26 @@ +package others; + +/* + * @Author: Wang Feng + * @Description: + * @Version: 1.0.0 + * @Date: 10:10 2021/3/9 + * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室 + */ +public class HumanImpl implements God,Animal { + @Override + public void sayHi() { + System.out.println("hi"); + } + + @Override + public void makeWorld() { + System.out.println("world"); + } + + public static void main(String[] args){ + HumanImpl h=new HumanImpl(); + h.sayHi(); + h.makeWorld(); + } +}