com.google.protobuf.Message.toByteArray()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(10.0k)|赞(0)|评价(0)|浏览(547)

本文整理了Java中com.google.protobuf.Message.toByteArray()方法的一些代码示例，展示了Message.toByteArray()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.toByteArray()方法的具体详情如下：
包路径：com.google.protobuf.Message
类名称：Message
方法名：toByteArray

Message.toByteArray介绍

暂无

代码示例

代码示例来源：origin: voldemort/voldemort

  1. public byte[] toBytes(T object) {
  2.   return object.toByteArray();
  3. }

代码示例来源：origin: redisson/redisson

  1. @Override
  2.   public byte[] apply(Object o) {
  3.     Assert.isInstanceOf(Message.class,
  4.               o,
  5.               "Can only serialize Protobuf messages. " +
  6.                   o.getClass().getName() +
  7.                   " is not an instance of " +
  8.                   Message.class.getName());
  9.     return ((Message)o).toByteArray();
  10.   }
  11. };

代码示例来源：origin: a2888409/face2face

  1. public static ByteBuf pack2Client(Message msg) {
  2.   byte[] bytes = msg.toByteArray();
  3.   int length =bytes.length;
  4.   int ptoNum = ParseMap.getPtoNum(msg);
  5.   ByteBuf buf = Unpooled.buffer(8 + length);
  6.   buf.writeInt(length);
  7.   buf.writeInt(ptoNum);
  8.   buf.writeBytes(bytes);
  9.   return buf;
  10. }

代码示例来源：origin: a2888409/face2face

  1. @Override
  2.   protected void encode(ChannelHandlerContext ctx, Message msg, ByteBuf out)
  3.       throws Exception {
  5.     byte[] bytes = msg.toByteArray();// 将对象转换为byte
  6.     int ptoNum = ParseMap.msg2ptoNum.get(msg);
  7.     int length = bytes.length;
  9.     /* 加密消息体
  10.     ThreeDES des = ctx.channel().attr(ClientAttr.ENCRYPT).get();
  11.     byte[] encryptByte = des.encrypt(bytes);
  12.     int length = encryptByte.length;*/
  14.     ByteBuf buf = Unpooled.buffer(8 + length);
  15.     buf.writeInt(length);
  16.     buf.writeInt(ptoNum);
  17.     buf.writeBytes(bytes);
  18.     out.writeBytes(buf);
  20.     logger.info("GateServer Send Message, remoteAddress: {}, content length {}, ptoNum: {}", ctx.channel().remoteAddress(), length, ptoNum);
  22.   }
  23. }

代码示例来源：origin: apache/hbase

  1. @Override
  2. public int compareTo(Row o) {
  3.  int res = Bytes.compareTo(this.getRow(), o.getRow());
  4.  if ((o instanceof RegionCoprocessorServiceExec) && res == 0) {
  5.   RegionCoprocessorServiceExec exec = (RegionCoprocessorServiceExec) o;
  6.   res = method.getFullName().compareTo(exec.getMethod().getFullName());
  7.   if (res == 0) {
  8.    res = Bytes.compareTo(request.toByteArray(), exec.getRequest().toByteArray());
  9.   }
  10.  }
  11.  return res;
  12. }

代码示例来源：origin: pinterest/secor

  1. @Override
  2. public KeyValue next() throws IOException {
  3.   Builder messageBuilder = (Builder) reader.read();
  4.   if (messageBuilder != null) {
  5.     return new KeyValue(offset++, messageBuilder.build().toByteArray());
  6.   }
  7.   return null;
  8. }

代码示例来源：origin: apache/hbase

  1. public static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.
  2.   CoprocessorServiceResponse getResponse(final Message result, final byte [] regionName) {
  3.  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.
  4.   CoprocessorServiceResponse.Builder builder =
  5.    org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse.
  6.    newBuilder();
  7.  builder.setRegion(RequestConverter.buildRegionSpecifier(RegionSpecifierType.REGION_NAME,
  8.   regionName));
  9.  // TODO: UGLY COPY IN HERE!!!!
  10.  builder.setValue(builder.getValueBuilder().setName(result.getClass().getName())
  11.    .setValue(org.apache.hbase.thirdparty.com.google.protobuf.ByteString.
  12.      copyFrom(result.toByteArray())));
  13.  return builder.build();
  14. }

