37 Commits

Author SHA1 Message Date
qhd
0a38df71c9 refactor: 将分布式锁从 redis 迁移至 utils 包 2026-03-27 09:49:43 +08:00
qhd
ee6d3c9033 重构消息队列模块,新增NATS和RabbitMQ连接实现,移除旧版消息队列代码 2026-03-12 08:51:45 +08:00
Cold
65b231b88f 更新对gateway的匹配 2026-03-12 08:51:38 +08:00
Cold
1fcaeae3b0 更新redis调用 2026-03-12 08:51:38 +08:00
Cold
4d6aa1f384 修复redis和queueprocessor 2026-03-12 08:51:28 +08:00
Cold
138b81640c 2026-03-12 08:51:28 +08:00
Cold
1fe3f127c3 更新redis重试三次,http方法兼容ragflow格式 2026-03-12 08:51:28 +08:00
Cold
a068e95017 修复redis.go中残留的consts引用 2026-03-12 08:51:25 +08:00
Cold
4269b4fd79 feat: HTTP模式支持 - 优化Stream消费逻辑,添加pending消息优先读取 2026-03-12 08:51:20 +08:00
qhd
38ae9edd54 redis消费队列接口优化 2026-03-12 08:51:17 +08:00
qhd
836460306e mongo数据库增加是否重缓存查询数据,增加随机修改删除状态接口;redis增加-队列消息读取封装方法 2026-03-12 08:51:17 +08:00
cc67dd2485 修改限流 2026-03-12 08:51:17 +08:00
qhd
c80ecb19e4 mongo数据库增加是否重缓存查询数据,增加随机修改删除状态接口;redis增加-队列消息读取封装方法 2026-03-12 08:51:17 +08:00
qhd
c342345c0b redis Lock方法 增加-锁重试次数耗尽返回信息 2026-03-12 08:51:17 +08:00
6c9e8b125a common/redis增加Lock方法, 2026-03-12 08:51:17 +08:00
a464e4187a common/redis增加Lock方法, 2026-03-12 08:51:17 +08:00
c4b4cfe50f common/redis增加Lock方法, 2026-03-12 08:51:17 +08:00
Cold
7e3b0362d9 修改轮询为阻塞消息 2026-03-12 08:51:17 +08:00
Cold
ecf3c29759 提交5个文件, 修改了mongo方法, 如果token获取错误, 然后获取完租户id后, 把错误清除 2026-03-12 08:51:17 +08:00
Cold
3683aae9af session缓存方法(tenantId+userId隔离) 2026-03-12 08:51:17 +08:00
Cold
7c103a1d1d redis 缓存方式修改 2026-03-12 08:51:17 +08:00
Cold
2a31e3faac 将go Httpserver.Run() 挪到 routeregister方法 2026-03-12 08:51:17 +08:00
Cold
7381d57b77 完成websocket对话演示和main方法的功能抽离 2026-03-12 08:51:15 +08:00
Cold
53c3392227 服务器准备 2026-03-12 08:51:13 +08:00
Cold
8823f54370 话术redis更新 2026-03-12 08:51:13 +08:00
Cold
03aef62184 第五次对话发卡片, 用redis记录卡片次数 2026-03-12 08:51:13 +08:00
Cold
5e3a7f30f7 增加es归档 分布式和constants变量 2026-03-12 08:51:07 +08:00
Cold
43a8834c5a 不同服务注册不同组件模块 2026-03-12 08:51:05 +08:00
Cold
87b3ac9878 连接池,redis,和配置文件 2026-03-12 08:51:00 +08:00
Cold
4b2b5e6177 重构了一下 rag的方法, 使用 goframe的框架, 还有redis连接部分 2026-03-12 08:51:00 +08:00
Cold
f7cb007491 协程池单例模式 2026-03-12 08:51:00 +08:00
Cold
86661c687a map预分配容量避免动态扩容,优化了返回值复用情况 2026-03-12 08:51:00 +08:00
Cold
15ce1cf345 使用 gtime设置redis时间戳 2026-03-12 08:51:00 +08:00
Cold
70b8b7b1d0 更改 redis方法 2026-03-12 08:51:00 +08:00
Cold
01999b56a4 redis使用stream方式 2026-03-12 08:50:59 +08:00
Cold
3f4ac12f52 redis 2026-03-12 08:50:55 +08:00
eed57aa41a token失效错误返回 2026-03-12 08:50:52 +08:00