因為是我的書包，所以我喜歡JavaScript 。 實際上，我已經開始喜歡JavaScritp的面向異步回調的編程風格 。 因此，當我發現自己處于非JavaScript環境中時（例如Java） ，我往往會錯過使用回調的機會。

好消息是您可以在Java中模擬異步回調。 實際上，我最近在一個我稱為Ahoy的圖書館中做到了！ ，這是適用于AWS的Java SQS庫的異步SQS適配器 。

對于初學者來說， SQS是一個基于云的消息傳遞平臺 –使用SQS，您可以創建隊列并將消息放入這些隊列，然后可以稍后或通過其他某個過程或相同的確切過程讀取這些消息。 所有這些都利用Amazon的大規模冗余架構在面對并發訪問時提供了極高的可用性。

Java中的異步回調可以通過兩個功能實現：匿名類（包含一個方法）和Java的java.util.concurrent包。

因為Java不允許您輕松地將函數（或方法）作為參數傳遞，以模擬回調，所以您可以創建一個包含一個方法的接口，該方法基本上模仿一個函數。 對于Ahoy，有兩個接口： MessageSendCallback和MessageReceivedCallback –都有一個方法：分別是onSend和onReceive 。 因此，Ahoy！的主要類被稱為SQSAdapter ， SQSAdapter公開了兩個簡單的方法： send和receive并且都采用了它們相關的回調接口。

要理解的最直接的回調是receive方法。 可以想象， receive是為了處理從特定隊列接收到消息時的行為。 因此， receive方法定義如下：

SQSAdapter的接收方法

public void receive(final MessageReceivedCallback callback) {}

MessageReceivedCallback接口如下所示：

MessageReceivedCallback接口

public interface MessageReceivedCallback {public void onReceive(String messageId, String message); }

請注意， onReceive方法需要一個消息ID（特定于SQS）和消息本身-在SQS的情況下，它始終是一個String （請記住， String可以容納您想要的任何內容：JSON，XML，字節序列）等）。

至此，客戶淘！ 在收到消息時提供消息的預期行為。 此行為可能是將某些內容寫入數據庫，生成另一條消息，然后將其發送到另一個隊列（您命名）。

現在，有趣的部分是Ahoy！的receive方法的實現。 為了實現異步性，我使用了Java的java.util.concurrent包，可悲的是，它似乎不受歡迎。

接收方法的實現與回調被調用

private void receive(final AmazonSQS sqs, final String queueURL, final MessageReceivedCallback callback) {pool.execute(new Runnable() {public void run() {final List<Message> messages = sqs.receiveMessage(new ReceiveMessageRequest(queueURL).withMaxNumberOfMessages(10).withWaitTimeSeconds(20)).getMessages();if (messages.size() > 0) {for (final Message message : messages) {callback.onReceive(message.getMessageId(), message.getBody());sqs.deleteMessage(new DeleteMessageRequest(queueURL, message.getReceiptHandle()));}}}}); }

使用固定的線程池，將創建一個線程，該線程等待消息到達特定隊列。 當顯示一條消息時，將為每條消息調用傳入的MessageReceivedCalledback 。

有關如何對Ahoy！客戶端進行工作的示例，下面是一個測試用例，用于驗證回調的執行：

接收方法已實現

final boolean[] wasReceived = {false}; ahoy.receive(new MessageReceivedCallback() {public void onReceive(String messageId, String message) {wasReceived[0] = true;assertNotNull("message id was null", messageId);assertEquals("message wasn't " + origMessage, origMessage, message);} });

同樣，發送消息也很相似–創建一個新的Runnable實例，該實例發送特定的消息并調用MessageSentCallback的onSend方法中傳遞的onSend ，并傳遞新發送的消息的ID。

send方法也是異步的

private void send(final AmazonSQS sqs, final String queueURL, final String message, final MessageSentCallback callback) {pool.execute(new Runnable() {public void run() {SendMessageResult res = sqs.sendMessage(new SendMessageRequest(queueURL, message));if (callback != null) {callback.onSend(res.getMessageId());}}}); }

順便說一下，AWS Java SDK 確實提供了一個異步客戶端 。 但是，此客戶端的實現利用了Java的Futures 。 盡管Futures是一個簡潔的概念 ，但Ahoy！的實現比Futures更方便（ 至少對我來說以及我使用SQS的方式 ），因為一旦發送或接收消息，就不會涉及任何輪詢。

雖然不一定在Java中本地支持回調，但是您可以很好地模擬它們并實現與JavaScript相同的代碼簡潔性。 而且，如果您需要方便的方法來與AWS SQS進行交互，請給Ahoy！ 嘗試一下 ！ 你能挖出來嗎，伙計？

參考： 嗨，那里有回調！ 從我們的JCG合作伙伴 Andrew Glover在The Disco Blog博客中獲得。

翻譯自: https://www.javacodegeeks.com/2013/10/ahoy-there-callbacks.html

總結

以上是生活随笔為你收集整理的嗨，那里有回调！的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。