org.apache.catalina.connector.Response.getOutputStream()方法的使用及代码示例

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

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

Response.getOutputStream介绍

[英]Return the servlet output stream associated with this Response.
[中]返回与此响应关联的servlet输出流。

代码示例

代码示例来源：origin: org.jboss.web/jbossweb

public AbstractServletOutputStream getOutputStream() throws IOException {
  return (AbstractServletOutputStream) response.getOutputStream();
}

代码示例来源：origin: org.glassfish.main.web/web-core

@Override
public ServletOutputStream getOutputStream() throws IOException {
  // Disallow operation if the object has gone out of scope
  if (response == null) {
    throw new IllegalStateException(rb.getString(LogFacade.NULL_RESPONSE_OBJECT));
  }
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished())
    response.setSuspended(true);
  return (sos);
}

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished()) {
    response.setSuspended(true);
  }
  return sos;
}

代码示例来源：origin: jboss.web/jbossweb

public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished())
    response.setSuspended(true);
  return (sos);
}

代码示例来源：origin: tomcat/catalina

public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished())
    response.setSuspended(true);
  return (sos);
}

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished())
    response.setSuspended(true);
  return (sos);
}

代码示例来源：origin: org.apache.catalina/com.springsource.org.apache.catalina

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished()) {
    response.setSuspended(true);
  }
  return (sos);
}

代码示例来源：origin: com.ovea.tajin.server/tajin-server-tomcat7

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished())
    response.setSuspended(true);
  return (sos);
}

代码示例来源：origin: codefollower/Tomcat-Research

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished()) {
    response.setSuspended(true);
  }
  return (sos);
}

代码示例来源：origin: org.jboss.web/jbossweb

public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished())
    response.setSuspended(true);
  return (sos);
}

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished()) {
    response.setSuspended(true);
  }
  return sos;
}

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished())
    response.setSuspended(true);
  return (sos);
}

代码示例来源：origin: org.apache.geronimo.ext.tomcat/catalina

@Override
public ServletOutputStream getOutputStream()
  throws IOException {
  //        if (isFinished())
  //            throw new IllegalStateException
  //                (/*sm.getString("responseFacade.finished")*/);
  ServletOutputStream sos = response.getOutputStream();
  if (isFinished()) {
    response.setSuspended(true);
  }
  return (sos);
}

代码示例来源：origin: com.tomitribe.tribestream/tribestream-container

@Override
public State onBodyPartReceived(final HttpResponseBodyPart bodyPart) throws Exception {
  if (nonNull(bodyPart) && nonNull(bodyPart.getBodyByteBuffer())) {
    bytesSent += bodyPart.getBodyPartBytes().length;
    isLast = bodyPart.isLast();
    context.getResponse().getOutputStream().write(bodyPart.getBodyPartBytes());
  }
  return State.CONTINUE;
}

代码示例来源：origin: com.tomitribe.tribestream/tribestream-container

private boolean handleResponse(final Response proxyResponse) throws IOException {
  final Integer statusCode = (proxyResponse != null) ? proxyResponse.getStatusCode() : null;
  if (responseHandled(statusCode)) return true;
  // Send the content to the client
  final byte[] entity = proxyResponse.getResponseBodyAsBytes();
  setXProxyElapsed();
  context.getEventHandler().info("proxy", "Copying proxy response finished");
  final BufferedInputStream bufferedInputStream = new BufferedInputStream(new ByteArrayInputStream(entity));
  final OutputStream outputStreamClientResponse = context.getResponse().getOutputStream();
  long size = 0;
  int intNextByte;
  while ((intNextByte = bufferedInputStream.read()) != -1) {
    outputStreamClientResponse.write(intNextByte);
    size++;
  }
  flushResponseBytes(size);
  return true;
}

代码示例来源：origin: org.jboss.resteasy/skeleton-key-as7

protected void tokenGrant(Request request, Response response) throws IOException
{
 if (!request.isSecure())
 {
   response.sendError(400);
   return;
 }
 GenericPrincipal gp = basicAuth(request, response);
 if (gp == null) return;
 SkeletonKeyToken token = buildToken(gp);
 AccessTokenResponse res = accessTokenResponse(realmPrivateKey, token);
 response.setStatus(200);
 response.setContentType("application/json");
 accessTokenResponseWriter.writeValue(response.getOutputStream(), res);
 response.getOutputStream().flush();
}

代码示例来源：origin: org.glassfish.main.web/web-core

} catch (IllegalStateException ise1) {
  try {
    getOutputStream().print(sb.toString());
  } catch (IllegalStateException ise2) {

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

private boolean sendErrorPage(String location, Response response) {
  File file = new File(location);
  if (!file.isAbsolute()) {
    file = new File(getContainer().getCatalinaBase(), location);
  }
  if (!file.isFile() || !file.canRead()) {
    getContainer().getLogger().warn(
        sm.getString("errorReportValve.errorPageNotFound", location));
    return false;
  }
  // Hard coded for now. Consider making this optional. At Valve level or
  // page level?
  response.setContentType("text/html");
  response.setCharacterEncoding("UTF-8");
  try (OutputStream os = response.getOutputStream();
      InputStream is = new FileInputStream(file);){
    IOTools.flow(is, os);
  } catch (IOException e) {
    getContainer().getLogger().warn(
        sm.getString("errorReportValve.errorPageIOException", location), e);
    return false;
  }
  return true;
}

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

private boolean sendErrorPage(String location, Response response) {
  File file = new File(location);
  if (!file.isAbsolute()) {
    file = new File(getContainer().getCatalinaBase(), location);
  }
  if (!file.isFile() || !file.canRead()) {
    getContainer().getLogger().warn(
        sm.getString("errorReportValve.errorPageNotFound", location));
    return false;
  }
  // Hard coded for now. Consider making this optional. At Valve level or
  // page level?
  response.setContentType("text/html");
  response.setCharacterEncoding("UTF-8");
  try (OutputStream os = response.getOutputStream();
      InputStream is = new FileInputStream(file);){
    IOTools.flow(is, os);
  } catch (IOException e) {
    getContainer().getLogger().warn(
        sm.getString("errorReportValve.errorPageIOException", location), e);
    return false;
  }
  return true;
}

代码示例来源：origin: org.glassfish.main.web/web-core

new WebConnectionImpl(
        req.getInputStream(),
        ((org.apache.catalina.connector.Response)req.getResponse()).getOutputStream());
wc.setRequest(req);
req.setWebConnection(wc);

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

response

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Response类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com