被標記爲事務的方法互相調用的坑(下)

參考:https://www.iteye.com/topic/1122740數據庫

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

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

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

咱們須要新建一個接口:app

public interface OtherService {
    void insertCodeMonkey();
}
複製代碼

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

@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;
    }
}
複製代碼

修改本來的實現類:post

@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);
    }
}
複製代碼

運行,查看數據庫: 測試

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

讓咱們再看看控制檯的日誌: ui

image.png

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

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

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;
    }
}
複製代碼

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

image.png
翻譯下:不能找到當前的代理,須要設置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);
    }
}
複製代碼

再次運行:

image.png

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

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

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接口:

@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;
    }
}
複製代碼

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

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

相關文章
相關標籤/搜索