AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 77698752
Accepted
al.truisme
al.truisme
Asked: 2023-12-21 22:51:11 +0800 CST2023-12-21 22:51:11 +0800 CST 2023-12-21 22:51:11 +0800 CST

Spring-integration 5.5.18 tempos limite do gateway de mensagens

  • 772

Estou usando @MessagingGatewaypara fazer a ponte entre spring-mvc @Controllere spring-integration. A @MessagingGatewaydeclaração fica assim:

package a.b.c;

import org.springframework.integration.annotation.*;
import org.springframework.stereotype.Component;

@MessagingGateway(name="inboundGateway" defaultRequestTimeout="2000"
                                        defaultReplyTimeout="2000")

@Component
public interace InboundGateway {

    @Gateway(requestChannel = "getSomething")
    Message<SomeValue> getSomething(@Headers Map<String, Object> headers);

}

que é referenciado por um controlador

@Controller
@RequestMapping("/some/base/path")
public class SomeController {

    private final InboundGateway inboundGateway;

    public SomeController(InboundGateway inboundGateway) {
        this.inboundGateway = inboundGateway;
    }

    @GetMapping(value = "things", produces = { "application/json" })
    public ResponseEntity<SomeValue> getSomething(RequestContext<String> requestContext) {
        Message<SomeValue> response = inboundGateway.getSomething(requestContext);
        ....
}

Eu estava pensando que as definições de defaultRequestTimeoute defaultReplyTimeoutgerariam um tempo limite inboundGatewayse a resposta não fosse retornada dentro do tempo especificado.

Porém, estou vendo que o tempo utilizado no método getSomething()pode ultrapassar o tempo especificado, neste exemplo, 2 segundos. Parece que os 2 segundos são usados ​​como tempo limite para as chamadas para sistemas downstream, mas não como tempo limite para o retorno de getSomething().

Estou entendendo isso corretamente? Existe alguma maneira simples e declarativa de gerenciar o tempo limite no inboundGatewaynível? Qualquer indicação será apreciada.

spring-mvc
  • 1 1 respostas
  • 19 Views

1 respostas

  • Voted
  1. Best Answer
    Artem Bilan
    2023-12-21T23:01:22+08:002023-12-21T23:01:22+08:00

    O comportamento que você explica é típico de fluxos em que você inboundGatewayé um arquivo DirectChannel. Dessa forma, o processo da mensagem é executado diretamente no thread que produz essa mensagem. Portanto, ele não pode alcançar o replyTimeoutresultado for, pois esse thread está bloqueado aguardando o tratamento da mensagem.

    Veja mais informações nos documentos para diferentes canais: https://docs.spring.io/spring-integration/reference/channel/implementations.html

    Consulte também a documentação sobre esses tempos limite no Gateway: https://docs.spring.io/spring-integration/reference/gateway.html

    Como uma solução simples para sua expectativa, você pode considerar usar um QueueChnanelfor that inboundGatewayou um ExecutorChannel. Desta forma, o processamento será transferido para um thread diferente e o gateway poderá facilmente passar para o bloco de espera de resposta. E é aí que isso replyTimeoutterá efeito.

    Também é explicado naquele atributo de anotação JavaDocs:

    /**
     * Provides the amount of time dispatcher would wait to send a {@code Message}. This
     * timeout would only apply if there is a potential to block in the send call. For
     * example if this gateway is hooked up to a {@code QueueChannel}. Value is specified
     * in milliseconds; it can be a simple long value or a SpEL expression; array variable
     * #args is available.
     * See {@link Gateway#requestTimeout()} for per-method configuration.
     * @return the suggested timeout in milliseconds, if any
     */
    String defaultRequestTimeout() default IntegrationContextUtils.DEFAULT_TIMEOUT_STRING;
    
    • 1

relate perguntas

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    destaque o código em HTML usando <font color="#xxx">

    • 2 respostas
  • Marko Smith

    Por que a resolução de sobrecarga prefere std::nullptr_t a uma classe ao passar {}?

    • 1 respostas
  • Marko Smith

    Você pode usar uma lista de inicialização com chaves como argumento de modelo (padrão)?

    • 2 respostas
  • Marko Smith

    Por que as compreensões de lista criam uma função internamente?

    • 1 respostas
  • Marko Smith

    Estou tentando fazer o jogo pacman usando apenas o módulo Turtle Random e Math

    • 1 respostas
  • Marko Smith

    java.lang.NoSuchMethodError: 'void org.openqa.selenium.remote.http.ClientConfig.<init>(java.net.URI, java.time.Duration, java.time.Duratio

    • 3 respostas
  • Marko Smith

    Por que 'char -> int' é promoção, mas 'char -> short' é conversão (mas não promoção)?

    • 4 respostas
  • Marko Smith

    Por que o construtor de uma variável global não é chamado em uma biblioteca?

    • 1 respostas
  • Marko Smith

    Comportamento inconsistente de std::common_reference_with em tuplas. Qual é correto?

    • 1 respostas
  • Marko Smith

    Somente operações bit a bit para std::byte em C++ 17?

    • 1 respostas
  • Martin Hope
    fbrereto Por que a resolução de sobrecarga prefere std::nullptr_t a uma classe ao passar {}? 2023-12-21 00:31:04 +0800 CST
  • Martin Hope
    比尔盖子 Você pode usar uma lista de inicialização com chaves como argumento de modelo (padrão)? 2023-12-17 10:02:06 +0800 CST
  • Martin Hope
    Amir reza Riahi Por que as compreensões de lista criam uma função internamente? 2023-11-16 20:53:19 +0800 CST
  • Martin Hope
    Michael A formato fmt %H:%M:%S sem decimais 2023-11-11 01:13:05 +0800 CST
  • Martin Hope
    God I Hate Python std::views::filter do C++20 não filtrando a visualização corretamente 2023-08-27 18:40:35 +0800 CST
  • Martin Hope
    LiDa Cute Por que 'char -> int' é promoção, mas 'char -> short' é conversão (mas não promoção)? 2023-08-24 20:46:59 +0800 CST
  • Martin Hope
    jabaa Por que o construtor de uma variável global não é chamado em uma biblioteca? 2023-08-18 07:15:20 +0800 CST
  • Martin Hope
    Panagiotis Syskakis Comportamento inconsistente de std::common_reference_with em tuplas. Qual é correto? 2023-08-17 21:24:06 +0800 CST
  • Martin Hope
    Alex Guteniev Por que os compiladores perdem a vetorização aqui? 2023-08-17 18:58:07 +0800 CST
  • Martin Hope
    wimalopaan Somente operações bit a bit para std::byte em C++ 17? 2023-08-17 17:13:58 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve