本文整理了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
暂无
代码示例来源: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);
内容来源于网络,如有侵权,请联系作者删除!