最近有點時間娱据，關注了下Vert.x,從測試數(shù)據(jù)來看，性能不錯浦箱，適合目前移動互聯(lián)網的高并發(fā)要求吸耿。
Vert.x 是什么
- Polyglot(多種語言支持) (Java, JavaScript, Groovy, and Ruby)
- Simplicity 編寫的代碼是完全基于異步事件的,異步執(zhí)行并且通信是無阻塞的
- Scalability(可擴展) 基于Actor模型
- Concurrency(并發(fā)性) Vert.x本身內置三種線程池幫你處理
- Modular(模塊化) Vert.x本身內置強大的模塊管理機制
- 分布式消息傳輸 Vert.x基于分布式Bus消息機制實現(xiàn)其Actor模型
- WebSocket 支持WebSocket協(xié)議兼容SockJS
基本概念
Verticle
Vert.xAPI的代碼就是一個Verticle.他可以用Scala Clojure JS Ruby等語言實現(xiàn). 多個Verticle實例可以并行的被執(zhí)行.一個基于Vert.x的服務也許需要多個verticles來實現(xiàn),而且要部署在多臺服務器上. 他們之間通過vert.x事件進行通信.你可以之間通過vert.x命令啟動,也可以將verticle包裝成vert.x modules.(推薦這么做)
Module
Vert.x應用由一個或多個modules來實現(xiàn).一個模塊呢由多個verticles來實現(xiàn).你可以把module想象出一個個Java package. 里面可能是特定業(yè)務的實現(xiàn),或者公共的服務實現(xiàn)(那些可以重用的服務).Vert.x編寫好的module,可以發(fā)布到maven的倉庫里. 以zip包裝成二進制格式.或者發(fā)布到vert.x module 注冊中心.實際上這種以模塊方式的開發(fā),支撐著整個Vert.x生態(tài)系統(tǒng). Module更多的信息,我需要單獨開一個系列來講解.
Vert.x 實例
Verticles 其實是跑在 Vert.x實例上的.所謂Vert.x實例其實就是一個運行在某一個JVM上的Vert.x對象實例. 可以將多個Verticles運行在一個Vert.x實例上,而vert.x實例可以跑在單個JVM上,也可以跑在其他JVM上,通過分布式event bus 來維持通信.注意vert.x實例其實是由vertx命令行啟動的.你可以指定實例數(shù)目在單個JVM上.
Event Loops
上面提到Vert.x實例,每個Vert.x實例內部維持幾個線程,線程數(shù)目基本與CPU核數(shù)一致.這些線程在Vert.x內部叫做事件循環(huán)(Event Loop) 這個思想在很多事件驅動的架構都有,典型的就是IOS事件,它操作系統(tǒng)內部也有一個事件監(jiān)控線程,不停捕捉外部的事件,比如touch,多點觸摸等. 然后分配到指定的處理函數(shù)上,在vert.x里這些處理函數(shù)是Handler接口. 在Vert.x里這些事件可以是從Socket里讀到數(shù)據(jù),或者是一個定時器觸發(fā),亦或是一個HTTP請求接受到. 一個部署好的verticle都會得到一個event loop,來處理相關的事件.相關的后續(xù)的處理都會在這個event loop解決掉(也就是一個線程里) ,注意在同一個時間里有且只有一個線程處理.即Handler接口里是線程同步的.這點非常類似 reactor pattern.
不要在Event Loops寫一些阻塞代碼,因此下面code不應該存在
阻塞處理
事件處理之外肯定會發(fā)生其長時間數(shù)據(jù)處理請求.比如處理一個圖片上傳,然后轉存到磁盤上等.或者一次長時間的排序計算等. 在Verticle類型里,有一種特別的verticle叫做Worker.不同于標準的verticle,他不使用event loop.而是采用vert.x內部的 另一個線程池叫做worker pool.
其區(qū)別在于,worker verticles不會并行的執(zhí)行Handler.而是阻塞式的,等待上一個Handler處理完了,才會再執(zhí)行后面的請求.你可以 想象出隊列的方式執(zhí)行某些請求.
所以為了支持標準的與阻塞式的worker verticles, Vert.x 提供了一種混合線程模型,你可以選擇適當?shù)哪Ｐ陀糜谀愕膽? worker verticle是一種阻塞式的方法,但是不可以做到并發(fā)水平擴展的
共享數(shù)據(jù)
消息通過Bus可以在各個Vert.x實例直接傳輸.但是如果多個Verticle在一個Vert.x實例內,是可以避免進行消息傳輸?shù)?比如單個JVM內,你不會 通過Socket互相在兩個Java 對象之間傳輸消息吧.但是因為實例隔離,因為Actor模型,所以對象數(shù)據(jù)如果要傳到Handler里,必須通過消息傳輸. Vert.x提供了一個簡單的共享Map與Set來解決這個問題.數(shù)據(jù)被存儲到一個不可變的數(shù)據(jù)結構了,各個實例直接通過此API獲取數(shù)據(jù).(看例子更容易)
Core API提供
- TCP/SSL servers and clients
- HTTP/HTTPS servers and clients
- WebSockets servers and clients
- The distributed event bus
- Periodic and one-off timers
- Buffers
- Flow control
- File-system access
- Shared map and sets
- Accessing configuration
- SockJS
安裝
verx.io下載3.0，解壓設置環(huán)境變量
vertx -version
Hello world
package vertx;
import io.vertx.core.AbstractVerticle;
public class Server extends AbstractVerticle{
public void start () throws Exception {
vertx.createHttpServer().requestHandler(req -> {
req.response()
.putHeader("content-type", "text/plain")
.end("Hello World.");
}).listen(8080);
}
}
vertx run Server.java
