如何配置Spring Integration以使用多线程从Redis读取？

Question

我正在创建一个int-redis:queue-inbound-channel-adapter，其中包含一个executor-task，pool-size=500和queue-capacity=0。

<redis:queue-inbound-channel-adapter
            id="fromRedis" channel="privateAggregationExecutorChannel" queue="${instance}_private"
            receive-timeout="1000" recovery-interval="3000" expect-message="false" error-channel="distributionErrors"
            auto-startup="false" task-executor="robotTaskExecutor"/>

<task:executor
            id="robotTaskExecutor"
            pool-size="500"
            queue-capacity="0"
            keep-alive="50"
            rejection-policy="CALLER_RUNS" />

<int:service-activator input-channel="privateAggregationExecutorChannel" ref="aggregationExecutor" method="run" />

我不知道我做错了什么，也不知道我是否遗漏了什么。我很感激你的帮助。

Answer 1

没错。RedisQueueMessageDrivenEndpoint实际上是单线程组件：

@Override
protected void doStart() {
    if (!this.active) {
        this.active = true;
        this.restart();
    }
}

private void restart() {
    this.taskExecutor.execute(new ListenerTask());
}

正如您所看到的，只有一个ListenerTask从这个通道适配器被调度。

为了使它是多线程的，最好有一个executorchannel来从这个通道适配器发送消息。这样，即使RedisQueueMessageDrivenEndpoint是单线程处理，您仍然可以使用多线程处理。