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

HttpResponse.getHeader介绍

暂无

代码示例

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

@Override
public String getHeader(String name) {
  return response.getHeader(name);
}

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

@Override
public boolean isComplete(HttpResponse response) throws Exception {
  log.debugf( "COMPLETE? " + response );
  String challengeResponse = response.getHeader( "Sec-WebSocket-Accept" );
  return this.challenge.verify( challengeResponse );
}

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

@Override
public boolean isComplete(HttpResponse response) throws Exception {
  log.debugf( "COMPLETE? " + response );
  String challengeResponse = response.getHeader( "Sec-WebSocket-Accept" );
  return this.challenge.verify( challengeResponse );
}

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

@Override
public boolean isComplete(HttpResponse response) throws Exception {
  log.debugf( "COMPLETE? " + response );
  String challengeResponse = response.getHeader( "Sec-WebSocket-Accept" );
  return this.challenge.verify( challengeResponse );
}

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

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
  HttpResponse response = (HttpResponse) e.getMessage();
  String webSocketAccept = response.getHeader(Hybi.SEC_WEBSOCKET_ACCEPT);
  verifySecWebSocketAccept(webSocketAccept);
  adjustPipelineToWebSocket(ctx, e, HybiWebSocketFrameDecoder.clientSide(outboundMaskingKey), new HybiWebSocketFrameEncoder());
}

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

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
  if (!handshakeCompleted) {
    HttpResponse response = (HttpResponse)e.getMessage();
    final HttpResponseStatus status = new HttpResponseStatus(101, "Web Socket Protocol Handshake");
    final boolean validStatus = response.getStatus().equals(status);
    final boolean validUpgrade = response.getHeader(Names.UPGRADE).equals(Values.WEBSOCKET);
    final boolean validConnection = response.getHeader(Names.CONNECTION).equals(Values.UPGRADE);
    if (!validStatus || !validUpgrade || !validConnection) {
      throw new WebSocketException("Invalid handshake response");
    }
    
    handshakeCompleted = true;
    ctx.getPipeline().replace("decoder", "ws-decoder", new WebSocketFrameDecoder());
    callback.onConnect(this);
    return;
  }
  if (e.getMessage() instanceof HttpResponse) {
    HttpResponse response = (HttpResponse) e.getMessage();
    throw new WebSocketException("Unexpected HttpResponse (status=" + response.getStatus() + ", content=" + response.getContent().toString(CharsetUtil.UTF_8) + ")");
  }
  DefaultWebSocketFrame frame = (DefaultWebSocketFrame)e.getMessage();
  callback.onMessage(this, frame);
}

代码示例来源：origin: com.n3twork.druid/druid-server

url = response.getResponse().getHeader("Location");
log.info("Redirecting rule request to [%s]", url);
response = httpClient.get(new URL(url))

代码示例来源：origin: com.proofpoint.platform/http-client-experimental

String connectionHeader = response.getHeader(Names.CONNECTION);
if (connectionHeader != null && connectionHeader.equalsIgnoreCase(Values.CLOSE)) {
  nettyConnectionPool.destroyConnection(channel);

代码示例来源：origin: caskdata/coopr

logEntry.setResponseCode(response.getStatus().getCode());
if (response.containsHeader(HttpHeaders.Names.CONTENT_LENGTH)) {
 String lengthString = response.getHeader(HttpHeaders.Names.CONTENT_LENGTH);
 try {
  logEntry.setResponseContentLength(Long.valueOf(lengthString));

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

@Override
public void messageReceived(final ChannelHandlerContext ctx, final MessageEvent e) throws Exception
{
  HttpResponse response = (HttpResponse)e.getMessage();
  if (httpRequiresSessionId && !active)
  {
   Set<Cookie> cookieMap = cookieDecoder.decode(response.getHeader(HttpHeaders.Names.SET_COOKIE));
   for (Cookie cookie : cookieMap)
   {
     if (cookie.getName().equals("JSESSIONID"))
     {
      cookieEncoder.addCookie(cookie);
      this.cookie = cookieEncoder.encode();
     }
   }
   active = true;
   handShakeFuture.run();
  }
  MessageEvent event = new UpstreamMessageEvent(e.getChannel(), response.getContent(), e.getRemoteAddress());
  waitingGet = false;
  ctx.sendUpstream(event);
}