【实时同步处理与分析设备采集信息】

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class DeviceDataProcessor {

    private BlockingQueue<DeviceData> dataQueue;

    public DeviceDataProcessor() {
        this.dataQueue = new LinkedBlockingQueue<>();
    }

    public void addData(DeviceData data) {
        try {
            dataQueue.put(data);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public void startProcessing() {
        while (true) {
            try {
                DeviceData data = dataQueue.take();
                process(data);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    private void process(DeviceData data) {
        // 解析和分析数据的具体逻辑
        // 生成异常信息和单设备信息记录
        // 记录采集数据的ID
        System.out.println("Processing data: " + data.getId());
    }

    public static void main(String[] args) {
        DeviceDataProcessor processor = new DeviceDataProcessor();

        // 模拟数据采集并添加到处理队列中
        new Thread(() -> {
            for (int i = 1; i <= 10; i++) {
                DeviceData data = new DeviceData(i, "Device " + i, System.currentTimeMillis());
                processor.addData(data);
                try {
                    Thread.sleep(1000); // 模拟数据采集的间隔
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();

        // 开始处理数据
        processor.startProcessing();
    }
}

class DeviceData {
    private int id;
    private String deviceName;
    private long timestamp;

    public DeviceData(int id, String deviceName, long timestamp) {
        this.id = id;
        this.deviceName = deviceName;
        this.timestamp = timestamp;
    }

    public int getId() {
        return id;
    }

    public String getDeviceName() {
        return deviceName;
    }

    public long getTimestamp() {
        return timestamp;
    }
}