Enterprise 4.17.1. Http Service 4.17.2. WebContainer (JSP/Servlet) 4.17.3. Naming (JNDI) 4.17.4. Transaction (JTA) 4.17.5. DataSources (JDBC) 4.17.6. JMS 4.17.7. Persistence (JPA) 4.17.8. EJB 4.17.9 2013-12-06 10:52 repository/org/springframework/ org.springframework.transaction/3.2.4.RELEASE/ org.springframework.transaction-3.2.4.RELEASE.jar 16513 2013-12-06 10:52 repository/org/apache/servicemix/bundles/ name using an OSGi service (identified by its ID). • unbind(name) unbinds a JNDI name. 4.17.4. Transaction (JTA) Apache Karaf provides container managed transactions, available as OSGi services. As most

package:(&(package=javax.naming.spi)) package:(&(package=javax.sql)) package:(&(package=javax.transaction)) package:(&(package=javax.transaction.xa)) package:(&(package=org.apache.commons.pool)(version>=1.3.0)(!(version>=2 uses:=org.apache.commons.dbcp,javax.sql,org.apache.commons.pool.impl,javax.transaction,org.apache.commons.pool,javax.transaction.xa, version=1.4.0} package:{package=org.apache.commons.dbcp.datasources, package:(&(package=javax.naming.spi)) package:(&(package=javax.sql)) package:(&(package=javax.transaction)) package:(&(package=javax.transaction.xa)) package:(&(package=org.apache.commons.pool)(version>=1.3.0)(!(version>=2

Agent B Agent C Agent Request(Transaction ID) A(application) Trasanctionid（CA SDK support） TOM (who) Create a checklist(action) At 2018-0930(time) 日志输出（Transaction ID） C(application) Trasanctionid（CA checklist(action) At 2018-0930(time) 日志输出 Get the corresponding logs for one time request by transaction ID Request(Transaction ID)Java探针的基本原理 A.class 1 2 3 4 5 8 9 Request Response JVM 6 10 7 Class Loader Cloud Native App POD Agent logfile Proxy Transaction ID Transaction ID Cloud Native App POD Agent logfile Proxy Transaction ID Transaction ID …Commit to Client Success 成就客户卓越Mixer组件功能介绍Mixer的介绍

更新 transaction stable table： 如果是 prepared 消息记，通过 TransactionStateService 服 务将消息加到存储事务状态的表格 tranStateTable 的文件中；如果是 commitType 和 rollbackType 消息， 修改事物状态表格 tranStateTable 中的消息状态。 记 录 Transaction Redo 查询消息，根据 commitLogOffset 和 msgSize 到 commitlog 查找消息 向 Producder 发起请求,请求 code 类型为 CHECK_TRANSACTION_STATE，producer 的 DefaultMQProducerImpl. checkTransactionState()方法来处理 broker 定时回调的请求， 这里构 建 一 个 时间点重新生成 redolog， 重新分发 消息 DispatchRequest, 分发消息到位置信息到 ConsumeQueue 更新 Transaction State Table 记录 Transaction Redo Log 删除事物状态表 tranStateTable 通过 RedoLog 全量恢复 StateTable 重头扫描 RedoLog，

t:10009/ Connected to: Spark SQL (version 1.0.2) Driver: Hive JDBC (version 2.3.7) Transaction isolation: TRANSACTION_REPEATABLE_READ Beeline version 2.3.7 by Apache Hive 0: jdbc:hive2://localhost:10009/> table/column list for tab-completion --autoCommit=[true/false] enable/disable automatic transaction commit --verbose=[true/false] show verbose error messages and debug info -- delimiter- separated values output format (default: |) --isolation=LEVEL set the transaction isolation level --nullemptystring=[true/false] set to true to get historic behavior of printing

t:10009/ Connected to: Spark SQL (version 1.0.2) Driver: Hive JDBC (version 2.3.7) Transaction isolation: TRANSACTION_REPEATABLE_READ Beeline version 2.3.7 by Apache Hive 0: jdbc:hive2://localhost:10009/> table/column list for tab-completion --autoCommit=[true/false] enable/disable automatic transaction commit --verbose=[true/false] show verbose error messages and debug info -- delimiter- separated values output format (default: |) --isolation=LEVEL set the transaction isolation level --nullemptystring=[true/false] set to true to get historic behavior of printing

CC需要幂等，能够⽀支持重试 5. 如果CC重试不不成功/超时，需要⼿手⼯工⼲干预 Apache RocketMQ 消息事务 Send a message first or execute local transaction first ? Member service Account service Send message Receive message 先执⾏行行本地事务还是先发送消息？ prepareMsg commitMsg rollbackMsg checkMsg TransactionMsgCheckService Bridge OP Msg User Side Transaction Service Part Storage Part 事务消息存储设计 Half Topic: prepare message TransactionMessageCheckService Service TxCoordinator 3 store TxQue Master Broker TxEvent Commit/Rollback Global Transaction ID Branch Transaction ID 1 RMQ Producer 2 CallbackListener 3 TxMessageProcessor begin begin begin begin

t:10009/ Connected to: Spark SQL (version 1.0.2) Driver: Hive JDBC (version 2.3.7) Transaction isolation: TRANSACTION_REPEATABLE_READ Beeline version 2.3.7 by Apache Hive 0: jdbc:hive2://localhost:10009/> table/column list for tab-completion --autoCommit=[true/false] enable/disable automatic transaction commit --verbose=[true/false] show verbose error messages and debug info --sh delimiter- separated values output format (default: |) --isolation=LEVEL set the transaction isolation level --nullemptystring=[true/false] set to true to get historic behavior of printing

t:10009/ Connected to: Spark SQL (version 1.0.2) Driver: Hive JDBC (version 2.3.7) Transaction isolation: TRANSACTION_REPEATABLE_READ Beeline version 2.3.7 by Apache Hive 0: jdbc:hive2://localhost:10009/> table/column list for tab-completion --autoCommit=[true/false] enable/disable automatic transaction commit --verbose=[true/false] show verbose error messages and debug info --sh delimiter- separated values output format (default: |) --isolation=LEVEL set the transaction isolation level --nullemptystring=[true/false] set to true to get historic behavior of printing

t:10009/ Connected to: Spark SQL (version 1.0.2) Driver: Hive JDBC (version 2.3.7) Transaction isolation: TRANSACTION_REPEATABLE_READ Beeline version 2.3.7 by Apache Hive 0: jdbc:hive2://localhost:10009/> table/column list for tab-completion --autoCommit=[true/false] enable/disable automatic transaction commit --verbose=[true/false] show verbose error messages and debug info --sh delimiter- separated values output format (default: |) --isolation=LEVEL set the transaction isolation level --nullemptystring=[true/false] set to true to get historic behavior of printing