Redis（生菜）总是发布到单线程

Question

此外，对于一个粗心大意的开发人员来说，当前的行为难道不危险吗？也许应该稍微调整一下默认值。我认为理想的场景是Lettuce可以重用WebFlux中的相同事件循环。

我添加了这个spring boot单类代码片段，可以用来重现我所描述的内容：

@SpringBootApplication
public class ReactiveApplication {
    public static void main(String[] args) {
        SpringApplication.run(ReactiveApplication.class, args);
    }
}

@Controller
class TestController {

    private final RedisReactiveCommands<String, String> redis = RedisClient.create("redis://localhost:6379").connect().reactive();

    @RequestMapping("/test")
    public Mono<Void> test() {
        return redis.exists("key")
            .doOnSubscribe(subscription -> System.out.println("\nonSubscribe called on thread " + Thread.currentThread().getName()))
            .doOnNext(aLong -> System.out.println("onNext called on thread " + Thread.currentThread().getName()))
            .then();
    }

}

如果继续调用/testendpoint，将得到以下输出：

onSubscribe called on thread reactor-http-nio-2
onNext called on thread lettuce-nioEventLoop-4-1

onSubscribe called on thread reactor-http-nio-3
onNext called on thread lettuce-nioEventLoop-4-1

onSubscribe called on thread reactor-http-nio-4
onNext called on thread lettuce-nioEventLoop-4-1

Answer 1

这是一个极好的问题！

Lettuce总是使用绑定到netty通道的I/O线程发布。这可能适合也可能不适合您的工作量。

Redis是单线程的，因此保持单个TCP连接是有意义的。Netty的线程模型是所有I/O工作都由绑定到通道的EventLoop线程处理。因为这个星座，你在同一线程上接收所有的反应信号。使用具有各种选项的各种反应序列对影响进行基准测试是有意义的。

这种责任的双重性（完成命令、执行I/O）可能会对计算量更大的工作负载产生一定的影响，从而降低I/O的性能。

额外资源：

• 研究响应线程切换#905。