被標記爲事務的方法互相調用的坑（下）

上一節，主要分析了 被標記爲事務的方法互相調用，事務失效的緣由，思考比較多，這一節主要說說解決方案，思考會少一些。

解決方案的核心： 經過代理對象去調用方法

1.把方法放到不一樣的類：

若是想學習Java工程化、高性能及分佈式、深刻淺出。微服務、Spring，MyBatis，Netty源碼分析的朋友能夠加個人Java高級交流：854630135，羣裏有阿里大牛直播講解技術，以及Java大型互聯網技術的視頻免費分享給你們。

咱們須要新建一個接口：

public interface OtherService {
 void insertCodeMonkey();
}

再定義一個類去實現這個接口：

@Service
public class OtherServiceImpl implements OtherService {
 @Autowired
 AccountMapper mapper;
 @Override
 @Transactional(propagation=Propagation.REQUIRES_NEW)
 public void insertCodeMonkey() {
 Account account = new Account();
 account.setAccount("CodeMonkey");
 account.setPassword("CodeMonkey");
 mapper.insert(account);
 int a = 1 / 0;
 }
}

修改本來的實現類：

@Service
public class AccountSerivceImpl implements AccountService {
 @Autowired
 AccountMapper mapper;
 @Autowired
 OtherService otherService;
 @Transactional
 @Override
 public void insertCodeBear() {
 try {
 otherService.insertCodeMonkey();
 } catch (Exception e) {
 e.printStackTrace();
 }
 Account account = new Account();
 account.setAccount("CodeBear");
 account.setPassword("CodeBear");
 mapper.insert(account);
 }
}

運行，查看數據庫：

 

只有一條數據，insertCodeBear方法執行成功了，insertCodeMonkey執行失敗，而且回滾了。

讓咱們再看看控制檯的日誌：

 

若是想學習Java工程化、高性能及分佈式、深刻淺出。微服務、Spring，MyBatis，Netty源碼分析的朋友能夠加個人Java高級交流：854630135，羣裏有阿里大牛直播講解技術，以及Java大型互聯網技術的視頻免費分享給你們。

能夠看到是開了兩個事務去執行的。

這種解決方案最簡單，不須要了解其餘東西，可是這種方案須要修改代碼結構，原本兩個方法都是屬於同一個類的，如今須要強行把它們拆開。

2. AopContext：

咱們的目標是要在實現類中獲取本類的代理對象，Spring提供了Aop上下文，即：AopContext，經過AopContext，能夠很方便的獲取到代理對象：

@Service
public class AccountSerivceImpl implements AccountService {
 @Autowired
 AccountMapper mapper;
 @Transactional
 @Override
 public void insertCodeBear() {
 try {
 ((AccountService)AopContext.currentProxy()).insertCodeMonkey();
 } catch (Exception ex) {
 ex.printStackTrace();
 }
 Account account = new Account();
 account.setAccount("CodeBear");
 account.setPassword("CodeBear");
 mapper.insert(account);
 }
 @Transactional(propagation = Propagation.REQUIRES_NEW)
 @Override
 public void insertCodeMonkey() {
 Account account = new Account();
 account.setAccount("CodeMonkey");
 account.setPassword("CodeMonkey");
 mapper.insert(account);
 int a = 1 / 0;
 }
}

當寫好代碼，很愉快的去測試，發現居然報錯了:

 

翻譯下：不能找到當前的代理，須要設置exposeProxy屬性爲 true使其能夠。

expose字面意思就是 暴露。也就是說 咱們須要容許暴露代理。

咱們須要在Spring Boot啓動類上+一個註解：

@EnableAspectJAutoProxy(exposeProxy = true)
@SpringBootApplication
@MapperScan(basePackages = "com.codebear.Dao")
public class SpringbootApplication {
 public static void main(String[] args) throws Exception {
 SpringApplication.run(SpringbootApplication.class, args);
 }
}

再次運行：

 

確實是開啓了兩個事務去執行的。

再看看數據庫，也沒有問題。

3. ApplicationContext：

@Service
public class AccountSerivceImpl implements AccountService {
 @Autowired
 AccountMapper mapper;
 @Autowired
 ApplicationContext context;
 AccountService service;
 @PostConstruct
 private void setSelf() {
 service = context.getBean(AccountService.class);
 }
 @Transactional
 @Override
 public void insertCodeBear() {
 try {
 service.insertCodeMonkey();
 } catch (Exception e) {
 e.printStackTrace();
 }
 Account account = new Account();
 account.setAccount("CodeBear");
 account.setPassword("CodeBear");
 mapper.insert(account);
 }
 @Transactional(propagation = Propagation.REQUIRES_NEW)
 @Override
 public void insertCodeMonkey() {
 Account account = new Account();
 account.setAccount("CodeMonkey");
 account.setPassword("CodeMonkey");
 mapper.insert(account);
 int a = 1 / 0;
 }
}

驗證的圖片就省略了。

此方法不適用於prototype

在這裏，我用了一個@PostConstruct註解，在初始化的時候，會調用被@PostConstruct標記的方法(注意，僅僅是初始化的時候，纔會被調用。之後都不會被調用了，你們能夠打個斷點試一下)，這裏這麼作的目的就是爲了提高一下效率，不用每次都getBean。因此若是這個類是prototype的，就不適用這個方法了。若是是prototype的話，就在insertCodeBear方法中使用getBean方法吧。

上兩種方法比較方便，沒有新建其餘的接口或者是類，可是沒有很好的封裝得到Aop代理對象的過程，也不是很符合 迪比特法則，也就是最少知識原則。

4. 重寫BeanPostProcessor接口：

關於這個接口是作什麼的，這裏就不詳細闡述了，簡單的來講這是Spring提供的接口，咱們能夠經過重寫它，在初始化Bean以前或者以後，自定義一些額外的邏輯。

首先，咱們須要定義一個接口：

public interface WeavingSelfProxy {
 void setSelfProxy(Object bean);
}

要得到代理對象的類，須要去實現它：

@Service
public class AccountSerivceImpl implements AccountService, WeavingSelfProxy {
 @Autowired
 AccountMapper mapper;
 AccountService service;
 @Override
 public void setSelfProxy(Object bean) {
 System.out.println("進入到setSelfProxy方法");
 service = (AccountService) bean;
 }
 @Transactional
 @Override
 public void insertCodeBear() {
 try {
 service.insertCodeMonkey();
 } catch (Exception e) {
 e.printStackTrace();
 }
 Account account = new Account();
 account.setAccount("CodeBear");
 account.setPassword("CodeBear");
 mapper.insert(account);
 }
 @Transactional(propagation = Propagation.REQUIRES_NEW)
 @Override
 public void insertCodeMonkey() {
 Account account = new Account();
 account.setAccount("CodeMonkey");
 account.setPassword("CodeMonkey");
 mapper.insert(account);
 int a = 1 / 0;
 }
}

重寫BeanPostProcessor接口：

若是想學習Java工程化、高性能及分佈式、深刻淺出。微服務、Spring，MyBatis，Netty源碼分析的朋友能夠加個人Java高級交流：854630135，羣裏有阿里大牛直播講解技術，以及Java大型互聯網技術的視頻免費分享給你們。

@Component
public class SetSelfProxyProcessor implements BeanPostProcessor {
 @Override
 public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
 return bean;
 }
 @Override
 public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
 if(bean instanceof WeavingSelfProxy){
 System.out.println("實現了WeavingSelfProxy接口");
 ((WeavingSelfProxy) bean).setSelfProxy(bean);
 }
 return bean;
 }
}

這樣就能夠了，驗證的圖片也省略了。

以上就是四種解決方案，能夠說 各有千秋，沒有哪一個好，哪一個壞，只有適不適合。

若是想學習Java工程化、高性能及分佈式、深刻淺出。微服務、Spring，MyBatis，Netty源碼分析的朋友能夠加個人Java高級交流：854630135，羣裏有阿里大牛直播講解技術，以及Java大型互聯網技術的視頻免費分享給你們。