优化事件处理

Question

我在我的java服务器组件中使用Oracle的Coherence缓存。我正在使用以下事件处理程序订阅和侦听缓存更改事件：

public void entryUpdated(MapEvent mapEvent) 
        { 
         processUpdateEvent(mapEvent);
        }

public void entryDeleted(MapEvent mapEvent) 
        {
        //processDeleteEvent(mapEvent);
        } 
    public void entryInserted(MapEvent mapEvent) 
        {
             processInsertEvent(mapEvent);
        } 

有时，我们会在缓存中获得大量的“更新”事件(“删除”或“插入”事件的数量非常少)...and我们当前的java代码似乎没有足够的可伸缩性来处理这种情况。因此，它在事件处理方面落后。

我正在尝试重新设计和优化这段代码。

我想到的一件事就是使用下面的方法。但我认为这是没有意义的，因为它会为每个新事件启动新的线程，这将再次降低服务器的整体性能。有没有其他方法可以优化这段代码？

Thread thread = new Thread(new Runnable() {
                    public void run() {
processUpdateEvent();
                       }
                    });
                thread.start();

谢谢。

Answer 1

coherence侦听器使用单个线程工作，因此唯一可能的解决方案是将事件处理委托给另一个线程，并尽快释放侦听器线程。

优化您的事件驱动架构的一个可能的解决方案要求您进行架构更改:您可以在数据存储节点上注册拦截器，并在主题kafka上编写事件。这样，每个拦截器将只工作一部分事件(只有在同一数据存储节点中创建的事件)，并且您的Kafka消费者池可以配置为高性能和高可用性。

coherence listener方法的另一个风险是您无法获得集群客户端和高可用性客户端。