通過抽象方法給子類實(shí)現(xiàn)钠右，從而達(dá)到高度抽象的目的摊腋，這里針對不同類而言
通過傳遞匿名內(nèi)部類的形式將需要執(zhí)行的內(nèi)容傳遞給公共抽象類對應(yīng)方法辨萍，這里適合類里面有多個方法需要抽象
future模式近忙，異步執(zhí)行骄酗，結(jié)果處理抽象妥畏，具體實(shí)現(xiàn)各個子類實(shí)現(xiàn)
反射邦邦，動態(tài)代理抽象

通過抽象方法給子類實(shí)現(xiàn)，從而達(dá)到高度抽象的目的醉蚁，這里針對不同類而言

public class Test {
    public static void main(String[] args) {
        TestService testService = new TestService();
        testService.getResp(new Object());
    }

    private static class TestService extends BaseService {
        public Object getResp(Object req) {
            return service(req);
        }


        @Override
        protected void validateRequest(Object o) {
            System.out.println("來自TestService的驗證");
        }
    }
}

public abstract class BaseService<Request, Response> {

    /**
     * 總體是通過抽象方法給子類實(shí)現(xiàn)燃辖，從而達(dá)到高度抽象的目的
     */
    public final Response service(Request request) {
        System.out.println("調(diào)用公共的service");
        // 各個子類實(shí)現(xiàn)
        validateRequest(request);
        // 各個子類實(shí)現(xiàn)，具體業(yè)務(wù)邏輯, 此處省略getBiz獲取各個子類實(shí)際業(yè)務(wù)邏輯類
        /*Response response = getBiz().biz(request);*/
        System.out.println("結(jié)束調(diào)用公共的service");
        // 只是展示
        return null;
    }

    protected abstract void validateRequest(Request request);

    /*protected abstract Biz<Request, Response> getBiz();*/
}

輸出

調(diào)用公共的service
來自TestService的驗證
結(jié)束調(diào)用公共的service

通過傳遞匿名內(nèi)部類的形式將需要執(zhí)行的內(nèi)容傳遞給公共抽象類對應(yīng)方法网棍，這里適合類里面有多個方法需要抽象

public class Provider extends AbstractProvider {

    // 獲取請求
    public void get(final String key) {
        executeCommand(key, () -> System.out.println("執(zhí)行了獲取指令, key：" + key), null);
    }

    // 判斷是否存在
    public void exists(final String key) {
        executeCommand(key, () -> System.out.println("執(zhí)行了判斷是否存在指令, key：" + key), null);
    }

    public static void main(String[] args) {
        Provider provider = new Provider();
        provider.get("ss");
        provider.exists("sss");
    }
}

public abstract class AbstractProvider {

    protected <T> void executeCommand(String key, Command<T> command, T defaultValue) {
        command.execute();
    }
}

public interface Command<T> {
    void execute();
}

future模式黔龟，異步執(zhí)行，結(jié)果處理抽象滥玷，具體實(shí)現(xiàn)各個子類實(shí)現(xiàn)

先看下異步響應(yīng)之后的調(diào)用時序圖

異步響應(yīng)時序圖.png
這里在發(fā)送完請求之后氏身，還會調(diào)用再次調(diào)用RequestFuture的compose方法，為RequestFuture增加listener惑畴，這里的listener作用是調(diào)用各個ResponHandleAdapter實(shí)現(xiàn)類蛋欣，也就是各個請求的實(shí)現(xiàn)類。這樣就把解析響應(yīng)交回各個子類如贷。時序圖為: 1.1.1是future模式陷虎，1.1.2是為ReuqestFuture添加listener以便回調(diào)各個子類實(shí)現(xiàn)的onSuccess

時序圖.png
具體看代碼

public class SendJoinGroupRequest extends AbstractRequestSend implements ResponseHandleAdapter {
    public void sendJoinGroupRequest(String s){
        send(s).compose(this);
    }

    @Override
    public void onSuccess(String s) {
        System.out.println("SendJoinGroupRequest執(zhí)行結(jié)果: " + s);
    }

    public static void main(String[] args) {
        SendJoinGroupRequest sendJoinGroupRequest = new SendJoinGroupRequest();
        sendJoinGroupRequest.sendJoinGroupRequest("測試發(fā)送JoinGroup檢測請求");
        // 寫SendHeartbeatRequest 類似的
       /* SendHeartbeatRequest sendHeartbeatRequest = new SendHeartbeatRequest();
        sendHeartbeatRequest.sendHeartbeat("測試發(fā)送心跳檢測請求");*/
    }
}

public abstract class AbstractRequestSend {

    /**
     * 模擬異步執(zhí)行任務(wù)
     */
    ExecutorService executorService = Executors.newSingleThreadExecutor();

    public RequestFuture send(String s) {
        // 這里是Future模式
        RequestFuture requestFuture = new RequestFuture();
        executorService.execute(new AsyncExeRemoteInvoke(requestFuture, s));
        return requestFuture;
    }

    private static class AsyncExeRemoteInvoke implements Runnable {
        private RequestFuture requestFuture;
        private String s;

        public AsyncExeRemoteInvoke(RequestFuture requestFuture, String s) {
            this.requestFuture = requestFuture;
            this.s = s;
        }

        @Override
        public void run() {
            // 模擬遠(yuǎn)程調(diào)用耗時
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            String res = s + "遠(yuǎn)程調(diào)用結(jié)束";
            requestFuture.onComplete(res);
        }
    }
}

public interface ResponseHandleAdapter {
    void onSuccess(String s);
}

