Java：许多线程中的XA事务传播
如何在Java SE（非Java EE或Spring）中使用事务管理器（如Bitronix，JBoss TS或Atomikos）来支持以下用例：
我们假设我们有以下类：
public class Dao {
public void updateDatabase(DB db) {
connet to db
run a sql
}
}
public class MyRunnable extends Runnable {
Dao dao;
DB db;
public MyRunnable(Dao dao, DB db) {
this.dao=dao;
this.db = db;
}
public run() throws Exception {
return dao.updateDatabase(db);
}
}
public class Service {
public void updateDatabases() {
BEGIN TRANSACTION;
ExecutorService es = Executors.newFixedThreadPool(10);
ExecutorCompletionService ecs = new ExecutorCompletionService(es);
List<Future<T>> futures = new ArrayList<Future<T>>(n);
Dao dao = new Dao();
futures.add(ecs.submit(new MyRunnable(dao, new DB("db1")));
futures.add(ecs.submit(new MyRunnable(dao, new DB("db2")));
futures.add(ecs.submit(new MyRunnable(dao, new DB("db3")));
for (int i = 0; i < n; ++i) {
completionService.take().get();
}
END TRANSACTION;
}
}
public MyServlet extend HttpServlet {
protected void service(final HttpServletRequest request, final HttpServletResponse response) throws IOException {
Service service = new Service();
service.updateDatabases();
}
}
没有找到相关结果
已邀请:
3 个回复
好按紊叉
//first start a tx TransactionManager tm = ... tm.begin(); Waiter waiter = new Waiter(); //the code that calls the first EIS; defined by you SubTxCode code1 = ... //the associated thread SubTxThread thread1 = new SubTxThread ( waiter , code1 ); //the code that calls the second EIS; defined by you SubTxCode code2 = ... //the associated thread SubTxThread thread2 = new SubTxThread ( waiter , code2 ); //start each thread thread1.start(); thread2.start(); //wait for completion of all calls waiter.waitForAll(); //check result if ( waiter.getAbortCount() == 0 ) { //no failures -> commit tx tm.commit(); } else { tm.rollback(); }淑灯
将你的数据源指定为InitialContext ctx = new InitialContext(parms); UserTransaction ut = (UserTransaction) ctx.lookup("java:comp/UserTransaction"); ut.begin(); //Some Transactional Code ut.commit();丧泉缝锋