JBoss Data Grid 不仅是一个可扩展的内存数据网格，而且还有许多强大的功能，这些功能在存储数据之外的不同场景中都很有用。在本系列或文章中，我们将仔细研究具有多个实际用例的可扩展事件。我们将看到如何使用数据网格中的事件来扩展 websocket，或者如何在基于事件的集成场景中使用它。首先，我们将从 JBoss 数据网格中的事件侦听器概览开始。
听众概述
JBoss 数据网格有两种主要类型的侦听器，一种是在数据网格嵌入应用程序运行时使用（也称为库模式），一种是简单的事件侦听器。另一种类型在数据网格运行在与应用程序不同的进程中时使用（也称为远程模式），称为远程事件侦听器。
数据库触发器和远程事件侦听器之间的一个主要区别是，在后一种替代方案中，任意代码在客户端而不是在数据库内部执行。
远程事件监听器
远程事件侦听器是 Hot Rod 的一项功能，这意味着它被设计用于客户端/服务器模式，在该模式下，数据网格在与客户端不同的进程中运行。然而，在嵌入式模式下也有监听器，但为了清楚起见，我们将只关注远程监听器以作为本文的提醒。
Hot Rod 客户端支持以下事件：
- 已创建缓存条目
- 缓存条目已修改
- 缓存条目已删除
创建事件监听器非常简单，只需要两步：
创建一个客户端事件监听器类
package ...;
import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated;
import org.infinispan.client.hotrod.annotation.ClientListener;
import org.infinispan.client.hotrod.event.ClientCacheEntryCreatedEvent;
import org.jboss.logging.Logger;
@ClientListener
public class MessageListener {
private Logger logger = ...
@ClientCacheEntryCreated
public void handleCreated(ClientCacheEntryCreatedEvent<String> e) {
logger.info(String.format("Received Cache Event of type %s with key %s", e.getType().toString(), e.getKey()));
}
}
在缓存中注册你的事件监听器，
package ...;
import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated;
import org.infinispan.client.hotrod.annotation.ClientListener;
import org.infinispan.client.hotrod.event.ClientCacheEntryCreatedEvent;
import org.jboss.logging.Logger;
@ClientListener
public class MessageListener {
private Logger logger = ...
@ClientCacheEntryCreated
public void handleCreated(ClientCacheEntryCreatedEvent<String> e) {
logger.info(String.format("Received Cache Event of type %s with key %s", e.getType().toString(), e.getKey()));
}
}
每当这个或另一个数据网格的客户端存储一个新条目（即使用 put 或 putIfAbsent）时，MessageListener 将被执行并打印日志语句。
过滤事件
如果预期的工作负载有利于写入而不是读取，则可能需要过滤发送到客户端的事件以防止生成大量过多的流量。我们将在后面的文章中介绍如何过滤事件，但由于过滤器是在服务器端执行的，这意味着我们必须将逻辑部署到数据网格服务器。
自定义远程事件
出于性能原因，事件默认仅包含键和事件类型（创建、修改或删除）。但是，如果所有消耗的事件都将使用该值，那么还包含该事件的值可能会更有效。请注意，与默认事件相比，自定义事件具有更大的事件负载。
在下一部分中，我们将仔细研究可以使用可扩展事件的示例用例。