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

YarProtocol.buildRequest介绍

暂无

代码示例

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

final byte[] contentBytes = new byte[buf.readableBytes()];
buf.getBytes(0, contentBytes);
YarRequest yarRequest = new AttachmentRequest(YarProtocol.buildRequest(contentBytes), attachments);
yarRequest.setRequestPath(requestPath);
yarResponse = (YarResponse) orgHandler.handle(channel, 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();
}