From 5e945858fb85c874050ac803968c415c50b4662f Mon Sep 17 00:00:00 2001 From: "review512jwy@163.com" <“review512jwy@163.com”> Date: Sun, 12 Jul 2026 10:45:28 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datacenter/receiver/listener/RedisStreamConsumer.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java index 1a86b7e..79f3c20 100644 --- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java +++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java @@ -13,6 +13,7 @@ import org.springframework.data.domain.Range; import org.springframework.data.redis.connection.stream.*; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; +import org.springframework.scheduling.concurrent.CustomizableThreadFactory; import org.springframework.stereotype.Component; import java.net.InetAddress; @@ -34,6 +35,8 @@ public class RedisStreamConsumer { @Resource private DataCenterEnvConfig dataCenterEnvConfig; + private static final Gson gson = new Gson(); + private static final int PARTITIONS = 16; private static final String STREAM_PREFIX = "aeon_tcp_stream_"; private static final String GROUP = "aeon_tcp_stream_consumer_group"; @@ -56,7 +59,7 @@ public class RedisStreamConsumer { private final LongAdder receiveCounter = new LongAdder(); private final ExecutorService consumerExecutor = - Executors.newFixedThreadPool(PARTITIONS); + Executors.newFixedThreadPool(PARTITIONS, new CustomizableThreadFactory("redis-stream-consumer-")); private final ExecutorService workerExecutor = new ThreadPoolExecutor( @@ -242,10 +245,9 @@ public class RedisStreamConsumer { /** * ===== 业务逻辑 ===== */ - Gson gson = new Gson(); String jsonParams = gson.toJson(body); MyHTTPResponse response = this.defaultHttpRequestUtil.postJson(dataCenterEnvConfig.getF10ApiUrl(), jsonParams); - if (response.getCode() == 200) { + if (response != null && response.getCode() == 200) { log.info("[F10] F10 data sent successfully: {}", jsonParams); } else { log.error("[F10] F10 data sent failed....");