亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Google Guava EventBus

系統(tǒng) 2000 0

在Google Guava 10版本引入了EventBus, 它主要用來(lái)簡(jiǎn)化我們處理生產(chǎn)/消費(fèi)者編程模型.?

基本用法 ?
使用Guava之后, 如果要訂閱消息, 就不用再繼承指定的接口, 只需要在指定的方法上加上@Subscribe注解即可:?

Java代碼?? 收藏代碼
  1. public ? class ?EventListener?{??
  2. ???
  3. ???? public ? int ?lastMessage?=? 0 ;??
  4. ???
  5. ???? @Subscribe ??
  6. ???? public ? void ?listen(OurTestEvent?event)?{??
  7. ????????lastMessage?=?event.getMessage();??
  8. ????}??
  9. ???
  10. ???? public ? int ?getLastMessage()?{??
  11. ???????? return ?lastMessage;??
  12. ????}??
  13. }??



上面的lastMessage用來(lái)接收消息.?

下面定義的類(lèi)用來(lái)對(duì)消息進(jìn)行封裝:?

Java代碼?? 收藏代碼
  1. public ? class ?OurTestEvent?{??
  2. ???
  3. ???? private ? final ? int ?message;??
  4. ???
  5. ???? public ?OurTestEvent( int ?message)?{??
  6. ???????? this .message?=?message;??
  7. ????}??
  8. ???
  9. ???? public ? int ?getMessage()?{??
  10. ???????? return ?message;??
  11. ????}??
  12. }??



通過(guò)寫(xiě)一個(gè)測(cè)試來(lái)了解EventBus如何工作:?

Java代碼?? 收藏代碼
  1. @Test ??
  2. public ? void ?shouldReceiveEvent()? throws ?Exception?{??
  3. ???
  4. ???? //?given ??
  5. ????EventBus?eventBus?=? new ?EventBus( "test" );??
  6. ????EventListener?listener?=? new ?EventListener();??
  7. ???
  8. ????eventBus.register(listener);??
  9. ???
  10. ???? //?when ??
  11. ????eventBus.post( new ?OurTestEvent( 200 ));??
  12. ???
  13. ???? //?then ??
  14. ????assertThat(listener.getLastMessage()).isEqualTo( 200 );??
  15. }??



上面的測(cè)試是不是很簡(jiǎn)單??

MultiListener的使用 ?

只需要在要訂閱消息的方法上加上@Subscribe注解即可實(shí)現(xiàn)對(duì)多個(gè)消息的訂閱:?

Java代碼?? 收藏代碼
  1. public ? class ?MultipleListener?{??
  2. ???
  3. ???? public ?Integer?lastInteger;??
  4. ???? public ?Long?lastLong;??
  5. ???
  6. ???? @Subscribe ??
  7. ???? public ? void ?listenInteger(Integer?event)?{??
  8. ????????lastInteger?=?event;??
  9. ????}??
  10. ???
  11. ???? @Subscribe ??
  12. ???? public ? void ?listenLong(Long?event)?{??
  13. ????????lastLong?=?event;??
  14. ????}??
  15. ???
  16. ???? public ?Integer?getLastInteger()?{??
  17. ???????? return ?lastInteger;??
  18. ????}??
  19. ???
  20. ???? public ?Long?getLastLong()?{??
  21. ???????? return ?lastLong;??
  22. ????}??
  23. }??



下面是對(duì)應(yīng)的測(cè)試:?

Java代碼?? 收藏代碼
  1. @Test ??
  2. public ? void ?shouldReceiveMultipleEvents()? throws ?Exception?{??
  3. ???
  4. ???? //?given ??
  5. ????EventBus?eventBus?=? new ?EventBus( "test" );??
  6. ????MultipleListener?multiListener?=? new ?MultipleListener();??
  7. ???
  8. ????eventBus.register(multiListener);??
  9. ???
  10. ???? //?when ??
  11. ????eventBus.post( new ?Integer( 100 ));??
  12. ????eventBus.post( new ?Long( 800 ));??
  13. ???
  14. ???? //?then ??
  15. ????assertThat(multiListener.getLastInteger()).isEqualTo( 100 );??
  16. ????assertThat(multiListener.getLastLong()).isEqualTo(800L);??
  17. }??



高級(jí)用法 ?

1.Dead Event ?

如果EventBus發(fā)送的消息都不是訂閱者關(guān)心的稱(chēng)之為Dead Event. 看下面的例子:?

Java代碼?? 收藏代碼
  1. /** ?
  2. ?*?Listener?waiting?for?the?event?that?any?message?was?posted?but?not?delivered?to?anyone ?
  3. ?*/ ??
  4. public ? class ?DeadEventListener?{??
  5. ???
  6. ???? boolean ?notDelivered?=? false ;??
  7. ???
  8. ???? @Subscribe ??
  9. ???? public ? void ?listen(DeadEvent?event)?{??
  10. ????????notDelivered?=? true ;??
  11. ????}??
  12. ???
  13. ???? public ? boolean ?isNotDelivered()?{??
  14. ???????? return ?notDelivered;??
  15. ????}??
  16. }??



下面是測(cè)試類(lèi):?

