今天動(dòng)力節(jié)點(diǎn)java培訓(xùn)機(jī)構(gòu)小編為大家介紹“如何將java對(duì)象轉(zhuǎn)成byte數(shù)組”，希望通過此文能夠幫助到大家，下面就隨小編一起看看java對(duì)象轉(zhuǎn)成byte數(shù)組的幾種方法。

java對(duì)象轉(zhuǎn)成byte數(shù)組，在使用netty進(jìn)行通信協(xié)議傳輸?shù)膱?chǎng)景中是非常常見的。比如，協(xié)議有一些定好的協(xié)議頭、classid，messageid等等信息，還有一個(gè)關(guān)鍵的內(nèi)容是payload。不同的協(xié)議內(nèi)容都會(huì)放到payload中，而這個(gè)payload往往就是一個(gè)byte數(shù)組。

　　那么，如何方便的將一個(gè)java對(duì)象構(gòu)造成一個(gè)byte數(shù)組呢?

　　1、 bytebuf填充

　　我們以下面這個(gè)對(duì)象舉例：

public class UgvData implements Serializible{

 private static final long serialVersionUID = -219988432063763456L;

 //狀態(tài)碼

 byte status;

 //當(dāng)前GPS經(jīng)度

 float longitude;

 //當(dāng)前GPS緯度

 float latitude;

 //行駛速度 單位是 m/s，帶一個(gè)小數(shù)點(diǎn)

 float speed;

 //當(dāng)前電量百分比

 short batteryPercentage;

 //任務(wù)編號(hào)

 long quest;

 public byte[] toByteArray() {

  ByteBuf buf = Unpooled.buffer(32);

  buf.writeByte(this.getStatus());

  buf.writeFloat(getLongitude());

  buf.writeFloat(getLatitude());

  buf.writeFloat(getSpeed());

  buf.writeShort(getBatteryPercentage());

  buf.writeLong(getQuest());

  return buf.array();

 }

 //省略get set

}

　　那么只需要new出一個(gè)上面的對(duì)象，調(diào)用其toByteArray方法，即可將這個(gè)對(duì)象轉(zhuǎn)成byte數(shù)組。

　　2 、巧用json

　　我們都知道，字符串是可以轉(zhuǎn)成byte數(shù)組的。將一個(gè)對(duì)象轉(zhuǎn)成json字符串也很容易，直接使用fastjson就可以了。

JSON.toJsonString(ugvData).getBytes()

　　3、 反射的方式

　　第一種方法的缺點(diǎn)在于，每一個(gè)類都要這么寫一個(gè)toByteArray方法。如果類多了是非常麻煩的。有什么方便的方法嗎?當(dāng)然是有的，利用反射的方式(只會(huì)在第一次反射，后面會(huì)做本地緩存，所以性能開銷不大)。需要在一個(gè)文件夾下添加下面五個(gè)類。

　　（1）Codecable

import com.fasterxml.jackson.annotation.JsonIgnore;

import com.google.common.collect.Lists;

import lombok.Data;

import java.lang.reflect.Field;

import java.util.Collections;

import java.util.Comparator;

import java.util.List;

@Data

public abstract class Codecable {

 public static List<FieldWrapper> resolveFileldWrapperList(Class clazz){

  Field[] fields = clazz.getDeclaredFields();

  List<FieldWrapper> fieldWrapperList = Lists.newArrayList();

  for (Field field : fields) {

   CodecProprety codecProprety = field.getAnnotation(CodecProprety.class);

   if (codecProprety == null) {

    continue;

   }

   FieldWrapper fw = new FieldWrapper(field, codecProprety);

   fieldWrapperList.add(fw);

  }

  Collections.sort(fieldWrapperList, new Comparator<FieldWrapper>() {

   @Override

   public int compare(FieldWrapper o1, FieldWrapper o2) {

    return o1.getCodecProprety().order() - o2.getCodecProprety().order();

   }

  });

  return fieldWrapperList;

 }

 @JsonIgnore

 public abstract List<FieldWrapper> getFieldWrapperList();

}

（2）CodecProprety

import java.lang.annotation.ElementType;

import java.lang.annotation.Retention;

import java.lang.annotation.RetentionPolicy;

import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)

@Target({ElementType.FIELD})

public @interface CodecProprety {

 /**

  * 屬性順序

  * @return

  */

 int order();

 /**

  * 數(shù)據(jù)長(zhǎng)度。解碼時(shí)用，除了簡(jiǎn)單數(shù)據(jù)類型之外才起作用（如：String）。

  * @return

  */

 int length() default 0;

}

（3）FieldWrapper

import lombok.AllArgsConstructor;

import lombok.Data;

import java.lang.reflect.Field;

@Data

@AllArgsConstructor

public class FieldWrapper {

 /**

  * 上下行數(shù)據(jù)屬性

  */

 private Field field;

 /**

  * 上下行數(shù)據(jù)屬性上的注解

  */

 private CodecProprety codecProprety;

}

（4）PayloadDecoder

import io.netty.buffer.ByteBuf;

import io.netty.buffer.Unpooled;

import java.lang.reflect.Field;

import java.lang.reflect.Method;

import java.nio.charset.Charset;

import java.util.List;

public class PayloadDecoder {

 public static <T extends Codecable> T resolve(byte[] src, Class<T> clazz) {

  T instance = null;

  try {

   instance = clazz.newInstance();

  } catch (Exception e) {

   throw new RuntimeException("實(shí)例化類失敗", e);

  }

  List<FieldWrapper> fieldWrapperList = instance.getFieldWrapperList();

  ByteBuf buffer = Unpooled.buffer().writeBytes(src);

  for (FieldWrapper fieldWrapper : fieldWrapperList) {

   fillData(fieldWrapper, instance, buffer);

  }

  return instance;

 }

 private static void fillData(FieldWrapper fieldWrapper, Object instance, ByteBuf buffer) {

  Field field = fieldWrapper.getField();

  field.setAccessible(true);

  String typeName = field.getType().getName();

  try {

   switch (typeName) {

    case "java.lang.Boolean":

    case "boolean":

     boolean b = buffer.readBoolean();

     field.set(instance, b);

     break;

    case "java.lang.Character":

    case "char":

     CharSequence charSequence = buffer.readCharSequence(fieldWrapper.getCodecProprety().length(), Charset.forName("UTF-8"));

     field.set(instance, charSequence);

     break;

    case "java.lang.Byte":

    case "byte":

     byte b1 = buffer.readByte();

     field.set(instance, b1);

     break;

    case "java.lang.Short":

    case "short":

     short readShort = buffer.readShort();

     field.set(instance, readShort);

     break;

    case "java.lang.Integer":

    case "int":

     int readInt = buffer.readInt();

     field.set(instance, readInt);

     break;

    case "java.lang.Long":

    case "long":

     long l = buffer.readLong();

     field.set(instance, l);

     break;

    case "java.lang.Float":

    case "float":

     float readFloat = buffer.readFloat();

     field.set(instance, readFloat);

     break;

    case "java.lang.Double":

    case "double":

     double readDouble = buffer.readDouble();

     field.set(instance, readDouble);

     break;

    case "java.lang.String":

     String readString = buffer.readCharSequence(fieldWrapper.getCodecProprety().length(), Charset.forName("UTF-8")).toString();

     field.set(instance, readString);

     break;

    default:

     throw new RuntimeException(typeName + "不支持，bug");

   }

  } catch (Exception e) {

   throw new RuntimeException(typeName + "讀取失敗，field:" + field.getName(), e);

  }

 }

}

（5）PayloadEncoder

import io.netty.buffer.ByteBuf;

import io.netty.buffer.Unpooled;

import java.lang.reflect.Field;

import java.lang.reflect.Method;

