org.glassfish.grizzly.http.server.Response.getNIOOutputStream()方法的使用及代码示例

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

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

Response.getNIOOutputStream介绍

[英]Return the NIOOutputStream associated with this Response. This NIOOutputStream will write content in a non-blocking manner.
[中]返回与此响应关联的NIOUTPUTSTREAM。这个NIOOutputStream将以非阻塞方式写入内容。

代码示例

代码示例来源: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: org.glassfish.grizzly/grizzly-websockets-server

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

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

private static void sendUsingBuffers(final Response response, final File file)
    throws FileNotFoundException, IOException {
  final int chunkSize = 8192;
  
  response.suspend();
  
  final NIOOutputStream outputStream = response.getNIOOutputStream();
  
  outputStream.notifyCanWrite(
      new NonBlockingDownloadHandler(response, outputStream,
          file, chunkSize));
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-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: javaee/grizzly

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: 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: javaee/grizzly

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: javaee/grizzly

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: org.mule.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: javaee/grizzly

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: javaee/grizzly

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: javaee/grizzly

private void doEvent(CometEvent event, CometHandler handler) throws IOException {
  if (event.getType() == CometEvent.Type.NOTIFY) {
    final NIOOutputStream outputStream = handler.getResponse().getNIOOutputStream();
    outputStream.write((Byte) event.attachment());
    outputStream.flush();
    if (!useStreaming) {
      cometContext.resumeCometHandler(handler);
    }
  }
}

相关文章

微信公众号

最新文章

更多

Response类方法