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

YarProtocol.toProtocolBytes介绍

暂无

代码示例

代码示例来源：origin: weibocom/motan

responseBytes = YarProtocol.toProtocolBytes(yarResponse);
} catch (IOException e) {
  throw new MotanFrameworkException("convert yar response to bytes fail.", e);

代码示例来源：origin: com.weibo/yar-java

protected byte[] buildRequestBtyes(long id, String path, String method, String packageName, Object... parameterObject)
    throws IOException {
  YarRequest yarRequest = new YarRequest(id, packageName, method, parameterObject);
  return YarProtocol.toProtocolBytes(yarRequest);
}

代码示例来源：origin: com.weibo/yar-java

@Override
protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest msg) throws Exception {
  ByteBuf buf = msg.content();
  byte[] bytes = new byte[buf.readableBytes()];
  buf.getBytes(0, bytes);
  YarRequest yarRequest = YarProtocol.buildRequest(bytes);
  YarResponse yarResponse = process(yarRequest);
  FullHttpResponse response =
      new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, Unpooled.wrappedBuffer(YarProtocol
          .toProtocolBytes(yarResponse)));
  response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "application/x-www-form-urlencoded");
  response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, response.content().readableBytes());
  if (HttpHeaders.isKeepAlive(msg)) {
    response.headers().set(HttpHeaders.Names.CONNECTION, Values.KEEP_ALIVE);
  }
  ctx.write(response);
  ctx.flush();
  ctx.close();
}

代码示例来源：origin: com.weibo/yar-java

public static byte[] toProtocolBytes(YarRequest request) throws IOException {
  if (request == null) {
    throw new YarException("YarRequest is null");
  }
  Map<String, Object> requestMap = new HashMap<String, Object>();
  requestMap.put("i", request.getId());
  requestMap.put("m", request.getMethodName());
  requestMap.put("p", Arrays.asList(request.getParameters()));
  String packagerName = request.getPackagerName();
  return toProtocolBytes(request.getId(), packagerName, requestMap);
}

代码示例来源：origin: com.weibo/yar-java

public static byte[] toProtocolBytes(YarResponse response) throws IOException {
  if (response == null) {
    throw new YarException("YarResponse is null");
  }
  Map<String, Object> responseMap = new HashMap<String, Object>();
  responseMap.put("i", response.getId());
  responseMap.put("s", response.getStatus());
  if (response.getRet() != null) {
    responseMap.put("r", response.getRet());
  }
  if (response.getOutput() != null) {
    responseMap.put("o", response.getOutput());
  }
  if (response.getError() != null) {
    responseMap.put("e", response.getError());
  }
  String packagerName = response.getPackagerName();
  return toProtocolBytes(response.getId(), packagerName, responseMap);
}