PROSAGA码农传奇-智能网关-Spring-Integration：QueueChannel

Spring-Integration：QueueChannel

作者: نسر الصحراء
发布时间: 2024-10-18 06:59:32 (15天前)
转自：

<div class =“post-text”itemprop =“text”>
  <P>
    我不确定你的意思是“不阻止”。这对我来说很好......
  </p>
   <pre>
    <code>
      @SpringBootApplication
public class So46973604Application {

private final Logger LOGGER = LoggerFactory.getLogger(So46973604Application.class);

public static void main(String[] args) {
        SpringApplication.run(So46973604Application.class, args).close();
    }

@Bean
    ApplicationRunner runner(Gate gate) {
        return args -> {
            for (int i = 0; i < 20; i++) {
                gate.send("foo");
                LOGGER.info("Sent " + i);
            }
        };
    }

@Bean
    QueueChannel channel() {
        return new QueueChannel(10);
    }

@ServiceActivator(inputChannel = "channel", poller = @Poller(fixedDelay = "0"))
    public void handle(String in) throws InterruptedException {
        Thread.sleep(1_000);
    }

@MessagingGateway(defaultRequestChannel = "channel")
    public interface Gate {

void send(String out);

}

</code>
  </pre>
  <P>
    由于阻塞等待队列空间，前10个立即发送，然后每秒发送一个。
  </p>
  <P>
    如果要阻止呼叫者，为什么觉得需要异步网关？
  </p>
</DIV>