Skip to content

Commit 56e9084

Browse files
committed
feat(redis):优化Redis会话命令写入机制- 引入WriteBuffer依赖以支持高效数据写入
-重构RedisSession构造函数,接受WriteBuffer参数 - 新增writeCommand方法处理命令写入和并发控制 - 实现基于信号量的命令队列处理机制 - 添加Tuple内部类用于存储命令和Future的组合 - 移除旧的计数器逻辑,简化会话管理流程- 在RedisMessageProcessor中调用flush确保数据及时发送
1 parent 2eb4c27 commit 56e9084

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

src/main/java/tech/smartboot/redisun/RedisSession.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,6 @@ public void flush() {
9898
try {
9999
Tuple tuple;
100100
while ((tuple = commandQueue.poll()) != null) {
101-
offerCount++;
102101
pipeline.offer(tuple.future);
103102
tuple.command.writeTo(writeBuffer);
104103
}

0 commit comments

Comments
 (0)