import java.nio.charset.Charset;

import java.util.List;

public class PayloadEncoder {

 public static <T extends Codecable> byte[] getPayload(T command) {

  List<FieldWrapper> fieldWrapperList = command.getFieldWrapperList();

  ByteBuf buffer = Unpooled.buffer();

  fieldWrapperList.forEach(fieldWrapper -> write2ByteBuf(fieldWrapper, command, buffer));

  return buffer.array();

 }

 /**

  * 數(shù)據(jù)寫入到ByteBuf

  *

  * @param fieldWrapper

  * @param instance

  * @param buffer

  */

 private static void write2ByteBuf(FieldWrapper fieldWrapper, Object instance, ByteBuf buffer) {

  Field field = fieldWrapper.getField();

  String typeName = field.getType().getName();

  field.setAccessible(true);

  Object value = null;

  try {

   value = field.get(instance);

  } catch (IllegalAccessException e) {

   new RuntimeException("反射獲取值失敗，filed:" + field.getName(), e);

  }

  switch (typeName) {

   case "java.lang.Boolean":

   case "boolean":

    buffer.writeBoolean((Boolean) value);

    break;

   case "java.lang.Character":

   case "char":

    buffer.writeCharSequence((CharSequence) value, Charset.forName("UTF-8"));

    break;

   case "java.lang.Byte":

   case "byte":

    buffer.writeByte((byte) value);

    break;

   case "java.lang.Short":

   case "short":

    buffer.writeShort((short) value);

    break;

   case "java.lang.Integer":

   case "int":

    buffer.writeInt((int) value);

    break;

   case "java.lang.Long":

   case "long":

    buffer.writeLong((long) value);

    break;

   case "java.lang.Float":

   case "float":

    buffer.writeFloat((float) value);

    break;

   case "java.lang.Double":

   case "double":

    buffer.writeDouble((double) value);

    break;

   case "java.lang.String":

    buffer.writeCharSequence((CharSequence) value, Charset.forName("UTF-8"));

    break;

   default:

    throw new RuntimeException(typeName + "不支持，bug");

  }

 }

}

　　添加完上面五個(gè)類之后，使用也很簡(jiǎn)單，只需要如下所示，就可以把driveStartData轉(zhuǎn)成byte數(shù)組。

　　PayloadEncoder.getPayload(driveStartData)

　　4 、總結(jié)

　　可能會(huì)有人問了，上面三種，明顯第二種轉(zhuǎn)json最簡(jiǎn)單，為什么還要用另外兩種呢?

　　其實(shí)，第一種和第三種可以歸為一類，都是把對(duì)象直接轉(zhuǎn)成byte數(shù)組，下一層做解析的話，可以一個(gè)一個(gè)元素取;

　　第二種情況是把對(duì)象的json字符串轉(zhuǎn)成byte數(shù)組，問題就在于，json字符串最開頭是”{“，也就是轉(zhuǎn)成的byte數(shù)組的第一位是”{“對(duì)應(yīng)的數(shù)值

　　在使用中應(yīng)該根據(jù)情況來，如果下一層做解析是直接取元素，對(duì)象少的話用第一種;對(duì)象多的話用第三種;

　　如果下一層做了排除掉json的一些格式的解析，就用第二種。

以上就是動(dòng)力節(jié)點(diǎn)java培訓(xùn)機(jī)構(gòu)小編介紹的“如何將java對(duì)象轉(zhuǎn)成byte數(shù)組”的內(nèi)容，希望能夠幫助到大家，更多java最新資訊請(qǐng)繼續(xù)關(guān)注動(dòng)力節(jié)點(diǎn)java培訓(xùn)機(jī)構(gòu)官網(wǎng)，每天會(huì)有精彩內(nèi)容分享與你。

相關(guān)免費(fèi)視頻教程推薦

java對(duì)象數(shù)組視頻教程下載：http://m.dabaquan.cn/xiazai/2546.html