使用多线程遇到的bug_nginx 多线程 bug

作者：盐析白兔 | 2024-06-15 05:31:53

踩

nginx 多线程 bug

应用场景

从kafka消费数据，每批次消费启用一个spring 异步处理，将数据保存到MongoDB，监控某个字段，和上条数据对比，值是否发生改变

原先方法：

Async1:

收到第一条数据A1存到MongoDB

收到第二条数据A2，存入到MongoDB，根据时间查询MongoDB中最新的一条，跟A2做对比

Async2:

收到第一条数据A3存到MongoDB

收到第二条数据A4，存入到MongoDB，根据时间查询MongoDB中最新的一条，跟A2做对比

.....................................................................

问题，如果在单线程中可行，但kafka消费中可能启动了n个异步任务，本来A2需要和A1对比，但A3在对比之前也可能插入MongoDB了，这样查出的最新可能就是A3

解决方法：如果对比A2，查询时间小于A2的最新一条数据

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop博客】