官方承諾：K60至尊版將會首批升級MIUI 15
全新的MIUI 15今天也有了消息，在官宣了K60至尊版將會搭載天璣9200+處理器和獨(dú)顯芯片X7的同時，Redmi給出了官方承諾，K60至尊重大更新首批升級，會首批推送MIUI 15。也就是說雖然
環(huán)境：SpringBoot3.0.9
簡單介紹下出現(xiàn)問題的場景；用戶注冊后，系統(tǒng)需要發(fā)送一封確認(rèn)郵件。一旦郵件發(fā)送成功，用戶的狀態(tài)應(yīng)更新為“已發(fā)送”。但是，在使用Spring Data JPA時，出現(xiàn)了重復(fù)數(shù)據(jù)的問題，注冊的用戶有2條。
@Servicepublic class UserService { @Resource private UserRepository userRepository ; private static final ThreadPoolExecutor POOL = new ThreadPoolExecutor(2, 2, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>()) ; private final Function<User, Runnable> action = user -> () -> { System.out.printf("給【%s】發(fā)送郵件%n", user.getEmail()) ; user.setState(1) ; userRepository.save(user) ; } ; @Transactional public void saveUser(User user) { this.userRepository.save(user) ; POOL.execute(action.apply(user)) ; // 模擬其它操作 TimeUnit.SECONDS.sleep(1) ; } }測試
@Resourceprivate UserService userService ;@Testpublic void testSave() { User user = new User() ; user.setName("張三") ; user.setEmail("zs@qq.com") ; userService.saveUser(user) ;}控制臺輸出
Hibernate: insert into t_user (email, name, state) values (?, ?, ?)給【zs@qq.com】發(fā)送郵件Hibernate: select u1_0.id,u1_0.email,u1_0.name,u1_0.state from t_user u1_0 where u1_0.id=?Hibernate: insert into t_user (email, name, state) values (?, ?, ?)Hibernate: update t_user set email=?, name=?, state=? where id=?輸出2條insert，數(shù)據(jù)庫中有2條結(jié)果
圖片
在保存用戶后打印User對象，同時在發(fā)郵件處再次查詢數(shù)據(jù)
this.userRepository.save(user) ;System.out.println(user.getId() + " ---- ") ;// 發(fā)送郵件處查詢數(shù)據(jù)user.setState(1) ;System.out.println(userRepository.findById(user.getId()).orElseGet(() -> null)) ;執(zhí)行結(jié)果
Hibernate: insert into t_user (email, name, state) values (?, ?, ?)22 ---- 給【zs@qq.com】發(fā)送郵件Hibernate: select u1_0.id,u1_0.email,u1_0.name,u1_0.state from t_user u1_0 where u1_0.id=?null打印出了User的id值，但是在發(fā)送郵件再次查詢時打印的null，數(shù)據(jù)庫并沒有數(shù)據(jù)。既然沒有數(shù)據(jù)，那么調(diào)用save方法當(dāng)然會執(zhí)行insert操作。也就是說在發(fā)送郵件操作時，上一步的保存用戶的事務(wù)并沒有提交。
在一個事務(wù)中如果你調(diào)用save方法，這時候并不會里面將數(shù)據(jù)插入到數(shù)據(jù)庫中，而是會等到事務(wù)提交以后。
在對應(yīng)的UserRepository中重寫findById的方法，然后在方法上添加共享鎖 （lock in share mode）
public interface UserRepository extends JpaRepository<User, Long> { @Lock(LockModeType.PESSIMISTIC_READ) Optional<User> findById(Long id);}接下來在發(fā)送郵件的方法出調(diào)用上面的findById方法重新從數(shù)據(jù)庫中拉取數(shù)據(jù)
private final Function<User, Runnable> action = user -> () -> { System.out.printf("給【%s】發(fā)送郵件%n", user.getEmail()) ; // 由于加了鎖，所以這里會一直等待另外一個線程的事務(wù)結(jié)束或才會繼續(xù)執(zhí)行 User ret = userRepository.findById(user.getId()).get() ; ret.setState(1) ; userRepository.save(ret) ;}控制臺輸出
Hibernate: insert into t_user (email, name, state) values (?, ?, ?)26 ---- 給【zs@qq.com】發(fā)送郵件Hibernate: select u1_0.id,u1_0.email,u1_0.name,u1_0.state from t_user u1_0 where u1_0.id=? lock in share modeHibernate: select u1_0.id,u1_0.email,u1_0.name,u1_0.state from t_user u1_0 where u1_0.id=?Hibernate: update t_user set email=?, name=?, state=? where id=?執(zhí)行的sql上自動添加了共享鎖lock in share mode
縮小事務(wù)范圍，不要在saveUser方法上加事務(wù)；調(diào)用的save方法內(nèi)部實(shí)現(xiàn)是已經(jīng)帶有了@Transactional注解，如下：
SimpleJpaRepository
@Transactional@Overridepublic <S extends T> S save(S entity) { // ...}去掉了saveUser方法上的事務(wù)后，數(shù)據(jù)正常insert了一條，update一條。
該種方法實(shí)現(xiàn)非常的簡單，但是如果saveUser方法中有多個事務(wù)操作，這時候你的通過別的方式實(shí)現(xiàn)。
通過事件機(jī)制，該種方式有如下優(yōu)點(diǎn)：
實(shí)現(xiàn)方式如下
// 定義事件對象class UserCreatedEvent extends ApplicationEvent { private static final long serialVersionUID = 1L; private User source ; public UserCreatedEvent(User user) { super(user); this.source = user ; }}// 定義事件監(jiān)聽器// 在事務(wù)提交完成以后執(zhí)行@TransactionalEventListener(phase = TransactionPhase.AFTER_COMPLETION)@Asyncpublic void sendMail(UserCreatedEvent event) { User user = event.getUser(); System.out.printf("%s - 給【%s】發(fā)送郵件%n", Thread.currentThread().getName(), user.getEmail()) ; user.setState(1); userRepository.save(user) ;}// 在saveUser方法中需要發(fā)送事件@Transactionalpublic void saveUser(User user) { this.userRepository.save(user) ; eventMulticaster.multicastEvent(new UserCreatedEvent(user)) ;}測試
Hibernate: insert into t_user (email, name, state) values (?, ?, ?)40 ---- task-1 - 給【zs@qq.com】發(fā)送郵件Hibernate: select u1_0.id,u1_0.email,u1_0.name,u1_0.state from t_user u1_0 where u1_0.id=?Hibernate: update t_user set email=?, name=?, state=? where id=?正確執(zhí)行。
總結(jié)：在不同的線程上下文中對同一數(shù)據(jù)操作，要確保上一個事務(wù)正確的提交。否則會出現(xiàn)數(shù)據(jù)不一致的情況。在本例中是插入后再更新。如果是對已存在的數(shù)據(jù)做更新操作情況是一樣的出現(xiàn)數(shù)據(jù)不一致的情況。
完畢！！！
本文鏈接：http://www.www897cc.com/showinfo-26-59646-0.html被簡單的用戶注冊坑了！出現(xiàn)用戶重復(fù)
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： 教你如何使用 eval 函數(shù)解析和執(zhí)行字符串代碼，讓你的程序更加智能！
下一篇： 性能工程成熟度模型
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號