screen-api 添加从kafka取出时间戳

kaiyu

2021-07-14 f8c2609bca86f6e4a2acd2e92a7eae29b86c2070

screen-api
                 添加从kafka取出时间戳

 screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java

@@ -29,10 +29,11 @@
@Component
public class SecondDataConsumer implements ConsumerSeekAware {

    @KafkaListener(topics = "second_data", groupId = "SecondsDataGroup997")
    @KafkaListener(topics = "second_data", groupId = "SecondsDataGroup996")
    public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception {
        String messageStr = record.value();
        Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr);
        long serverStartTime = System.currentTimeMillis();
        CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
        for (SingleDeviceServer socket : sockets) {
            //判断消息书否数据该socket
@@ -84,6 +85,7 @@
            resultMessgae.put("time",message.get("time"));
            resultMessgae.put("time1",message.get("time1"));
            resultMessgae.put("serverTime",System.currentTimeMillis());
            resultMessgae.put("serverStartTime",serverStartTime);
            socket.sendMessage(JSON.toJSONString(resultMessgae));
        }
    }