org.glassfish.grizzly.http.server.Response类的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(10.6k)|赞(0)|评价(0)|浏览(113)

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

Response介绍

[英]Wrapper object for the Coyote response.
[中]Coyote响应的包装器对象。

代码示例

代码示例来源：origin: opentripplanner/OpenTripPlanner

response.setContentType("application/json");
  response.setStatus(HttpStatus.BAD_REQUEST_400);
  response.setDetailMessage("path should have at least one part");
    mapper.readTree(request.getInputStream());
    response.setStatus(HttpStatus.OK_200);
      response.setStatus(HttpStatus.NOT_FOUND_404);
      response.setDetailMessage("no job IDs were found");
      response.setStatus(HttpStatus.OK_200);
      OutputStream os = response.getOutputStream();
      mapper.writeValue(os, ret);
      os.close();
      request.getRequest().getConnection()
          .addCloseListener((closeable, iCloseType) -> {
            broker.removeSuspendedResponse(graphAffinity, response);
          });
      response.suspend(); // The request should survive after the handler function exits.
      broker.registerSuspendedResponse(graphAffinity, response);
        request.getRequest().getConnection()
            .addCloseListener((closeable, iCloseType) -> {
              broker.deletePriorityTask(task.taskId);
            });
        response.suspend(); // The request should survive after the handler function exits.
        return;

代码示例来源：origin: uber/AthenaX

@Override
 public void service(Request rqst, Response rspns) throws Exception {
  rspns.setStatus(HttpStatus.NOT_FOUND_404.getStatusCode(), "Not found");
  rspns.getWriter().write("404: not found");
 }
});

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

@Override
public OutputStream writeResponseStatusAndHeaders(final long contentLength,
                         final ContainerResponse context)
    throws ContainerException {
  try {
    final javax.ws.rs.core.Response.StatusType statusInfo = context.getStatusInfo();
    if (statusInfo.getReasonPhrase() == null) {
      grizzlyResponse.setStatus(statusInfo.getStatusCode());
    } else {
      grizzlyResponse.setStatus(statusInfo.getStatusCode(), statusInfo.getReasonPhrase());
    }
    grizzlyResponse.setContentLengthLong(contentLength);
    for (final Map.Entry<String, List<String>> e : context.getStringHeaders().entrySet()) {
      for (final String value : e.getValue()) {
        grizzlyResponse.addHeader(e.getKey(), value);
      }
    }
    return grizzlyResponse.getOutputStream();
  } finally {
    logger.debugLog("{0} - writeResponseStatusAndHeaders() called", name);
  }
}

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

@Override
public void commit() {
  try {
    if (grizzlyResponse.isSuspended()) {
      grizzlyResponse.resume();
    }
  } finally {
    logger.debugLog("{0} - commit() called", name);
  }
}

代码示例来源：origin: opentripplanner/OpenTripPlanner

@Override
public void service(Request req, Response resp) throws Exception {
  try {
    OTPRequest oreq = new OTPRequest(req, graph);
    Object result = handlers.get(oreq.action).handle(oreq);
    ObjectMapper mapper;
    if (oreq.sfmt == SerializeFormat.XML) {
      resp.setContentType("application/xml");
      mapper = xmlMapper;
    } else {
      resp.setContentType("application/json");
      mapper = jsonMapper;
    }
    resp.setStatus(200);
    mapper.writeValue(resp.getNIOOutputStream(), result);            
  } catch (Exception ex) {
    resp.setStatus(500);
    resp.setContentType("text/plain");
    resp.getNIOWriter().write("Error: " + ex.toString());
  }
}

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

