大噶好我又來了喊熟，沒了解過Vert.x的同學(xué)可以先看一下上一篇文章愿待。
OK, 這次我們來看點(diǎn)新東西硝皂。這次我們要做的場景是：發(fā)起一個(gè)POST請求新建一個(gè)User教馆，這個(gè)請求提交了一個(gè)Json文件到我們的Server，然后Server接受到這個(gè)Json之后序列化成了我們定義的Bean扒腕。在驗(yàn)證完Json的合法性之后通過集成的RedisClient存入redis。有一些概念我們需要先了解一下：EventBus萤悴、Verticle瘾腰。
首先是EventBus，"eventBus是vertx的神經(jīng)系統(tǒng)" by 官方文檔覆履。eventBus允許我們程序中不同模塊互相之間交換數(shù)據(jù)蹋盆，而這些模塊可以不使用同一種編程語言編寫。簡單的說就像是一個(gè)回轉(zhuǎn)壽司店硝全，不同的模塊就是不同桌的客人栖雾，但是這些客人都可以在中間環(huán)形的傳送帶上取到自己想食的壽司(壽司師傅也會(huì)把捏好的壽司放在傳送帶上給客人)，聰明的你肯定已經(jīng)發(fā)現(xiàn)了這個(gè)壽司就是不同模塊之間交換的數(shù)據(jù)伟众，可以是各種類型析藕。但是在vertx中，兩個(gè)模塊之間如果想要交換數(shù)據(jù)必須指定一個(gè)address凳厢，就好比你要去xxx壽司店才能吃到xx師傅捏的xx壽司账胧。
接下來是Verticle，Verticle基本可以看作是Akka中的actor-model先紫，但是嚴(yán)格上講也不是完全相同的實(shí)現(xiàn)方式治泥。在vertx中使用verticle可以大幅度的降低并發(fā)編程的難度，每一個(gè)verticle都是獨(dú)立的線程遮精，互相之間不共享數(shù)據(jù)與耦合居夹，我們的一個(gè)程序中可以有任意多個(gè)verticle實(shí)例，每個(gè)實(shí)例可以負(fù)責(zé)不同的業(yè)務(wù)邏輯本冲。既然verticle都是獨(dú)立線程准脂，那么它們之間是怎么交換數(shù)據(jù)呢？(你真是太聰明了)當(dāng)然是使用eventBus啦檬洞，比如我們有V1和V2兩個(gè)verticle意狠，它們兩個(gè)共同指定了"interesting"這個(gè)address，那么V1向這個(gè)地址發(fā)送數(shù)據(jù)疮胖，V2此時(shí)就可以獲取到這個(gè)數(shù)據(jù)再進(jìn)行后續(xù)的處理环戈。而這個(gè)流程和消息訂閱/發(fā)布系統(tǒng)是極為相似的闷板，大家可以類比的理解一下。
那么我們開始院塞，首先是定義Bean遮晚，PojoBase集成了序列化接口所以我們需要UID(IDE幫我們生成了)：
在編寫Verticle之前先來看一下架構(gòu)：
從PersistenceVerticle開始看。每個(gè)verticle都繼承了AbstractVerticle拦止，為了部署每一個(gè)實(shí)例都需要重寫父類的start方法县遣，這里的PersistenceVerticle只是單純的啟動(dòng)了RedisClientVerticle做了一層解耦：
接下來看RedisClientVerticle：
這一篇我們只用redis最最簡單的set和get，所以只需要傳一個(gè)host地址進(jìn)去作為參數(shù)汹族，通過vertx實(shí)例我們啟動(dòng)好了redis客戶端然后打一個(gè)log美滋滋萧求。還記得eventBus的address嗎，之后這個(gè)MessageConsumer就是用來處理adress顶瞒，我們注冊newUser和getUser作為eventBus的地址便于接受其他verticle發(fā)來的數(shù)據(jù)夸政，這個(gè)數(shù)據(jù)的類型就是泛型的類型啦。
因?yàn)関ertx基于netty榴徐，所以我們都是用異步的方式來處理所有的邏輯守问，實(shí)現(xiàn)倆handler來完成get和set：
把user類中的id作為redis里的key值，這里拼接了一個(gè)"Vertx_X"作為key坑资，value是user的toString的結(jié)果耗帕。到這里redis的部分基本就完成了，get和set都會(huì)返回一個(gè)異步的結(jié)果袱贮，我們通過這個(gè)結(jié)果來判斷是否set/get成功仿便。關(guān)于bean的序列化我們在后面講。
首先我們部署web服務(wù)器的verticle：
接下來是重寫start方法啟動(dòng)httpserver：
這個(gè)地方是并發(fā)的寫法攒巍，當(dāng)httpserver啟動(dòng)后調(diào)用future的complete方法完成最終的啟動(dòng)探越，在startRouter里面設(shè)置了幾個(gè)路由：
這個(gè)地方聲明了一個(gè)Router對象，BodyHandler是為了用來接受和傳遞json數(shù)據(jù)窑业，consumes和produces設(shè)置了數(shù)據(jù)傳遞的格式钦幔，接下來我們處理GET和POST請求：
這個(gè)地方我另寫了一個(gè)webhandler類來處理請求，這個(gè)createUser方法首先接受routingContext作為參數(shù)常柄，這個(gè)參數(shù)就像是Servlet里面的HttpServletRequest/Response保存了請求和返回的各類信息鲤氢，第二個(gè)參數(shù)是Handler<AsyncResult<JsonObect>>類型的，因?yàn)槲覀兪褂玫氖钱惒降膶懛ㄎ髋耍祷亓艘粋€(gè)異步的結(jié)果卷玉，實(shí)現(xiàn)如下：
在Vertx中提供了Json.decode和encode兩個(gè)方法序列化json數(shù)據(jù)，第二個(gè)參數(shù)是要序列化轉(zhuǎn)化的Bean類喷市，這個(gè)地方就是轉(zhuǎn)化成User相种，之后序列化成功后我們把結(jié)果封裝進(jìn)異步結(jié)果在返回給路由，如果捕獲到了異常就封裝一個(gè)異常返回品姓，當(dāng)路由得到了成功序列化的user后就發(fā)送給事先設(shè)置好的address：
另一端RedisClientVerticle會(huì)訂閱這個(gè)"newUser"的address寝并，當(dāng)有數(shù)據(jù)發(fā)來的時(shí)候就對這個(gè)message進(jìn)行處理箫措，set進(jìn)redis。
那么getUser同理衬潦，首先是路由：
這里用了router的路徑參數(shù):id這個(gè)寫法斤蔓，接下來是handler：
我們把得到的id作為key封裝進(jìn)異步結(jié)果然后傳給路由，路由接受到成功結(jié)果后發(fā)給redis：
RedisClientVerticle取到數(shù)據(jù)后會(huì)進(jìn)入redis查詢镀岛，然后reply方法返回查詢到的數(shù)據(jù)：
到這里主要的邏輯我們就寫完了弦牡，那么怎么把這兩部分統(tǒng)一到一起啟動(dòng)呢？你寫一個(gè)main同時(shí)啟動(dòng)兩個(gè)verticle啊漂羊，是的驾锰，我們寫一個(gè)main：
然后stream操作不懂的趕緊卸載你的jdk6，上次我就說了走越。
我們把main跑起來試試效果：
然后結(jié)果是：
然后我們再get id 2：
完全沒有問題椭豫，至此就結(jié)束啦！
最近還看了Netty买喧，然后工作的原因一直在搞Spring這一塊的東西捻悯。對比起來看reactive和servlet那一套各有各的好吧匆赃，不過我自己還是挺喜歡reactive這套方法的2333淤毛。
