io.netty.handler.codec.http.HttpResponse.setHeader()方法的使用及代码示例

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

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

HttpResponse.setHeader介绍

暂无

代码示例

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

/**
 * Sets the Date header for the HTTP response
 * 
 * @param response
 *            HTTP response
 */
private void setDateHeader(HttpResponse response) {
  SimpleDateFormat dateFormatter = new SimpleDateFormat(HTTP_DATE_FORMAT, Locale.US);
  dateFormatter.setTimeZone(TimeZone.getTimeZone(HTTP_DATE_GMT_TIMEZONE));
  Calendar time = new GregorianCalendar();
  response.setHeader(HttpHeaders.Names.DATE, dateFormatter.format(time.getTime()));
}

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

/**
 * Sets the Date and Cache headers for the HTTP Response
 * 
 * @param response
 *            HTTP response
 * @param fileToCache
 *            file to extract content type
 */
private void setDateAndCacheHeaders(HttpResponse response, File fileToCache) {
  SimpleDateFormat dateFormatter = new SimpleDateFormat(HTTP_DATE_FORMAT, Locale.US);
  dateFormatter.setTimeZone(TimeZone.getTimeZone(HTTP_DATE_GMT_TIMEZONE));
  // Date header
  Calendar time = new GregorianCalendar();
  response.setHeader(HttpHeaders.Names.DATE, dateFormatter.format(time.getTime()));
  // Add cache headers
  time.add(Calendar.SECOND, HTTP_CACHE_SECONDS);
  response.setHeader(HttpHeaders.Names.EXPIRES, dateFormatter.format(time.getTime()));
  response.setHeader(HttpHeaders.Names.CACHE_CONTROL, "private, max-age=" + HTTP_CACHE_SECONDS);
  response.setHeader(HttpHeaders.Names.LAST_MODIFIED, dateFormatter.format(new Date(fileToCache.lastModified())));
}

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

/**
 * Sets the content type header for the HTTP Response
 * 
 * @param response
 *            HTTP response
 * @param file
 *            file to extract content type
 */
private void setContentTypeHeader(HttpResponse response, File file) {
  MimetypesFileTypeMap mimeTypesMap = new MimetypesFileTypeMap();
  response.setHeader(HttpHeaders.Names.CONTENT_TYPE, mimeTypesMap.getContentType(file.getPath()));
}

代码示例来源:origin: shuaiweili/Dubbo-Zookeeper-Netty-SpringMVC

private static void sendError(ChannelHandlerContext ctx, HttpResponseStatus status) {
  HttpResponse response = new DefaultHttpResponse(HTTP_1_1, status);
  response.setHeader(CONTENT_TYPE, "text/plain; charset=UTF-8");
  response.setContent(Unpooled.copiedBuffer(
      "Failure: " + status.toString() + "\r\n",
      CharsetUtil.UTF_8));
  // Close the connection as soon as the error message is sent.
  ctx.write(response).addListener(ChannelFutureListener.CLOSE);
}

代码示例来源:origin: linsongze/nettyholdspringmvc

private static void sendError(ChannelHandlerContext ctx, HttpResponseStatus status) {
  HttpResponse response = new DefaultHttpResponse(HTTP_1_1, status);
  response.setHeader(CONTENT_TYPE, "text/plain; charset=UTF-8");
  response.setContent(Unpooled.copiedBuffer(
      "Failure: " + status.toString() + "\r\n",
      CharsetUtil.UTF_8));
  // Close the connection as soon as the error message is sent.
  ctx.write(response).addListener(ChannelFutureListener.CLOSE);
}

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

HttpResponseStatus.OK);
response.setContent(buf);
response.setHeader(HttpHeaders.Names.CONTENT_TYPE,
    "text/html; charset=UTF-8");
response.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buf
    .readableBytes()));

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

