??? ? ???? ???? LLM ?????? ?????? ? ?? ????

LLM ?????? ?? ? ? ??? ?? ??? ?????? ???? ??? ? ?? ? ?? ???? ???? ?? ? ? ??? ???????. ? ??? ?? Spring Webflux? ?????? ???? ??? ??? ????. ?? ?? B ??? ?? ????? B ??? ???? ?? ?? C? ?? ???? ??.

?? ??

LLM ????? ?? ??? ??? ????. ?????-> ?????-> ?? B. ?? B? ?? ????? ??? ???? ?????? ?? C? ?? ? ???? ??? ? ??? ????.?? ???? ?????? ?? B? ?? ?? ??? ???? ??? ?? C? ???? ?? ? ? ??????.

?? ?? ? ?? ???

?? ?? B ?? ?? C? ????? ??? ???? ?? sseHttp ???? ?? ?????.

 ??<response> ResponseFlux = webClient.create (URL)
                .??()
                .Headers (httpheaders-> Setheaders (httpheaders, ??)))
                .ContentType (MediaType.Application_json)
                .BodyValue (jsonbody)
                .????()
                .onstatus (?? -> ??! = httpstatus.ok, ?? -> {
                    // ?? ?? ??})
                // ... ?? ?? ...</response>

? ?? ??? ????? ??? ???? ?? B? ?? ?? ??? ???? ?? C? ???????. ?? ???? ? ?? ??? ????. ??? try-catch Flux ???? ??? ?? ? ????. subscribe ??? ???? ???? ?? ?? ??? ? ??? ???? ????.

?? ?? : retryWhen ???? onErrorResume

?? ??? ???? ?? Spring Webflux?? ???? retryWhen ? onErrorResume ???? ???????.

?? sseHttp ???? ???? ? ?? ??? ??????.

 ??<response> ssehttp (string url) {
    webclient? ?????.
            .??()
            .Headers (httpheaders-> Setheaders (httpheaders, ??)))
            .ContentType (MediaType.Application_json)
            .BodyValue (jsonbody)
            .????()
            .onstatus (httpstatus :: iserror, clientResponse-> {
                // ??? ?? mono.error (new WebClientResponseException ( "?? ?? ?? ?? :"clientResponse.RawStatusCode (), ClientResponse.RawStatusCode (), ClientResponse.headers (). AshTtPheaders ()
            })
            .BodyToflux (typeref)
            .retryWhen (retry.backoff (3, duration.ofseconds) (1))
                    .filter (Throwable-> WARDABLE ???? WebClientResponseException)
                    .OnRetryExhaEstedThrow ((??, ??) -> ??? GatewayException ( "?? ?? ? ?? B ? ?? C? ???? ?????."));
}</response>

? ??? onStatus ???? HTTP ?? ?? ??? ???? 1 ?? ?? ???? 3 ??? retryWhen ? ? ?? ?????. filter WebClientResponseException ??? ?? ? ??? ? ?????. ? ??? ?? ???? GatewayException ? ?????.

?? ?? sseHttp ???? ?? ?? B? ??? ???? ?? C? ???? ?? onErrorResume ??????.

 ???<response> responsemono = ssehttp (Serverburl)
        .OnerRorResume (WebClientResponseException.class, ex-> {
            log.warn ( "?? b : {}", ex.getMessage ())? ???? ?????. // ?? ?? ?? return SSEHTTP (ServerCurl);
        })
        .??();</response>

? ??? ?? ?? B? ????? ???? WebClientResponseException ???? ?? C? ????????. next() ???? ??? ?? ? ????????.

?? ???? ??? ?????

?? B? ?? C? ?? ???? ????? ???? ??? ?? ? ????????. AtomicBoolean ??? ??? ????? ?????? ??? ???? ? ??? ? ????.

 Atomicboolean ?? = ??? Atomicboolean (False);

??<response> ssehttp (string url) {
    // ... (?? ??) ...
    .doonNext (?? -> {
        if (success.compareAndset (false, true)) {
            // ???? ?? ??}
    })
    // ... (??? ???) ...
}</response>

?? ?? ??? ?? ??? ?? ?? ??? ????? ???? LLM ?????? ? ???? ?? ? ????? ??? ? ?? ????? ??????. ?? ??? ?????? ?? ??? ??? ???????.

? ??? LLM ?????? ?? ? ? Spring WebFlux? ???? ServerB?? ServerC ?? ? ?? ??? ???? ??? ??????? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!