Netty通过无锁串行化设计实现高性能并发处理，其核心是将每个Channel绑定到特定EventLoop，由单线程串行处理所有事件。这种设计避免了多线程竞争和锁开销，通过事件队列机制保证同一Channel的操作始终在同一线程执行。代码示例展示了NioEventLoopGroup和ChannelPipeline的创建过程，其中每个ChannelHandler都在绑定EventLoop的线程中运行，确

Kafka通过多重机制确保消息"不重不丢"：采用副本机制防止数据丢失，通过位移记录避免重复消费；生产者使用确认机制和幂等性发送，消费者通过自动提交位移保证精准消费。示例代码展示了Java实现的Kafka生产者和消费者，生产者每1秒发送一条消息，消费者持续轮询并处理消息，通过位移跟踪实现可靠消费。这些机制共同保障了消息的可靠传递和精确消费。

综上所述，Kafka通过合理的分区设计、生产者端的消息幂等性配置、Broker端的写入确认机制以及消费者端的单线程或多线程（带内存队列）消费策略，共同保证了消息的顺序性。这些机制相互协作，使得Kafka成为了一个高效、可靠且易于扩展的分布式消息系统。

摘要：本文系统解析了同步/异步、阻塞/非阻塞两组正交维度的四种组合模式。同步关注结果主动获取，异步依赖回调通知；阻塞会挂起线程，非阻塞允许线程继续执行。重点分析了同步阻塞（如Java BIO）、同步非阻塞（如NIO轮询）、异步阻塞（不合理模式）和异步非阻塞（如Netty）的特点、流程及应用场景。强调异步非阻塞是高并发终极方案，并提供了面试应答策略：先厘清维度区分，结合技术栈（NIO/AIO）和业务

问题原因，通过feignClient进行远程调用的时候，被调用的服务和调用服务的返回值不同。这里我们只是为了简单测试，就把FeignCient的返回值改为String了。

显然不符合预期，后面只要有一个OR成立，则整个整理，前面的passenger_id 就变成了被忽略的条件，不会真正用来过滤。打印出来的SQL语句。那代码里如何实现呢？