债务人报告预览

批次+债务人+不同sku:存redis,设置过期时间

数据采集完毕生成报告文件存OSS,设置版本号

根据批次+债务人+报告文件来维护版本号

前端查询时,没有采集完成就从Redis获取数据,采集完成就直接从OSS获取

记录 / 2025-12-07

多线程数据采集

//全部采集完成的债务人

SetdebtorsCompleted = ConcurrentHashMap.newKeySet();

//全部未开始采集的债务人

SetdebtorsUncompleted = ConcurrentHashMap.newKeySet();

//债务人正在采集中的sku

SetexistKeySet = getCompletingSkus(debtorBatchList);

Lis...

记录 / 2025-11-05

RocketMQ使用注意事项

生产者:

1.Producer Group 唯一且固定

2.发送超时配置

3.消息大小限制

4.消息发送方式

消费者:

1.Consumer Group 管理

2.消费模式

3.消费重试机制

4.消费幂等性

MQ配置:

1.消息存储路径(持久化)

2.Broker 参数调优(broker.conf)

3.NameServer 高可用(至少部署 2 个 NameServer)

4.Topic 管理(Topic 应该提前创建)

记录 / 2025-10-18
皖ICP备2025092356号-1 | 沪公网安备31011202021249号