Flume学习——Flume中事务的定义

首先要搞清楚的问题是：Flume中的事务用来干嘛？

Flume中的事务用来保证消息的可靠传递。

当使用继承自BasicChannelSemantics的Channel时，Flume强制在操作Channel时采用特定的程序结构，并且强制channel实现特定的方法以使得Channel本身可以应对存入或取出失败的情况，并且使得channel的使用者有可能根据操作是否成功采取适当的方法。

Channel在Flume的架构中主要起了缓存的作用，当使用FileChannel时，它是一个持久化的缓存。

若把Channel类比为数据库，而把Flume的事务类比为数据库事务，那么Flume通过事务来确保Source和Sink采用特定的方式访问Channel，从而保证Channel状态的一致性。比如当一个事务中需要把一个batch的event全放入Channel时，需要确保这个操作是原子的，要不全放进去，要不一个不放。

更高层次、更广范围的事务可以以此为基础构建。

下面是Transaction注释中对Transaction使用的举例：

org.apache.flume.Transaction

 

Provides the transaction boundary while accessing a channel

A Transaction instance is used to encompass channel access via the following idiom:

 Channel ch = ...
 Transaction tx = ch.getTransaction();
 try {
   tx.begin();
   ...
   // ch.put(event) or ch.take()
   ...
   tx.commit();
 } catch (ChannelException ex) {
   tx.rollback();
   ...
 } finally {
   tx.close();
 }

Depending upon the implementation of the channel, the transaction semantics may be strong, or best-effort only.

Transactions must be thread safe. To provide a guarantee of thread safe access to Transactions, see BasicChannelSemantics and BasicTransactionSemantics.

可实现这个的事务语法，需要几个类的合作, 需要这些类有特定的语法。包括Channel的语法和从Channel中获取的Transaction对象的语法。

下面是事务有关的各个类

其中AbstractChannel主要实现了NamedComponent、LifecycleAware和Configurable这几个基本的接口，和事务无关。

BasicChannelSemantics实现在在local-thread中保存一个BasicTransactionSemantics对象的功能。它对Channel接口中take和put方法的实现为：确保当前的线程中有Transaction的一个可用的实例，然后把take和put代理给本线程transaction对象的同名方法。

BasicTransactionSemantics确保了事务相关的操作只有按正确的顺序执行才可以。即tx.begin =》 channel.take/put =》 tx.commit =》  tx.close。它只保证了对Channel操作的顺序，由子类实现doBegin, doTake, doPut, doCommit, doRollback, doClose等方法。

因此BasicChannelSemantic类和BasicTransactionSemantics类一起保证了操作Channel的逻，。提供了所有Channel的父类。事务中的各个操作的语义，则由BasicTransactionSemantics的子类去实现，即它的子类来说明事务开始时干嘛，事务回滚时干嘛，取出消息时干嘛、放入消息时干嘛等等。(可以类比下模版方法模式，不过这里父类通过特殊的手段强制了方法的调用顺序)