Java与C#通过Byte[]字节数组实现消息传递，跨语言数据序列化
支持类型：
byte、short、int、long、float、double、boolean、char、String、byte\[\]
Java中的BitConverter ：[http://baike.xsoftlab.net/view/1191.html](http://baike.xsoftlab.net/view/1191.html)
Java代码
```java
package com.itshidu.io;
import java.nio.charset.Charset;
import com.itshidu.util.BitConverter;
/**
* 发送的请求数据
* 数据类型：String_255=0;String_65535=1;Int8=2;Int16=3;Int32=4;Int64=5;Float=6;Double=7;Boolean=8;Char=9;Byte[]=10;
* String类型数值最大65535字节（UTF8字符集，每个汉字3字节）
* @author Master.Xia
*/
public class NetMessage{
public static byte[] Concat(byte[]... bs) {
int len = 0,idx=0;
for(byte[] b:bs)len+=b.length;
byte[] buffer = new byte[len];
for(byte[] b:bs) {
System.arraycopy(b,0, buffer, idx, b.length);
idx+=b.length;
}
return buffer;
}
public int code;
public Object[] data;
public byte[] GetBytes() {
byte[] buffer = BitConverter.GetBytes(code);
buffer = Concat(buffer,new byte[] {(byte)data.length});
for(int i=0;i<data.length;i++) {
if(data[i] instanceof String) { //String
byte[] typeBytes = null;
byte[] lenBytes = null;
byte[] strBytes=((String)data[i]).getBytes(Charset.forName("UTF-8"));
if(strBytes.length<=255) {
typeBytes = new byte[]{(byte)0};
lenBytes=new byte[]{(byte)(strBytes.length-128)};
}else if(strBytes.length<=65535) {
typeBytes = new byte[]{(byte)1};
lenBytes=BitConverter.GetBytes((short)(strBytes.length-32768));
}else {
throw new RuntimeException("String Byte Length Out of Bounds:"+strBytes.length);
}
buffer = Concat(buffer,typeBytes,lenBytes,strBytes);
}else if(data[i] instanceof Byte) { //Int8
byte[] typeBytes = new byte[]{(byte)2};
byte[] dataBytes = new byte[]{(byte)data[i]};
buffer = Concat(buffer,typeBytes,dataBytes);
}else if(data[i] instanceof Short) { //Int16
byte[] typeBytes = new byte[]{(byte)3};
byte[] dataBytes=BitConverter.GetBytes((short)data[i]);
buffer = Concat(buffer,typeBytes,dataBytes);
}else if(data[i] instanceof Integer) { //Int32
byte[] typeBytes = new byte[]{(byte)4};
byte[] dataBytes=BitConverter.GetBytes((int)data[i]);
buffer = Concat(buffer,typeBytes,dataBytes);
}else if(data[i] instanceof Long) { //Int64
byte[] typeBytes = new byte[]{(byte)5};
byte[] dataBytes=BitConverter.GetBytes((long)data[i]);
buffer = Concat(buffer,typeBytes,dataBytes);
}else if(data[i] instanceof Float) { //Float
byte[] typeBytes = new byte[]{(byte)6};
byte[] dataBytes = BitConverter.GetBytes((float)data[i]);
buffer = Concat(buffer,typeBytes,dataBytes);
}else if(data[i] instanceof Double) { //Double
byte[] typeBytes = new byte[]{(byte)7};
byte[] dataBytes = BitConverter.GetBytes(Double.doubleToLongBits((double)data[i]));
buffer = Concat(buffer,typeBytes,dataBytes);
}else if(data[i] instanceof Boolean) { //Boolean
byte[] typeBytes = new byte[]{(byte)8};
byte[] dataBytes = new byte[]{(byte)(((boolean)data[i])? 1:0)};
buffer = Concat(buffer,typeBytes,dataBytes);
}else if(data[i] instanceof Character) {//Char
byte[] typeBytes = new byte[]{(byte)9};
byte[] dataBytes = new String(new char[] {(char)data[i]}).getBytes(Charset.forName("UTF-8"));
byte[] lenBytes = new byte[] { (byte)dataBytes.length };
buffer = Concat(buffer,typeBytes,lenBytes,dataBytes);
}else if(data[i] instanceof byte[]&##124;&##124;data[i] instanceof Byte[]) { //byte[]:&##124;Type:1byte&##124;DataLen:4byte&##124;Data&##124;
byte[] typeBytes = new byte[]{(byte)10};
byte[] dataBytes = null;
if(data[i] instanceof Byte[]){
Byte[] bs1 = (Byte[])data[i];
dataBytes = new byte[bs1.length];
for(int m=0;m<bs1.length;m++){
dataBytes[m]=(byte)bs1[m];
}
}else {
dataBytes = (byte[])data[i];
}
byte[] lenBytes=BitConverter.GetBytes(dataBytes.length);
buffer = Concat(buffer,typeBytes,lenBytes,dataBytes);
}
}
return buffer;
}
public NetMessage(byte[] bytes){
this.code = BitConverter.ToInt32(bytes, 0);
int count = BitConverter.ByteToInt(bytes[4]);
int index = 5;
this.data = new Object[count];
for(int i=0;i<count;i++) {
int argType = BitConverter.ByteToInt(bytes[index++]);
if(argType==0) { //String_256
int len = BitConverter.ByteToInt((byte)(128+bytes[index++]));
data[i] = new String(bytes,index,len,Charset.forName("UTF-8"));
index += len;
}else if(argType==1) { //String_65535
int len = BitConverter.ToInt16(bytes, index)+32768;
index += 2;
data[i] = new String(bytes,index,len,Charset.forName("UTF-8"));
index += len;
}else if(argType==2) { //Byte
data[i] = BitConverter.ByteToInt(bytes[index++]);
}else if(argType==3) { //Short
data[i] = BitConverter.ToInt16(bytes, index);
index += 2;
}else if(argType==4) { //Int
data[i] = BitConverter.ToInt32(bytes, index);
index += 4;
}else if(argType==5) { //Long
data[i] = BitConverter.ToInt64(bytes, index);
index += 8;
}else if(argType==6) { //Float
data[i] = BitConverter.ToFloat(bytes, index);
index += 4;
}else if(argType==7) { //Double
data[i] = Double.longBitsToDouble(BitConverter.ToInt64(bytes, index));
index+=8;
}else if(argType==8) { //Boolean
data[i]=(bytes[index++]==0x00)? false:true;
}else if(argType==9) { //Char
Charset charset = Charset.forName("UTF-8");
int len = BitConverter.ByteToInt(bytes[index++]);
data[i] = new String(bytes,index,len,charset).toCharArray()[0];
index += len;
}else if(argType==10) { //Byte[]
int len6 = BitConverter.ToInt32(bytes, index);
index += 4;
data[i] = new byte[len6];
System.arraycopy(bytes, index, data[i], 0, len6);
index += len6;
}else {
System.out.println("无法识别的类型码："+argType);
}
}
}
public byte[] pack() {
byte[] dataBytes = this.GetBytes();
byte[] lenBytes = BitConverter.GetBytes(dataBytes.length);
return Concat(lenBytes,dataBytes);
}
public NetMessage(int code,Object...objects) {
this.code = code;
this.data = objects;
}
public NetMessage(int code) {
this.code = code;
}
public static void main(String[] args) {
NetMessage a = new NetMessage(
12,(byte)100,(short)1000,(int)10000,(long)100000,1.414f,3.141592654,true,false,'@','哈'
,"HelloWorld".getBytes()
,"中华人民共和国万岁".getBytes()
,123
);
byte[] bs = a.GetBytes();
NetMessage b = new NetMessage(bs);
System.out.println(b.code);
for(Object o : b.data) {
System.out.println(o);
}
System.out.println(new String((byte[])b.data[b.data.length-2]));
}
}
```
C#代码
```cs
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
namespace com.itshidu.io {
public class NetMessage {
public int code;
public object[] data;
private int ByteToInt(byte b) {
return b & 0xFF;
}
public static byte[] Concat(params byte[][] arrays) {
int total = 0;
foreach (byte[] bs in arrays) {
total += bs.Length;
}
byte[] buffer = new byte[total];
int index = 0;
foreach (byte[] bs in arrays) {
bs.CopyTo(buffer, index);
index += bs.Length;
}
return buffer;
}
public static byte[] LongToBytes(long values) {
byte[] buffer = new byte[8];
for (int i = 0; i < 8; i++) {
int offset = 64 - (i + 1) * 8;
buffer[i] = (byte)((values >> offset) & 0xff);
}
return buffer;
}
public static long BytesToLong(byte[] buffer,int offset) {
long values = 0;
for (int i = 0; i < 8; i++) {
values <<= 8;
values &##124;= (byte)(buffer[offset+i] & 0xFF);
}
return values;
}
public NetMessage(byte[] bytes, int offset, int len) {
byte[] buffer = new byte[len];
Array.Copy(bytes, offset, buffer, 0, len);
Parse(buffer);
}
public NetMessage(byte[] bytes) {
Parse(bytes);
}
public NetMessage(int code, params object[] objects) {
this.code = code;
this.data = objects;
}
public void Parse(byte[] bytes) {
this.code = BitConverter.ToInt32(bytes, 0);
int count = bytes[4] & 0xFF;
int index = 5;
this.data = new object[count];
for (int i = 0; i < count; i++) {
int argType = bytes[index++] & 0xFF;
if (argType == 0) { //String_255
int len = ByteToInt((byte)(128 + bytes[index++]));
data[i] = Encoding.UTF8.GetString(bytes, index, len);
index += len;
} else if (argType == 1) { //String_65535
int len = BitConverter.ToInt16(bytes, index)+ 32768;
index += 2;
data[i] = Encoding.UTF8.GetString(bytes, index, len);
index += len;
} else if (argType == 2) { //Byte
data[i] = ByteToInt(bytes[index++]);
} else if (argType == 3) { //Short
data[i] = BitConverter.ToInt16(bytes, index);
index += 2;
} else if (argType == 4) { //Int
data[i] = BitConverter.ToInt32(bytes, index);
index += 4;
} else if (argType == 5) { //Long
data[i] = BytesToLong(bytes, index);
index += 8;
} else if (argType == 6) { //Float
data[i] = BitConverter.ToSingle(bytes, index);
index += 4;
} else if (argType == 7) { //Double
data[i] = BitConverter.Int64BitsToDouble(BytesToLong(bytes, index));
index += 8;
} else if (argType == 8) { //Boolean
data[i] = (bytes[index++] == 0x00) ? false : true;
} else if (argType == 9) { //Char
int len = ByteToInt(bytes[index++]);
data[i] = Encoding.UTF8.GetChars(bytes, index, len)[0];
index += len;
} else if (argType == 10) { //Byte[]
int len6 = BitConverter.ToInt32(bytes, index);
index += 4;
byte[] buf = new byte[len6];
data[i] = buf;
Array.Copy(bytes, index, buf, 0, len6);
index += len6;
} else {
Console.WriteLine("无法识别的类型码：" + argType);
}
}
}
public byte[] GetBytes() {
byte[] buffer = BitConverter.GetBytes(code);
buffer = Concat(buffer, new byte[] { (byte)data.Length });
for (int i = 0; i < data.Length; i++) {
if (data[i].GetType() == typeof(string)) { //String
byte[] typeBytes = null;
byte[] lenBytes = null;
byte[] strBytes = Encoding.UTF8.GetBytes((string)data[i]);
if (strBytes.Length <= 255) {
typeBytes = new byte[] { (byte)0 }; //String_255
lenBytes = new byte[] { (byte)(strBytes.Length - 128) };
} else if (strBytes.Length <= 65535) {
typeBytes = new byte[] { (byte)1 }; //String_65535
lenBytes = BitConverter.GetBytes((short)(strBytes.Length - 32768));
}
buffer = Concat(buffer, typeBytes, lenBytes, strBytes);
} else if (data[i].GetType() == typeof(byte)) { //Int8
byte[] typeBytes = new byte[] { (byte)2 };
byte[] dataBytes = new byte[] { (byte)data[i] };
buffer = Concat(buffer, typeBytes, dataBytes);
}else if (data[i].GetType() == typeof(short)) { //Int16
byte[] typeBytes = new byte[] { (byte)3 };
byte[] dataBytes = BitConverter.GetBytes((short)data[i]);
buffer = Concat(buffer, typeBytes, dataBytes);
}else if (data[i].GetType() == typeof(int)) { //Int32
byte[] typeBytes = new byte[] { (byte)4 };
byte[] dataBytes = BitConverter.GetBytes((int)data[i]);
buffer = Concat(buffer, typeBytes, dataBytes);
}else if (data[i].GetType() == typeof(long)) { //Int64
byte[] typeBytes = new byte[] { (byte)5 };
byte[] dataBytes = LongToBytes((long)data[i]);
buffer = Concat(buffer, typeBytes, dataBytes);
}else if (data[i].GetType() == typeof(float)) { //Float
byte[] typeBytes = new byte[] { (byte)6 };
byte[] dataBytes = BitConverter.GetBytes((float)data[i]);
buffer = Concat(buffer, typeBytes, dataBytes);
}else if (data[i].GetType() == typeof(double)) {//Double
byte[] typeBytes = new byte[] { (byte)7 };
byte[] dataBytes=LongToBytes(BitConverter.DoubleToInt64Bits((double)data[i]));
buffer = Concat(buffer, typeBytes,dataBytes);
} else if (data[i].GetType() == typeof(bool)) { //Boolean
byte[] typeBytes = new byte[] { (byte)8 };
byte[] dataBytes = new byte[] { (byte)(((bool)data[i]) ? 1 : 0) };
buffer = Concat(buffer, typeBytes, dataBytes);
}else if (data[i].GetType() == typeof(char)) {//Char
byte[] typeBytes = new byte[] { (byte)9 };
byte[] dataBytes = Encoding.UTF8.GetBytes(new char[] { (char)data[i] });
byte[] lenBytes = new byte[] { (byte)dataBytes.Length };
buffer = Concat(buffer, typeBytes,lenBytes,dataBytes);
}else if (data[i].GetType() == typeof(byte[])) { //byte[]:&##124;Type:1byte&##124;DataLen:4byte&##124;Data&##124;
byte[] typeBytes = new byte[] { (byte)10 };
byte[] dataBytes = (byte[])data[i];
byte[] lenBytes = BitConverter.GetBytes(dataBytes.Length);
buffer = Concat(buffer, typeBytes, lenBytes, dataBytes);
}
}
return buffer;
}
public byte[] pack() {
byte[] msgBytes = this.GetBytes();
byte[] lenBytes = BitConverter.GetBytes(msgBytes.Length);
return NetMessage.Concat(lenBytes, msgBytes);
}
}
}
```