大年初二，朋友問(wèn)了我一個(gè)技術(shù)的問(wèn)題(朋友實(shí)在是好學(xué)，佩服！)

創(chuàng)新互聯(lián)是專(zhuān)業(yè)的網(wǎng)站建設(shè)公司,提供網(wǎng)站建設(shè),網(wǎng)站制作,網(wǎng)站設(shè)計(jì)等網(wǎng)站開(kāi)發(fā)一體化解決方案;包括html5,成都小程序開(kāi)發(fā),網(wǎng)站定制,企業(yè)網(wǎng)站建設(shè),購(gòu)物商城網(wǎng)站建設(shè),成都響應(yīng)式網(wǎng)站建設(shè)公司,建網(wǎng)站,PHP網(wǎng)站建設(shè),軟件開(kāi)發(fā)，軟文營(yíng)銷(xiāo)，網(wǎng)站營(yíng)銷(xiāo)。歡迎做網(wǎng)站的企業(yè)前來(lái)合作洽談,創(chuàng)新互聯(lián)將竭誠(chéng)為您服務(wù)!

開(kāi)啟10000個(gè)線程，每個(gè)線程給員工表的money字段【初始值是0】加1，沒(méi)有使用悲觀鎖和樂(lè)觀鎖，但是在業(yè)務(wù)層方法上加了synchronized關(guān)鍵字，問(wèn)題是代碼執(zhí)行完畢后數(shù)據(jù)庫(kù)中的money 字段不是10000，而是小于10000 問(wèn)題出在哪里？

Service層代碼：

SQL代碼(沒(méi)有加悲觀/樂(lè)觀鎖)：

用1000個(gè)線程跑代碼：

簡(jiǎn)單來(lái)說(shuō)：多線程跑一個(gè)使用synchronized關(guān)鍵字修飾的方法，方法內(nèi)操作的是數(shù)據(jù)庫(kù)，按正常邏輯應(yīng)該最終的值是1000，但經(jīng)過(guò)多次測(cè)試，結(jié)果是低于1000。這是為什么呢？

一、我的思考
既然測(cè)試出來(lái)的結(jié)果是低于1000，那說(shuō)明這段代碼不是線程安全的。不是線程安全的，那問(wèn)題出現(xiàn)在哪呢？眾所周知，synchronized方法能夠保證所修飾的代碼塊、方法保證有序性、原子性、可見(jiàn)性。

講道理，以上的代碼跑起來(lái)，問(wèn)題中Service層的increaseMoney()是有序的、原子的、可見(jiàn)的，所以斷定跟synchronized應(yīng)該沒(méi)關(guān)系。既然Java層面上找不到原因，那分析一下數(shù)據(jù)庫(kù)層面的吧(因?yàn)榉椒▋?nèi)操作的是數(shù)據(jù)庫(kù))。在increaseMoney()方法前加了@Transcational注解，說(shuō)明這個(gè)方法是帶有事務(wù)的。事務(wù)能保證同組的SQL要么同時(shí)成功，要么同時(shí)失敗。講道理，如果沒(méi)有報(bào)錯(cuò)的話，應(yīng)該每個(gè)線程都對(duì)money值進(jìn)行+1。從理論上來(lái)說(shuō)，結(jié)果應(yīng)該是1000的才對(duì)。
br/>既然Java層面上找不到原因，那分析一下數(shù)據(jù)庫(kù)層面的吧(因?yàn)榉椒▋?nèi)操作的是數(shù)據(jù)庫(kù))。在increaseMoney()方法前加了@Transcational注解，說(shuō)明這個(gè)方法是帶有事務(wù)的。事務(wù)能保證同組的SQL要么同時(shí)成功，要么同時(shí)失敗。講道理，如果沒(méi)有報(bào)錯(cuò)的話，應(yīng)該每個(gè)線程都對(duì)money值進(jìn)行+1。從理論上來(lái)說(shuō)，結(jié)果應(yīng)該是1000的才對(duì)。

首先貼一下我的測(cè)試代碼：

@RestController
public class EmployeeController {

    @Autowired
    private EmployeeService employeeService;

    @RequestMapping("/add")
    public void addEmployee() {
        for (int i = 0; i < 1000; i++) {
            new Thread(() -> employeeService.addEmployee()).start();
        }
    }

}

@Service
public class EmployeeService {

    @Autowired
    private EmployeeRepository employeeRepository;

    @Transactional
    public synchronized void addEmployee() {

        // 查出ID為8的記錄，然后每次將年齡增加一
        Employee employee = employeeRepository.getOne(8);
        System.out.println(employee);
        Integer age = employee.getAge();
        employee.setAge(age + 1);

        employeeRepository.save(employee);
    }

}

簡(jiǎn)單地打印了每次拿到的employee值，并且拿到了SQL執(zhí)行的順序，如下(貼出小部分)：

