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

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

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

HttpRequest.addHeader介绍

暂无

代码示例

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

@Override
public void addHeader(String name, Object value) {
  request.addHeader(name, value);
}

代码示例来源:origin: projectodd/stilts

public HttpRequest generateRequest(URI uri) throws Exception {
  HttpRequest request = new DefaultHttpRequest( HttpVersion.HTTP_1_1, HttpMethod.GET, uri.getPath() );
  request.addHeader( "Sec-WebSocket-Version", "7" );
  request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" );
  request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" );
  request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() );
  request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" );
  request.addHeader( "Sec-WebSocket-Key", this.challenge.getNonceBase64() );
  request.setContent( ChannelBuffers.EMPTY_BUFFER );
  return request;
}

代码示例来源:origin: projectodd/stilts

public HttpRequest generateRequest(URI uri) throws Exception {
  HttpRequest request = new DefaultHttpRequest( HttpVersion.HTTP_1_1, HttpMethod.GET, uri.getPath() );
  request.addHeader( "Sec-WebSocket-Version", "7" );
  request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" );
  request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" );
  request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() );
  request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" );
  request.addHeader( "Sec-WebSocket-Key", this.challenge.getNonceBase64() );
  request.setContent( ChannelBuffers.EMPTY_BUFFER );
  return request;
}

代码示例来源:origin: projectodd/stilts

public HttpRequest generateRequest(URI uri) throws Exception {
  HttpRequest request = new DefaultHttpRequest( HttpVersion.HTTP_1_1, HttpMethod.GET, uri.getPath() );
  request.addHeader( "Sec-WebSocket-Version", getVersion() );
  request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" );
  request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" );
  request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() );
  request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" );
  request.addHeader( "Sec-WebSocket-Key", this.challenge.getNonceBase64() );
  request.setContent( ChannelBuffers.EMPTY_BUFFER );
  return request;
}

代码示例来源:origin: aslakhellesoy/eventsource-java

@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
  HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, uri.toString());
  request.addHeader(Names.ACCEPT, "text/event-stream");
  request.addHeader(Names.HOST, uri.getHost());
  request.addHeader(Names.ORIGIN, "http://" + uri.getHost());
  request.addHeader(Names.CACHE_CONTROL, "no-cache");
  if (lastEventId != null) {
    request.addHeader("Last-Event-ID", lastEventId);
  }
  e.getChannel().write(request);
  channel = e.getChannel();
}

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

@Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
  String path = url.getPath();
  if (url.getQuery() != null && url.getQuery().length() > 0) {
    path = url.getPath() + "?" + url.getQuery();
  }
  HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, path);
  request.addHeader(Names.UPGRADE, Values.WEBSOCKET);
  request.addHeader(Names.CONNECTION, Values.UPGRADE);
  request.addHeader(Names.HOST, url.getHost());
  request.addHeader(Names.ORIGIN, "http://" + url.getHost());
  e.getChannel().write(request);
  ctx.getPipeline().replace("encoder", "ws-encoder", new WebSocketFrameEncoder());
  channel = e.getChannel();
}

代码示例来源:origin: projectodd/stilts

public HttpRequest generateRequest(URI uri) throws Exception {
  HttpRequest request = new DefaultHttpRequest( HttpVersion.HTTP_1_1, HttpMethod.GET, uri.toString() );
  request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" );
  request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" );
  request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() );
  request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" );
  request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_KEY1, this.challenge.getKey1String() );
  request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_KEY2, this.challenge.getKey2String() );
  ChannelBuffer buffer = ChannelBuffers.dynamicBuffer( 6 );
  buffer.writeBytes( challenge.getKey3() );
  buffer.writeByte( '\r' );
  buffer.writeByte( '\n' );
  request.setContent( buffer );
  
  return request;
}

代码示例来源:origin: org.hornetq/hornetq-core

if (cookie != null)
  httpRequest.addHeader(HttpHeaders.Names.COOKIE, cookie);
httpRequest.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buf.writerIndex()));
Channels.write(ctx, e.getFuture(), httpRequest, e.getRemoteAddress());
lastSendTime = System.currentTimeMillis();

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

if (cs > 0) //chunked encoding
 request.addHeader(HttpHeaders.Names.TRANSFER_ENCODING, HttpHeaders.Values.CHUNKED);

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

request.addHeader(HttpHeaders.Names.HOST, target.getAuthority());
request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
setAdditionalHeaders(request, additionalHeaders);
setActualChunkedLength(request, callProps);

代码示例来源:origin: com.n3twork.druid/http-client

httpRequest.addHeader(HttpHeaders.Names.HOST, getHost(url));
 httpRequest.addHeader(key, obj);

相关文章