phoenix_事务支持

旧城等待， 2022-05-25 08:36 124阅读 0赞

注：官网对这块的介绍非常简洁，在实际工作过程当中也没有成功，但还是把使用过程记录在此，待以后补充（生产中的问题通过hbase原生的API-checkandput解决了，因此暂时对这块的需求没那么强烈）。

在每一个**regionServer**的hbase-site.xml中加入如下的属性：

<name>phoenix.transactions.enabled</name>

</property>

在每一个**Master**的hbase-site.xml中加入如下的属性：

<name>data.tx.snapshot.dir</name>

<value>/tmp/tephra/snapshots</value>

</property>

<name>data.tx.timeout</name>

<description> set the transaction timeout (time after which open transactions become invalid) to a reasonable value.</description>

</property>

<table> 
 <tbody> 
 <tr> 
 <td style="background:rgb(247,247,247);">名称</td> 
 <td style="background:rgb(247,247,247);">默认</td> 
 <td style="background:rgb(247,247,247);">描述</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(249,249,249);">data.tx.bind.port</td> 
 <td style="background:rgb(249,249,249);">15165</td> 
 <td style="background:rgb(249,249,249);">要绑定的端口</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(247,247,247);">data.tx.bind.address</td> 
 <td style="background:rgb(247,247,247);">0.0.0.0</td> 
 <td style="background:rgb(247,247,247);">要监听的服务器地址</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(249,249,249);">data.tx.server.io.threads</td> 
 <td style="background:rgb(249,249,249);">2</td> 
 <td style="background:rgb(249,249,249);">套接字IO的线程数</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(247,247,247);">data.tx.server.threads</td> 
 <td style="background:rgb(247,247,247);">20</td> 
 <td style="background:rgb(247,247,247);">处理程序线程的数量</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(249,249,249);">data.tx.timeout</td> 
 <td style="background:rgb(249,249,249);">30</td> 
 <td style="background:rgb(249,249,249);">交易完成超时（秒）</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(247,247,247);">data.tx.long.timeout</td> 
 <td style="background:rgb(247,247,247);">86400</td> 
 <td style="background:rgb(247,247,247);">长时间运行的事务完成超时（秒）</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(249,249,249);">data.tx.cleanup.interval</td> 
 <td style="background:rgb(249,249,249);">10</td> 
 <td style="background:rgb(249,249,249);">检查超时交易的频率（秒）</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(247,247,247);">data.tx.snapshot.dir</td> 
 <td style="background:rgb(247,247,247);">&nbsp;</td> 
 <td style="background:rgb(247,247,247);">HDFS目录用于存储tx状态的快照</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(249,249,249);">data.tx.snapshot.interval</td> 
 <td style="background:rgb(249,249,249);">300</td> 
 <td style="background:rgb(249,249,249);">写入新快照的频率</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(247,247,247);">data.tx.snapshot.retain</td> 
 <td style="background:rgb(247,247,247);">10</td> 
 <td style="background:rgb(247,247,247);">要保留的旧事务快照的数量</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(249,249,249);">data.tx.metrics.period</td> 
 <td style="background:rgb(249,249,249);">60</td> 
 <td style="background:rgb(249,249,249);">指标报告频率（秒）</td> 
 </tr> 
 </tbody> 
</table>

启动事务管理器：

tephra start

![20180511101629114][]

查看tephra状态

![20180511101635225][]

查找pid文件：

![20180511101641675][]

日志路径：

/tmp/tephra-root/tephra-service-root-z1.y.log

日志中报错：

2018-04-17 15:45:49,556 INFO  \[main\] inmemory.InMemoryTransactionService: Configuring TransactionService, address: 0.0.0.0, port: 15165, threads: 20, io threads: 2, max read buffer (bytes): 16777216

2018-04-17 15:45:49,559 INFO  \[main\] tephra.TransactionServiceMain: Starting TransactionServiceMain

Exception in thread "main" java.lang.NoClassDefFoundError: com/google/common/util/concurrent/Service$Listener

at org.apache.tephra.distributed.TransactionService.doStart(TransactionService.java:87)

at com.google.common.util.concurrent.AbstractService.start(AbstractService.java:90)

at com.google.common.util.concurrent.AbstractService.startAndWait(AbstractService.java:129)

at org.apache.tephra.TransactionServiceMain.start(TransactionServiceMain.java:118)

at org.apache.tephra.TransactionServiceMain.doMain(TransactionServiceMain.java:85)

at org.apache.tephra.TransactionServiceMain.main(TransactionServiceMain.java:49)

Caused by: java.lang.ClassNotFoundException: com.google.common.util.concurrent.Service$Listener

at java.net.URLClassLoader$1.run(URLClassLoader.java:372)

at java.net.URLClassLoader$1.run(URLClassLoader.java:361)

at java.security.AccessController.doPrivileged(Native Method)

at java.net.URLClassLoader.findClass(URLClassLoader.java:360)

at java.lang.ClassLoader.loadClass(ClassLoader.java:424)

at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

at java.lang.ClassLoader.loadClass(ClassLoader.java:357)

... 6 more

提示找不到类文件：com/google/common/util/concurrent/Service

而这个文件在hbase的lib中/opt/hbase/hbase-1.3.2/lib/guava-12.0.1.jar

即，hbase中有此包，但是没加载到，说明classpath不正确。

未完待续

[20180511101629114]: /images/20220525/e273d441b0484509b34e3c9b42d70777.png
[20180511101635225]: /images/20220525/1f2e4f2bc7444592a1e350206bd79c75.png
[20180511101641675]: /images/20220525/dbbd5c6686994517bf5612d8d4fca3e8.png