SSH + atomikos 打造Java分布式事务

package mutilDataSource; import java.sql.Connection; import java.sql.Statement; import javax.naming.InitialContext; import javax.sql.XAConnection; import javax.sql.XADataSource; import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; import javax.transaction.xa.Xid; //在使用JTA之前，你必须首先实现一个Xid类用来标识事务（在普通情况下这将由事务管理程序来处理） public class MyXid implements Xid { // formatID通常是零，这意味着你将使用OSI CCR（Open Systems Interconnection Commitment, // Concurrency和Recovery 标准）来命名。如果你要是用另外一种格式，那么formatID应该大于零。-1值意味着Xid为无效。 protected int formatId; // gtrid和bqual可以包含64个字节二进制码来分别标识全局事务和分支事务。唯一的要求是gtrid和bqual必须是全局唯一的。此外，这可以通过使用指定在OSI // CCR中的命名规则规范来完成。 protected byte gtrid[];// 全局事务标识符 protected byte bqual[];// 分支修饰词标识符 public MyXid() { } public MyXid(int formatId, byte gtrid[], byte bqual[]) { this.formatId = formatId; this.gtrid = gtrid; this.bqual = bqual; } public byte[] getBranchQualifier() { // TODO Auto-generated method stub return bqual; } public int getFormatId() { // TODO Auto-generated method stub return formatId; } public byte[] getGlobalTransactionId() { // TODO Auto-generated method stub return gtrid; } public XADataSource getXADataSource() throws Exception { InitialContext ctx = new InitialContext(); XADataSource ds = (XADataSource) ctx.lookup("jdbc/xaDS"); return ds; } public void test() throws Exception { XADataSource xaDS; XAConnection xaCon; XAResource xaRes; Xid xid; Connection con; Statement stmt; int ret; xaDS = getXADataSource(); xaCon = xaDS.getXAConnection(); xaRes = xaCon.getXAResource(); con = xaCon.getConnection(); stmt = con.createStatement(); xid = new MyXid(100, new byte[] { 0x01 }, new byte[] { 0x02 }); try { xaRes.start(xid, XAResource.TMNOFLAGS); stmt.executeUpdate("insert into test_table values (100)"); xaRes.end(xid, XAResource.TMSUCCESS); ret = xaRes.prepare(xid); if (ret == XAResource.XA_OK) { xaRes.commit(xid, false); } } catch (XAException e) { e.printStackTrace(); } finally { stmt.close(); con.close(); xaCon.close(); } } }