java 框架根据以下方式完成非阻塞式编程：servlet 容器应用 nio 技术处理要求，将要求放进队列中由工作线程池处理。异步servlet 容许servlet 以非阻塞方式处理要求，交由异步线程池。vert.x 应用事件总线系统，容许部件以非阻塞方法通信处理要求。 zvvq
zvvq
Java 架构如何做到非阻塞式编程
非阻塞式编程是一种编程范式，容许应用软件回应事情（比如网络请求或文档 I/O 操作）而不用等他们进行。可以将要求放进序列并由其他进程解决，Java 架构能够实现非阻塞式编程。这使得应用软件能够同时处理多个要求，从而提高并发性。
怎么使用Java 架构完成非阻塞式编程 copyright zvvq
Servlet 容器Servlet 容器，比如 Apache Tomcat 和 Jetty，应用 NIO（非阻塞式 I/O） 技术来解决传到要求。NIO 使 Servlet 容器可以监控多个套接字，并把传到要求放进队列中，便于由工作线程池解决。
// Servlet（应用 Servlet 3.1+API）
@WebServlet(urlPatterns = "/hello")
zvvq.cn
public class HelloServlet extends HttpServlet {
@Override 内容来自zvvq
protected void doGet(HttpServletRequest req, HttpServletResponse resp) {
zvvq
// 解决要求
本文来自zvvq
// ...
本文来自zvvq
} copyright zvvq
}
Java EE异步 ServletJava EE异步 Servlet 是 Servlet 3.1+的一个特点，它允许servlet 以非阻塞方式处理要求。根据启用 AsyncContext#start() 方式，servlet 能将要求委任给一个异步线程池。异步线程池将解决要求，而servlet 进程可以继续接纳别的要求。 内容来自samhan666
// 异步 Servlet（应用 Servlet 3.1+API） zvvq好，好zvvq
@WebServlet(urlPatterns = "/hello")
本文来自zvvq
public class HelloAsyncServlet extends HttpServlet { zvvq.cn
@Override
内容来自zvvq
protected void doGet(HttpServletRequest req, HttpServletResponse resp) { zvvq
AsyncContext asyncContext = req.startAsync(); 本文来自zvvq
// 异步处理要求，并在结束时启用 onComplete() 方式
asyncContext.addListener(new AsyncListener() { zvvq好，好zvvq
@Override 内容来自samhan666
public void onComplete(AsyncEvent event) {
内容来自zvvq，别采集哟
// 进行后处理
}
}); 内容来自zvvq
// 运行异步线程，解决要求
copyright zvvq
asyncContext.start(new Runnable() { zvvq好，好zvvq
@Override 内容来自zvvq，别采集哟
public void run() { 内容来自zvvq
// 解决要求 zvvq
// ... 内容来自samhan666
asyncContext.complete(); // 结束后通告servlet 进程
} 内容来自samhan666
}); zvvq好，好zvvq
} 内容来自zvvq
} copyright zvvq
Vert.xVert.x 是一个流行的异步编程架构。它使用事件总线去处理传到要求。事件总线是一个基于消息的系统，它允许部件（如 HTTP 服务器、数据库或文件系统）以非阻塞方法进行通信。
//Vert.x HTTP 要求解决
copyright zvvq
import io.vertx.core.Vertx; zvvq.cn
import io.vertx.core.http.HttpServer; zvvq.cn
public class VertxHttpServer { copyright zvvq
public static void main(String[] args) {
copyright zvvq
Vertx vertx = Vertx.vertx(); zvvq.cn
HttpServer server = vertx.createHttpServer();
内容来自samhan666
server.requestHandler(req -> { zvvq好，好zvvq
// 解决要求
本文来自zvvq
// ... 本文来自zvvq
}); 内容来自zvvq，别采集哟
server.listen(8080); copyright zvvq
} zvvq
}
实战案例应用 Servlet 容器来构建一个简单的 Web 服务器
内容来自samhan
importjavax.servlet.ServletException;
内容来自zvvq
importjavax.servlet.annotation.WebServlet; copyright zvvq
importjavax.servlet.http.HttpServlet; zvvq好，好zvvq
importjavax.servlet.http.HttpServletRequest; 内容来自samhan666
importjavax.servlet.http.HttpServletResponse; 内容来自zvvq
importjava.io.IOException; zvvq
@WebServlet(urlPatterns="/hello") zvvq好，好zvvq
publicclassHelloServletextendsHttpServlet{ copyright zvvq
@Override 内容来自zvvq
protectedvoiddoGet(HttpServletRequestreq,HttpServletResponseresp)throws ServletException,IOException{ 内容来自samhan666
resp.getWriter().write("HelloWorld!");
zvvq好，好zvvq
}
zvvq.cn
} 内容来自samhan
应用 Vert.x 来构建一个简单的闲聊服务器 copyright zvvq
import io.vertx.core.Vertx;
import io.vertx.core.VertxOptions; zvvq好，好zvvq
import io.vertx.core.http.HttpServer; zvvq
import io.vertx.core.http.HttpServerOptions;
zvvq.cn
import io.vertx.core.http.WebsocketServerOptions; copyright zvvq
public class VertxChatServer { zvvq好，好zvvq
public static void main(String[] args) {
copyright zvvq
// 开启 TCP_NODELAY 选项以提升网络性能
VertxOptions options = new VertxOptions().setTcpSendBufferSize(16384).setReceiveBufferSize(16384).setTcpNodelay(true); 本文来自zvvq
Vertx vertx = Vertx.vertx(options);
本文来自zvvq
// 配备 Websocket 服务器选项 zvvq好，好zvvq
WebsocketServerOptions websocketOptions = new WebsocketServerOptions().setIdleTimeout(0);
zvvq好，好zvvq
// 配备 HTTP 服务器选项 copyright zvvq
HttpServerOptions serverOptions = new HttpServerOptions().setUsePooledBuffers(true).setCompressionSupported(true).setCompressedMimeType("text/html;charset=utf-8"); copyright zvvq
// 建立 HTTP 服务器 内容来自samhan666
vertx.createHttpServer(serverOptions).websocketHandler(websocket -> { 内容来自samhan
// 解决 websocket 信息
内容来自samhan
}).listen(8080);
zvvq
} 内容来自zvvq，别采集哟
}
内容来自zvvq，别采集哟
以上就是Java架构如何做到非阻塞式编程？的详细内容，大量请关注其他类似文章！