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

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

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

HttpRequest.setHeader介绍

暂无

代码示例

代码示例来源:origin: landy8530/netty-file-parent

private void setHeaderDatas() {
  this.request.setHeader("Host", this.host);
  this.request.setHeader("Connection", "close");
  this.request.setHeader("Accept-Encoding", "gzip,deflate");
  this.request.setHeader("Accept-Charset",
      "ISO-8859-1,utf-8;q=0.7,*;q=0.7");
  this.request.setHeader("Accept-Language", "fr");
  this.request.setHeader("Referer", this.uri.toString());
  this.request.setHeader("User-Agent", "Netty Simple Http Client side");
  this.request
      .setHeader("Accept",
          "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
}

代码示例来源:origin: org.vert-x/vertx-core

private void writeHeaders() {
 if (headers != null) {
  for (Map.Entry<String, Object> header: headers.entrySet()) {
   String key = header.getKey();
   request.setHeader(key, header.getValue());
  }
 }
}

代码示例来源:origin: neilbeveridge/zuul-netty

@Override
  public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
    //only set this on request - proceeding chunks will be routed on same outbound connection
    if (e.getMessage() instanceof HttpRequest) {
      HttpRequest request = (HttpRequest) e.getMessage();

      request.setHeader(ROUTE_HEADER, STATIC_ROUTE);
      LOG.debug("setting header {} to {}", ROUTE_HEADER, STATIC_ROUTE);

      request.setHeader("host", new URL(STATIC_ROUTE).getHost());
    }

    super.messageReceived(ctx, e);
  }
}

代码示例来源:origin: cgbystrom/netty-tools

@Override
protected Object encode(ChannelHandlerContext context, Channel channel,	Object message) throws Exception {
  ChannelBuffer content = (ChannelBuffer) message;
  HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, uri);
  request.setHeader(HttpHeaders.Names.HOST, host);
  request.setHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
  request.setHeader(HttpHeaders.Names.CONTENT_LENGTH, content.readableBytes());
  request.setContent(content);
  return request;
}

代码示例来源:origin: org.webbitserver/webbit

private HttpRequest createNettyHttpRequest() {
  HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, getPath(uri));
  request.setHeader(HttpHeaders.Names.HOST, remoteAddress.getHostName() + ':' + remoteAddress.getPort());
  request.setHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.UPGRADE);
  request.setHeader(HttpHeaders.Names.UPGRADE, "websocket");
  request.setHeader(HttpHeaders.Names.ACCEPT_ENCODING, HttpHeaders.Values.GZIP);
  request.setHeader(Hybi.SEC_WEBSOCKET_VERSION, VERSION);
  StringBuilder builder = new StringBuilder();
  boolean first = true;
  for(HttpCookie cookie : cookies){
    if(!first){
      builder.append("; ");
    }
    builder.append(cookie.toString());
    first = false;
  }
  if(!first){
    request.setHeader(org.webbitserver.HttpRequest.COOKIE_HEADER, builder.toString());
  }
  base64Nonce = base64Nonce();
  request.setHeader(Hybi.SEC_WEBSOCKET_KEY, base64Nonce);
  return request;
}

代码示例来源:origin: org.vert-x/vertx-core

private void writeHead() {
 request.setChunked(chunked);
 if (!raw) {
  request.setHeader(HttpHeaders.Names.HOST, conn.hostHeader);
  if (chunked) {
   request.setHeader(HttpHeaders.Names.TRANSFER_ENCODING, HttpHeaders.Values.CHUNKED);
  }
 }
 writeHeaders();
 conn.write(request);
}

代码示例来源:origin: com.proofpoint.platform/http-client-experimental

nettyRequest.setHeader(Names.HOST, uri.getHost());
nettyRequest.setHeader(Names.HOST, uri.getHost() + ":" + uri.getPort());
nettyRequest.setHeader(header.getKey(), header.getValue());
bodyGenerator.write(out);
nettyRequest.setHeader(Names.CONTENT_LENGTH, content.readableBytes());
nettyRequest.setContent(content);

代码示例来源:origin: org.jboss.ws.native/jbossws-native-core

marshaller.write(reqMessage, os);
os.flush();
request.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(content.readableBytes()));
request.setContent(content);
return channel.write(request);

代码示例来源:origin: caskdata/coopr

accessTokenTransformer.transform(accessToken);
logEntry.setUserName(accessTokenIdentifierPair.getAccessTokenIdentifierObj().getUsername());
msg.setHeader(HttpHeaders.Names.AUTHORIZATION,
       "CDAP-verified " + accessTokenIdentifierPair.getAccessTokenIdentifierStr());
return true;

代码示例来源:origin: cgbystrom/sockjs-netty

req.setHeader(CONNECTION, UPGRADE);
req.setHeader(SEC_WEBSOCKET_VERSION, "8");

相关文章