Spring Boot小型项目怎么使用异步任务管理器实现不同业务间的解耦

本篇内容介绍了“Spring Boot小型项目怎么使用异步任务管理器实现不同业务间的解耦”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

一、异步任务管理器是什么？

顾名思义，就是用来对异步任务进行统一的管理，并提供了一种访问其唯一对象的方式，这样做的好处就是，在内存中有且仅有一个实例，减少了内存的开销，尤其对于频繁的创建和销毁实例，用这种方式来频繁执行多个异步任务性能是相对比较好的。

二、实现步骤

1.自定义线程池

执行异步任务时，需要将执行的任务放入到线程池中，所以需配置好我们的线程池。并创建一个调度线程池执行器，用来执行异步任务。

代码如下（示例）：

2. 新建异步任务管理器类

代码如下（示例）：

public class AsyncManager {
    /**
     * 操作延迟10毫秒
     */
    private final int OPERATE_DELAY_TIME = 10;
    /**
     * 异步操作任务调度线程池
     */
    private ScheduledExecutorService executor = SpringUtils.getBean("scheduledExecutorService");
    /**
     * 饿汉式单例模式
     */
    private AsyncManager(){}

    private static AsyncManager me = new AsyncManager();

    public static AsyncManager me() {
        return me;
    }
    /**
     * 执行任务
     * @param task 任务
     */
    public void execute(TimerTask task) {
        executor.schedule(task, OPERATE_DELAY_TIME, TimeUnit.MILLISECONDS);
    }

3. 新建异步工厂类

设计这个类主要是用来产生 TimerTask 的，代码如下（示例）：

@Slf4j
public class AsyncFactory {
    /**
     * 记录登录信息
     * @param username 用户名
     * @param status 状态
     * @param message 消息
     * @param args 列表
     * @return 任务task
     */
    public static TimerTask recordLoginLog(final String username, final String status, final String message,final Object... args) {
        // 客户端操作系统、浏览器等信息
        final UserAgent userAgent = UserAgentUtil.parse(ServletUtils.getRequest().getHeader("User-Agent"));
        // 请求的IP地址
        final String ip = ServletUtil.getClientIP(ServletUtils.getRequest());
        return new TimerTask() {
            @Override
            public void run() {
                String address = AddressUtils.getRealAddressByIp(ip);
                // 获取客户端操作系统
                String os = userAgent.getOs().getName();
                // 获取客户端浏览器
                String browser = userAgent.getBrowser().getName();
                // 封装对象
                XlLoginLog loginLog = new XlLoginLog();
                loginLog.setUserCode(username);
                loginLog.setIpaddr(ip);
                loginLog.setLoginLocation(address);
                loginLog.setBrowser(browser);
                loginLog.setOs(os);
                loginLog.setMsg(message);
                loginLog.setLoginTime(new Date());
                // 日志状态
                if (Constants.LOGIN_FAIL.equals(status)) {
                    loginLog.setStatus(Integer.valueOf(Constants.FAIL));
                } else {
                    loginLog.setStatus(Integer.valueOf(Constants.SUCCESS));
                }
                // 插入数据
                SpringUtils.getBean(IXlLoginLogService.class).create(loginLog);
            }
        };
    }
}

4. 调用

例如：在登录的方法中链式调用，与同步方式不同，开发者不用考虑当进行登录操作是否进行日志操作，在异步的方式中，业务的操作与日志的操作分开来。执行流程：AsyncManager.me()获取一个AsyncManager对象，执行execute方法，执行任务，传入的是一个task对象。实现了Runnable接口，是一个任务，由线程Thread去执行。

recordLoginLog方法返回的是TimerTask定时任务类，将用户登录信息记录到日志中作为一个定时任务，交给定时任务调度线程池scheduledExecutorService，scheduledExecutorService通过在异步任务管理器类中，用getBean()从IOC容器中获取。

5. 实现效果

进行登录操作时，会异步进行日志的记录。

“Spring Boot小型项目怎么使用异步任务管理器实现不同业务间的解耦”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！