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

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

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

HttpRequest.setContent介绍

暂无

代码示例

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

request.setContent(ChannelBuffers.copiedBuffer(key3));

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

request.setContent(ChannelBuffers.EMPTY_BUFFER);
} else {
  request.setContent(chunk.getContent());

代码示例来源：origin: apache/incubator-druid

httpRequest.setContent(request.getContent());

代码示例来源：origin: org.graylog2/jersey-netty

public HttpRequest assemble(Channel channel) {
  List<HttpChunk> chunkList = chunkMap.remove(channel);
  HttpRequest request = initialRequests.remove(channel);
  ChannelBuffer dstBuffer = ChannelBuffers.dynamicBuffer();
  request.setContent(dstBuffer);
  try {
    for (HttpChunk chunk : chunkList) {
      dstBuffer.writeBytes(chunk.getContent());
    }
  } catch (Exception e) {
    LOG.warn("Error while assembling HTTP request chunks", e);
  }
  return request;
}

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

@Override
protected Object encode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {
  if ( msg instanceof StompFrame ) {
    ChannelBuffer buffer = StompFrameCodec.INSTANCE.encode( (StompFrame) msg );
    HttpRequest httpReq = new DefaultHttpRequest( HttpVersion.HTTP_1_1, HttpMethod.POST, this.uri );
    httpReq.setContent(  buffer );
    return httpReq;
  }
  return msg;
}

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

httpRequest = new DefaultHttpRequest(httpVersion, method, requestUri);
httpRequest.setContent(buffer);
nettyRequest = new NettyRequest(httpRequest, null);

代码示例来源：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: com.proofpoint.platform/http-client-experimental

nettyRequest.setContent(content);

代码示例来源：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.hornetq/hornetq-core

httpRequest.setContent(buf);
httpRequest.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buf.writerIndex()));
Channels.write(ctx, e.getFuture(), httpRequest, e.getRemoteAddress());

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

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

代码示例来源：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: com.facebook.nifty/nifty-client

@Override
protected ChannelFuture writeRequest(ChannelBuffer request)
{
  HttpRequest httpRequest = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST,
                           endpointUri);
  httpRequest.headers().add(HttpHeaders.HOST, hostName);
  httpRequest.headers().add(HttpHeaders.CONTENT_LENGTH, request.readableBytes());
  httpRequest.headers().add(HttpHeaders.CONTENT_TYPE, "application/x-thrift");
  httpRequest.headers().add(HttpHeaders.ACCEPT, "application/x-thrift");
  httpRequest.headers().add(HttpHeaders.USER_AGENT, "Java/Swift-HttpThriftClientChannel");
  if (headerDictionary != null) {
    for (Map.Entry<String, String> entry : headerDictionary.entrySet()) {
      httpRequest.headers().add(entry.getKey(), entry.getValue());
    }
  }
  httpRequest.setContent(request);
  return underlyingNettyChannel.write(httpRequest);
}

代码示例来源：origin: org.apache.camel/camel-netty-http

request.setContent(buffer);
int len = buffer.readableBytes();

代码示例来源：origin: k3po/k3po

httpRequest.setContent(httpContent);
  ChannelFuture future = transport.write(httpRequest);
  if (httpReadableBytes == getContentLength(httpRequest)) {
  chainWriteCompletes(future, httpFuture, httpReadableBytes);
} else if (httpRequest.headers().contains(Names.UPGRADE)) {
  httpRequest.setContent(httpContent);
  ChannelFuture future = transport.write(httpRequest);
  httpClientChannel.writeState(UPGRADEABLE);
} else if (httpClientConfig.getMaximumBufferedContentLength() >= httpReadableBytes) {
  httpRequest.setContent(httpContent);
  httpBufferedRequest = httpRequest;
  httpClientChannel.writeState(CONTENT_BUFFERED);
int httpBufferedBytes = httpBufferedContent.readableBytes();
if (httpClientConfig.getMaximumBufferedContentLength() >= httpBufferedBytes + httpReadableBytes) {
  httpBufferedRequest.setContent(copiedBuffer(httpBufferedContent, httpContent));
  httpFuture.setSuccess();
} else {

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

httpRequest = new DefaultHttpRequest(httpVersion, method, requestUri);
httpRequest.setContent(buffer);
nettyRequest = new NettyRequest(httpRequest, null);

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

httpRequest = new DefaultHttpRequest(httpVersion, method, requestUri);
httpRequest.setContent(buffer);
nettyRequest = new NettyRequest(httpRequest, null);

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

httpRequest = new DefaultHttpRequest(httpVersion, method, requestUri);
httpRequest.setContent(ChannelBuffers.wrappedBuffer(bytes));
nettyRequest = new NettyRequest(httpRequest, null);

内容来源于网络，如有侵权，请联系作者删除！

HttpRequest

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com