同步、異步

異步，歸根結底你仍是須要關心結果的，但可能不是當時的時間點關心，能夠用輪詢或者回調等方式處理結果；同步是須要當時關心的結果的；而oneway是發出去就無論死活的方式，這種對於某些徹底對可靠性沒有要求的場景仍是適用的。（參考：http://tech.meituan.com/mq-design.html）

輪詢

while（true）{...}無限循環詢問線程是否執行完成，效率較低。

回調

參考

http://lavasoft.blog.51cto.com/62575/98796/

http://blog.csdn.net/jjavaboy/article/details/43281537

https://github.com/ConnL/littleproject/tree/master/callback

一、接口調用方式

軟件模塊之間老是存在着必定的接口，從調用方式上，能夠把他們分爲三類：同步調用、回調和異步調用。

回調是一種特殊的調用，至於三種方式也有點不一樣。

一、同步回調，即阻塞，單向。

二、回調，即雙向（相似自行車的兩個齒輪）。

三、異步調用，即經過異步消息進行通知。

二、使用場景

一、Windows平臺的消息機制

二、異步調用微信接口，根據微信返回狀態對出業務邏輯響應。

三、Servlet中的Filter(過濾器)是基於回調函數，需容器支持。

package callback;

/**
 * 場景：客戶端發送msg給服務端，服務端處理後（5秒），回調給客戶端，告知處理成功
 * 關鍵點：
 * 一、接口做爲方法參數，其實際傳入引用指向的是實現類
   二、Client的sendMsg方法中，參數爲final，由於要被內部類一個新的線程能夠使用。這裏就體現了異步。
   三、調用server的getClientMsg()，參數傳入了Client自己（對應第一點）。
 */
public class CallBackTest {
    public static void main(String[] args) {
        Server server = new Server();
        Client client = new Client(server);
        client.sendMsg("Server,Hello~");
    }
}


package callback;

/**
 * 回調模式-回調接口類
 */
public interface CSCallBack {

    void process(String status);
}


package callback;

/**
 * 回調模式-模擬客戶端類
 */
public class Client implements CSCallBack {
    
    private Server server;

    public Client(Server server) {
        this.server = server;
    }

    public void sendMsg(final String msg){
        System.out.println("客戶端：發送的消息爲：" + msg);
        new Thread(new Runnable() {
            @Override
            public void run() {
                server.getClientMsg(Client.this,msg);
            }
        }).start();
        System.out.println("客戶端：異步發送成功");
    }

    @Override
    public void process(String status) {
        System.out.println("客戶端：服務端回調狀態爲：" + status);
    }
}


package callback;

/**
 * 回調模式-模擬服務端類
 */
public class Server {
    public void getClientMsg(CSCallBack csCallBack , String msg) {
        System.out.println("服務端：服務端接收到客戶端發送的消息爲:" + msg);
        // 模擬服務端須要對數據處理
        try {
            Thread.sleep(5 * 1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("服務端: 數據處理成功，返回成功狀態 200");
        String status = "200";
        csCallBack.process(status);
    }
}