screen-manage kafka消费者添加判断mac功能

kaiyu

2021-07-14 1052b3f30916f86415ecdab45158afc71bdfb188

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

@@ -36,8 +36,11 @@
        CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
        for (SingleDeviceServer socket : sockets) {
            //判断消息书否数据该socket
            //取出基本信息
            String messageMac = (String) message.get("mac");
            String mac = socket.getMac();
            if(!mac.equals(messageMac))
                return;
            //取出基本信息
            Map<String, Device> devicesInfo = socket.getDevicesInfo();
            Device device = devicesInfo.get(mac);
            //创建最终消息对象