欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Mybatis中攔截器的使用場景和技巧分享

 更新時間:2023年10月23日 11:40:09   作者:襄垣  
Mybatis提供了一些機(jī)制,可以允許我們在做數(shù)據(jù)庫操作的時候進(jìn)行我們額外的一些程序,當(dāng)然,這看起來并沒有JPA的EntityListener好用,本文小編將給大家詳細(xì)的介紹了Mybatis中攔截器的使用場景和技巧,需要的朋友可以參考下

場景描述

中小業(yè)務(wù)系統(tǒng)中,有時候會面臨一些比較相似的業(yè)務(wù)場景。

  • 當(dāng)XXX創(chuàng)建成功后,需要給XXX推送一條業(yè)務(wù)消息;
  • 當(dāng)XXX更新的時候,需要給XXX推送一條業(yè)務(wù)提醒;
  • 當(dāng)XXX創(chuàng)建OR更新的時候,需要將最新的數(shù)據(jù)推送到搜索引擎中,以方便其他業(yè)務(wù)系統(tǒng)在搜索引擎中能查詢到;
  • 當(dāng)XXX更新的時候,需要更新分布式緩存的XXX數(shù)據(jù);
  • ……

這些場景都有相似的特征,如下

特征描述
異步實(shí)際上與主流程關(guān)系不大,可以作為附屬流程異步執(zhí)行
事務(wù)大多在事務(wù)結(jié)束之后執(zhí)行
并行可以串行執(zhí)行,也可以并行執(zhí)行,對最終結(jié)果影響不大

Mybatis攔截器

Mybatis提供了一些機(jī)制,可以允許我們在做數(shù)據(jù)庫操作的時候進(jìn)行我們額外的一些程序。當(dāng)然,這看起來并沒有JPA的EntityListener好用。

但是通過這些機(jī)制,我們可以達(dá)成我們主要的目的,解耦合。(解耦合的好處顯而易見,我們在關(guān)注主流程業(yè)務(wù)的時候,附屬流程的業(yè)務(wù)也更容易擴(kuò)展)

下面是我們即將用到的一些簡單概念,如下

概念描述
解耦解耦的本質(zhì)就是將類之間的直接關(guān)系轉(zhuǎn)換成間接關(guān)系
觀察者模式一種行為設(shè)計模式,允許你定義一種訂閱機(jī)制,可在對象事件發(fā)生時通知多個“觀察”該對象的其他對象。
EventBus基于事件驅(qū)動,觀察者們監(jiān)聽自己感興趣的特定事件,進(jìn)行相應(yīng)的處理。

錨定事件發(fā)生

首先,我們要找到事件發(fā)生的地方,通常來說我們更愿意在業(yè)務(wù)代碼里寫

Company company = new Company();
company.setCompanyName(companyName);
companyMapper.insert(company);
// 創(chuàng)建XXX成功后,觸發(fā)了一些操作;
doSomething(company);

但是,這種方式是耦合的,我們在doSomething() 里發(fā)生的一些異常會影響到主流程,而每一次增加附屬流程的改動,都會產(chǎn)生影響范圍的蔓延。

這里,我們使用Mybatis提供的一種方式來錨定事件發(fā)生

@Component
@Intercepts( {
    @Signature(method = "update", type = Executor.class, args = {
        MappedStatement.class,
        Object.class
    })
})
public class EntityInterceptor implements Interceptor {
    private static final Logger LOGGER = LoggerFactory.getLogger(EntityInterceptor.class);

    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        Object proceed = invocation.proceed();
        try {
            Object[] args = invocation.getArgs();
            MappedStatement ms = (MappedStatement) args[0];
            Object params = args[1];
            if (SqlCommandType.INSERT.equals(ms.getSqlCommandType())) {
                insertCommond(params);
            }
            if (SqlCommandType.UPDATE.equals(ms.getSqlCommandType())) {
                updateCommond(params);
            }
        } catch (Exception e) {
            LOGGER.warn("entity change warning: {}", e.getMessage());
        } finally {
            return proceed;
        }
    }
    
        private void insertCommond(Object params) {
        if (Objects.isNull(params)) {
            return;
        }
        // 插入Company的事件
        if (params instanceof Company) {
            Company company = (Company) params;
            CompanyEvent companyEvent =
                new CompanyEvent(CompanyEvent.TOPIC_ADD, WebUtils.getOpenId(), CompanyVo.from(company));
            SpringUtil.getApplicationContext().publishEvent(companyEvent);
            LOGGER.info("[發(fā)布事件:{}] - [事件內(nèi)容:{}]", CompanyEvent.TOPIC_ADD, JSON.toJSONString(companyEvent));
        }
    }
}

在這里,我們監(jiān)聽了MybatisExecutor對象的update方法,來監(jiān)聽對象的新增和修改。

package org.apache.ibatis.executor;

