From 28670b2f0240a33c982818462d4e716fac0c45c2 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Thu, 01 Jul 2021 16:47:42 +0800
Subject: [PATCH] 周数据统计
---
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java | 4 +++-
1 files changed, 3 insertions(+), 1 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
index 6865acf..54fab17 100644
--- a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
+++ b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -19,15 +19,17 @@
* @Date 2021/6/15 14:49
* @Version TODO
**/
-//@Component
+@Component
public class SecondDataConsumer implements ConsumerSeekAware {
@KafkaListener(topics = "second_data",groupId = "SecondsDataGroup3")
public void listen(ConsumerRecord<String, String> record , Consumer consumer) throws Exception {
String messageStr = record.value();
Map<String,String> message = (Map<String,String>)JSON.parse(messageStr);
+ System.out.println(message);
CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
for (SingleDeviceServer socket : sockets) {
+ //���������������������������socket
socket.sendMessage(message.toString());
}
System.out.println(message);
--
Gitblit v1.8.0