從打印的情況我們可以得出：多線程情況下并沒(méi)有串行執(zhí)行addEmployee()方法。這就導(dǎo)致對(duì)同一個(gè)值做重復(fù)的修改，所以最終的數(shù)值比1000要少。

二、圖解出現(xiàn)的原因
發(fā)現(xiàn)并不是同步執(zhí)行的，于是我就懷疑synchronized關(guān)鍵字和Spring肯定有點(diǎn)沖突。于是根據(jù)這兩個(gè)關(guān)鍵字搜了一下，找到了問(wèn)題所在。

我們知道Spring事務(wù)的底層是Spring AOP，而Spring AOP的底層是動(dòng)態(tài)代理技術(shù)。跟大家一起回顧一下動(dòng)態(tài)代理：

  public static void main(String[] args) {

        // 目標(biāo)對(duì)象
        Object target ;

        Proxy.newProxyInstance(ClassLoader.getSystemClassLoader(), Main.class, new InvocationHandler() {
            @Override
            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

                // 但凡帶有@Transcational注解的方法都會(huì)被攔截

                // 1... 開(kāi)啟事務(wù)

                method.invoke(target);

                // 2... 提交事務(wù)

                return null;
            }

        });
    }

實(shí)際上Spring做的處理跟以上的思路是一樣的，我們可以看一下TransactionAspectSupport類(lèi)中invokeWithinTransaction()：

調(diào)用方法前開(kāi)啟事務(wù)，調(diào)用方法后提交事務(wù)

在多線程環(huán)境下，就可能會(huì)出現(xiàn)：方法執(zhí)行完了(synchronized代碼塊執(zhí)行完了)，事務(wù)還沒(méi)提交，別的線程可以進(jìn)入被synchronized修飾的方法，再讀取的時(shí)候，讀到的是還沒(méi)提交事務(wù)的數(shù)據(jù)，這個(gè)數(shù)據(jù)不是最新的，所以就出現(xiàn)了這個(gè)問(wèn)題。

三、解決問(wèn)題
從上面我們可以發(fā)現(xiàn)，問(wèn)題所在是因?yàn)锧Transcational注解和synchronized一起使用了，加鎖的范圍沒(méi)有包括到整個(gè)事務(wù)。所以我們可以這樣做：

新建一個(gè)名叫SynchronizedService類(lèi)，讓其去調(diào)用addEmployee()方法，整個(gè)代碼如下：

@RestController
public class EmployeeController {

    @Autowired
    private SynchronizedService synchronizedService ;

    @RequestMapping("/add")
    public void addEmployee() {
        for (int i = 0; i < 1000; i++) {
            new Thread(() -> synchronizedService.synchronizedAddEmployee()).start();
        }
    }
}

// 新建的Service類(lèi)
@Service
public class SynchronizedService {

    @Autowired
    private EmployeeService employeeService ;

    // 同步
    public synchronized void synchronizedAddEmployee() {
        employeeService.addEmployee();

    }
}

@Service
public class EmployeeService {

    @Autowired
    private EmployeeRepository employeeRepository;

    @Transactional
    public void addEmployee() {

        // 查出ID為8的記錄，然后每次將年齡增加一
        Employee employee = employeeRepository.getOne(8);
        System.out.println(Thread.currentThread().getName() + employee);
        Integer age = employee.getAge();
        employee.setAge(age + 1);

        employeeRepository.save(employee);

    }
}

我們將synchronized鎖的范圍包含到整個(gè)Spring事務(wù)上，這就不會(huì)出現(xiàn)線程安全的問(wèn)題了。在測(cè)試的時(shí)候，我們可以發(fā)現(xiàn)1000個(gè)線程跑起來(lái)比之前要慢得多，當(dāng)然我們的數(shù)據(jù)是正確的：

最后
可以發(fā)現(xiàn)的是，雖然說(shuō)Spring事務(wù)用起來(lái)我們是非常方便的，但如果不了解一些Spring事務(wù)的細(xì)節(jié)，很多時(shí)候出現(xiàn)Bug了就百思不得其解。還是得繼續(xù)加油努力呀~~~

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性?xún)r(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專(zhuān)為企業(yè)上云打造定制，能夠滿(mǎn)足用戶(hù)豐富、多元化的應(yīng)用場(chǎng)景需求。

標(biāo)題名稱(chēng)：Synchronized鎖在Spring事務(wù)管理下，為啥還線程不安全？-創(chuàng)新互聯(lián)
分享URL：http://www.rwnh.cn/article18/epjdp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供全網(wǎng)營(yíng)銷(xiāo)推廣、電子商務(wù)、網(wǎng)站建設(shè)、網(wǎng)站導(dǎo)航、自適應(yīng)網(wǎng)站、標(biāo)簽優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)