org.jboss.netty.handler.codec.http.HttpResponse.getProtocolVersion()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(91)

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

HttpResponse.getProtocolVersion介绍

暂无

代码示例

代码示例来源:origin: io.netty/netty

@Override
  protected void encodeInitialLine(ChannelBuffer buf, HttpMessage message)
      throws Exception {
    HttpResponse response = (HttpResponse) message;
    buf.writeBytes(response.getProtocolVersion().toString().getBytes("ASCII"));
    buf.writeByte((byte) ' ');
    buf.writeBytes(String.valueOf(response.getStatus().getCode()).getBytes("ASCII"));
    buf.writeByte((byte) ' ');
    buf.writeBytes(String.valueOf(response.getStatus().getReasonPhrase()).getBytes("ASCII"));
    buf.writeByte((byte) '\r');
    buf.writeByte((byte) '\n');
  }
}

代码示例来源:origin: io.netty/netty

@Override
  protected void encodeInitialLine(ChannelBuffer buf, HttpMessage message) throws Exception {
    HttpResponse response = (HttpResponse) message;
    encodeAscii(response.getProtocolVersion().toString(), buf);
    buf.writeByte(SP);
    encodeAscii(String.valueOf(response.getStatus().getCode()), buf);
    buf.writeByte(SP);
    encodeAscii(String.valueOf(response.getStatus().getReasonPhrase()), buf);
    buf.writeByte(CR);
    buf.writeByte(LF);
  }
}

代码示例来源:origin: io.netty/netty

private SpdySynReplyFrame createSynReplyFrame(HttpResponse httpResponse)
    throws Exception {
  boolean chunked = httpResponse.isChunked();
  // Get the Stream-ID from the headers
  int streamId = SpdyHttpHeaders.getStreamId(httpResponse);
  SpdyHttpHeaders.removeStreamId(httpResponse);
  // The Connection, Keep-Alive, Proxy-Connection, and Transfer-Encoding
  // headers are not valid and MUST not be sent.
  httpResponse.headers().remove(HttpHeaders.Names.CONNECTION);
  httpResponse.headers().remove("Keep-Alive");
  httpResponse.headers().remove("Proxy-Connection");
  httpResponse.headers().remove(HttpHeaders.Names.TRANSFER_ENCODING);
  SpdySynReplyFrame spdySynReplyFrame = new DefaultSpdySynReplyFrame(streamId);
  spdySynReplyFrame.setLast(!chunked && !httpResponse.getContent().readable());
  // Unfold the first line of the response into name/value pairs
  SpdyHeaders.setStatus(spdyVersion, spdySynReplyFrame, httpResponse.getStatus());
  SpdyHeaders.setVersion(spdyVersion, spdySynReplyFrame, httpResponse.getProtocolVersion());
  // Transfer the remaining HTTP headers
  for (Map.Entry<String, String> entry: httpResponse.headers()) {
    spdySynReplyFrame.headers().add(entry.getKey(), entry.getValue());
  }
  return spdySynReplyFrame;
}

代码示例来源:origin: com.ning/async-http-client

@Override
public String getProtocolName() {
  return response.getProtocolVersion().getProtocolName();
}

代码示例来源:origin: com.ning/async-http-client

@Override
public int getProtocolMinorVersion() {
  return response.getProtocolVersion().getMinorVersion();
}

代码示例来源:origin: com.ning/async-http-client

@Override
public int getProtocolMajorVersion() {
  return response.getProtocolVersion().getMajorVersion();
}

代码示例来源:origin: com.ning/async-http-client

@Override
public String getProtocolText() {
  return response.getProtocolVersion().getText();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3

@Override
public int getProtocolMajorVersion() {
  return response.getProtocolVersion().getMajorVersion();
}

代码示例来源:origin: io.gatling/async-http-client

@Override
public int getProtocolMajorVersion() {
  return response.getProtocolVersion().getMajorVersion();
}

代码示例来源:origin: io.gatling/async-http-client

@Override
public int getProtocolMinorVersion() {
  return response.getProtocolVersion().getMinorVersion();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3-provider

@Override
public String getProtocolText() {
  return response.getProtocolVersion().getText();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3

@Override
public String getProtocolName() {
  return response.getProtocolVersion().getProtocolName();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3

@Override
public int getProtocolMinorVersion() {
  return response.getProtocolVersion().getMinorVersion();
}

代码示例来源:origin: io.gatling/async-http-client

@Override
public String getProtocolText() {
  return response.getProtocolVersion().getText();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3-provider

@Override
public String getProtocolName() {
  return response.getProtocolVersion().getProtocolName();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3-provider

@Override
public int getProtocolMinorVersion() {
  return response.getProtocolVersion().getMinorVersion();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3

@Override
public String getProtocolText() {
  return response.getProtocolVersion().getText();
}

代码示例来源:origin: io.gatling/async-http-client

@Override
public String getProtocolName() {
  return response.getProtocolVersion().getProtocolName();
}

代码示例来源:origin: org.asynchttpclient/async-http-client-netty3-provider

@Override
public int getProtocolMajorVersion() {
  return response.getProtocolVersion().getMajorVersion();
}

代码示例来源:origin: com.couchbase.client/couchbase-client

private void logResponse(HttpResponse response) {
 finerLog("STATUS: " + response.getStatus());
 finerLog("VERSION: " + response.getProtocolVersion());
 if (!response.getHeaderNames().isEmpty()) {
  for (String name : response.getHeaderNames()) {
   for (String value : response.getHeaders(name)) {
    finerLog("HEADER: " + name + " = " + value);
   }
  }
  finerLog(System.getProperty("line.separator"));
 }
 if (response.getStatus().getCode() == 200 && response.isChunked()) {
  readingChunks = true;
  finerLog("CHUNKED CONTENT {");
 } else if(response.getStatus().getCode() == 200) {
  ChannelBuffer content = response.getContent();
  if (content.readable()) {
   finerLog("CONTENT {");
   finerLog(content.toString(CharsetUtil.UTF_8));
   finerLog("} END OF CONTENT");
  }
 } else {
  throw new ConnectionException("Could not retrieve configuration chunk. "
   + "Response Code is: " + response.getStatus());
 }
}

相关文章