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

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

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

HttpResponse.setContent介绍

暂无

代码示例

代码示例来源: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

response.setContent(buf);
response.setHeader(HttpHeaders.Names.CONTENT_TYPE,
    "text/html; charset=UTF-8");

代码示例来源: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

response.setContent(buf);
response.setHeader(HttpHeaders.Names.CONTENT_TYPE,
    "text/plain; charset=UTF-8");

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

private void sendHttpResponse(ChannelHandlerContext ctx, HttpRequest req, HttpResponse res) {
  // Generate an error page if response status code is not OK (200).
  if (res.getStatus().getCode() != 200) {
    res.setContent(ChannelBuffers.copiedBuffer(res.getStatus().toString(), CharsetUtil.UTF_8));
    setContentLength(res, res.getContent().readableBytes());
  }
  // Send the response and close the connection if necessary.
  ChannelFuture f = ctx.getChannel().write(res);
  if (!isKeepAlive(req) || res.getStatus().getCode() != 200) {
    f.addListener(ChannelFutureListener.CLOSE);
  }
}

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

private void sendHttpResponse(ChannelHandlerContext ctx, HttpRequest req, HttpResponse res) {
  // Generate an error page if response status code is not OK (200).
  if (res.getStatus().getCode() != 200) {
    res.setContent(ChannelBuffers.copiedBuffer(res.getStatus().toString(), CharsetUtil.UTF_8));
    setContentLength(res, res.getContent().readableBytes());
  }
  // Send the response and close the connection if necessary.
  ChannelFuture f = ctx.getChannel().write(res);
  if (!isKeepAlive(req) || res.getStatus().getCode() != 200) {
    f.addListener(ChannelFutureListener.CLOSE);
  }
}

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

private void sendHttpResponse(ChannelHandlerContext ctx, HttpRequest req, HttpResponse res) {
  // Generate an error page if response status code is not OK (200).
  if (res.getStatus().getCode() != 200) {
    res.setContent(ChannelBuffers.copiedBuffer(res.getStatus().toString(), CharsetUtil.UTF_8));
    setContentLength(res, res.getContent().readableBytes());
  }
  // Send the response and close the connection if necessary.
  ChannelFuture f = ctx.getChannel().write(res);
  if (!isKeepAlive(req) || res.getStatus().getCode() != 200) {
    f.addListener(ChannelFutureListener.CLOSE);
  }
}

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

response.setContent(ChannelBuffers.copiedBuffer(buf.toString(), CharsetUtil.UTF_8));
response.setHeader(CONTENT_TYPE, "text/plain; charset=UTF-8");

代码示例来源: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);
  }
}

代码示例来源: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);
  }
}

相关文章