com.sun.grizzly.tcp.http11.GrizzlyResponse类的使用及代码示例

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

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

GrizzlyResponse介绍

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

代码示例

代码示例来源:origin: com.sun.grizzly/grizzly-http-utils

throws IOException {
if (isCommitted())
  throw new IllegalStateException
    (sm.getString("response.sendRedirect.ise"));
resetBuffer();
  absolute = toAbsolute(location);
  setStatus(302);
  setHeader("Location", absolute);
} catch (IllegalArgumentException e) {
  setStatus(404);
setSuspended(true);

代码示例来源:origin: org.glassfish.external/grizzly-module

/**
 * Add the specified integer header to the specified value.
 *
 * @param name Name of the header to set
 * @param value Integer value to be set
 */
public void addIntHeader(String name, int value) {
  if (isCommitted())
    return;
  // Ignore any call from an included servlet
  if (included)
    return;
  addHeader(name, "" + value);
}

代码示例来源:origin: com.sun.grizzly/grizzly-utils

@Override
public boolean timeout(){
  // If the buffers are empty, commit the response header
  try{                             
    cancel();
  } finally {
    if (!grizzlyResponse.isCommitted()){
      try{
        grizzlyResponse.finishResponse();
      } catch (IOException ex){
        // Swallow?
      }
    }
  }
  return true;
}

代码示例来源:origin: com.sun.grizzly/grizzly-http-utils

/**
 * Reset this response, and specify the values for the HTTP status code
 * and corresponding message.
 *
 * @exception IllegalStateException if this response has already been
 *  committed
 */
public void reset(int status, String message) {
  reset();
  setStatus(status, message);
}

代码示例来源:origin: org.glassfish.external/grizzly-module

/**
 * Application commit flag accessor.
 */
public boolean isAppCommitted() {
  return (this.appCommitted || isCommitted() || isSuspended()
      || ((getContentLength() > 0) 
        && (getContentCount() >= getContentLength())));
}

代码示例来源:origin: com.sun.grizzly/grizzly-utils

/**
 * Application commit flag accessor.
 */
public boolean isAppCommitted() {
  return (this.appCommitted || isCommitted() || isBufferSuspended()
      || ((getContentLength() > 0) 
        && (getContentCount() >= getContentLength())));
}

代码示例来源:origin: com.sun.grizzly/grizzly-utils

if (isCommitted())
  throw new IllegalStateException
    (sm.getString("response.sendRedirect.ise"));
resetBuffer();
  String absolute = toAbsolute(location, true);
  setStatus(302);
  setHeader("Location", absolute);
  setContentType("text/html");
  setLocale(Locale.getDefault());
  String filteredMsg = filter(absolute);
  StringBuilder sb = new StringBuilder(150 + absolute.length());
    getWriter().write(sb.toString());
    getWriter().flush();
  } catch (IllegalStateException ise1) {
    try {
      getOutputStream().print(sb.toString());
    } catch (IllegalStateException ise2) {
  setStatus(404);
setSuspended(true);

代码示例来源:origin: com.sun.jersey/jersey-bundle

public OutputStream writeStatusAndHeaders(long contentLength, 
    ContainerResponse cResponse) throws IOException {
  final javax.ws.rs.core.Response.StatusType statusInfo = cResponse.getStatusType();
  if (statusInfo.getReasonPhrase() == null) {
    response.setStatus(statusInfo.getStatusCode());
  } else {
    response.setStatus(statusInfo.getStatusCode(), statusInfo.getReasonPhrase());
  }
  if (contentLength != -1 && contentLength < Integer.MAX_VALUE) 
    response.setContentLength((int)contentLength);
  for (Map.Entry<String, List<Object>> e : cResponse.getHttpHeaders().entrySet()) {
    for (Object value : e.getValue()) {
      response.addHeader(e.getKey(), ContainerResponse.getHeaderValue(value));
    }
  }
  String contentType = response.getHeader("Content-Type");
  if (contentType != null) {
    response.setContentType(contentType);
  }
    
  return response.getOutputStream();
}

代码示例来源:origin: com.sun.grizzly/grizzly-http-utils

/**
 * Send an error response with the specified status and message.
 *
 * @param status HTTP status code to send
 * @param message Corresponding message to send
 *
 * @exception IllegalStateException if this response has
 *  already been committed
 * @exception IOException if an input/output error occurs
 */
public void sendError(int status, String message) throws IOException {
  checkResponse();
  if (isCommitted())
    throw new IllegalStateException
      (sm.getString("response.sendError.ise"));
  // Ignore any call from an included servlet
  if (included)
    return; 
  setError();
  response.setStatus(status);
  response.setMessage(message);
  // Clear any data content that has been buffered
  resetBuffer();
  // Cause the response to be finished (from the application perspective)
  setSuspended(true);
}

代码示例来源:origin: com.sun.grizzly/grizzly-websockets

final WSGrizzlyRequestImpl grizzlyRequest = new WSGrizzlyRequestImpl(1024);
grizzlyRequest.setRequest(request);
final GrizzlyResponse grizzlyResponse = new GrizzlyResponse(false, false, 1024);
grizzlyResponse.setResponse(response);
grizzlyRequest.setResponse(grizzlyResponse);
grizzlyResponse.setRequest(grizzlyRequest);
try {

代码示例来源:origin: com.sun.grizzly/grizzly-utils

final GrizzlyAdapter adapter = entry.getKey();
adapter.service(request, response);
if (response.getStatus() == 404 && i != size - 1) {
  response.setStatus(200, "OK");
} else {
  req.setNote(INVOKED_ADAPTER, adapter);
  adapter.service(request.getRequest(), response.getResponse());
  req.setNote(INVOKED_ADAPTER, adapter);
} else {
  response.getResponse().setStatus(404);
  customizedErrorPage(req, response.getResponse());
  response.setStatus(404);
  if (logger.isLoggable(Level.FINE)) {
    logger.log(Level.FINE, "Invalid URL: " + req.decodedURI(), t);
  customizedErrorPage(req, response.getResponse());
} catch (Exception ex2) {
  if (logger.isLoggable(Level.WARNING)) {

代码示例来源:origin: com.sun.grizzly/grizzly-utils

/**
 * Set the HTTP status to be returned with this response.
 *
 * @param status The new HTTP status
 */
public void setStatus(int status) {
  setStatus(status, null);
}

代码示例来源:origin: jcabi/jcabi-http

response.addHeader(name, value);
response.addHeader(
  HttpHeaders.SERVER,
  String.format(
response.setStatus(answer.status());
final byte[] body = answer.bodyBytes();
response.getStream().write(body);
response.setContentLength(body.length);
if (cond.decrement() == 0) {
  iter.remove();

代码示例来源:origin: com.sun.grizzly/grizzly-http-servlet

/**
 * Customize the error page returned to the client.
 * @param response  the {@link GrizzlyResponse}
 * @param message   the Http error message
 * @param errorCode the error code.
 */
public void customizeErrorPage(GrizzlyResponse response,String message, int errorCode){                    
  response.setStatus(errorCode, message);
  response.setContentType("text/html");
  try{
    response.getWriter().write("<html><body><h1>" + message
        + "</h1></body></html>");
    response.getWriter().flush();
  } catch (IOException ex){
    // We are in a very bad shape. Ignore.
  }
}

代码示例来源:origin: org.glassfish.external/grizzly-module

@Override
  public void service(GrizzlyRequest request, GrizzlyResponse response) {
    try {
      response.setStatus(404);
      response.flushBuffer();
    } catch (IOException ex) {
      Logger.getLogger(GrizzlyWebServer.class.getName()).log(
          Level.SEVERE, null, ex);
    }
  }
});

代码示例来源:origin: org.glassfish.external/grizzly-module

/**
 {@link GrizzlyAdapter} are called one by one, and the invokation stops when
 * set the {@link GrizzlyResponse#getStatus} return the Http code <tt>200</tt>, 
 * which will stop the chain invokation. 
 * @param request The {@link GrizzlyRequest}
 * @param response The {@link GrizzlyResponse}
 */
@Override
public void service(GrizzlyRequest request, GrizzlyResponse response) {    
  int size =  adapters.size();
  for (int i=0; i < size; i++){          
    adapters.get(i).service(request, response);
    if (response.getStatus() == 404 && i != size -1){
      response.setStatus(200, "OK");
    } else {
      return;
    }
  }  
}

代码示例来源:origin: com.sun.grizzly/grizzly-http-utils

setCharacterEncoding(getCharacterEncoding());

代码示例来源:origin: org.jvnet.jax-ws-commons/jaxws-grizzly-httpspi

@Override
public void addResponseHeader(String name, String value) {
  response.addHeader(name, value);
}

代码示例来源:origin: com.sun.grizzly/grizzly-http-utils

response.finishResponse();
response.recycle();

代码示例来源:origin: jcabi/jcabi-http

/**
 * Notify this response about failure.
 * @param response The response to notify
 * @param failure The failure just happened
 */
private static void fail(final GrizzlyResponse<?> response,
  final Throwable failure) {
  response.setStatus(HttpURLConnection.HTTP_INTERNAL_ERROR);
  final PrintWriter writer;
  try {
    writer = new PrintWriter(
      new OutputStreamWriter(
        response.getStream(),
        MkGrizzlyAdapter.ENCODING
      )
    );
  } catch (final UnsupportedEncodingException ex) {
    throw new IllegalStateException(ex);
  }
  try {
    writer.print(Logger.format("%[exception]s", failure));
  } finally {
    writer.close();
  }
}

相关文章

微信公众号

最新文章

更多