关于java:Spring认证中国教育管理中心Apache-Geode-的-Spring-数据教程十九

原题目：Spring 认证中国教育管理中心 -Apache Geode 的 Spring 数据教程十九（Spring 中国教育管理中心）

Spring 认证中国教育管理中心 -Apache Geode 的 Spring 数据教程十九
7.5. 应用 @TransactionalEventListener
应用事务时，可能须要注册一个侦听器，以便在事务提交之前或之后或产生回滚之后执行某些操作。

Spring Data for Apache Geode 使创立侦听器变得容易，这些侦听器将在具备 @
TransactionalEventListener 正文的事务的特定阶段被调用。带正文的办法 @TransactionalEventListener（如下所示）将在指定的被告诉从事务办法公布的事件的，phase。

事务提交后事件侦听器

@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void handleAfterCommit(MyEvent event) {

// do something after transaction is committed

}
为了调用上述办法，您必须从事务中公布一个事件，如下所示：

公布交易事件

@Service
class MyTransactionalService {

@Autowired
private final ApplicationEventPublisher applicationEventPublisher;

@Transactional
public <Return-Type> someTransactionalServiceMethod() {

// Perform business logic interacting with and accessing multiple transactional resources atomically, then...

applicationEventPublisher.publishEvent(new MyApplicationEvent(...));

}

…
}
该 @
TransactionalEventListener 注解容许你指定交易 phase 在事件处理办法将被调用。选项包含：AFTER_COMMIT，AFTER_COMPLETION，AFTER_ROLLBACK，和 BEFORE_COMMIT。如果未指定，则 phase 默认为 AFTER_COMMIT。如果您心愿即便不存在事务也能调用侦听器，您能够设置 fallbackExecution 为 true。

7.6. 主动交易事件公布
从 Spring Data for Apache Geode 开始 Neumann/2.3，当初能够启用主动事务事件公布。

应用 @
EnableGemfireCacheTransactions 正文，将 enableAutoTransactionEventPublishing 属性设置为 true。默认值为 false。

启用主动交易事件公布

@EnableGemfireCacheTransactions(enableAutoTransactionEventPublishing = true)
class GeodeConfiguration {…}
而后，您能够创立带 @
TransactionalEventListener 正文的 POJO 办法来处理事务阶段 AFTER_COMMIT 或 AFTER_ROLLBACK 事务阶段的事务事件。

@Component
class TransactionEventListeners {

@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void handleAfterCommit(TransactionApplicationEvent event) {...}

@TransactionalEventListener(phase = TransactionPhase.AFTER_ROLLBACK)
public void handleAfterRollback(TransactionApplicationEvent event) {...}

}
仅反对
TransactionPhase.AFTER_COMMIT 和 TransactionPhase.AFTER_ROLLBACK。TransactionPhase.BEFORE_COMMIT 不反对，因为 1) SDG 适配了 Apache GeodeTransactionListener 和 TransactionWriter 接口来实现主动事务事件公布，以及 2) 当 Apache Geode TransactionWriter.beforeCommit(:TransactionEvent) 被调用时，它曾经在 AbstractPlatformTransactionManager.triggerBeforeCommit(:TransactionStatus)调用之后，@TranactionalEventListener 在事务生命周期中调用带正文的 POJO 办法。

应用主动事务事件公布，您无需
applicationEventPublisher.publishEvent(..) 在应用程序 @Transactional @Service 办法中显式调用该 办法。

然而，如果您依然心愿在“提交之前”接管事务事件，那么您依然必须
applicationEventPublisher.publishEvent(..) 在您的应用程序 @Transactional @Service 办法中调用该 办法。

7.7. 间断查问 (CQ)
Apache Geode 提供的一项弱小性能是 间断查问（或 CQ）。

简而言之，CQ 容许开发人员创立和注册 OQL 查问，而后在增加到 Apache Geode 的新数据与查问谓词匹配时主动收到告诉。Spring Data for Apache Geode 通过
org.springframework.data.gemfire.listener 包及其侦听器容器为 CQ 提供专门的反对；在性能和命名上与 Spring Framework 中的 JMS 集成十分类似；事实上，相熟 Spring 中 JMS 反对的用户应该会有宾至如归的感觉。

基本上，Apache Geode 的 Spring Data 容许 POJO 上的办法成为 CQ 的端点。只需定义查问并批示应调用的办法，以便在匹配时收到告诉。Apache Geode 的 Spring Data 负责其余的工作。这与 Java EE 的音讯驱动 bean 格调十分类似，但对基类或接口实现没有任何要求，基于 Apache Geode。

目前，仅在 Apache Geode 的客户端 / 服务器拓扑中反对间断查问。此外，应用的客户端池须要启用订阅。无关更多信息，请参阅 Apache Geode 文档。

7.7.1. 间断查问侦听器容器
Spring Data for Apache Geode 通过应用 SDG 来解决 CQ 四周的基础设施，简化了 CQ 事件的创立、注册、生命周期和分派，
SDGContinuousQueryListenerContainer 代表用户实现了所有沉重的工作。相熟 EJB 和 JMS 的用户应该会发现相熟的概念，因为它的设计尽可能靠近 Spring Framework 及其音讯驱动的 POJO (MDP) 中提供的反对。

SDGContinuousQueryListenerContainer 充当事件（或音讯）侦听器容器；它用于从注册的 CQ 接管事件并调用注入其中的 POJO。侦听器容器负责音讯接管的所有线程并分派到侦听器中进行解决。它充当 EDP（事件驱动的 POJO）和事件提供者之间的中介，负责 CQ 的创立和注册（接管事件）、资源获取和开释、异样转换等。这容许您作为应用程序开发人员编写与接管事件（并对其做出反馈）相干的（可能很简单）业务逻辑，并将样板 Apache Geode 基础设施问题委托给框架。

侦听器容器是齐全可定制的。开发人员能够抉择应用 CQ 线程来执行分派（同步交付）或通过定义适合的
java.util.concurrent.Executor（或 Spring 的 TaskExecutor）的异步办法的新线程（来自现有池）。依据负载、侦听器的数量或运行时环境，开发人员应该更改或调整执行器以更好地满足她的需要。特地是在托管环境（例如应用服务器）中，强烈建议抉择一个适合的 TaskExecutor 来利用其运行时。

7.7.2. 在 ContinuousQueryListener 与 ContinuousQueryListenerAdapter
该
ContinuousQueryListenerAdapter 班是 Spring 数据为 Apache 的 Geode CQ 反对的最初一个组件。简而言之，类容许您将简直所有实现类公开为具备起码束缚的 EDP。
ContinuousQueryListenerAdapter 实现 ContinuousQueryListener 接口，一个简略的监听器接口，相似于 Apache Geode 的 CqListener。

思考以下接口定义。留神各种事件处理办法及其参数：

public interface EventDelegate {

 void handleEvent(CqEvent event);
 void handleEvent(Operation baseOp);
 void handleEvent(Object key);
 void handleEvent(Object key, Object newValue);
 void handleEvent(Throwable throwable);
 void handleQuery(CqQuery cq);
 void handleEvent(CqEvent event, Operation baseOp, byte[] deltaValue);
 void handleEvent(CqEvent event, Operation baseOp, Operation queryOp, Object key, Object newValue);

}
package example;

class DefaultEventDelegate implements EventDelegate {

// implementation elided for clarity...

}
特地要留神 EventDelegate 接口的上述实现齐全没有 Apache Geode 依赖项。它的确是一个 POJO，咱们能够并且将通过以下配置将其制成 EDP。

该类不用实现接口；一个接口只是用来更好地展现合约和实现之间的解耦。

<?xml version=”1.0″ encoding=”UTF-8″?>
<beans xmlns=”http://www.springframework.org/schema/beans”

   xmlns:gfe="https://www.springframework.org/schema/geode"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="
http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd
https://www.springframework.org/schema/geode https://www.springframework.org/schema/geode/spring-geode.xsd

“>

<gfe:client-cache/>

<gfe:pool subscription-enabled="true">
   <gfe:server host="localhost" port="40404"/>
</gfe:pool>

<gfe:cq-listener-container>
   <!-- default handle method -->
   <gfe:listener ref="listener" query="SELECT * FROM /SomeRegion"/>
   <gfe:listener ref="another-listener" query="SELECT * FROM /AnotherRegion" name="myQuery" method="handleQuery"/>
</gfe:cq-listener-container>

<bean id="listener" class="example.DefaultMessageDelegate"/>
<bean id="another-listener" class="example.DefaultMessageDelegate"/>

…
<beans>
Spring 认证中国教育管理中心 -Apache Geode 的 Spring 数据教程十九
下面的例子展现了听众能够领有的几种不同的模式；至多，须要侦听器援用和理论查问定义。然而，能够为生成的间断查问指定一个名称（用于监督）以及办法的名称（默认为 handleEvent）。指定的办法能够有各种参数类型，EventDelegate 接口列出了容许的类型。

下面的示例应用 Spring Data for Apache Geode 命名空间来申明事件侦听器容器并主动注册侦听器。残缺的 bean 定义如下所示：

<!– this is the Event Driven POJO (MDP) –>
<bean id=”eventListener” class=”org.springframework.data.gemfire.listener.adapter.ContinuousQueryListenerAdapter”>

<constructor-arg>
    <bean class="gemfireexample.DefaultEventDelegate"/>
</constructor-arg>

</bean>

<!– and this is the event listener container… –>
<bean id=”gemfireListenerContainer” class=”org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer”>

<property name="cache" ref="gemfireCache"/>
<property name="queryListeners">
  <!-- set of CQ listeners -->
  <set>
    <bean class="org.springframework.data.gemfire.listener.ContinuousQueryDefinition" >
           <constructor-arg value="SELECT * FROM /SomeRegion" />
           <constructor-arg ref="eventListener"/>
    </bean>
  </set>
</property>

</bean>
Spring 认证中国教育管理中心 -Apache Geode 的 Spring 数据教程十九
每次接管到事件时，适配器都会主动在 Apache Geode 事件和所需的办法参数之间通明地执行类型转换。任何由办法调用引起的异样都会被容器捕捉并解决（默认状况下，被记录）。