|
@@ -2,6 +2,7 @@ package org.jeecg.modules.redission;
|
|
|
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
+import io.netty.channel.nio.NioEventLoopGroup;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.jeecg.modules.system.app.entity.AppOrder;
|
|
import org.jeecg.modules.system.app.entity.AppOrder;
|
|
import org.jeecg.modules.system.app.service.IAppOrderService;
|
|
import org.jeecg.modules.system.app.service.IAppOrderService;
|
|
@@ -59,6 +60,8 @@ public class RedissonDelayQueue {
|
|
}
|
|
}
|
|
//设置连接redis的心跳间隔(30s/次)
|
|
//设置连接redis的心跳间隔(30s/次)
|
|
serverConfig.setPingConnectionInterval(30000);
|
|
serverConfig.setPingConnectionInterval(30000);
|
|
|
|
+ config.useSingleServer();
|
|
|
|
+ config.setEventLoopGroup(new NioEventLoopGroup(16));
|
|
redissonClient = Redisson.create(config);
|
|
redissonClient = Redisson.create(config);
|
|
|
|
|
|
blockingQueue = redissonClient.getBlockingQueue("OrderTimeOutTask");
|
|
blockingQueue = redissonClient.getBlockingQueue("OrderTimeOutTask");
|