參考:https://www.iteye.com/topic/1122740數據庫
上一節,主要分析了 被標記爲事務的方法互相調用,事務失效的緣由,思考比較多,這一節主要說說解決方案,思考會少一些。bash
咱們須要新建一個接口: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);
}
}
複製代碼
運行,查看數據庫: 測試
只有一條數據,insertCodeBear方法執行成功了,insertCodeMonkey執行失敗,而且回滾了。讓咱們再看看控制檯的日誌: ui
能夠看到是開了兩個事務去執行的。spa
這種解決方案最簡單,不須要了解其餘東西,可是這種方案須要修改代碼結構,原本兩個方法都是屬於同一個類的,如今須要強行把它們拆開。prototype
咱們的目標是要在實現類中獲取本類的代理對象,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);
}
}
複製代碼
再次運行:
確實是開啓了兩個事務去執行的。
再看看數據庫,也沒有問題。
@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代理對象的過程,也不是很符合 迪比特法則,也就是最少知識原則。
關於這個接口是作什麼的,這裏就不詳細闡述了,簡單的來講這是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;
}
}
複製代碼
這樣就能夠了,驗證的圖片也省略了。
以上就是四種解決方案,能夠說 各有千秋,沒有哪一個好,哪一個壞,只有適不適合。