回調(diào)函數(shù)中有回調(diào)函數(shù)嗎

因?yàn)槭俏业臅?#xff0c;所以我喜歡JavaScript 。 實(shí)際上，我已經(jīng)開始喜歡JavaScritp的面向異步回調(diào)的編程風(fēng)格 。 因此，當(dāng)我發(fā)現(xiàn)自己處于非JavaScript環(huán)境中時(shí)（例如Java） ，我往往會(huì)錯(cuò)過(guò)使用回調(diào)的機(jī)會(huì)。

好消息是您可以在Java中模擬異步回調(diào)。 實(shí)際上，我最近在一個(gè)我稱為Ahoy的圖書館中做到了這一點(diǎn)！ ，這是適用于AWS的Java SQS庫(kù)的異步SQS適配器 。

對(duì)于初學(xué)者來(lái)說(shuō)， SQS是一個(gè)基于云的消息傳遞平臺(tái) –使用SQS，您可以創(chuàng)建隊(duì)列并將消息放入這些隊(duì)列，然后可以稍后或通過(guò)其他某個(gè)過(guò)程或相同的確切過(guò)程讀取這些消息。 所有這些都利用了Amazon的大規(guī)模冗余架構(gòu)，在面對(duì)并發(fā)訪問(wèn)時(shí)提供了極高的可用性。

Java中的異步回調(diào)可以通過(guò)兩個(gè)功能實(shí)現(xiàn)：匿名類（包含一個(gè)方法）和Java的java.util.concurrent包。

因?yàn)镴ava不允許您輕松地將函數(shù)（或方法）作為參數(shù)傳遞，以模擬回調(diào)，所以您可以創(chuàng)建一個(gè)包含一個(gè)基本上模仿函數(shù)的方法的接口。 對(duì)于Ahoy，有兩個(gè)接口： MessageSendCallback和MessageReceivedCallback –都有一個(gè)方法：分別是onSend和onReceive 。 因此，Ahooy！的主要類被稱為SQSAdapter ， SQSAdapter公開了兩個(gè)簡(jiǎn)單的方法： send和receive并且都采用了它們相關(guān)的回調(diào)接口。

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

SQSAdapter的接收方法

public void receive(final MessageReceivedCallback callback) {}

MessageReceivedCallback接口如下所示：

MessageReceivedCallback接口

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

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

至此，客戶淘！ 在收到消息時(shí)提供消息的預(yù)期行為。 此行為可能是將某些內(nèi)容寫入數(shù)據(jù)庫(kù)，生成另一條消息，然后將其發(fā)送到另一個(gè)隊(duì)列（您命名）。

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

接收方法的實(shí)現(xiàn)與回調(diào)被調(diào)用

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()));}}}}); }

使用固定的線程池，將創(chuàng)建一個(gè)線程，該線程等待消息到達(dá)特定隊(duì)列。 當(dāng)顯示一條消息時(shí)，將為每條消息調(diào)用傳入的MessageReceivedCalledback 。

有關(guān)此示例對(duì)Ahoy！客戶的工作方式的示例，下面是一個(gè)測(cè)試用例，用于驗(yàn)證回調(diào)的執(zhí)行：

接收方法已實(shí)現(xiàn)

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);} });

同樣，發(fā)送消息是相似的–創(chuàng)建了一個(gè)新的Runnable實(shí)例，該實(shí)例發(fā)送特定的消息并調(diào)用MessageSentCallback的onSend方法中傳遞的onSend ，并傳遞新發(fā)送的消息的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());}}}); }

順便說(shuō)一下，AWS Java SDK 確實(shí)提供了一個(gè)異步客戶端 。 但是，此客戶端的實(shí)現(xiàn)利用了Java的Futures 。 盡管Futures是一個(gè)簡(jiǎn)潔的概念 ，但Ahoy！的實(shí)現(xiàn)比Futures更方便（ 至少對(duì)我來(lái)說(shuō)以及我使用SQS的方式 ），因?yàn)橐坏┌l(fā)送或接收消息，就不會(huì)涉及任何輪詢。

雖然不一定在Java中本地支持回調(diào)，但是您可以很好地模擬它們并實(shí)現(xiàn)與JavaScript相同的代碼簡(jiǎn)潔性。 而且，如果您需要方便的方法來(lái)與AWS SQS進(jìn)行交互，請(qǐng)給Ahoy！ 嘗試一下 ！ 你能挖出來(lái)嗎，伙計(jì)？

參考： 嗨，有回調(diào)！ 來(lái)自The Disco Blog博客的JCG合作伙伴 Andrew Glover。

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

回調(diào)函數(shù)中有回調(diào)函數(shù)嗎

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的回调函数中有回调函数吗_嗨，那里有回调！的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。