快捷導(dǎo)航

java實(shí)現(xiàn)異步回調(diào)返回給前端的方法示例

更新時(shí)間：2024年03月18日 08:21:59 作者：JaneYork

在Java中實(shí)現(xiàn)異步回調(diào)并將結(jié)果返回給前端，通常是在Web應(yīng)用開發(fā)中處理耗時(shí)操作時(shí)所采用的技術(shù)手段，以避免阻塞HTTP請(qǐng)求線程并提高用戶體驗(yàn)，本文就來(lái)介紹一下如何實(shí)現(xiàn)，感興趣的可以了解一下

在Java中實(shí)現(xiàn)異步回調(diào)并將結(jié)果返回給前端，通常是在Web應(yīng)用開發(fā)中處理耗時(shí)操作時(shí)所采用的技術(shù)手段，以避免阻塞HTTP請(qǐng)求線程并提高用戶體驗(yàn)。以下是一個(gè)簡(jiǎn)單的例子，說(shuō)明如何通過Spring WebFlux或者Servlet 3.0及以上標(biāo)準(zhǔn)的異步API配合JSON響應(yīng)的方式實(shí)現(xiàn)這一目標(biāo)。

示例1 - 使用Spring WebFlux（非阻塞IO）

import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Mono;

@RestController
public class AsyncController {

    @GetMapping("/asyncTask")
    public Mono<String> asyncTask(@RequestParam("taskId") String taskId) {
        return doAsyncTask(taskId).map(result -> {
            // 這里假設(shè)doAsyncTask返回Mono對(duì)象，當(dāng)異步任務(wù)完成時(shí)會(huì)填充結(jié)果
            return ResponseEntity.ok().body(result);
        });
    }

    private Mono<YourResultType> doAsyncTask(String taskId) {
        return Mono.create(sink -> {
            // 創(chuàng)建一個(gè)異步任務(wù)，在完成后回調(diào)
            someService.doSomethingAsync(taskId, new SomeCallback(sink));
        });
    }

    class SomeCallback implements AsyncCallback<YourResultType> {
        private final MonoSink<YourResultType> sink;

        public SomeCallback(MonoSink<YourResultType> sink) {
            this.sink = sink;
        }

        @Override
        public void onResult(YourResultType result) {
            // 當(dāng)異步任務(wù)完成時(shí)，通過sink.success()傳遞結(jié)果
            sink.success(result);
        }

        @Override
        public void onError(Throwable error) {
            // 如果發(fā)生錯(cuò)誤，通過sink.error()傳遞異常
            sink.error(error);
        }
    }
}

// 假設(shè)`YourResultType`是你異步任務(wù)的結(jié)果類型

示例2 - 使用Servlet 3.0異步API（阻塞IO但不阻塞HTTP線程）

import javax.servlet.AsyncContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

@WebServlet(urlPatterns = "/asyncTask", asyncSupported = true)
public class AsyncServlet extends HttpServlet {

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

        final AsyncContext asyncContext = request.startAsync();
        Thread taskRunner = new Thread(() -> {
            YourResultType result;
            try {
                // 執(zhí)行異步任務(wù)
                result = someService.doSomethingAsync(request.getParameter("taskId"));
            } catch (Exception e) {
                handleError(asyncContext, e);
                return;
            }

            // 將結(jié)果寫回響應(yīng)并結(jié)束異步上下文
            writeResponse(asyncContext, result);
        });

        taskRunner.start();
    }

    private void writeResponse(AsyncContext asyncContext, YourResultType result) {
        HttpServletResponse response = (HttpServletResponse) asyncContext.getResponse();
        try {
            response.setContentType("application/json");
            response.getWriter().write(objectMapper.writeValueAsString(result));
            asyncContext.complete();
        } catch (IOException e) {
            handleError(asyncContext, e);
        }
    }

    private void handleError(AsyncContext asyncContext, Throwable error) {
        HttpServletResponse response = (HttpServletResponse) asyncContext.getResponse();
        try {
            response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
            response.getWriter().write(error.getMessage());
            asyncContext.complete();
        } catch (IOException e) {
            // 處理寫入錯(cuò)誤...
        }
    }
}

在這兩個(gè)示例中，核心思想都是啟動(dòng)一個(gè)異步任務(wù)，然后在任務(wù)完成后通過某種機(jī)制（如Reactor的MonoSink或Servlet的AsyncContext）將結(jié)果返回給前端。前端可以通過AJAX請(qǐng)求獲取異步任務(wù)的結(jié)果，并根據(jù)返回的狀態(tài)進(jìn)行相應(yīng)的處理，如展示數(shù)據(jù)或更新UI。

到此這篇關(guān)于java實(shí)現(xiàn)異步回調(diào)返回給前端的方法示例的文章就介紹到這了,更多相關(guān)java 異步回調(diào)返回給前端內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: