用Lambda武裝你的Java: 靈活的事務(wù)

The question 發(fā)布于2019-08-14 12:09 / 1861人閱讀

摘要：假如你寫了類似這樣的和偽代碼問題來了，和分別用了兩個分開的事務(wù)，如果你用了或，并且是的，這就沒法運行。你需要讓兩次調(diào)用運行在同一個事務(wù)里。

當(dāng)你采用Spring之類的框架，用了聲明式事務(wù)，難道每一段需要事務(wù)的代碼都必須寫成一個bean method，再標(biāo)上@Transactional？

未免太麻煩了，不信你瞧。假如你寫了類似這樣的Controller和Service (偽代碼):

class UserController {
  @Autowired UserService us;

  String updateUser(long userId) {
    User user = us.authorize(userId);
    Event e = us.update(user);
    publishToMQ(e);
    return "user-page";
  }
}

@Transactional
class UserService {
  User authorize(long userId) {...}
  void update(User user) {...}
}

問題來了，authorize和update分別用了兩個分開的事務(wù)，如果你用了Hibernate或JPA，并且user是lazy-loading的，這就沒法運行。你需要讓兩次調(diào)用運行在同一個事務(wù)里。通常的辦法是把UserController.updateUser也標(biāo)成@Transactional。可是這么一來，下一句publishToMQ(e);雖然不需要事務(wù)，卻也被包在事務(wù)里了。

我們可以做得更好！用Java 8做一個Transactor，任何代碼塊可隨時包在事務(wù)中！
然后controller可以重寫為：

String updateUser(long userId) {
  Event e = Transactor.get().apply(() -> {
    User user = us.authorize(userId);
    return us.update(user);
  });
  publishToMQ(e);
  return "user-page";
}

Transactor的實現(xiàn)：

@Component
@Transactional
public class Transactor {
  public static Transactor get() {
    return instance;
  }

  public  R apply(Supplier f) {
    return f.get(); // 有返回值的代碼塊
  }

  public void run(Runnable f) {
    f.run(); // 無返回值的代碼塊
  }

  @Autowired
  private ApplicationContext applicationContext;
  @PostConstruct
  void setup() {
    instance = applicationContext.getBean(Transactor.class); //不能寫instance=this
  }
  private static Transactor instance;
}

代碼中透出四個字：靈活，簡潔！

2015/7/5 Update: 可惜的是，有時會拋出org.hibernate.HibernateException: Could not obtain transaction-synchronized Session for current thread (雖然stacktrace中是有代理類的)
目前實測改用Spring的TransactionTemplate是可以的。