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

HttpRequest.getHeaders介绍

暂无

代码示例

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

@Override
public List<String> headers(String name) {
  return httpRequest.getHeaders(name);
}

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

@Override
public List<Map.Entry<String, String>> allHeaders() {
  return httpRequest.getHeaders();
}

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

@Override
public List<Map.Entry<String, String>> getHeaders() {
  return request.getHeaders();
}

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

@Override
public List<String> headers(String name) {
  return httpRequest.getHeaders(name);
}

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

@Override
public List<Map.Entry<String, String>> allHeaders() {
  return httpRequest.getHeaders();
}

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

public Map<String, String> headers() {
 if (headers == null) {
  headers = HeaderUtils.simplifyHeaders(request.getHeaders());
 }
 return headers;
}

代码示例来源：origin: org.deephacks.westty/westty-jaxrs

public static MultivaluedMap<String, String> extractRequestHeaders(HttpRequest request)
  {
    Headers<String> requestHeaders = new Headers<String>();

    for (Map.Entry<String, String> header : request.getHeaders())
    {
      requestHeaders.add(header.getKey(), header.getValue());
    }
    return requestHeaders;
  }
}

代码示例来源：origin: fgp/AirReceiver

@Override
public void messageReceived(final ChannelHandlerContext ctx, final MessageEvent evt)
  throws Exception
{
  final HttpRequest req = (HttpRequest)evt.getMessage();
  final Level level = Level.FINE;
  if (s_logger.isLoggable(level)) {
    final String content = req.getContent().toString(Charset.defaultCharset());
    final StringBuilder s = new StringBuilder();
    s.append(">");
    s.append(req.getMethod());
    s.append(" ");
    s.append(req.getUri());
    s.append("\n");
    for(final Map.Entry<String, String> header: req.getHeaders()) {
      s.append("  ");
      s.append(header.getKey());
      s.append(": ");
      s.append(header.getValue());
      s.append("\n");
    }
    s.append(content);
    s_logger.log(Level.FINE, s.toString());
  }
  super.messageReceived(ctx, evt);
}

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

private InBoundHeaders getHeaders(HttpRequest request)
  {
    InBoundHeaders headers = new InBoundHeaders();

    for (String name : request.getHeaderNames())
    {
      headers.put(name, request.getHeaders(name));
    }

    return headers;
  }
}

代码示例来源：origin: org.springframework.xd/spring-xd-http

if (content.readable()) {
  Map<String, String> messageHeaders = new HashMap<String, String>();
  for (Entry<String, String> entry : request.getHeaders()) {
    if (entry.getKey().equalsIgnoreCase("Content-Type")) {
      charsetToUse = MediaType.parseMediaType(entry.getValue()).getCharSet();

代码示例来源：origin: org.openmobster.core/dataService

buf.append("METHOD: " + request.getMethod().getName() + "\r\n\r\n");
for (Map.Entry<String, String> h: request.getHeaders()) {
  buf.append("HEADER: " + h.getKey() + " = " + h.getValue() + "\r\n");

代码示例来源：origin: org.elasticsoftware.elasticactors/elasticactors-http

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
  org.jboss.netty.handler.codec.http.HttpRequest nettyRequest = (org.jboss.netty.handler.codec.http.HttpRequest) e.getMessage();
  // convert request to our internal request
  Map<String,List<String>> headers = new HashMap<String,List<String>>();
  for (String headerName : nettyRequest.getHeaderNames()) {
    headers.put(headerName,nettyRequest.getHeaders(headerName));
  }
  // see if we have a body
  byte[] content = null;
  if(nettyRequest.getContent().hasArray() && nettyRequest.getContent().array().length > 0) {
    content = nettyRequest.getContent().array();
  } else if(nettyRequest.getContent().readableBytes() > 0) {
    // netty content not backed by array, need to copy
    content = new byte[nettyRequest.getContent().readableBytes()];
    nettyRequest.getContent().readBytes(content);
  }
  HttpRequest request = new HttpRequest(nettyRequest.getMethod().getName(),new URI(nettyRequest.getUri()).getPath(),headers,content);
  // create a temp actor to handle the response
  ActorRef replyActor = actorSystem.tempActorOf(HttpServiceResponseHandler.class,
                         new HttpServiceResponseHandler.State(ctx.getChannel()));
  // put the actor in the attachment to propagate disconnects
  ctx.setAttachment(replyActor);
  // async handling
  if(!httpService.doDispatch(request,replyActor)) {
    // send 404
    ctx.getChannel().write(new DefaultHttpResponse(HttpVersion.HTTP_1_1,HttpResponseStatus.NOT_FOUND)).addListener(ChannelFutureListener.CLOSE);
    actorSystem.stop(replyActor);
  }
}