如何在最先进的 MDB 中进行统计收集？

Question

我有多个 MDB（以及大量 mdb 实例）作为消息的使用者。我必须收集这些 Bean 内的某些统计信息，并每 X（当前为 30）秒将它们发送到 JMS 目的地。

可以在 bean 本身中执行此操作吗？

例如：bean 在本地收集数据并具有使用 @Scheduled 注释的 writeStatistic() 方法。

是否可以集中进行统计工作？

中央 bean 从所有 bean 实例收集所有统计数据并将其发送。如果可以的话，怎样才能做到呢？

编辑

我通过编写一个单例会话 bean 解决了我的任务，如下所示：

@Singleton
@Startup
@ConcurrencyManagement(ConcurrencyManagementType.BEAN)
@Asynchronous
public class StatisticsCollector {

    private ConcurrentMap<Integer, ConcurrentMap<String, AtomicInteger>> statistics = new ConcurrentHashMap<Integer, ConcurrentMap<String, AtomicInteger>>();

    public void trackDatum(int projectId, String property, int increment) {
        LOG.debug("Tracking datum: project: " + projectId + ", property: " + property + ", increment: " + increment);

        // get statistics for project
        ConcurrentMap<String, AtomicInteger> productstats;
        if (!statistics.containsKey(projectId)) {
            synchronized (statistics) {
                if (!statistics.containsKey(projectId)) {
                    productstats = new ConcurrentHashMap<String, AtomicInteger>();
                    statistics.put(projectId, productstats);
                } else {
                    productstats = statistics.get(projectId);
                }
            }
        } else {
            productstats = statistics.get(projectId);
        }

        // get current counter for property
        AtomicInteger value;
        if (!productstats.containsKey(property)) {
            synchronized (productstats) {
                if (!productstats.containsKey(property)) {
                    value = new AtomicInteger();
                    productstats.put(property, value);
                } else {
                    value = productstats.get(property);
                }
            }
        } else {
            value = productstats.get(property);
        }

        // increment
        value.addAndGet(increment);
    }

    @Schedule(minute = "*", hour = "*", second = "*/30", persistent = false)
    public void sendStatistics() {
        // send statistics to remote consumer via JMS
    }
}

我自己进行了并发管理，因为我想从 bean 中获得尽可能多的性能。

Answer 1

可以在 bean 本身中执行此操作吗？

我想你的意思是：

@MessageDriven(...)
public MDBean implements MessageListener {
     private Statistic statisticForThisBean;
     // ...

     @Timeout
     public void sendStatisticForThisBean() {
         // ...
     }
}

这当然不是一个选择。无法保证带有 @Timeout 注释的方法将针对所有 bean 实例完全运行，更不用说您要求每 30 秒运行一次了。超时方法在 MDB 的空闲实例之一上运行，并且容器选择它。

是否可以集中进行统计工作？

就我个人而言，我会这样做：让所有 MDB（所有实例）在其处理逻辑结束时将部分统计信息发送到队列。我将编写一个单独的组件，该组件将：

• 仅存在于一个实例中，在
• 30 秒内（循环）收集统计队列中的所有消息，生成摘要，然后将其发送到最终目的地，然后重新启动。

“组件”可以是计时器任务，也可以是单独的独立应用程序。

另一种可能的解决方案可能是单个有状态 bean，MDB 将依次调用该 bean 来更新统计信息。但是，存在以下限制：

• 很可能会导致性能问题，除非 SFSB 方法调用速度很快（即统计数据不复杂时），否则
• 它无法异步运行，因此无法保证调用之间的 30 秒跨度到统计收集引擎；如果 JMS 流量完全停止，那么 SFSB 也将停止响应。