private void sendError(ChannelHandlerContext ctx, HttpResponseStatus status) {
  HttpResponse response = new DefaultHttpResponse(HTTP_1_1, status);
  response.setHeader(CONTENT_TYPE, "text/plain; charset=UTF-8");
  response.setContent(ChannelBuffers.copiedBuffer(
      "Failure: " + status.toString() + "\r\n",
      CharsetUtil.UTF_8));
  // Close the connection as soon as the error message is sent.
  ctx.getChannel().write(response).addListener(ChannelFutureListener.CLOSE);
}

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

HttpResponseStatus.OK);
response.setContent(buf);
response.setHeader(HttpHeaders.Names.CONTENT_TYPE,
    "text/plain; charset=UTF-8");
  response.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String
      .valueOf(buf.readableBytes()));

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

response.setHeader(CONTENT_TYPE, "text/plain; charset=UTF-8");
  response.setHeader(CONTENT_LENGTH, response.getContent().readableBytes());

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

private void handleHttpRequest(ChannelHandlerContext ctx, HttpRequest req) throws Exception {
  // Allow only GET methods.
  if (req.getMethod() != GET) {
    sendHttpResponse(ctx, req, new DefaultHttpResponse(HTTP_1_1, FORBIDDEN));
    return;
  }
  // Send the demo page and favicon.ico
  if (req.getUri().equals("/")) {
    HttpResponse res = new DefaultHttpResponse(HTTP_1_1, OK);
    ChannelBuffer content = WebSocketServerIndexPage.getContent(getWebSocketLocation(req));
    res.setHeader(CONTENT_TYPE, "text/html; charset=UTF-8");
    setContentLength(res, content.readableBytes());
    res.setContent(content);
    sendHttpResponse(ctx, req, res);
    return;
  } else if (req.getUri().equals("/favicon.ico")) {
    HttpResponse res = new DefaultHttpResponse(HTTP_1_1, NOT_FOUND);
    sendHttpResponse(ctx, req, res);
    return;
  }
  // Handshake
  WebSocketServerHandshakerFactory wsFactory = new WebSocketServerHandshakerFactory(
      this.getWebSocketLocation(req), null, false);
  this.handshaker = wsFactory.newHandshaker(req);
  if (this.handshaker == null) {
    wsFactory.sendUnsupportedWebSocketVersionResponse(ctx.getChannel());
  } else {
    this.handshaker.handshake(ctx.getChannel(), req);
  }
}

代码示例来源:origin: org.jboss.errai.io.netty/netty-example

private void handleHttpRequest(ChannelHandlerContext ctx, HttpRequest req) throws Exception {
  // Allow only GET methods.
  if (req.getMethod() != GET) {
    sendHttpResponse(ctx, req, new DefaultHttpResponse(HTTP_1_1, FORBIDDEN));
    return;
  }
  // Send the demo page and favicon.ico
  if (req.getUri().equals("/")) {
    HttpResponse res = new DefaultHttpResponse(HTTP_1_1, OK);
    ChannelBuffer content = WebSocketSslServerIndexPage.getContent(getWebSocketLocation(req));
    res.setHeader(CONTENT_TYPE, "text/html; charset=UTF-8");
    setContentLength(res, content.readableBytes());
    res.setContent(content);
    sendHttpResponse(ctx, req, res);
    return;
  } else if (req.getUri().equals("/favicon.ico")) {
    HttpResponse res = new DefaultHttpResponse(HTTP_1_1, NOT_FOUND);
    sendHttpResponse(ctx, req, res);
    return;
  }
  // Handshake
  WebSocketServerHandshakerFactory wsFactory = new WebSocketServerHandshakerFactory(
      this.getWebSocketLocation(req), null, false);
  this.handshaker = wsFactory.newHandshaker(req);
  if (this.handshaker == null) {
    wsFactory.sendUnsupportedWebSocketVersionResponse(ctx.getChannel());
  } else {
    this.handshaker.handshake(ctx.getChannel(), req);
  }
}

相关文章