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