kaiyu
2021-09-16 d99988283de685d763df9460e180bdfcc686ac0b
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -39,7 +39,6 @@
    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);
        log.info(message.toString());
        //long serverStartTime = System.currentTimeMillis();
        CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
        for (SingleDeviceServer socket : sockets) {