Darks codec is a lightweight message protocol encoding and decoding framework. It supports encoding and decoding message object of most message protocol based on bytes. It helps developers build any message protocol easily and quickly. And help to solve network communication protocol TCP's stick package and broken package problem. It makes developers design attention more than the implementation of message protocol, which can help software design better.
If we want to build the message protocol with LITTLE-ENDIAN like:
FB FA [ID 32bits] [VERSION 8bits] [COMMAND] FF
We can build JAVA class like:
public class SimpleMsg
{
int id;
byte version;
String command;
}
In order to describe simple, we omit get/set method.
According to message protocol, we only need Head identify "FB FA" and tail identify "FF" besides message body, so we can configure object coder like:
ObjectCoder coder = new ObjectCoder(); coder.getCodecConfig().setEndianType(EndianType.LITTLE); coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xFAFB), new OCInt8(0xFF)));
Now we can encode message object easily.
SimpleMsg msg = new SimpleMsg(); msg.id = 32; msg.version = 1; msg.command = "running"; byte[] bytes = coder.encode(msg); System.out.println(ByteHelper.toHexString(bytes));
Code will output console information:
FB FA 20 00 00 00 01 72 75 6E 6E 69 6E 67 FF
Because of LITTLE-ENDIAN, 0xFAFB coded as "FB FA", ID which is 32 coded as "20 00 00 00", VERSION which is 1 coded as "01", command which is "running" coded as "72 75 6E 6E 69 6E 67" and 0xFF coded as "FF".
Now we try to decode message object easily.
SimpleMsg result = new SimpleMsg();
coder.decode(bytes, result);
System.out.println("ID:" + result.id);
System.out.println("VERSION:" + result.version);
System.out.println("COMMAND:" + result.command);
Code will output console information:
ID:32 VERSION:1 COMMAND:running
Some message protocol need replace tail identify with bytes total length.
We can set total length type to have the bytes total length. Total length type have AUTO, BODY and HEAD_BODY types.
AUTO : Automatic object total length. It calculate object length without head or tail wrapper's length only when autoLength is true.
BODY : Body total length will calculate object length and tail wrapper's length without head wrapper's length.
HEAD_BODY : Head and body total length will calculate head wrapper, tail wrapper and object length.
ObjectCoder coder = new ObjectCoder(); coder.getCodecConfig().setEndianType(EndianType.LITTLE); coder.getCodecConfig().setTotalLengthType(TotalLengthType.HEAD_BODY); coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xFAFB)));
Code will output console information:
FB FA 12 00 00 00 20 00 00 00 01 72 75 6E 6E 69 6E 67
Now, we have finished a simple example. You can find codes in /examples/darks/codec/examples/simple.
If message protocol have multiply object type such as String, Object, Bytes and so on,
we should set automatic length to ensure decoding message correctly.
Message protocol may like:
FB FA [TOTAL LENGTH] [ID 32bits] [VERSION 8bits] [CMD1 LEN 32bits] [COMMAND1] [CMD2 LEN 32bits] [COMMAND2]
Java bean class:
public class MultiCmdMsg
{
int id;
byte version;
String command1;
String command2;
}
Then we encode it object will automatic length:
ObjectCoder coder = new ObjectCoder(); coder.getCodecConfig().setEndianType(EndianType.LITTLE); coder.getCodecConfig().setTotalLengthType(TotalLengthType.HEAD_BODY); coder.getCodecConfig().setAutoLength(true); coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xFAFB))); MultiCmdMsg msg = new MultiCmdMsg(); msg.id = 32; msg.version = 1; msg.command1 = "ready"; msg.command2 = "running"; byte[] bytes = coder.encode(msg); System.out.println(ByteHelper.toHexString(bytes));
Code will output console information:
FB FA 1F 00 00 00 20 00 00 00 01 05 00 00 00 72 65 61 64 79 07 00 00 00 72 75 6E 6E 69 6E 67
You can see detail example codes in /examples/darks/codec/examples/autolen.
Besides using JAVA type directly, developers can use codec type which is in package darks.codec.type more flexibly to code.
OCInt32 : 32-bits integer type which based on OCInteger.
OCInt16 : 16-bits integer type which based on OCInteger.
OCInt8 : 8-bits integer type which based on OCInteger.
OCLong : 64-bits long type.
OCFloat : Just like float.
OCDouble: Just like double.
OCBytes : Bytes array type.
OCString: Just like String.
OCList : It can store collection data which based on java.util.List.
OCMap : It can store Key-value pair values which based on java.util.Map.
OCListMap: It can store multiply values in same key index besides Map feature.
OCObject: Java object can extends it to code flexibly.
Custom Type: Developers can build a class which inherit from OCBase or OCBaseType to customize type, which must add annotation @CodecType.
We can rebuild SimpleMsg by codec type.
public class SimpleMsg extends OCObject
{
OCInt32 id = new OCInt32();
OCInt8 version = new OCInt8();
OCString command = new OCString();
}
Also we can rebuild MultiCmdMsg by mix type.
public class MultiCmdMsg
{
int id;
byte version;
OCInt32 cmdLen1 = new OCInt32();
OCString command1 = new OCString(cmdLen1);
OCInt32 cmdLen2 = new OCInt32();
OCString command2 = new OCString(cmdLen2);
}
"command1 = new OCString(cmdLen1)" can set command1's length value to field "cmdLen1" automatically. And It will decode command1 by cmdLen1's value when decoding. Therefore we should set parameter "autoLength" false.
ObjectCoder coder = new ObjectCoder();
coder.getCodecConfig().setEndianType(EndianType.LITTLE);
coder.getCodecConfig().setTotalLengthType(TotalLengthType.HEAD_BODY);
coder.getCodecConfig().setAutoLength(false); //default false.
coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xFAFB)));
MultiCmdMsg msg = new MultiCmdMsg();
msg.id = 32;
msg.version = 1;
msg.command1.setValue("ready");
msg.command2.setValue("running");
byte[] bytes = coder.encode(msg);
System.out.println(ByteHelper.toHexString(bytes));
You can see detail example codes in /examples/darks/codec/examples/codectype.
We can try to build a multiple nested object. The message protocol just like:
FA FB [TOTAL LEN 32bits] [ID 32bits] [VERSION 8bits] [EXTERN LEN 16bits] [EXTERN BYTES] [SUB LEN 32 bits] [#SUB MSG#[CODE LEN 8bits] [CODE] [MODULAR 8bits] [SUB MODULAR 8bits] [#CMDS#[CMD CODE 8bits] [CODE length 16bits] [CODE] ... [CMD CODE 8bits] [CODE length 16bits] [CODE]]]
We can build JAVA bean like:
public class ComplexMsg
{
int id;
byte version;
OCInt16 externLength = new OCInt16();
OCBytes extern = new OCBytes(externLength);
OCInt32 subMsgLength = new OCInt32();
ComplexSubMsg subMsg = new ComplexSubMsg(subMsgLength);
}
class ComplexSubMsg extends OCObject
{
OCInt8 codeLen = new OCInt8();
OCString equipCode = new OCString(codeLen);
byte modular;
byte subModular;
OCMap commands = new OCMap();
public ComplexSubMsg(OCInteger lenType)
{
super(lenType);
}
}
class OrderMsg
{
OCInt16 orderLength = new OCInt16();
OCBytes order = new OCBytes(orderLength);
public OrderMsg()
{
}
public OrderMsg(OCBytes order)
{
this.order = order;
order.setLenType(orderLength);
}
}
Then we encode the message.
ObjectCoder coder = new ObjectCoder();
coder.getCodecConfig().setEndianType(EndianType.LITTLE);
coder.getCodecConfig().setTotalLengthType(TotalLengthType.HEAD_BODY);
coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xfafb)));
ComplexMsg msg = new ComplexMsg();
msg.id = 32;
msg.version = 1;
msg.subMsg.equipCode.setValue("2014");
msg.subMsg.modular = 0x08;
msg.subMsg.subModular = 0x01;
msg.subMsg.commands.put((byte)0x01, new OrderMsg(OCBytes.valueOf("ready")));
msg.subMsg.commands.put((byte)0x02, new OrderMsg(OCBytes.valueOf(128, true)));
msg.subMsg.commands.put((byte)0x03, new OrderMsg(OCBytes.valueOf("parameter")));
Code will output console information:
FB FA 33 00 00 00 20 00 00 00 01 00 00 22 00 00 00 #SUB MSG#04 32 30 31 34 08 01 #CMDS#03 09 00 70 61 72 61 6D 65 74 65 72 01 05 00 72 65 61 64 79 02 04 00 80 00 00 00
We can also decode the bytes.
ComplexMsg result = new ComplexMsg(); coder.decode(bytes, result);Code will output console information:OCMap<Byte, OrderMsg> cmds = result.subMsg.commands; System.out.println("ID:" + result.id + " VERSION:" + result.version); System.out.println("Equip Code:" + result.subMsg.equipCode.getValue()); System.out.println("Modular:" + result.subMsg.modular + " Sub Modular:" + result.subMsg.subModular); System.out.println("Command 01:" + cmds.get((byte)0x01).order.getString()); System.out.println("Command 02:" + cmds.get((byte)0x02).order.getInt32(true)); System.out.println("Command 03:" + cmds.get((byte)0x03).order.getString());
ID:32 VERSION:1 Equip Code:2014 Modular:8 Sub Modular:1 Command 01:ready Command 02:128 Command 03:parameter
To replace the large bytes and coding slowly of JAVA serialization, we can use darks-codec's simple serialization instead.
It only contains the full name of main class and object's data. Even it can use ObjectCoder's setting such as wrappers, total length and so on.
Object doesn't needs to implement interface java.io.Serializable. It can be serialized directly.
If we have a JAVA bean just like:
class SerialMainBean
{
int id;
int version;
SerialSub subSerial;
}
class SerialSubBean
{
String equip;
int code;
String content;
}
Then we configure object coder and build a SerialMainBean object. If you build JAVA bean without codec type, you should set automatic length true.
ObjectCoder coder = new ObjectCoder(); coder.getCodecConfig().setEndianType(EndianType.LITTLE); coder.getCodecConfig().setTotalLengthType(TotalLengthType.HEAD_BODY); coder.getCodecConfig().setAutoLength(true); coder.getCodecConfig().setCacheType(CacheType.LOCAL); coder.getCodecConfig().addWrap(new IdentifyWrapper((short)0xfafb)); coder.getCodecConfig().addWrap(VerifyWrapper.CRC16()); SerialMainBean bean = new SerialMainBean(); bean.id = 128; bean.version = 1; bean.subSerial = new SerialSubBean(); bean.subSerial.code = 10; bean.subSerial.content = "running"; bean.subSerial.equip = "2014";
Then we can serial object to bytes.
byte[] bytes = ObjectSerial.encode(coder, bean);
And we can convert bytes to object.
Object result = ObjectSerial.decode(coder, bytes);
To encode or decode object, darks-codec will get object's valid fields. We can use field cache to improve the speed
of getting fields. Cache have LOCAL and GLOBAL type. Default NONE.
LOCAL : Local cache is available in current ObjectCoder.
GLOBAL: Global cache is available in all ObjectCoder as global static object.
ObjectCoder coder = new ObjectCoder();
coder.getCodecConfig().setEndianType(EndianType.LITTLE);
coder.getCodecConfig().setCacheType(CacheType.LOCAL);
...
In some Android's dalvikVM, the fields get from object are sorted automatically by virtual machine. Therefore we cannot encode object fields according to the specified fields sequence. To solve the problem, we should define a field named "fieldSequence" in JAVA object or use OCObject's method "setFieldSequence". Java bean class like:
public class FieldMsg
{
static String[] fieldSequence = new String[]{"id", "version", "command"};
String command;
int id;
byte version;
}
Or
public class FieldCodecMsg extends OCObject
{
public FieldCodecMsg()
{
setFieldSequence(new String[]{"id", "version", "command"});
}
OCString command = new OCString();
int id;
byte version;
}
You can see detail example codes in /examples/darks/codec/examples/fieldseq.
When ObjectCoder encoding or decoding message,
It will use WrapperChain to call wrapper before and after encoding or decoding.
When developers add wrapper, wrapper will be added to the first of chain.
When encoding message, wrappers are called like LIFO, which will call the first addition of wrapper finally.
And when decoding message, wrappers are called like FIFO, which will call the first addition of wrapper firstly.
Example:
addWrap IdentifyWrapper addWrap VerifyWrapper addWrap ZipWrapper Encoding call sequence: ZipWrapper -> VerifyWrapper -> IdentifyWrapper Decoding call sequence: IdentifyWrapper -> VerifyWrapper -> ZipWrapper
TotalLengthWrapper will be added automatically when total length type is BODY or HEAD_BODY, so developers cannot add it manually again.
IdentifyWrapper can help developers add head identify and tail identify. You can add only head identify or both of them.
ObjectCoder coder = new ObjectCoder();
coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xFAFB), new OCInt8(0xFF)));
...
coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xFAFB)));
...
coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt8(0xFA)));
...
coder.getCodecConfig().addWrap(new IdentifyWrapper((short)0xFAFB));
VerifyWrapper can add verify bytes to the end of message bytes such as CRC16, CRC32, ADLER32 and so on.
ObjectCoder coder = new ObjectCoder();
coder.getCodecConfig().addWrap(VerifyWrapper.CRC16());
...
coder.getCodecConfig().addWrap(VerifyWrapper.CRC32());
...
coder.getCodecConfig().addWrap(new VerifyWrapper(new CustomVerifier()));
Example:
ObjectCoder coder = new ObjectCoder(); coder.getCodecConfig().setEndianType(EndianType.LITTLE); coder.getCodecConfig().setTotalLengthType(TotalLengthType.HEAD_BODY); coder.getCodecConfig().addWrap(new IdentifyWrapper(new OCInt16(0xFAFB))); coder.getCodecConfig().addWrap(VerifyWrapper.CRC16()); SimpleMsg msg = new SimpleMsg(); msg.id = 32; msg.version = 1; msg.command = "running"; byte[] bytes = coder.encode(msg); System.out.println(ByteHelper.toHexString(bytes));
Code will output console information:
FB FA 14 00 00 00 20 00 00 00 01 72 75 6E 6E 69 6E 67 D6 74
"D6 74" is the message bytes's CRC16 code.
If message bytes are so large, we can compress bytes to reduce communication traffic. It supports JDK GZIP, JZLIB (Need jzlib-1.1.x.jar), Commons Compress(Need commons-compress-1.x.jar) and custom compress.
ObjectCoder coder = new ObjectCoder();
coder.getCodecConfig().addWrap(ZipWrapper.JZLIB());
...
coder.getCodecConfig().getWrapChain().add(ZipWrapper.COMMON_COMPRESS(CompressorStreamFactory.BZIP2));
...
coder.getCodecConfig().addWrap(new ZipWrapper(new CustomZip()));
Developers can encrypt message bytes to ensure information secure.
ObjectCoder coder = new ObjectCoder();
coder.getCodecConfig().addWrap(CipherWrapper.AES("AESKEYS"));
...
coder.getCodecConfig().addWrap(new CipherWrapper(new CustomCipher()));
I wish you a pleasant to use darks-codec. If you have some good advice or bug report, please share with us. Thank you!