public interface Executor {

  int update(MappedStatement ms, Object parameter) throws SQLException;
}

當(dāng) Company 的 insert 事件發(fā)生時,我們發(fā)布了一條 CompanyEvent 的事件。

訂閱事件

我們使用發(fā)布-訂閱模型實(shí)現(xiàn)了解耦合,針對剛才發(fā)布的 CompanyEvent 事件,我們來寫一個事件消費(fèi)者。

@Component
public class CompanyListener {

    /**
     * 監(jiān)聽事件 - 公司.
     *
     * @param companyEvent 事件.
     */
    @Lazy
    @Async
    @TransactionalEventListener(
        fallbackExecution = true,
        phase = TransactionPhase.AFTER_COMPLETION,
        classes = CompanyEvent.class)
    public void doAsync(CompanyEvent companyEvent) {
        LOGGER.info("[Company 訂閱:{}] - [開始執(zhí)行:{}]",
            companyEvent.getTopic(), JSON.toJSONString(companyVo));
    }
}

代碼中涉及到一些注解,簡單介紹下

注解介紹
@Component會注冊為Spring的一個Bean
@Lazy該方法會異步執(zhí)行
@TransactionalEventListener在事務(wù)的不同階段去觸發(fā)執(zhí)行該監(jiān)聽

我們標(biāo)注了該事件是在TransactionPhase.AFTER_COMPLETION(事務(wù)提交完成)這個事務(wù)節(jié)點(diǎn)進(jìn)行事件處理。

觀察者模式

上面使用了SpringEventListener來實(shí)現(xiàn)的事件驅(qū)動,除此之外,還可以使用GuavaEventBusVert.xEventBus等方式實(shí)現(xiàn)。

很多工具類提供了關(guān)于EventBus的實(shí)現(xiàn),但是使用邏輯和方式上大多大同小異。

總結(jié)

觀察者模式監(jiān)聽模式都有利于解耦合,根據(jù)業(yè)務(wù)訴求合理的進(jìn)行開發(fā)設(shè)計,能為以后的擴(kuò)展打下堅實(shí)的基礎(chǔ)。

以上就是Mybatis中攔截器的使用場景和技巧分享的詳細(xì)內(nèi)容,更多關(guān)于Mybatis攔截器使用的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • 淺談Java中的Filter過濾器

    淺談Java中的Filter過濾器

    本篇文章主要介紹了淺談Java中的Filter過濾器,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-02-02
  • Java Stream流零基礎(chǔ)教程

    Java Stream流零基礎(chǔ)教程

    Java8的另一大亮點(diǎn)Stream,它與java.io包里的InputStream和OutputStream是完全不同的概念,下面這篇文章主要給大家介紹了關(guān)于Java8中Stream詳細(xì)使用方法的相關(guān)資料,需要的朋友可以參考下
    2022-11-11
  • Java中字符串轉(zhuǎn)int數(shù)據(jù)類型的三種方式

    Java中字符串轉(zhuǎn)int數(shù)據(jù)類型的三種方式

    這篇文章主要介紹了Java中字符串轉(zhuǎn)int數(shù)據(jù)類型的三種方式,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2023-03-03
  • 使用Spring注入Hibernate驗(yàn)證框架

    使用Spring注入Hibernate驗(yàn)證框架

    這篇文章主要介紹了使用Spring注入Hibernate驗(yàn)證框架方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-12-12
  • SpringBoot配置SwaggerUI訪問404錯誤的解決方法

    SpringBoot配置SwaggerUI訪問404錯誤的解決方法

    這篇文章主要為大家詳細(xì)介紹了SpringBoot配置SwaggerUI訪問404錯誤的解決方法,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-12-12
  • Java DOM4J方式生成XML的方法

    Java DOM4J方式生成XML的方法

    今天小編就為大家分享一篇Java DOM4J方式生成XML的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2018-07-07
  • java中Sources目錄Resources目錄的區(qū)別解讀

    java中Sources目錄Resources目錄的區(qū)別解讀

    這篇文章主要介紹了java中Sources目錄Resources目錄的區(qū)別解讀,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-12-12
  • IDEA整合jeesite4.x及安裝教程

    IDEA整合jeesite4.x及安裝教程

    本文給大家介紹IDEA整合jeesite4.x及安裝教程,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-07-07
  • hibernate屬性級別注解實(shí)例代碼

    hibernate屬性級別注解實(shí)例代碼

    這篇文章主要介紹了hibernate屬性級別注解實(shí)例代碼,涉及屬性級別注釋添加方式及種類,具有一定參考價值,需要的朋友可以了解下。
    2017-10-10
  • java中 == 與 equal 的區(qū)別講解

    java中 == 與 equal 的區(qū)別講解

    這篇文章介紹了java中 == 與 equal 的區(qū)別,有需要的朋友可以參考一下
    2013-10-10

最新評論