Java代碼?? 收藏代碼
  1. @Test ??
  2. public ? void ?shouldDetectEventWithoutListeners()? throws ?Exception?{??
  3. ???
  4. ???? //?given ??
  5. ????EventBus?eventBus?=? new ?EventBus( "test" );??
  6. ???
  7. ????DeadEventListener?deadEventListener?=? new ?DeadEventListener();??
  8. ????eventBus.register(deadEventListener);??
  9. ???
  10. ???? //?when ??
  11. ????eventBus.post( new ?OurTestEvent( 200 ));??
  12. ???
  13. ????assertThat(deadEventListener.isNotDelivered()).isTrue();??
  14. }??



如果沒(méi)有消息訂閱者監(jiān)聽(tīng)消息, EventBus將發(fā)送DeadEvent消息, 這時(shí)我們可以通過(guò)log的方式來(lái)記錄這種狀態(tài).?

2.Event的繼承 ?

如果Listener A監(jiān)聽(tīng)Event A, 而Event A有一個(gè)子類(lèi)Event B, 此時(shí)Listener A將同時(shí)接收Event A和B消息?

看下面的例子:?

Java代碼?? 收藏代碼
  1. public ? class ?NumberListener?{??
  2. ???
  3. ???? private ?Number?lastMessage;??
  4. ???
  5. ???? @Subscribe ??
  6. ???? public ? void ?listen(Number?integer)?{??
  7. ????????lastMessage?=?integer;??
  8. ????}??
  9. ???
  10. ???? public ?Number?getLastMessage()?{??
  11. ???????? return ?lastMessage;??
  12. ????}??
  13. }??
  14. ??
  15. ??????
  16. public ? class ?IntegerListener?{??
  17. ???
  18. ???? private ?Integer?lastMessage;??
  19. ???
  20. ???? @Subscribe ??
  21. ???? public ? void ?listen(Integer?integer)?{??
  22. ????????lastMessage?=?integer;??
  23. ????}??
  24. ???
  25. ???? public ?Integer?getLastMessage()?{??
  26. ???????? return ?lastMessage;??
  27. ????}??
  28. }??



對(duì)應(yīng)的測(cè)試類(lèi):?


Java代碼?? 收藏代碼
  1. @Test ??
  2. public ? void ?shouldGetEventsFromSubclass()? throws ?Exception?{??
  3. ???
  4. ???? //?given ??
  5. ????EventBus?eventBus?=? new ?EventBus( "test" );??
  6. ????IntegerListener?integerListener?=? new ?IntegerListener();??
  7. ????NumberListener?numberListener?=? new ?NumberListener();??
  8. ????eventBus.register(integerListener);??
  9. ????eventBus.register(numberListener);??
  10. ???
  11. ???? //?when ??
  12. ????eventBus.post( new ?Integer( 100 ));??
  13. ???
  14. ???? //?then ??
  15. ????assertThat(integerListener.getLastMessage()).isEqualTo( 100 );??
  16. ????assertThat(numberListener.getLastMessage()).isEqualTo( 100 );??
  17. ???
  18. ???? //when ??
  19. ????eventBus.post( new ?Long(200L));??
  20. ???
  21. ???? //?then ??
  22. ???? //?this?one?should?has?the?old?value?as?it?listens?only?for?Integers ??
  23. ????assertThat(integerListener.getLastMessage()).isEqualTo( 100 );??
  24. ????assertThat(numberListener.getLastMessage()).isEqualTo(200L);??
  25. }??

?

Google Guava EventBus


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索：z360901061

微信掃一掃加我為好友

QQ號(hào)聯(lián)系： 360901061

您的支持是博主寫(xiě)作最大的動(dòng)力，如果您喜歡我的文章，感覺(jué)我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。

【本文對(duì)您有幫助就好】元

您的支持是博主寫(xiě)作最大的動(dòng)力，如果您喜歡我的文章，感覺(jué)我的文章對(duì)您有幫助，請(qǐng)用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧，站長(zhǎng)會(huì)非常 感謝您的哦！！！

發(fā)表我的評(píng)論
最新評(píng)論 總共0條評(píng)論
主站蜘蛛池模板： 欧美人与zoxxxx另类9 | 国产精品久久久久激情影院 | 久久99视频免费 | 青青操在线观看 | 操你妹影院 | 九九热热| 香蕉尹人综合精品 | 亚洲欧美日韩国产精品第不页 | 亚洲性另类 | 99r8这里精品热视频免费看 | 成人日批视频 | 精品亚洲一区二区三区在线播放 | 国产自愉怕一区二区三区 | 亚洲精品久久久久综合91 | 9久9久热精品视频在线观看 | 久久一区二区精品综合 | 波多野结衣一区二区在线 | 日本中文字幕在线播放 | 日韩毛片在线看 | 一级性毛片 | 亚洲美色综合天天久久综合精品 | 国产成人一级片 | 欧美日韩大片 | 国产福利福利视频 | 婷婷久久五月天 | 欧美亚洲另类色国产综合 | 免费看国产精品麻豆 | 精品日韩一区二区三区 | 日本中文不卡 | 毛茸茸性毛茸茸大b | a级黄片毛片 | 视频一区国产 | 国产免费爱在线观看视频 | 成人欧美一区二区三区视频xxx | 亚洲精品人成网线在线 | 福利在线免费视频 | 亚洲欧美香蕉在线日韩精选 | 久久在线资源 | 国产91av视频 | 777色狠狠一区二区三区香蕉 | 久久国产精品永久免费网站 |