java異步執(zhí)行代碼處理方法(先返回結(jié)果,后執(zhí)行代碼)

更新時間：2023年07月12日 09:07:36 作者：天狼1222

這篇文章主要給大家介紹了關于java異步執(zhí)行代碼處理方法的相關資料,先返回結(jié)果,后執(zhí)行代碼,文中通過實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考借鑒價值,需要的朋友可以參考下

業(yè)務場景：

在用戶那，角色那變更后，要更新數(shù)據(jù)，因為更新要比較長時間，需要先返回結(jié)果（2:已接收待執(zhí)行）。更新結(jié)束后，再返回值結(jié)果。

（執(zhí)行結(jié)果. 0:執(zhí)行失敗； 1:執(zhí)行成功； 2:已接收待執(zhí)行）

處理1：簡單異步

使用 ExecutorService 異步

    public void onCallback(JSONObject param) {
        ExecutorService executor = Executors.newCachedThreadPool();
        executor.execute(() -> {
            try {
                Thread.sleep(1000 * 10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            // 這邊執(zhí)行具體的方法
            this.syncDealResult(param);
        });
        executor.shutdown();
    }
    public JSONObject dealResult(JSONObject params) {
        // 先返回結(jié)果，然后異步執(zhí)行
        this.onCallback(params);
        JSONObject result = new JSONObject();
        result.put("excRs", "2");
        return result;
    }
    public void syncDealResult(JSONObject params) {
        logger.info("deal abRole param {}", JSON.toJSONString(params));
        String logId = MapUtils.getString(params, "logId");
        String excRs = "1";
        try {
            // 具體操作
        } catch (Exception e) {
            e.printStackTrace();
            excRs = "-1";
        }
        logger.info("update abRole finish callRecordId {}, excRs {}", logId, excRs);
        // 處理完后推送結(jié)果
        JSONObject param = new JSONObject();
        param.put("logId", logId);
        param.put("excRs", excRs);
        // 推送結(jié)果
    }

加 Thread.sleep(1000 * 10); 就明顯看得出差別了。

如果是有多種異步執(zhí)行，比如：A執(zhí)行完后，B要做通知；C要入庫；D要做統(tǒng)計，這時候要怎么處理呢？

處理2：多個異步執(zhí)行

IRoleCallback

import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang3.StringUtils;
/**
 * AB角色異步調(diào)用接口
 *
 */
public interface IRoleCallback {
    /**
     * Computes a result, or throws an exception if unable to do so.
     *
     * @param param 結(jié)果
     * @return computed result
     * @throws Exception if unable to compute a result
     */
    Object call(JSONObject param) throws Exception;
    /**
     * unique name of callback
     *
     * @return callback name
     */
    default String name() {
        return StringUtils.uncapitalize(getClass().getSimpleName());
    }
    /**
     * prior to callback 用于排序
     *
     * @return order
     */
    default double order() {
        return 1.0d;
    }
}

RoleCallbackRegister

import java.util.*;
public class RoleCallbackRegister {
    private static final Map<String, IRoleCallback> CALLBACKS = new HashMap<>();
    public static boolean register(IRoleCallback callback) {
        if (CALLBACKS.containsKey(callback.name())) {
            return false;
        }
        CALLBACKS.put(callback.name(), callback);
        return true;
    }
    public static List<IRoleCallback> getCallbacks() {
        List<IRoleCallback> roleCallbacks = new ArrayList<>(CALLBACKS.values());
        roleCallbacks.sort(Comparator.comparingDouble(IRoleCallback::order));
        return roleCallbacks;
    }
}

SpringUtils

@Component
public class SpringUtils implements ApplicationContextAware {
    private static ApplicationContext applicationContext;
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        SpringUtils.applicationContext = applicationContext;
    }
    public static Object getBean(String name) {
        return applicationContext.getBean(name);
    }
    public static <T> T getBean(Class<T> clazz) {
        return applicationContext.getBean(clazz);
    }
}

AbstractRoleCallbackImpl

import com.web.work.common.support.SpringUtils;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.InitializingBean;
public abstract class AbstractRoleCallbackImpl implements IRoleCallback, InitializingBean {
    protected final Logger logger = LoggerFactory.getLogger(getClass());
    @Override
    public Object call(JSONObject param) throws Exception {
        return doCall(param);
    }
    protected abstract Object doCall(JSONObject param) throws Exception;
    @Override
    public String name() {
        return StringUtils.uncapitalize(getClass().getSimpleName());
    }
    @Override
    public void afterPropertiesSet() {
        boolean register = RoleCallbackRegister.register(SpringUtils.getBean(this.getClass()));
        if (!register) {
            logger.error("register role callback name:{} failed.", name());
        } else {
            logger.info("register role callback name:{} succeed.", name());
        }
    }
}

RoleCallBackService

@Service
public class RoleCallBackService implements InitializingBean, DisposableBean {
    private final static Logger logger = LoggerFactory.getLogger(RoleCallBackService.class);
    private ThreadPoolExecutor pool;
    public void onCallback(JSONObject param) {
        pool.execute(() -> {
            RoleCallbackRegister.getCallbacks().forEach(x -> {
                try {
                    logger.info("call {}", x.name());
                    x.call(param);
                } catch (Exception e) {
                    logger.error("回調(diào){}接口失?。?, x.name(), e);
                }
            });
        });
    }
    @Override
    public void afterPropertiesSet() {
        int size = Runtime.getRuntime().availableProcessors() + 1;
        pool = new ThreadPoolExecutor(size, size * 2, 300L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1000),
                Executors.defaultThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy());
    }
    @Override
    public void destroy() throws Exception {
        pool.shutdown();
    }
}

RoleUpdateService

@Service
public class RoleUpdateService extends AbstractRoleCallbackImpl {
    private final static Logger logger = LoggerFactory.getLogger(RoleUpdateService.class);
    @Override
    protected Object doCall(JSONObject params) throws Exception {
        Thread.sleep(1000 * 10);
        logger.info("deal abRole param {}", JSON.toJSONString(params));
        String logId = MapUtils.getString(params, "logId");
        String excRs = "1";
        try {
            // 執(zhí)行更新操作
        } catch (Exception e) {
            e.printStackTrace();
            excRs = "-1";
        }
        logger.info("update abRole finish callRecordId {}, excRs {}", logId, excRs);
        // 處理完后推送結(jié)果
        JSONObject param = new JSONObject();
        param.put("logId", logId);
        param.put("excRs", excRs);
        logger.info("update role record {}", JSON.toJSONString(param));
        // 推送結(jié)果
        return "";
    }
}

先返回結(jié)果后執(zhí)行

    @Resource
    private RoleCallBackService roleCallBackService;
    public JSONObject dealResult(JSONObject params) {
        // 先返回結(jié)果，然后異步執(zhí)行
        try {
            roleCallBackService.onCallback(params);
        } catch (Exception e) {
            e.printStackTrace();
        }
        JSONObject result = new JSONObject();
        result.put("excRs", "2");
        return result;
    }

總結(jié)：

要先返回結(jié)果，后執(zhí)行內(nèi)容，需要使用異步的方式，用ExecutorService進行處理。如果是單個的，就直接調(diào)用比較簡單。如果是多個的，就先要注冊下，然后遍歷去調(diào)用。

到此這篇關于java異步執(zhí)行代碼處理方法的文章就介紹到這了,更多相關java異步執(zhí)行代碼內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

Java并發(fā)編程之對象的組合
這篇文章主要介紹了Java并發(fā)編程之對象的組合，文章基于Java的相關資料展開主題內(nèi)容，具有一定的參考價值，需要的小伙伴可以參考一下
2022-04-04
Spring?Security安全框架之記住我功能
這篇文章主要介紹了Spring?Security安全框架之記住我，本次就來探究如何實現(xiàn)這種自動登錄、記住我的功能,通過實例代碼圖文相結(jié)合給大家介紹的非常詳細，需要的朋友可以參考下
2022-02-02
通過java反射機制動態(tài)調(diào)用某方法的總結(jié)(推薦)
下面小編就為大家?guī)硪黄ㄟ^java反射機制動態(tài)調(diào)用某方法的總結(jié)(推薦)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2016-07-07
Java中Switch的使用方法及新特性
在java中控制流程語句是由選擇語句、循環(huán)語句、跳轉(zhuǎn)語句構(gòu)成,選擇語句包括if和switch,在過多的使用if語句嵌套會使程序很難閱讀,這時就可以用到switch語句,這篇文章主要給大家介紹了關于Java中Switch的使用方法及新特性的相關資料,需要的朋友可以參考下
2023-11-11
Spring?Boot中的微信支付全過程(小程序)
微信支付是企業(yè)級項目中經(jīng)常使用到的功能，作為后端開發(fā)人員，完整地掌握該技術(shù)是十分有必要的。今天通過本文給大家介紹Spring?Boot中的微信支付全過程，感興趣的朋友一起看看吧
2022-05-05
深入理解ThreadLocal工作原理及使用示例
這篇文章主要介紹了深入理解ThreadLocal工作原理及使用示例，涉及ThreadLocal<T> 簡介和使用示例及ThreadLocal<T>的原理等相關內(nèi)容，具有一定參考價值，需要的朋友可以了解下。
2017-11-11
本篇文章主要介紹了JAVA collection集合之撲克牌游戲?qū)嵗?，使用了collection集合開發(fā)小游戲，有需要的可以了解一下。
2016-11-11