springboot异步操作

流程

extends ApplicationEvent建立操作事件—>业务service注册事件—>Listener监听消费

参考资料

https://www.jianshu.com/p/af2aa0fce0ed

https://www.jianshu.com/p/4359dd4b36a6

方案

说明：两种方案不同在于@Async性能有一定提升

listener可以多个业务共享建立不同监听方法

@Async需要对每个业务做不同监听

1，Listener

//建立操作事件

package com.onecardmall.core.event;

import lombok.Getter;

import org.springframework.context.ApplicationEvent;

@Getter

public class DemoApplicationEventextends ApplicationEvent {

public DemoApplicationEvent(Object source,String uname) {

super(source);

this.uname=uname;

}

private Stringuname;

}

//业务service注册事件

package com.onecardmall.core.service.impl;

import com.onecardmall.core.event.DemoApplicationEvent;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.ApplicationContext;

import org.springframework.context.ApplicationEvent;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;

@Service

public class DemoApplicationEventService {

@Autowired

ApplicationContextapplicationContext;

/**

* 用户注册方法

* @param uname

public void register(String uname)

{

//../省略其他逻辑

//发布UserRegisterEvent事件

applicationContext.publishEvent(new DemoApplicationEvent(this,uname));

}

//调用业务

package com.onecardmall.core.controller;

import com.onecardmall.core.annotation.GlobalException;

import com.onecardmall.core.service.impl.DemoApplicationEventService;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

@RestController

@RequestMapping("/demoevent")

@Slf4j

public class DemoApplicationEventCtronller {

//用户业务逻辑实现

@Autowired

private DemoApplicationEventServiceuserService;

/**

* 注册控制方法

* @param uname 用户对象

* @return

@RequestMapping(value ="/register")

public Stringregister

(

String uname

) {

//调用注册业务逻辑

userService.register(uname);

return "注册成功.";

}

//Listener监听消费

package com.onecardmall.core.listener;

import com.onecardmall.core.event.DemoApplicationEvent;

import org.springframework.context.ApplicationEvent;

import org.springframework.context.ApplicationListener;

import org.springframework.context.event.EventListener;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Component;

@Component

public class AnnotationRegisterListener {

/**

* 注册监听实现方法

* @param userRegisterEvent 用户注册事件

@EventListener

public void register(DemoApplicationEvent userRegisterEvent)

{

//输出注册用户信息

System.out.println("@EventListener注册信息，用户名："+userRegisterEvent.getUname());

}

2，@Async

//配置线程池

package com.onecardmall.core.constant;

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.annotation.AsyncConfigurer;

import org.springframework.scheduling.annotation.EnableAsync;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@Configuration

@EnableAsync

public class ListenerAsyncConfigurationimplements AsyncConfigurer {

/**

* 获取异步线程池执行对象

* @return

@Override

public ExecutorgetAsyncExecutor() {

//使用Spring内置线程池任务对象

ThreadPoolTaskExecutor taskExecutor =new ThreadPoolTaskExecutor();

//设置线程池参数

taskExecutor.setCorePoolSize(5);

taskExecutor.setMaxPoolSize(10);

taskExecutor.setQueueCapacity(25);

taskExecutor.initialize();

return taskExecutor;

}

@Override

public AsyncUncaughtExceptionHandlergetAsyncUncaughtExceptionHandler() {

return null;

}

//配置注解监听注意 implements ApplicationListener 这个和listener版本不同

package com.onecardmall.core.listener;

import com.onecardmall.core.event.DemoApplicationEvent;

import org.springframework.context.ApplicationListener;

import org.springframework.context.event.EventListener;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Component;

@Component

public class AsyncRegisterListener implements ApplicationListener {

@Async

public void onApplicationEvent(DemoApplicationEvent applicationEvent) {

System.out.println("@onApplicationEvent");

//转换事件类型

//获取注册用户对象信息

//输出注册用户信息

System.out.println("onApplicationEvent @EventListener注册信息，用户名："+applicationEvent.getUname());

}

其它同listener