Springboot中的事件Event

太过爱你忘了你带给我的痛 2022-01-07 00:37 358阅读 0赞

事件Event作为一种常用的线程通讯工具，在Springboot中可以方便地提供开发者进行线程交互。

1.事件定义

![复制代码][copycode.gif]

1 import org.springframework.context.ApplicationEvent; 2 3 /** 4 * WebSocket触发事件定义 5 * @author : Asp1rant 6 * @date : 19-3-11 上午10:33 7 */ 8 9 public class WebsocketMessageEvent extends ApplicationEvent { 10 11 public String username; 12 public String message; 13 14 public WebsocketMessageEvent(Object source, String username, String message){ 15 super(source); 16 this.username = username; 17 this.message = message; 18 } 19 }

![复制代码][copycode.gif]

2.编写服务，编写时添加接口供外部调用发布

![复制代码][copycode.gif]

1 import com.baosight.tos.util.event.WebsocketMessageEvent; 2 import org.springframework.beans.factory.annotation.Autowired; 3 import org.springframework.context.ApplicationContext; 4 import org.springframework.stereotype.Service; 5 6 /** 7 * Websocket事件服务 8 * @author : Asp1rant 9 * @date : 19-3-11 上午10:36 10 */ 11 12 @Service 13 public class WebsocketMessageService { 14 15 @Autowired 16 ApplicationContext applicationContext; 17 18 public void pubWebsocketMessage(String username, String message){ 19 applicationContext.publishEvent(new WebsocketMessageEvent(this, username, message)); 20 } 21 22 }

![复制代码][copycode.gif]

3.事件监听，两种写法：

3.1 定义监听器

![复制代码][copycode.gif]

1 import org.springframework.context.ApplicationListener; 2 3 public class WebsocketEventListener implements ApplicationListener<WebsocketMessageEvent> { 4 5 @Override 6 public void onApplicationEvent(WebsocketMessageEvent websocketMessageEvent){ 7 System.out.println("监听到WebsocketMessageEvent事件"); 8 try { 9 Thread.sleep(2000); 10 } catch (InterruptedException e) { 11 e.printStackTrace(); 12 } 13 } 14 15 }

![复制代码][copycode.gif]

3.2 注解EventListener

1 @EventListener 2 public synchronized void WebsocketListener(WebsocketMessageEvent event){ 3 System.out.println("监听到WebsocketMessageEvent事件"); 4 } 5 }

转载于:https://www.cnblogs.com/Asp1rant/p/10673095.html

[copycode.gif]: /images/20211227/e232a0892c5441ac8870a3a77b2eff07.png