代码示例来源：origin: apache/hbase

  1. @Override
  2. public CoprocessorServiceResponse execService(final RpcController controller,
  3.   final CoprocessorServiceRequest request) throws ServiceException {
  4.  try {
  5.   checkOpen();
  6.   requestCount.increment();
  7.   HRegion region = getRegion(request.getRegion());
  8.   com.google.protobuf.Message result = execServiceOnRegion(region, request.getCall());
  9.   CoprocessorServiceResponse.Builder builder = CoprocessorServiceResponse.newBuilder();
  10.   builder.setRegion(RequestConverter.buildRegionSpecifier(
  11.    RegionSpecifierType.REGION_NAME, region.getRegionInfo().getRegionName()));
  12.   // TODO: COPIES!!!!!!
  13.   builder.setValue(builder.getValueBuilder().setName(result.getClass().getName()).
  14.    setValue(org.apache.hbase.thirdparty.com.google.protobuf.ByteString.
  15.      copyFrom(result.toByteArray())));
  16.   return builder.build();
  17.  } catch (IOException ie) {
  18.   throw new ServiceException(ie);
  19.  }
  20. }

代码示例来源：origin: apache/hbase

  1. private static CoprocessorServiceCall getCoprocessorServiceCall(
  2.   final Descriptors.MethodDescriptor method, final Message request, final byte [] row) {
  3.  return CoprocessorServiceCall.newBuilder()
  4.  .setRow(org.apache.hbase.thirdparty.com.google.protobuf.UnsafeByteOperations.unsafeWrap(row))
  5.  .setServiceName(CoprocessorRpcUtils.getServiceName(method.getService()))
  6.  .setMethodName(method.getName())
  7.  // TODO!!!!! Come back here after!!!!! This is a double copy of the request if I read
  8.  // it right copying from non-shaded to shaded version!!!!!! FIXXXXX!!!!!
  9.  .setRequest(org.apache.hbase.thirdparty.com.google.protobuf.UnsafeByteOperations.
  10.    unsafeWrap(request.toByteArray())).build();
  11. }

