java - 实现支持衰老系列的最佳方式-6ren

java - 实现支持衰老系列的最佳方式

转载作者：行者123 更新时间：2023-12-01 18:45:27

我正在寻找使用 Java 处理以下问题集的最佳方法的想法。在这种情况下最好强调性能。

假设我们有许多银行分行。每个分支都有一个带有传感器的保险库，每当门的状态发生变化时，传感器就会向服务器发送一条消息(在本例中使用 UDP)。

服务器上有某种类型的集合，用于存储从传感器发送的每条消息。当代码收到消息时，它会插入一个事件(“开门分支 1”)。当传感器发送后续消息(“门关闭分支 1”)时，该消息将从集合中删除。每条消息都与时间戳一起存储在集合中。

我们想要的是当消息在集合中的时间超过指定的耗时(例如 2 分钟)时调用一个方法。在此用例中，“金库门已打开超过 2 分钟，请报警”。

最明显的解决方案是一个线程 hibernate 2 分钟，唤醒并运行集合检查时间戳。看起来很简单，但不确定这是否是处理问题的更有效的方法。它还需要并发收集，这不是问题。

在现实世界中，该集合需要处理大约 50K 条或更少的消息。

关于如何处理这个问题还有其他想法吗？在这种情况下是否有任何类(class)可以提供帮助。

谢谢

最佳答案

您可以使用一个或多个 DelayQueue来完成这个任务。

public static class BankCheck implements Delayed {
    private static final long delay = TimeUnit.NANOSECONDS.convert(2, TimeUnit.MINUTES);
    private final long created = System.nanoTime();
    private final Bank bank;

    public BankCheck(Bank bank) {
        this.bank = bank;
    }

    public Bank getBank() {
        return bank;
    }

    @Override
    public int compareTo(Delayed o) {
        if (o instanceof BankCheck) {
            BankCheck bc = (BankCheck) o;
            if (created == bc.created) {
                return 0;
            } else {
                return created < bc.created ? -1 : 1;
            }
        }

        long d = getDelay(TimeUnit.NANOSECONDS) - o.getDelay(TimeUnit.NANOSECONDS);
        if (d == 0) { return 0; }
        return d < 0 ? -1 : 1;
    }

    @Override
    public long getDelay(TimeUnit unit) {
        long elapsed = System.nanoTime() - created;
        long remaining = delay - elapsed;
        return remaining > 0 ? unit.convert(remaining, TimeUnit.NANOSECONDS) : 0;
    }
}

BlockingQueue<BankCheck> queue = new DelayQueue<>();

Thread messageReceiver = new Thread(new Runnable() {
    @Override
    public void run() {
        for(;;) {
            if(messageReceived) {
                queue.add(new BankCheck(getBankFromLastMessage()));
            }
        }
    }
}).start();
Thread bankChecker = new Thread(new Runnable() {
    @Override
    public void run() {
        try {
            for(;;) {
                Bank b = queue.take().getBank();
                if(!hasBeenClosed(b) {
                    alertAuthorities(b);
                }
            }
        } catch(InterruptedException e) {
            // handle exception
        }
    }
}).start();