@Override
public void service(Request request, Response response) throws Exception {
  String uri = request.getRequestURI();
    response.sendError(HttpStatus.NOT_FOUND_404.getStatusCode());
    return;
  final String resourcesContextPath = request.getContextPath();
  System.out.println("context: " + resourcesContextPath);
  if (resourcesContextPath != null && !resourcesContextPath.isEmpty()) {
    if (!uri.startsWith(resourcesContextPath)) {
      response.sendError(HttpStatus.NOT_FOUND_404.getStatusCode());
      return;
    response.sendError(HttpStatus.NOT_FOUND_404.getStatusCode());
  } else {
    response.setStatus(HttpStatus.OK_200);
    response.setContentType(mediaType);
    ReaderWriter.writeTo(fileStream, response.getOutputStream());

代码示例来源：origin: javaee/grizzly

request.setRequestExecutorProvider(getRequestExecutorProvider());
request.setSessionCookieName(getSessionCookieName());
request.setSessionManager(getSessionManager(request));
response.setErrorPageGenerator(getErrorPageGenerator(request));
if (request.requiresAcknowledgement()) {
  final HttpRequestPacket httpRequestPacket = request.getRequest();
  final RequestURIRef requestURIRef = httpRequestPacket.getRequestURIRef();
  requestURIRef.setDefaultURIEncoding(requestURIEncoding);
      requestURIRef.getDecodedRequestURIBC(allowEncodedSlash);
    } catch (CharConversionException e) {
      response.setStatus(HttpStatus.INTERNAL_SERVER_ERROR_500);
      response.setDetailMessage("Invalid URI: " + e.getMessage());
      return true;
  response.getResponse().setAllowCustomReasonPhrase(
      allowCustomStatusMessage);
      LogMessages.WARNING_GRIZZLY_HTTP_SERVER_HTTPHANDLER_SERVICE_ERROR(), t);
  HtmlHelper.setErrorAndSendErrorPage(request, response,
      response.getErrorPageGenerator(),
      500, HttpStatus.INTERNAL_SERVER_ERROR_500.getReasonPhrase(),
      HttpStatus.INTERNAL_SERVER_ERROR_500.getReasonPhrase(), t);

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-server-core

throws IOException {
final HttpContext context = request.getRequest()
    .getProcessingState().getHttpContext();
response.finish();
request.onAfterService();
final HttpRequestPacket httpRequest = request.getRequest();
final boolean isBroken = httpRequest.isContentBroken();
  response.recycle();
  request.recycle();
  final NextAction suspendNextAction = ctx.getSuspendAction();
  ctx.completeAndRecycle();
  return suspendNextAction;
return ctx.getStopAction();

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-server

checkResponse();
if (isCommitted())
  throw new IllegalStateException("Illegal attempt to call sendError() after the response has been committed.");
setError();
response.getHeaders().removeHeader(Header.TransferEncoding);
response.setContentLanguage(null);
response.setContentLengthLong(-1L);
response.setChunked(false);
response.setCharacterEncoding(null);
usingOutputStream = false;
setStatus(status, message);
HtmlHelper.sendErrorPage(request, this, getErrorPageGenerator(),
    status, nonNullMsg, nonNullMsg, null);
finish();

代码示例来源：origin: javaee/grizzly

public static void writeTraceMessage(final Request request,
    final Response response) throws IOException {
  response.setStatus(HttpStatus.OK_200);
  response.setContentType("message/http");
  final Writer writer = response.getWriter();
  writer.append(request.getMethod().toString()).append(' ')
      .append(request.getRequest().getRequestURIRef().getOriginalRequestURIBC().toString())
      .append(' ').append(request.getProtocol().getProtocolString())
      .append("\r\n");
  for (String headerName : request.getHeaderNames()) {
    for (String headerValue : request.getHeaders(headerName)) {
      writer.append(headerName).append(": ").append(headerValue).append("\r\n");
    }
  }
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-server

private static void sendResource(final Response response,
    final InputStream input) throws IOException {
  response.setStatus(HttpStatus.OK_200);
  response.addDateHeader(Header.Date, System.currentTimeMillis());
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          input, chunkSize));
}

代码示例来源：origin: eclipse-ee4j/tyrus

@Override
  public void service(Request request, Response response) throws Exception {
    if (request.getMethod().equals(Method.GET) && request.getRequestURI().endsWith("application.wsadl")) {
      getWsadlJaxbContext().createMarshaller().marshal(engine.getWsadlApplication(), response.getWriter());
      response.setStatus(200);
      response.setContentType(ContentType.newContentType("application/wsadl+xml"));
      return;
    }
    if (staticHttpHandler != null) {
      staticHttpHandler.service(request, response);
    } else {
      response.sendError(404);
    }
  }
}

代码示例来源：origin: opentripplanner/OpenTripPlanner

if (!response.getRequest().getRequest().getConnection().isOpen()) {
  LOG.debug("Consumer connection was closed. It will be removed.");
  return false;
  response.setStatus(HttpStatus.OK_200);
  OutputStream out = response.getOutputStream();
  mapper.writeValue(out, tasks);
  response.resume();
} catch (IOException e) {
  response.setStatus(HttpStatus.INTERNAL_SERVER_ERROR_500);
  response.resume();

代码示例来源：origin: org.glassfish.grizzly/grizzly-websockets-server

protected static void pickupContentType(final Response response,
    final String path) {
  if (!response.getResponse().isContentTypeSet()) {
    int dot = path.lastIndexOf('.');
    if (dot > 0) {
      String ext = path.substring(dot + 1);
      String ct = MimeType.get(ext);
      if (ct != null) {
        response.setContentType(ct);
      }
    } else {
      response.setContentType(MimeType.get("html"));
    }
  }
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-server

protected void onTraceRequest(final Request request,
    final Response response) throws IOException {
  if (config.isTraceEnabled()) {
    HtmlHelper.writeTraceMessage(request, response);
  } else {
    response.setStatus(HttpStatus.METHOD_NOT_ALLOWED_405);
    response.setHeader(Header.Allow, "POST, GET, DELETE, OPTIONS, PUT, HEAD");
  }
}

代码示例来源：origin: javaee/grizzly

@Override
public void service(final Request request, final Response response)
    throws Exception {
  response.setContentType("text/plain");
  
  response.getWriter().write("Works fine. Server certificate (DN): " +
      getServerCertificate(request).getIssuerDN().getName());
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-server

if (isCommitted())
  return;
MimeHeaders headers = response.getHeaders();
int n = headers.size();
for (int i = 0; i < n; i++) {
  if (headers.getName(i).toString().equals(headername)) {
    if (headers.getValue(i).toString().startsWith(startsWith)) {
      headers.getValue(i).setString(cookieString);
      set = true;
  addHeader(headername, cookieString);

代码示例来源：origin: javaee/grizzly

@Override
public void fail() throws IOException {
  if (isAcknowledged) {
    throw new IllegalStateException("Already acknowledged");
  }
  isAcknowledged = true;
  isFailAcknowledgement = true;
  
  response.setStatus(HttpStatus.EXPECTATION_FAILED_417);
  response.finish();
}

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

@Override
@SuppressWarnings("MagicNumber")
public void failure(final Throwable error) {
  try {
    if (!grizzlyResponse.isCommitted()) {
      try {
        if (configSetStatusOverSendError) {
          grizzlyResponse.reset();
          grizzlyResponse.setStatus(500, "Request failed.");
        } else {
          grizzlyResponse.sendError(500, "Request failed.");
        }
      } catch (final IllegalStateException ex) {
        // a race condition externally committing the response can still occur...
        logger.log(Level.FINER, "Unable to reset failed response.", ex);
      } catch (final IOException ex) {
        throw new ContainerException(
            LocalizationMessages.EXCEPTION_SENDING_ERROR_RESPONSE(500, "Request failed."),
            ex);
      }
    }
  } finally {
    logger.debugLog("{0} - failure(...) called", name);
    rethrow(error);
  }
}

代码示例来源：origin: opentripplanner/OpenTripPlanner

wr.response.setContentType("application/json");
OutputStream os = wr.response.getOutputStream();
mapper.writeValue(os, tasks);
os.close();
wr.response.resume();

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

response

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    Response类方法

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