代码示例来源：origin: apache/hbase

  1. exec.getRequest().toByteArray());
  2. if (cpBuilder == null) {
  3.  cpBuilder = ClientProtos.CoprocessorServiceCall.newBuilder();

代码示例来源：origin: apache/hbase

  1. exec.getRequest().toByteArray());
  2. if (cpBuilder == null) {
  3.  cpBuilder = ClientProtos.CoprocessorServiceCall.newBuilder();

代码示例来源：origin: apache/hbase

  1. .setName(result.getClass().getName())
  2.     .setValue(UnsafeByteOperations.unsafeWrap(result.toByteArray()))));
  3. } else if (action.hasMutation()) {
  4.  MutationType type = action.getMutation().getMutateType();

代码示例来源：origin: sixt/ja-micro

  1. public byte[] getProtobufData() {
  2.   byte[] envelopeData = getEnvelope().toByteArray();
  3.   byte[] payloadData = getPayload().toByteArray();
  4.   int size = envelopeData.length + payloadData.length + 8;
  5.   byte[] retval = new byte[size];
  6.   int offset = 0;
  7.   System.arraycopy(Ints.toByteArray(envelopeData.length), 0, retval, offset, 4);
  8.   offset += 4;
  9.   System.arraycopy(envelopeData, 0, retval, offset, envelopeData.length);
  10.   offset += envelopeData.length;
  11.   System.arraycopy(Ints.toByteArray(payloadData.length), 0, retval, offset, 4);
  12.   offset += 4;
  13.   System.arraycopy(payloadData, 0, retval, offset, payloadData.length);
  14.   return retval;
  15. }

代码示例来源：origin: org.apache.hbase/hbase-client

  1. @Override
  2. public int compareTo(Row o) {
  3.  int res = Bytes.compareTo(this.getRow(), o.getRow());
  4.  if ((o instanceof RegionCoprocessorServiceExec) && res == 0) {
  5.   RegionCoprocessorServiceExec exec = (RegionCoprocessorServiceExec) o;
  6.   res = method.getFullName().compareTo(exec.getMethod().getFullName());
  7.   if (res == 0) {
  8.    res = Bytes.compareTo(request.toByteArray(), exec.getRequest().toByteArray());
  9.   }
  10.  }
  11.  return res;
  12. }

代码示例来源：origin: sixt/ja-micro

  1. private void sendSuccessfulResponse(HttpServletResponse response,
  2.                   RpcEnvelope.Request rpcRequest,
  3.                   Message pbResponse) throws IOException {
  4.   response.setStatus(HttpServletResponse.SC_OK);
  5.   RpcEnvelope.Response rpcResponse = RpcEnvelope.Response.newBuilder().
  6.       setServiceMethod(rpcRequest.getServiceMethod()).
  7.       setSequenceNumber(rpcRequest.getSequenceNumber()).build();
  8.   byte responseHeader[] = rpcResponse.toByteArray();
  9.   byte responseBody[];
  10.   if (pbResponse == null) {
  11.     responseBody = new byte[0];
  12.   } else {
  13.     responseBody = pbResponse.toByteArray();
  14.   }
  15.   try {
  16.     ServletOutputStream out = response.getOutputStream();
  17.     out.write(Ints.toByteArray(responseHeader.length));
  18.     out.write(responseHeader);
  19.     out.write(Ints.toByteArray(responseBody.length));
  20.     out.write(responseBody);
  21.   } catch (IOException ioex) {
  22.     //there is nothing we can do, client probably went away
  23.     logger.debug("Caught IOException, assuming client disconnected");
  24.   }
  25. }

代码示例来源：origin: palantir/atlasdb

  1. @SuppressWarnings("unchecked")
  2. public byte[] persistJsonToBytes(ClassLoader classLoader, String str) throws ParseException {
  3.   final byte[] bytes;
  4.   if (format == Format.PERSISTABLE) {
  5.     throw new IllegalArgumentException("Tried to pass json into a persistable type.");
  6.   } else if (format == Format.PERSISTER) {
  7.     Persister<?> persister = getPersister();
  8.     if (JsonNode.class == persister.getPersistingClassType()) {
  9.       try {
  10.         JsonNode jsonNode = new ObjectMapper().readValue(str, JsonNode.class);
  11.         return ((Persister<JsonNode>) persister).persistToBytes(jsonNode);
  12.       } catch (IOException e) {
  13.         throw Throwables.throwUncheckedException(e);
  14.       }
  15.     } else {
  16.       throw new IllegalArgumentException("Tried to write json to a Persister that isn't for JsonNode.");
  17.     }
  18.   } else if (format == Format.PROTO) {
  19.     Message.Builder builder = createBuilder(classLoader);
  20.     // This will have issues with base64 blobs
  21.     JsonFormat.merge(str, builder);
  22.     bytes = builder.build().toByteArray();
  23.   } else {
  24.     bytes = type.convertFromString(str);
  25.   }
  26.   return CompressionUtils.compress(bytes, compression);
  27. }

代码示例来源：origin: org.apache.hbase/hbase-client

  1. public static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.
  2.   CoprocessorServiceResponse getResponse(final Message result, final byte [] regionName) {
  3.  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.
  4.   CoprocessorServiceResponse.Builder builder =
  5.    org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse.
  6.    newBuilder();
  7.  builder.setRegion(RequestConverter.buildRegionSpecifier(RegionSpecifierType.REGION_NAME,
  8.   regionName));
  9.  // TODO: UGLY COPY IN HERE!!!!
  10.  builder.setValue(builder.getValueBuilder().setName(result.getClass().getName())
  11.    .setValue(org.apache.hbase.thirdparty.com.google.protobuf.ByteString.
  12.      copyFrom(result.toByteArray())));
  13.  return builder.build();
  14. }

代码示例来源：origin: org.apache.hbase/hbase-client

  1. private static CoprocessorServiceCall getCoprocessorServiceCall(
  2.   final Descriptors.MethodDescriptor method, final Message request, final byte [] row) {
  3.  return CoprocessorServiceCall.newBuilder()
  4.  .setRow(org.apache.hbase.thirdparty.com.google.protobuf.UnsafeByteOperations.unsafeWrap(row))
  5.  .setServiceName(CoprocessorRpcUtils.getServiceName(method.getService()))
  6.  .setMethodName(method.getName())
  7.  // TODO!!!!! Come back here after!!!!! This is a double copy of the request if I read
  8.  // it right copying from non-shaded to shaded version!!!!!! FIXXXXX!!!!!
  9.  .setRequest(org.apache.hbase.thirdparty.com.google.protobuf.UnsafeByteOperations.
  10.    unsafeWrap(request.toByteArray())).build();
  11. }

代码示例来源：origin: palantir/atlasdb

  1. public static byte[] deserializeVal(ColumnValueDescription description,
  2.     JsonNode node) {
  3.   byte[] bytes;
  4.   switch (description.getFormat()) {
  5.     case PERSISTABLE:
  6.     case PERSISTER:
  7.       bytes = node.asToken().asByteArray();
  8.       break;
  9.     case PROTO:
  10.       Message.Builder builder = DynamicMessage.newBuilder(description.getProtoDescriptor());
  11.       try {
  12.         ForkedJsonFormat.merge(node.toString(), builder);
  13.       } catch (ForkedJsonFormat.ParseException e) {
  14.         throw Throwables.rewrapAndThrowUncheckedException(e);
  15.       }
  16.       bytes = builder.build().toByteArray();
  17.       break;
  18.     case VALUE_TYPE:
  19.       bytes = description.getValueType().convertFromJson(node.toString());
  20.       break;
  21.     default:
  22.       throw new EnumConstantNotPresentException(Format.class, description.getFormat().name());
  23.   }
  24.   return CompressionUtils.compress(bytes, description.getCompression());
  25. }

代码示例来源：origin: org.apache.hbase/hbase-client

  1. exec.getRequest().toByteArray());
  2. if (cpBuilder == null) {
  3.  cpBuilder = ClientProtos.CoprocessorServiceCall.newBuilder();

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com