342 Commits

Author SHA1 Message Date
40924e921f 提交代码 2025-04-19 13:57:08 +08:00
40b62caa83 解决合并冲突 2025-04-19 00:37:36 +08:00
2612cd5d0b 调整kafka结构 2025-04-19 00:35:21 +08:00
270abd656f 优化kafka解决订阅回调参数问题
订阅调整为批量订阅
2025-04-19 00:30:58 +08:00
ChenYi
fe51402b1f 完成电表定时抄读 2025-04-18 17:46:24 +08:00
ChenYi
6c2560669e 优化任务数据格式 2025-04-18 11:31:23 +08:00
cli
dc7416bdbf 去除CAP 和 MassTransit 2025-04-18 09:50:00 +08:00
a7602cde86 Merge pull request 'dev' (#2) from dev into master
Reviewed-on: daizan/JiShe.CollectBus#2
2025-04-18 01:31:49 +00:00
e6327a57df 合并代码 2025-04-18 09:29:38 +08:00
17b73b6a2a Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-18 09:29:03 +08:00
cb36fc463a 移除测试日志 2025-04-18 09:28:48 +08:00
cli
7704c6374e 修改gitignore 2025-04-18 08:33:15 +08:00
cli
26e361075d 修改忽略配置 2025-04-18 08:31:34 +08:00
c93feb631d 订阅特性优化 2025-04-18 08:23:31 +08:00
02d189358e 订阅消费暂时取消缓存消费实例 2025-04-18 08:22:52 +08:00
ca1e4e28e5 优化代码 2025-04-17 22:21:34 +08:00
db6e314aca 调整代码结构 2025-04-17 20:28:50 +08:00
444b01095f Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-17 19:41:43 +08:00
532acc575f 优化kafka 订阅增加判断时间分区数是否大于配置数 2025-04-17 19:41:09 +08:00
cli
19bc05c601 Merge branch 'cassandra' into dev 2025-04-17 18:45:15 +08:00
f11e514ef4 Merge branch 'dev' into zhy_feat_dev_v2 2025-04-17 18:09:21 +08:00
c4d4078bd9 Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-17 18:08:48 +08:00
b064ff3d14 代码修改 2025-04-17 18:08:27 +08:00
ChenYi
ac546dd029 Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-17 17:23:23 +08:00
ChenYi
3020a49672 提交代码 2025-04-17 17:23:20 +08:00
cli
76ae008e01 合并冲突 2025-04-17 16:21:42 +08:00
cli
f1082ce8a2 修改为缓存读取 2025-04-17 16:19:46 +08:00
cli
e91db2d0d4 修改配置文件 2025-04-17 16:10:47 +08:00
cli
73c12e5160 Merge remote-tracking branch 'origin/dev' into cassandra 2025-04-17 16:09:19 +08:00
ChenYi
d002472854 移除无用代码,减少Kafka订阅线程数量 2025-04-17 15:49:57 +08:00
48b91183c2 增加测试主题 2025-04-17 15:06:30 +08:00
0ba64a4b90 优化发布订阅 2025-04-17 14:39:14 +08:00
ChenYi
871ed615a4 提交代码 2025-04-17 14:12:02 +08:00
0584515df9 Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-17 13:56:25 +08:00
72f8222ec2 kafka消费者订阅增加批量消费 2025-04-17 13:56:17 +08:00
ChenYi
902993e481 Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-17 13:55:18 +08:00
ChenYi
6c0ce01634 优化Kafka配置项获取 2025-04-17 13:54:18 +08:00
4c5f7231bf 删除未多余的配置类 2025-04-17 13:41:53 +08:00
26ffffa233 调整kafka自动注册消费者 2025-04-17 13:41:18 +08:00
ChenYi
6c8ffb3ae5 修改代码 2025-04-17 13:35:08 +08:00
96e066376f 增加kafka订阅自动取程序所有的订阅者 2025-04-17 13:01:26 +08:00
fa18377f10 提交代码 2025-04-17 11:53:29 +08:00
33feb60e46 Merge branch 'zhy_feat_dev_v1' into dev 2025-04-17 11:43:30 +08:00
8fd5f985ab 暂存 2025-04-17 11:42:35 +08:00
ChenYi
c97634e474 合并代码,解决冲突 2025-04-17 11:41:46 +08:00
ChenYi
13e986168e 百万级的任务数据集中器所在分组单独保存 2025-04-17 11:29:26 +08:00
ChenYi
4737c5b53d 优化代码 2025-04-17 09:10:01 +08:00
ChenYi
cadb69f4b9 将10万Redis的Hash表数据读取优化到13秒以内。 2025-04-17 08:29:32 +08:00
ChenYi
78127f7cea 解决Redis大批量数据读取总数不准的问题,并将10万记录读取时间控制在23秒以内。 2025-04-17 08:20:54 +08:00
ChenYi
849e0f9ac2 修改代码 2025-04-16 23:51:27 +08:00