kaiyu
2021-09-02 bdfebb42f054802d6bc50b005a16ab4b03456d0c
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) {