引言

Spring Boot是Spring框架的一個(gè)擴(kuò)展，旨在簡化Spring應(yīng)用的初始搭建和開發(fā)過程。它提供了大量的自動(dòng)配置和可插拔的組件，使得開發(fā)人員能夠快速構(gòu)建基于Java的應(yīng)用程序。 通過將Hint集成到Spring Boot應(yīng)用中，可以快速地在原有的代碼中實(shí)現(xiàn)Hint語法 功能。這種集成方式利用了Spring Boot的自動(dòng)配置和依賴注入特性，使得代碼的編寫和維護(hù)更加簡單。

背景

現(xiàn)在MYSQL數(shù)據(jù)庫架構(gòu)采用一主多從；

主庫（Master）：唯一接受寫請求的節(jié)點(diǎn)，通過二進(jìn)制日志（binlog）記錄變更，承擔(dān)數(shù)據(jù)一致性的核心職責(zé)。

從庫（Slave）：實(shí)時(shí)異步復(fù)制主庫的binlog，通過relay log重放實(shí)現(xiàn)數(shù)據(jù)同步，支持水平擴(kuò)展讀能力。

優(yōu)勢：讀擴(kuò)展性、高可用基石、數(shù)據(jù)安全、負(fù)載隔離

典型問題：主從延遲難題、主庫單點(diǎn)瓶頸、數(shù)據(jù)一致性保障

保障主數(shù)據(jù)庫安全，采用了讀寫隔離，但這樣可能就會(huì)遇到主從延遲難題。下面介紹我們遇到的問題及解決方案。

問題：

我們數(shù)據(jù)庫是騰訊云的MYSQL，并開始了數(shù)據(jù)庫代理功能（數(shù)據(jù)庫代理功能：自動(dòng)讀寫分離功能、自適應(yīng)負(fù)載均衡功能、事務(wù)拆分功能等）。但是存在一個(gè)問題：新增數(shù)據(jù)或者修改數(shù)據(jù)后，因?yàn)槲覀冏x寫分離的，讀是鏈接從庫，寫是主庫，短時(shí)間內(nèi)再去查詢偶爾出現(xiàn)數(shù)據(jù)延遲問題。

解決方案：

• 代碼連接多個(gè)數(shù)據(jù)源：當(dāng)需要方案主庫時(shí)候切換到主庫數(shù)據(jù)源。
• 數(shù)據(jù)庫采用代理方式，使用hint語法指定SQL強(qiáng)制路由到主庫。

組件實(shí)現(xiàn)內(nèi)容：

使用 Hint 語法可以強(qiáng)制 SQL 請求在指定的實(shí)例上執(zhí)行，Hint 的路由優(yōu)先級最高，例如，Hint 不受一致性、事務(wù)的約束，使用前請合理評估業(yè)務(wù)場景是否需要。

云數(shù)據(jù)庫 MySQL Hint 語法使用

組件設(shè)計(jì)

源碼地址github

核心代碼解析

Hint上下文

上下文主要管理Hint 語句、及SQL添加Hint標(biāo)志等。

public class HintContext {

    private static final ThreadLocal<String> hint = ThreadLocal.withInitial(() -> null);

    public static void markHint(String s) {
        hint.set(s);
    }

    public static boolean isHint() {
        return StringUtils.isNotBlank(hint.get());
    }

    public static String getHint() {
        return hint.get();
    }

    public static void clear() {
        hint.remove();
    }

}

攔截器

作為MyBatis的靈魂組件，攔截器的核心價(jià)值在于實(shí)現(xiàn)SQL執(zhí)行全流程的精細(xì)化控制，覆蓋參數(shù)處理、SQL改寫、結(jié)果集加工等場景。其底層通過動(dòng)態(tài)代理攔截四大核心接口：

• Executor：控制SQL執(zhí)行邏輯（增刪改查）
• StatementHandler：介入SQL預(yù)編譯與參數(shù)綁定
• ParameterHandler：實(shí)現(xiàn)參數(shù)二次處理
• ResultSetHandler：定制化結(jié)果集映射。

主要運(yùn)用了Executor攔截器，對查詢SQL進(jìn)行攔截，當(dāng)Hint上下文存在時(shí)候，對SQL進(jìn)行修改，下面代碼是今天SQL修改核心代碼。

     private void changeSQL(BoundSql boundSql, String hint) {
                String originalSql = boundSql.getSql();
                String newSql = originalSql.replaceFirst("(?i)SELECT\s+", "SELECT "+ hint +" ");
                // 使用MetaObject對象將新的SQL語句設(shè)置到BoundSql對象中
                MetaObject metaObject = SystemMetaObject.forObject(boundSql);
                metaObject.setValue("sql", newSql);
        }

快速開始

源代碼

添加maven

<dependency>
  <groupId>com.github.hint</groupId>
  <artifactId>mybatis-hint-spring-boot-starter</artifactId>
</dependency>

添加配置

hint:
  enable: true

代碼demo

hint上下文設(shè)置hint語句（HintContext.markHint(MysqlEnum.TO_MASTER.getHint());）

備注：TO_MASTER("/*FORCE_MASTER*/", "強(qiáng)制走主庫")

接下來執(zhí)行SQL，User pojo = this.getById(id);

//采用MysqlEnum的hint語句
public UserInfoVO getInfoById(Long id) {

        // 強(qiáng)制路由到主庫查詢
        HintContext.markHint(MysqlEnum.TO_MASTER.getHint());
        // 執(zhí)行數(shù)據(jù)庫查詢
        User pojo = this.getById(id);
        if (pojo == null) {
            return null;
        }
        UserInfoVO userInfoVO = new UserInfoVO();
        userInfoVO.setCode(pojo.getCode());
        userInfoVO.setName(pojo.getUsername());
        return userInfoVO;
    }

//自定義的hint語句
public UserInfoVO getInfoById(Long id) {

        // 強(qiáng)制路由到指定的實(shí)例
        HintContext.markHint("/* to server test_ro_1 */");
        // 執(zhí)行數(shù)據(jù)庫查詢
        User pojo = this.getById(id);
        if (pojo == null) {
            return null;
        }
        UserInfoVO userInfoVO = new UserInfoVO();
        userInfoVO.setCode(pojo.getCode());
        userInfoVO.setName(pojo.getUsername());
        return userInfoVO;
    }

執(zhí)行結(jié)果：SELECT /*FORCE_MASTER*/ id,code,username,password FROM test_user WHERE id=?

到此這篇關(guān)于SpringBoot集成Hint語法組件的代碼詳解的文章就介紹到這了,更多相關(guān)SpringBoot集成Hint內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論