From 0dab86f0b8b8ee2d735362a3336eb95f69650d10 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期五, 19 四月 2024 10:22:34 +0800
Subject: [PATCH] 临时提交
---
src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java b/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java
index e3617a7..9746c2e 100644
--- a/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java
+++ b/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java
@@ -14,6 +14,7 @@
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;
@@ -151,6 +152,7 @@
public RedisRpcResponse request(RedisRpcRequest request, int timeOut) {
request.setSn((long) random.nextInt(1000) + 1);
SynchronousQueue<RedisRpcResponse> subscribe = subscribe(request.getSn());
+
try {
sendRequest(request);
return subscribe.poll(timeOut, TimeUnit.SECONDS);
@@ -209,4 +211,10 @@
public int getCallbackCount(){
return callbacks.size();
}
+
+ @Scheduled(fixedRate = 1000) //姣�1绉掓墽琛屼竴娆�
+ public void execute(){
+ System.out.println("callbacks鐨勯暱搴�: " + callbacks.size());
+ System.out.println("闃熷垪鐨勯暱搴�: " + topicSubscribers.size());
+ }
}
--
Gitblit v1.8.0