日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

java异步servlet_Servlet 3.0 异步处理详解

發布時間:2025/3/13 编程问答 26 豆豆
生活随笔 收集整理的這篇文章主要介紹了 java异步servlet_Servlet 3.0 异步处理详解 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

相關系列文章:

Servlet 3.0 開始提供了AsyncContext用來支持異步處理請求,那么異步處理請求到底能夠帶來哪些好處?

Web容器一般來說處理請求的方式是:為每個request分配一個thread。我們都知道thread的創建不是沒有代價的,Web容器的thread pool都是有上限的。

那么一個很容易預見的問題就是,在高負載情況下,thread pool都被占著了,那么后續的request就只能等待,如果運氣不好客戶端會報等待超時的錯誤。

在AsyncContext出現之前,解決這個問題的唯一辦法就是擴充Web容器的thread pool。

但是這樣依然有一個問題,考慮以下場景:

有一個web容器,線程池大小200。有一個web app,它有兩個servlet,Servlet-A處理單個請求的時間是10s,Servlet-B處理單個請求的時間是1s。

現在遇到了高負載,有超過200個request到Servlet-A,如果這個時候請求Servlet-B就會等待,因為所有HTTP thread都已經被Servlet-A占用了。

這個時候工程師發現了問題,擴展了線程池大小到400,但是負載依然持續走高,現在有400個request到Servlet-A,Servlet-B依然無法響應。

看到問題了沒有,因為HTTP thread和Worker thread耦合在了一起(就是同一個thread),所以導致了當大量request到一個耗時操作時,就會將HTTP thread占滿,導致整個Web容器就會無法響應。

但是如果使用AsyncContext,我們就可以將耗時的操作交給另一個thread去做,這樣HTTP thread就被釋放出來了,可以去處理其他請求了。

注意,只有使用AsyncContext才能夠達到上面所講的效果,如果直接new Thread()或者類似的方式的,HTTP thread并不會歸還到容器。

下面是一個官方的例子:

@WebServlet(urlPatterns={"/asyncservlet"}, asyncSupported=true)

public class AsyncServlet extends HttpServlet {

/* ... Same variables and init method as in SyncServlet ... */

@Override

public void doGet(HttpServletRequest request,

HttpServletResponse response) {

response.setContentType("text/html;charset=UTF-8");

final AsyncContext acontext = request.startAsync();

acontext.start(new Runnable() {

public void run() {

String param = acontext.getRequest().getParameter("param");

String result = resource.process(param);

HttpServletResponse response = acontext.getResponse();

/* ... print to the response ... */

acontext.complete();

}

});

}

}

陷阱

在這個官方例子里,每個HTTP thread都會開啟另一個Worker thread來處理請求,然后把HTTP thread就歸還給Web容器。但是看AsyncContext.start()方法的javadoc:

Causes the container to dispatch a thread, possibly from a managed thread pool, to run the specified Runnable.

實際上這里并沒有規定Worker thread到底從哪里來,也許是HTTP thread pool之外的另一個thread pool?還是說就是HTTP thread pool?

The Limited Usefulness of AsyncContext.start()文章里寫道:不同的Web容器對此有不同的實現,不過Tomcat實際上是利用HTTP thread pool來處理AsyncContext.start()的。

這也就是說,我們原本是想釋放HTTP thread的,但實際上并沒有,因為有HTTP thread依然被用作Worker thread,只不過這個thread和接收請求的HTTP thread不是同一個而已。

這個結論我們也可以通過AsyncServlet1和SyncServlet的Jmeter benchmark看出來,兩者的throughput結果差不多。啟動方法:啟動Main,然后利用Jmeter啟動benchmark.jmx(Tomcat默認配置下HTTP thread pool=200)。

使用ExecutorService

前面看到了Tomcat并沒有單獨維護Worker thread pool,那么我們就得自己想辦法搞一個,見AsyncServlet2,它使用了一個帶Thread pool的ExecutorService來處理AsyncContext。

其他方式

所以對于AsyncContext的使用并沒有固定的方式,你可以根據實際需要去采用不同的方式來處理,為此你需要一點Java concurrent programming的知識。

對于性能的誤解

AsyncContext的目的并不是為了提高性能,也并不直接提供性能提升,它提供了把HTTP thread和Worker thread解藕的機制,從而提高Web容器的響應能力。

不過AsyncContext在某些時候的確能夠提高性能,但這個取決于你的代碼是怎么寫的。

比如:Web容器的HTTP thread pool數量200,某個Servlet使用一個300的Worker thread pool來處理AsyncContext。

相比Sync方式Worker thread pool=HTTP thread pool=200,在這種情況下我們有了300的Worker thread pool,所以肯定能夠帶來一些性能上的提升(畢竟干活的人多了)。

相反,如果當Worker thread的數量<=HTTP thread數量的時候,那么就不會得到性能提升,因為此時處理請求的瓶頸在Worker thread。

你可以修改AsyncServlet2的線程池大小,把它和SyncServlet比較benchmark結果來驗證這一結論。

一定不要認為Worker thread pool必須比HTTP thread pool大,理由如下:

兩者職責不同,一個是Web容器用來接收外來請求,一個是處理業務邏輯

thread的創建是有代價的,如果HTTP thread pool已經很大了再搞一個更大的Worker thread pool反而會造成過多的Context switch和內存開銷

AsyncContext的目的是將HTTP thread釋放出來,避免被操作長期占用進而導致Web容器無法響應

所以在更多時候,Worker thread pool不會很大,而且會根據不同業務構建不同的Worker thread pool。

比如:Web容器thread pool大小200,一個慢速Servlet的Worker thread pool大小10,這樣一來,無論有多少請求到慢速操作,它都不會將HTTP thread占滿導致其他請求無法處理。

相關資料

總結

以上是生活随笔為你收集整理的java异步servlet_Servlet 3.0 异步处理详解的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。