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