快捷導(dǎo)航

Mybatis多線程下如何使用Example詳解

更新時(shí)間：2019年12月15日 08:45:28 作者：k2

這篇文章主要給大家介紹了關(guān)于Mybatis多線程下如何使用Example的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用Mybatis具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧

前言

服務(wù)器每收到一個(gè)請(qǐng)求，都會(huì)從線程池中調(diào)度一個(gè)空閑線程來處理，spring整合的web時(shí)，controller和service一般都是單例的，這樣導(dǎo)致無論你的Example標(biāo)注的是單例還是多例，同一個(gè)service下的Example也只有一個(gè)，多線程訪問時(shí)產(chǎn)生的

問題如下

問題詳情

工程目錄結(jié)構(gòu)如下

MyService 的service（）方法接收兩個(gè)參數(shù)并據(jù)此查詢數(shù)據(jù)庫(kù)

@Service
public class MyService {
 @Autowired
 StudentMapper studentMapper;
 @Autowired
 StudentExample studentExample;
 public void service(Integer begin,Integer end){
  StudentExample.Criteria criteria1 = studentExample.createCriteria();
  criteria1.andAgeBetween(begin,end);
  List<Student> list=studentMapper.selectByExample(studentExample);
  studentExample.clear();
  System.out.println(list);
 }
}

當(dāng)同時(shí)有兩個(gè)請(qǐng)求時(shí)，兩個(gè)請(qǐng)求的StudentExample相同

請(qǐng)求1如下

begin=2,end=8

請(qǐng)求2如下

begin=4,end=8

先放行請(qǐng)求1，請(qǐng)求1成功添加條件

再放行請(qǐng)求2，請(qǐng)求2添加失敗

這時(shí)如果請(qǐng)求2在請(qǐng)求1執(zhí)行查詢操作前就已經(jīng)執(zhí)行完studentExample.clear (),請(qǐng)求1的查詢條件就失效了

至此兩個(gè)請(qǐng)求都沒有得到正確的結(jié)果。

解決方案

可以使用ThreadLocal為每個(gè)線程配備單獨(dú)的Example，為保證每次都能獲取到值，這里對(duì)ThreadLocal簡(jiǎn)單擴(kuò)展一下，如果當(dāng)前線程沒有對(duì)應(yīng)的Example（多例），就從spring容器中獲取一個(gè)并與這個(gè)線程綁定。

ThreadLocalExtension

public class ThreadLocalExtension<T> extends ThreadLocal<T> {
   //獲取ApplicationContext方法見下
  @Autowired
  ApplicationContext applicationContext;
  public ThreadLocalExtension(){
    super();
  }
  public T get(Class<T> example){
    T bean=super.get();
    if(bean==null){
      super.set((T) applicationContext.getBean(example));
    }
    return super.get();
  }
}

spring泛型依賴注入

由于Example會(huì)有很多個(gè)，所以這里使用了泛型，spring4.0提供了對(duì)泛型依賴注入的支持。

首先實(shí)際類型對(duì)應(yīng)的ThreadLocalExtension交由spring管理

@Repository
public class StudentExampleThreadLocal extends ThreadLocalExtension<StudentExample> {
}

然后直接在代碼中注入

@Autowired
ThreadLocalExtension<StudentExample> studentExampleThreadLocal;

修改后的MyService

@Service
public class MyService {
  @Autowired
  StudentMapper studentMapper;
  @Autowired
  ThreadLocalExtension<StudentExample> studentExampleThreadLocal;
  public void service(Integer begin,Integer end){
    StudentExample studentExample = studentExampleThreadLocal.get(StudentExample.class);
    StudentExample.Criteria criteria1 = studentExample.createCriteria();
    criteria1.andAgeBetween(begin,end);
    List<Student> list=studentMapper.selectByExample(studentExample);
    studentExample.clear();
    System.out.println(list);
  }
}

獲取ApplicationContext

創(chuàng)建一個(gè)類實(shí)現(xiàn)ApplicationContextAware，并向spring容器中注入applicationContext

@Component
public class ApplicationContextHelper implements ApplicationContextAware {
  private static ApplicationContext applicationContext;

  public ApplicationContextHelper() {
  }
  @Bean(name="applicationContext")
  public ApplicationContext getApplicationContext(){
    return applicationContext;
  }

  @Override
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
    ApplicationContextHelper.applicationContext = applicationContext;
  }

  public static Object getBean(String beanName) {
    return applicationContext != null?applicationContext.getBean(beanName):null;
  }
}

結(jié)果

至此，整個(gè)改造完成，看看效果

請(qǐng)求1