CDI 事件機制是整個精髓所在的榛,有點類似于觀察者模式
。
定義一個Room
類型 的一個添加房間的事件類型哥谷,名字并不重要棺榔,重要的是類型
@Inject
@Add
Event<Room> roomAddEvent;
頁面上點擊按鈕觸發(fā)事件瓶堕,事件生產(chǎn)者通過調(diào)用fire()方法,并傳遞"事件對象"從而激活事件處理. 。
/**
* 入住房間
*
* @return 這里利用JSF的特性:返回空字符串或者null表示刷新當前頁面
*/
public String checkIn(Room room) {
roomAddEvent.fire(room);
return null;
}
這個時候@Observers
修飾的訂閱者就可以接收事件症歇,并執(zhí)行任務(wù)郎笆,并通過@Add這個qualifter來區(qū)別唯一事件類型。
public void onAddRoom(@Observes @Add Room room){
log.info("add room:{}.",room);
room.setStatus(RoomStatus.AVAILABLE);
rooms.add(room);
}
動態(tài)注入事件
這樣如果有多個事件就不需要為每個事件都定義一個Qualifter了忘晤。
roomAddEvent.select(new AnnotationLiteral<Add>(){}).fire(Room);
定義一個有條件的觀察者
默認情況下,在當前上下文如果沒有一個觀察者的實例,容器將為事件實例化觀察者.但我們希望傳遞給觀察者的實例是已經(jīng)存在于上下文中的觀察者.指定一個有條件的觀察者的方式是在@Observes注釋上添加receive = IF_EXISTS
public void refreshOnDocumentUpdate(@Observes(receive = IF_EXISTS) @Updated Document d) { ... }
為Qualifter設(shè)置成員變量
可以通過@Qualifter的value值傳遞信息給observer.
@Qualifier
@Target({METHOD, FIELD, PARAMETER, TYPE})
@Retention(RUNTIME)
public @interface Role {
RoleType value();
}
訂閱事件時候調(diào)用
public void adminLoggedIn(@Observes @Role(ADMIN) LoggedIn event) { ... }
多重qualifiers
@Inject @Blog Event<Document> blogEvent;
...
if (document.isBlog()) blogEvent.select(newAnnotationLiteral<Updated>(){}).fire(
下面的觀察者都可以得到通知
public void afterBlogUpdate(@Observes @Updated @Blog Document document) { ... }
public void afterDocumentUpdate(@Observes @Updated Document document) { ... }
public void onAnyBlogEvent(@Observes @Blog Document document) { ... }
public void onAnyDocumentEvent(@Observes Document document) { ... }}}
但是下面這個方法不會得到通知宛蚓,因為@Personal沒有包含在事件發(fā)生處
public void afterPersonalBlogUpdate(@Observes @Updated @Personal @Blog Document document) { ... }
事物處理的Event
1. IN_PROGRESS --- observers被立即通知 (default)
2. AFTER_SUCCESS --- 在事務(wù)成功完成后,observers會被通知.
3. AFTER_FAILURE --- 在事務(wù)完成失敗后,observers會被通知.
4. AFTER_COMPLETION --- observers在交易完成后的階段被調(diào)用
5. BEFORE_COMPLETION --- observers在交易完成前階段被調(diào)用
比如下面這個只有事物成功后才會被通知。
public void refreshCategoryTree(@Observes(during = AFTER_SUCCESS) CategoryUpdateEvent event) { ... }
參考:
https://my.oschina.net/zhaoqian/blog/265207
示例代碼:
https://github.com/liuqinyi/weld-tutorial
https://github.com/liuqinyi/quickstart.git