• 

• 山東小木

• 2021-10-06 21:16

需求：后端有通知和待辦，及時(shí)推送給前端相關(guān)用戶，在頁面顯示提示信息。

用到技術(shù)：

1、websocket 后端推送最終使用的是websocket 前端用戶登錄后與后端服務(wù)器建立websocket鏈接

2、JFinal-event 異步執(zhí)行消息推送 與主業(yè)務(wù)解耦 不能在新增一條todo待辦或者notice通知后立馬同步執(zhí)行websocket的推送，如果系統(tǒng)里有1000個(gè)客戶端，你得等都推送完了才能結(jié)束這個(gè)業(yè)務(wù)的響應(yīng) 顯然不合理。需要在todo和notice save之后 向事件處理隊(duì)列或者pool里推送一個(gè)事件就立馬結(jié)束這個(gè)業(yè)務(wù)，等待事件監(jiān)聽器起作用后異步處理。

save成功立馬post一個(gè)事件。

監(jiān)聽器監(jiān)聽這個(gè)事件

監(jiān)聽到事件后異步執(zhí)行websocket推送就行了

上效果：

如何在項(xiàng)目里引入JFinal-event：

1、pom.xml 

版本3.1.3

2、配置插件

3、創(chuàng)建EventListener 寫注解

package cn.jbolt._admin.event; import com.jfinal.log.Log; import cn.jbolt.common.model.SysNotice;import cn.jbolt.common.model.Todo;import net.dreamlu.event.core.EventListener;/** * JBolt 內(nèi)部事件監(jiān)聽處理 * @ClassName:  JBoltEventListener    * @author: JFinal學(xué)院-小木 QQ：909854136  * @date:   2021年10月6日    */public class JBoltEventListener {	private static final Log LOG = Log.getLog(JBoltEventListener.class);	/**	 * 全局通知事件監(jiān)聽處理	 * @param notice	 */	@EventListener(async = true)	public void sysNotice(SysNotice notice) {			}		/**	 * todo事件監(jiān)聽處理	 * @param todo	 */	@EventListener(async = true)	public void todo(Todo todo) {			}}

4、找到合適的地方執(zhí)行

EventKit.post(event)就行了