public class RequestFuture {
    private List<RequestFutureListener> requestFutureListenerList;

    public RequestFuture() {
        this.requestFutureListenerList = new ArrayList<>();
    }

    public void onComplete(String s){
        // 假設(shè)只執(zhí)行成功的方法
        fireSuccess(s);
    }

    private void fireSuccess(String s) {
        // 假設(shè)只執(zhí)行成功的方法
        requestFutureListenerList.forEach(requestFutureListener -> requestFutureListener.onSuccess(s));
    }

    private void addListener(RequestFutureListener requestFutureListener){
        requestFutureListenerList.add(requestFutureListener);
    }

    /**
     * 相當(dāng)于給RequestFuture addListener
     */
    public void compose(ResponseHandleAdapter responseHandleAdapter){
        addListener(new RequestFutureListener() {
            @Override
            public void onSuccess(String s) {
                // 交回給各個請求處理類處理
                responseHandleAdapter.onSuccess(s);
            }

            @Override
            public void onFail() {
                // 暫時不處理
            }
        });
    }


}

public interface RequestFutureListener {
     void onSuccess(String s);

     void onFail();
}

如果需要實(shí)現(xiàn)鏈?zhǔn)秸{(diào)用，即調(diào)用了各個ResponseHandleAdapter 處理結(jié)果之后倒得，還需要繼續(xù)回調(diào)泻红，那么可以修改

RequestFuture的compose方法為

public RequestFuture compose(ResponseHandleAdapter responseHandleAdapter){
    // 這里實(shí)現(xiàn)將結(jié)果傳播出去的關(guān)鍵代碼，執(zhí)行完各個responseHandleAdapter后霞掺，
    // 鏈?zhǔn)降膱?zhí)行調(diào)用compose方法谊路，調(diào)用compose方法會添加一個listener
    final RequestFuture future = new RequestFuture();
    addListener(new RequestFutureListener() {
        @Override
        public void onSuccess(String s) {
            // 交回給各個請求處理類處理
            responseHandleAdapter.onSuccess(s, future);
        }

        @Override
        public void onFail() {
            // 暫時不處理
        }
    });
    return future;
}

修改ResponseHandleAdapter

public interface ResponseHandleAdapter {
    void onSuccess(String s, RequestFuture future);
}

修改SendJoinGroupRequest

public class SendJoinGroupRequest extends AbstractRequestSend implements ResponseHandleAdapter {
    public RequestFuture sendJoinGroupRequest(String s){
        return send(s).compose(this);
    }

    @Override
    public void onSuccess(String s, RequestFuture future) {
        System.out.println("SendJoinGroupRequest執(zhí)行結(jié)果: " + s);
        //將結(jié)果傳播出去
        future.onComplete(s);
    }

    public static void main(String[] args) {
        SendJoinGroupRequest sendJoinGroupRequest = new SendJoinGroupRequest();
        RequestFuture future = sendJoinGroupRequest.sendJoinGroupRequest("測試發(fā)送JoinGroup檢測請求");
        future.addListener(new RequestFutureListener() {
            @Override
            public void onSuccess(String s) {
                System.out.println("我是SendJoinGroupRequest傳播出來的，請求為:" + s);

            }

            @Override
            public void onFail() {

            }
        });

       /* SendHeartbeatRequest sendHeartbeatRequest = new SendHeartbeatRequest();
        RequestFuture future1 = sendHeartbeatRequest.sendHeartbeat("測試發(fā)送心跳檢測請求");
        future1.addListener(new RequestFutureListener() {
            @Override
            public void onSuccess(String s) {
                System.out.println("我是SendHeartbeatRequest傳播出來的菩彬，請求為:" + s);
            }

            @Override
            public void onFail() {

            }
        });*/
    }
}

修改執(zhí)行執(zhí)行結(jié)果為

SendJoinGroupRequest執(zhí)行結(jié)果: 測試發(fā)送JoinGroup檢測請求遠(yuǎn)程調(diào)用結(jié)束
我是SendJoinGroupRequest傳播出來的缠劝，請求為:測試發(fā)送JoinGroup檢測請求遠(yuǎn)程調(diào)用結(jié)束

反射，動態(tài)代理抽象

這種是更高一級的抽象

高度抽象代碼方法總結(jié)

高度抽象代碼方法總結(jié)

目錄

通過抽象方法給子類實(shí)現(xiàn)，從而達(dá)到高度抽象的目的醉蚁，這里針對不同類而言

通過傳遞匿名內(nèi)部類的形式將需要執(zhí)行的內(nèi)容傳遞給公共抽象類對應(yīng)方法网棍，這里適合類里面有多個方法需要抽象

future模式黔龟，異步執(zhí)行，結(jié)果處理抽象滥玷，具體實(shí)現(xiàn)各個子類實(shí)現(xiàn)

反射，動態(tài)代理抽象

高度抽象代碼方法總結(jié)

目錄

通過抽象方法給子類實(shí)現(xiàn)，從而達(dá)到高度抽象的目的醉蚁，這里針對不同類而言

通過傳遞匿名內(nèi)部類的形式將需要執(zhí)行的內(nèi)容傳遞給公共抽象類對應(yīng)方法网棍，這里適合類里面有多個方法需要抽象

future模式黔龟，異步執(zhí)行，結(jié)果處理抽象滥玷， 具體實(shí)現(xiàn)各個子類實(shí)現(xiàn)

反射，動態(tài)代理抽象

future模式黔龟，異步執(zhí)行，結(jié)果處理抽象滥玷，具體實(shí)現(xiàn)各個子類實(shí)現(xiàn)