Python 官方文档:入门教程 => 点击学习
目录SpringBoot开启一个监听线程执行任务springboot中监听事件的创建流程事件的大体步骤第一种第二种第三种总结springboot开启一个监听线程执行任务 public
public class StartApplicationListener implements ApplicationListener<ContextRefreshedEvent> {
@Override
public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
ApplicationContext applicationContext = contextRefreshedEvent.getApplicationContext();
ApplicationContext parent = applicationContext.getParent();
if (parent == null) {
CacheManager cacheManager = applicationContext.getBean(CacheManager.class);
Cache cache = cacheManager.getCache(MsConstants.node_CACHE_NAME);
new Thread(new Runnable() {
@Override
public void run() {
//代码
}
}).start();
}
}
public static void main(String[] args) {
SpringApplication app = new SpringApplication(FigureServerApplication.class);
app.addListeners(new StartApplicationListener());
app.run(args);
}
事件监听有同步和异步两种方式,springboot项目中提供了一个用于异步处理的注解:@Async。
废话不多说,简单叙述几个不同方式的demo。
首先,我们先创建一个springboot项目。
1:定义一个事件,需要继承ApplicationEvent
public class MyEvent extends ApplicationEvent {
public MyEvent(Object source) {
super(source);
System.out.println("我是一个事件,目前在事件的构造器内");
}
}
2:创建一个监听器。直接实现ApplicationListener接口,重写其中onApplicationEvent方法.
public class MyEventListener implements ApplicationListener<MyEvent> {
@Override
public void onApplicationEvent(MyEvent event) {
System.out.println("现在开始执行监听器中的内容,我是直接实现ApplicationListener接口的方式进行的");
System.out.println("event.getSource() = " + event.getSource());
}
}
3:将监听器手动添加进应用容器内,并进行发布事件。
@SpringBootApplication
public class EventTestApplication {
public static void main(String[] args) {
// SpringApplication.run(EventTestApplication.class, args);
//第一种:自己手动将监听器添加到application中
SpringApplication application = new SpringApplication(EventTestApplication.class);
//添加监听器
application.addListeners(new MyEventListener());
ConfigurableApplicationContext context = application.run(args);
//进行发布事件
context.publishEvent(new MyEvent("Event数据源"));
context.close();
}
}
4:启动主启动类,进行打印测试。
1:同第一种的1
2:创建一个监听器。
@Component
public class MyEventListener2 implements ApplicationListener<MyEvent> {
@Override
public void onApplicationEvent(MyEvent event) {
System.out.println("现在开始执行监听器中的内容,我是打Compoent注解的方式进行的");
System.out.println("event.getSource() = " + event.getSource());
}
}
3:发布事件,后续进行启动类测试即可。
@SpringBootApplication
public class EventTestApplication {
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(EventTestApplication.class, args);
//发布事件
context.publishEvent(new MyEvent("source"));
context.close();
}
}
全部采用注解的方式
1:同第一种的1
2:创建一个监听器。
@Component
public class MyEventListener3 {
@Async//异步注解。开启一个新线程。 去掉此注解则会变成同步监听。
@EventListener(classes = MyEvent.class)
public void TestListener(MyEvent myEvent){
System.out.println("我是@EventListener注解的方式实现的监听器");
System.out.println("myEvent.getSource() = " + myEvent.getSource());
}
}
3:发布事件,后续进行启动类测试即可。
@SpringBootApplication
public class EventTestApplication {
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(EventTestApplication.class, args);
//发布事件
context.publishEvent(new MyEvent("source"));
context.close();
}
}
以上就是三种创建的方式。
下面是代码的结构图:
以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程网。
--结束END--
本文标题: springboot如何开启一个监听线程执行任务
本文链接: https://lsjlt.com/news/197817.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
2024-03-01
2024-03-01
2024-03-01
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0