日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
SpringBoot整合MyCat實現(xiàn)讀寫分離

MyCat一個徹底開源的，面向企業(yè)應(yīng)用開發(fā)的大數(shù)據(jù)庫集群?；诎⒗镩_源的Cobar產(chǎn)品而研發(fā)。能滿足數(shù)據(jù)庫數(shù)據(jù)大量存儲；提高了查詢性能。文章介紹如何實現(xiàn)MyCat連接MySQL實現(xiàn)主從分離，并集成SpringBoot實現(xiàn)讀寫分離。

MySQL配置主從關(guān)系

說明

  •  192.168.0.105 Linux 數(shù)據(jù)庫作為主master數(shù)據(jù)庫
  •  127.0.0.1 Window 作為從slave數(shù)據(jù)庫

master主數(shù)據(jù)庫配置

binlog是Mysql sever層維護的一種二進制日志，主要是用來記錄對Mysql數(shù)據(jù)更新或潛在發(fā)生更新的SQL語句，記錄了所有的寫語句，并以事務(wù)的形式保存在磁盤中，還包含語句所執(zhí)行的消耗的時間，MySQL的二進制日志是事務(wù)安全型的。

master上開啟log_bin

 
 
 
 
    
  
  
  
  
  1. $ vim /etc/my.cnf  
    2.   
  
  
  
  2. log-bin           = mysql-bin  #[必須]啟用二進制日志  
    3.   
  
  
  
  3. server-id         = 4          #[必須]服務(wù)器唯一ID，默認(rèn)是1，最好取ip的后3位  
    4.   
  
  
  
  4. expire-logs-days  = 7           #只保留7天的二進制日志，以防磁盤被日志占滿  
    5.   
  
  
  
  5. binlog-ignore-db  = mysql       #不備份的數(shù)據(jù)庫  
    6.   
  
  
  
  6. binlog-ignore-db  = information_schema  
    7.   
  
  
  
  7. binlog-ignore-db  = performation_schema  
    8.   
  
  
  
  8. binlog-ignore-db  = sys  
    9.   
  
  
  
  9. binlog-do-db=itools_simple #需要做復(fù)制的數(shù)據(jù)庫名，如果有多個，復(fù)制binlog-do-db即可 
    10.

登錄mysql，測試log_bin是否成功開啟

 
 
 
 
    
  
  
  
  
  1. $ mysql -u root -p  
    2.   
  
  
  
  2.   Root@123  
    3.   
  
  
  
  3. // log_bin ON表示開啟成功，OFF表示開啟失敗  
    4.   
  
  
  
  4. mysql> show variables like '%log_bin%';  
    5.   
  
  
  
  5. +---------------------------------+--------------------------------+  
    6.   
  
  
  
  6. | Variable_name                   | Value                          |  
    7.   
  
  
  
  7. +---------------------------------+--------------------------------+  
    8.   
  
  
  
  8. | log_bin                         | ON                             |  
    9.   
  
  
  
  9. | log_bin_basename                | /var/lib/mysql/mysql-bin       |  
    10.   
  
  
  
  10. | log_bin_index                   | /var/lib/mysql/mysql-bin.index |  
    11.   
  
  
  
  11. | log_bin_trust_function_creators | OFF                            |  
    12.   
  
  
  
  12. | log_bin_use_v1_row_events       | OFF                            |  
    13.   
  
  
  
  13. | sql_log_bin                     | ON                             |  
    14.   
  
  
  
  14. +---------------------------------+--------------------------------+  
    15.   
  
  
  
  15. 6 rows in set (0.01 sec) 
    16.

新增備份賬戶

 
 
 
 
    
  
  
  
  
  1. mysql> grant replication slave on *.* to 'backup'@'%' identified by 'Root@123';  
    2.   
  
  
  
  2. mysql> use mysql  
    3.   
  
  
  
  3. mysql> select user,authentication_string,host from user; 
    4.

重啟mysql

 
 
 
 
    
  
  
  
  
  1. $ systemctl restart mysqld 
    2.

登錄mysql，并設(shè)置只讀

 
 
 
 
    
  
  
  
  
  1. $ mysql -u root -p  
    2.   
  
  
  
  2.   Root@123  
    3.   
  
  
  
  3. mysql> flush tables with read lock;  
    4.   
  
  
  
  4. mysql> show master status \G  
    5.   
  
  
  
  5. *************************** 1. row ***************************  
    6.   
  
  
  
  6.              File: mysql-bin.000003  
    7.   
  
  
  
  7.          Position: 154  
    8.   
  
  
  
  8.      Binlog_Do_DB: itools_simple  
    9.   
  
  
  
  9.  Binlog_Ignore_DB: mysql,information_schema,performation_schema,sys  
    10.   
  
  
  
  10. Executed_Gtid_Set:  
    11.   
  
  
  
  11.  1 row in set (0.01 sec)  
    12.   
  
  
  
  12. // 導(dǎo)出數(shù)據(jù)庫，進入到一個合適的文件夾  
    13.   
  
  
  
  13. $ mysqldump -u root -p itools_simple > itools_simple.txt  
    14.   
  
  
  
  14. // 把生成的文件導(dǎo)出到本機  
    15.   
  
  
  
  15. $ sz itools_simple.txt  
    16.   
  
  
  
  16. // 在window本機打開cmd，登錄slave本機mysql數(shù)據(jù)庫，導(dǎo)入數(shù)據(jù)庫  
    17.   
  
  
  
  17. $ .\mysql -u root -p -hlocalhost mycat_master < .\itools_simple.txt 
    18.

slave從數(shù)據(jù)庫配置

配置 my.ini 文件

 
 
 
 
    
  
  
  
  
  1. [mysql]  
    2.   
  
  
  
  2. #default-character-set=utf8  
    3.   
  
  
  
  3. [mysqld]   
    4.   
  
  
  
  4. max_connections=200  
    5.   
  
  
  
  5. character-set-server=utf8  
    6.   
  
  
  
  6. default-storage-engine=INNODB  
    7.   
  
  
  
  7. # 添加一下配置  
    8.   
  
  
  
  8. log-bin=mysql-bin  
    9.   
  
  
  
  9. server-id=223 
    10.

重啟slave數(shù)據(jù)庫

 
 
 
 
    
  
  
  
  
  1. net stop mysql  
    2.   
  
  
  
  2. net start mysql 
    3.

登錄slave數(shù)據(jù)庫

 
 
 
 
    
  
  
  
  
  1. $ mysql -u root -p  
    2.   
  
  
  
  2.   123456  
    3.   
  
  
  
  3. // 停止 slave  
    4.   
  
  
  
  4. mysql> stop slave;  
    5.   
  
  
  
  5. // 根據(jù)master中的status，添加以下配置  
    6.   
  
  
  
  6. msyql> change master to master_host='192.168.0.105',master_user='backup',master_password='Root@123',master_log_file='mysql-bin.000003',master_log_pos=154;  
    7.   
  
  
  
  7. // 啟用slave  
    8.   
  
  
  
  8. mysql> start slave;  
    9.   
  
  
  
  9. // 查看slave狀態(tài)  
    10.   
  
  
  
  10. mysql> show slave status \G  
    11.   
  
  
  
  11. *************************** 1. row ***************************  
    12.   
  
  
  
  12.                Slave_IO_State: Waiting for master to send event  
    13.   
  
  
  
  13.                   Master_Host: 192.168.0.105  
    14.   
  
  
  
  14.                   Master_User: backup  
    15.   
  
  
  
  15.                   Master_Port: 3306  
    16.   
  
  
  
  16.                 Connect_Retry: 60  
    17.   
  
  
  
  17.               Master_Log_File: mysql-bin.000003  
    18.   
  
  
  
  18.           Read_Master_Log_Pos: 154  
    19.   
  
  
  
  19.                Relay_Log_File: DESKTOP-OB9O5N7-relay-bin.000002  
    20.   
  
  
  
  20.                 Relay_Log_Pos: 320  
    21.   
  
  
  
  21.         Relay_Master_Log_File: mysql-bin.000003  
    22.   
  
  
  
  22.              Slave_IO_Running: Yes  
    23.   
  
  
  
  23.             Slave_SQL_Running: Yes  
    24.   
  
  
  
  24.              ..............  
    25.   
  
  
  
  25. 1 row in set (0.00 sec)  
    26.   
  
  
  
  26. // 出現(xiàn)下面兩個說明配置正確  
    27.   
  
  
  
  27.  Slave_IO_Running: Yes  
    28.   
  
  
  
  28. Slave_SQL_Running: Yes 
    29.

關(guān)閉master數(shù)據(jù)庫的只讀設(shè)置

 
 
 
 
    
  
  
  
  
  1. mysql> unlock tables; 
    2.

存儲引擎

InnoDB特性

MySQL5.5版本后，MySQL的默認(rèn)內(nèi)置存儲引擎已經(jīng)從MyISAM變成InnoDB

  •  支持事務(wù);
  •  行級鎖定(更新數(shù)據(jù)時一般指鎖定當(dāng)前行)：通過索引實現(xiàn)、全表掃描忍讓時表鎖、注意間隙所的影響;
  •  讀寫阻塞與事務(wù)的隔離級別相關(guān)；
  •  具有非常高的緩存特性(既能緩存索引、也能緩存數(shù)據(jù))；
  •  這個表和主鍵以組(Cluster)的方式存儲、組成一顆平衡樹；
  •  所有的輔助索引(secondary indexes)都會保存主鍵信息；
  •  支持分區(qū)、表空間類似與oracle 數(shù)據(jù)庫；
  •  支持外鍵約束、不支持全文檢索(5.5.5之前的MyISAM支持全文檢索、5.5.5之后就不在支持);
  •  相對MyISAM而言、對硬件的要求比較高

MyISAM特性

  •  不支持事務(wù)
  •  表級鎖定，數(shù)據(jù)更新時鎖定整個表：其鎖定機制是表級鎖定，這雖然可以讓鎖定的實現(xiàn)成本很小但是也同時大大降低了其并發(fā)性能。
  •  讀寫互相阻塞：不僅會在寫入的時候阻塞讀取，myisam還會在讀取的時候阻塞寫入，但讀本身并不會阻塞另外的讀。
  •  只會緩存索引：MyISAM可以通過key_buffer_size緩存索引，以大大提高訪問性能，減少產(chǎn)品IO，但是這個緩存區(qū)只會緩存索引，而不會緩存數(shù)據(jù)。
  •  讀取速度較快，占用資源相對少。
  •  不支持外鍵約束，但支持全文索引。

修改slave數(shù)據(jù)庫存儲引擎

 
 
 
 
    
  
  
  
  
  1. mysql> show variables like '%storage_engine%';  
    2.   
  
  
  
  2. +----------------------------------+--------+  
    3.   
  
  
  
  3. | Variable_name                    | Value  |  
    4.   
  
  
  
  4. +----------------------------------+--------+  
    5.   
  
  
  
  5. | default_storage_engine           | InnoDB |  
    6.   
  
  
  
  6. | default_tmp_storage_engine       | InnoDB |  
    7.   
  
  
  
  7. | disabled_storage_engines         |        |  
    8.   
  
  
  
  8. | internal_tmp_disk_storage_engine | InnoDB |  
    9.   
  
  
  
  9. +----------------------------------+--------+  
    10.   
  
  
  
  10. 4 rows in set (0.00 sec)  
    11.   
  
  
  
  11. // 修改配置文件  
    12.   
  
  
  
  12. $ vim /etc/my.ini  
    13.   
  
  
  
  13.     [mysqld]  
    14.   
  
  
  
  14.     default-storage-engine=MyISAM  
    15.   
  
  
  
  15. $ systemctl restart mysqld 
    16.   
  
  
  
  16. mysql> show variables like '%storage_engine%';  
    17.   
  
  
  
  17. +----------------------------------+--------+  
    18.   
  
  
  
  18. | Variable_name                    | Value  |  
    19.   
  
  
  
  19. +----------------------------------+--------+  
    20.   
  
  
  
  20. | default_storage_engine           | MyISAM |  
    21.   
  
  
  
  21. | default_tmp_storage_engine       | InnoDB |  
    22.   
  
  
  
  22. | disabled_storage_engines         |        |  
    23.   
  
  
  
  23. | internal_tmp_disk_storage_engine | InnoDB |  
    24.   
  
  
  
  24. +----------------------------------+--------+  
    25.   
  
  
  
  25. 4 rows in set (0.00 sec) 
    26.

修改表存儲引擎

如果是slave數(shù)據(jù)庫的表是MyISAM，master數(shù)據(jù)庫的表是InnoDB。直接覆蓋master數(shù)據(jù)庫來同步數(shù)據(jù)的話，slave數(shù)據(jù)庫表的存儲引擎也將會同步變成InnoDB。擴展：InnoDB一棵B+樹可以存放多少行數(shù)據(jù)？

更換存儲引擎遇到的問題

This function has none of DETERMINISTIC, NO SQL, or READS SQL DATA in its declaration and binary logging is enabled (you might want to use the less safe log_bin_trust_function_creators variable)

出現(xiàn)的原因

在function里面，只有 DETERMINISTIC, NO SQL 和 READS SQL DATA 被支持。

如果我們開啟了 bin-log, 我們就必須為我們的function指定一個參數(shù)。

解決方案

 
 
 
 
    
  
  
  
  
  1. mysql> set global log_bin_trust_function_creators=TRUE; 
    2.

Specified key was too long; max key length is 1000 bytes

出現(xiàn)的原因

  1.  DB的 engine 是 MyISAM
  2.  字符集是 utf8 ，1個 utf8=3bytes
  3.  (索引長度總和) * 3 > 1000。

解決方案

  1.  修改DB engine 至 innodb
  2.  更改字符集
  3.  減小字段長度

注意：一定不要手動去修改slave數(shù)據(jù)庫中的數(shù)據(jù)，需要給slave的用戶設(shè)置只讀。

至此，mysql的數(shù)據(jù)庫主從設(shè)置已經(jīng)配置成功。在master中修改數(shù)據(jù)庫，會同步到slave中。

Mycat基于MySQL的讀寫分離

Mycat不負(fù)責(zé)數(shù)據(jù)的同步，所以要還是要基于MySQL的主從配置來實現(xiàn)讀寫分離。

安裝Mycat

由于github限制，所以以后新版本從以下地址下載 http://dl.mycat.io

Linux創(chuàng)建文件夾/usr/local/mycat，進入文件夾，下載安裝包

 
 
 
 
    
  
  
  
  
  1. $ wget http://dl.mycat.io/1.6.7.5/2020-3-3/Mycat-server-1.6.7.5-test-20200303154735-linux.tar.gz  
    2.   
  
  
  
  2. $ tar -zxvf Mycat-server-1.6.7.5-test-20200303154735-linux.tar.gz  
    3.   
  
  
  
  3. $ cd mycat  
    4.   
  
  
  
  4. $ useradd mycat  
    5.   
  
  
  
  5. $ chown -R mycat:mycat /usr/local/mycat/mycat  
    6.   
  
  
  
  6. $ passwd mycat  
    7.   
  
  
  
  7. // 配置hostname，添加以下配置  
    8.   
  
  
  
  8. [root@localhost mycat] vim /etc/sysconfig/network  
    9.   
  
  
  
  9.     HOSTNAME=localhost（主機名）  
    10.   
  
  
  
  10. // 查看是否配置主機  
    11.   
  
  
  
  11. $ vim /etc/hosts 
    12.

將Mycat配置到環(huán)境變量中

 
 
 
 
    
  
  
  
  
  1. $ vim /etc/profile  
    2.   
  
  
  
  2. // 在最后添加  
    3.   
  
  
  
  3. MYCAT_HOME=/usr/local/mycat/mycat  
    4.   
  
  
  
  4. PATH=$MYCAT_HOME/bin:$PATH  
    5.   
  
  
  
  5. export PATH  
    6.   
  
  
  
  6. // 使配置生效  
    7.   
  
  
  
  7. $ source /etc/profile 
    8.

在master數(shù)據(jù)庫中添加user1（寫）、user2（只讀）兩個賬戶，并配置權(quán)限。

配置mycat的schema.xml

 
 
 
 
    
  
  
  
  
  1.   
    2.   
  
  
  
  2.   
    3.   
  
  
  
  3.   
    4.   
  
  
  
  4.       
    5.   
  
  
  
  5.       
    6.   
  
  
  
  6.       
    7.   
  
  
  
  7.       
  
  
  
  8.               writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">  
    9.   
  
  
  
  9.         select user()  
    10.   
  
  
  
  10.           
    11.   
  
  
  
  11.               
    12.   
  
  
  
  12.               
    13.   
  
  
  
  13.           
    14.   
  
  
  
  14.       
    15.   
  
  
  
  15.  
    16.

配置mycat的server.xml，增加兩個用戶

 
 
 
 
    
  
  
  
  
  1.   
    2.   
  
  
  
  2.     Root@123  
    3.   
  
  
  
  3.     itools_simple  
    4.   
  
  
  
  4.     itools_simple  
    5.   
  
  
  
  5.   
    6.   
  
  
  
  6.   
    7.   
  
  
  
  7.     Root@123  
    8.   
  
  
  
  8.     itools_simple  
    9.   
  
  
  
  9.     true  
    10.   
  
  
  
  10.     itools_simple  
    11.   
  
  
  
  11.  
    12.

啟動Mycat

啟動mycat

 
 
 
 
    
  
  
  
  
  1. $ mycat start  
    2.   
  
  
  
  2. Starting Mycat-server... 
    3.

查看啟動日志

 
 
 
 
    
  
  
  
  
  1. $ cat wrapper.log  
    2.   
  
  
  
  2. MyCAT Server startup successfully. see logs in logs/mycat.log 
    3.

使用客戶端連接mycat

使用SQLyog連接(使用此方式連接，不能直接通過點擊表查看數(shù)據(jù))

使用Navicat連接

可通過客戶端直接查看master數(shù)據(jù)，也可通過修改mycat數(shù)據(jù)，查看master和slave的數(shù)據(jù)是否會同步

SpringBoot 整合 MyCat 實現(xiàn)讀寫分離

  •  首先需要配置好數(shù)據(jù)庫的主從關(guān)系。
  •  配置好MyCat服務(wù)。
  •  實現(xiàn)MyCat與MySQL讀寫分離。

添加依賴

 
 
 
 
    
  
  
  
  
  1.   
    2.   
  
  
  
  2.     org.springframework.boot  
    3.   
  
  
  
  3.     spring-boot-starter-aop  
    4.   
  
  
  
  4.   
    5.   
  
  
  
  5.   
    6.   
  
  
  
  6.     com.alibaba  
    7.   
  
  
  
  7.     druid  
    8.   
  
  
  
  8.     1.0.23  
    9.   
  
  
  
  9.  
    10.

創(chuàng)建數(shù)據(jù)源

 
 
 
 
    
  
  
  
  
  1. package com.muycode.itoolsimple.datasource;  
    2.   
  
  
  
  2. import org.springframework.boot.context.properties.ConfigurationProperties;  
    3.   
  
  
  
  3. import org.springframework.boot.jdbc.DataSourceBuilder;  
    4.   
  
  
  
  4. import org.springframework.context.annotation.Bean;  
    5.   
  
  
  
  5. import org.springframework.context.annotation.Configuration;  
    6.   
  
  
  
  6. import javax.sql.DataSource;  
    7.   
  
  
  
  7. @Configuration  
    8.   
  
  
  
  8. public class DataSourceConfig {  
    9.   
  
  
  
  9.     /**  
    10.   
  
  
  
  10.      * 創(chuàng)建可讀數(shù)據(jù)源  
    11.   
  
  
  
  11.      *  
    12.   
  
  
  
  12.      * @return  
    13.   
  
  
  
  13.      */  
    14.   
  
  
  
  14.     @Bean(name = "selectDataSource")  
    15.   
  
  
  
  15.     @ConfigurationProperties(prefix = "spring.datasource.select")  
    16.   
  
  
  
  16.     public DataSource dataSource1() {  
    17.   
  
  
  
  17.         return DataSourceBuilder.create().build();  
    18.   
  
  
  
  18.     }  
    19.   
  
  
  
  19.     /**  
    20.   
  
  
  
  20.      * 創(chuàng)建可寫數(shù)據(jù)源  
    21.   
  
  
  
  21.      *  
    22.   
  
  
  
  22.      * @return  
    23.   
  
  
  
  23.      */  
    24.   
  
  
  
  24.     @Bean(name = "updateDataSource")  
    25.   
  
  
  
  25.     @ConfigurationProperties(prefix = "spring.datasource.update")  
    26.   
  
  
  
  26.     public DataSource dataSource2() {  
    27.   
  
  
  
  27.         return DataSourceBuilder.create().build();  
    28.   
  
  
  
  28.     }  
    29.   
  
  
  
  29. } 
    30.

設(shè)置數(shù)據(jù)源

 
 
 
 
    
  
  
  
  
  1. package com.muycode.itoolsimple.datasource;  
    2.   
  
  
  
  2. import org.springframework.context.annotation.Lazy;  
    3.   
  
  
  
  3. import org.springframework.stereotype.Component;  
    4.   
  
  
  
  4. @Component  
    5.   
  
  
  
  5. @Lazy(false)  
    6.   
  
  
  
  6. public class DataSourceContextHolder {  
    7.   
  
  
  
  7.     /**  
    8.   
  
  
  
  8.      * 采用ThreadLocal 保存本地多數(shù)據(jù)源  
    9.   
  
  
  
  9.      */  
    10.   
  
  
  
  10.     private static final ThreadLocal contextHolder = new ThreadLocal<>();  
    11.   
  
  
  
  11.     /**  
    12.   
  
  
  
  12.      * 設(shè)置數(shù)據(jù)源類型  
    13.   
  
  
  
  13.      *  
    14.   
  
  
  
  14.      * @param dbType  
    15.   
  
  
  
  15.      */  
    16.   
  
  
  
  16.     public static void setDbType(String dbType) {  
    17.   
  
  
  
  17.         contextHolder.set(dbType);  
    18.   
  
  
  
  18.     }  
    19.   
  
  
  
  19.     /**  
    20.   
  
  
  
  20.      * 獲取數(shù)據(jù)源類型  
    21.   
  
  
  
  21.      */  
    22.   
  
  
  
  22.     public static String getDbType() {  
    23.   
  
  
  
  23.         return contextHolder.get();  
    24.   
  
  
  
  24.     }  
    25.   
  
  
  
  25.     public static void clearDbType() {  
    26.   
  
  
  
  26.         contextHolder.remove();  
    27.   
  
  
  
  27.     }  
    28.   
  
  
  
  28. } 
    29.

返回數(shù)據(jù)源

 
 
 
 
    
  
  
  
  
  1. package com.muycode.itoolsimple.datasource; 
    2.   
  
  
  
  2. import org.springframework.beans.factory.annotation.Autowired;  
    3.   
  
  
  
  3. import org.springframework.beans.factory.annotation.Qualifier;  
    4.   
  
  
  
  4. import org.springframework.context.annotation.Primary;  
    5.   
  
  
  
  5. import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;  
    6.   
  
  
  
  6. import org.springframework.stereotype.Component;  
    7.   
  
  
  
  7. import javax.sql.DataSource;  
    8.   
  
  
  
  8. import java.util.HashMap;  
    9.   
  
  
  
  9. import java.util.Map;  
    10.   
  
  
  
  10. @Component  
    11.   
  
  
  
  11. @Primary 
    12.   
  
  
  
  12.  public class DynamicDataSource extends AbstractRoutingDataSource {  
    13.   
  
  
  
  13.     @Autowired  
    14.   
  
  
  
  14.     @Qualifier("selectDataSource")  
    15.   
  
  
  
  15.     private DataSource selectDataSource; 
    16.   
  
  
  
  16.     @Autowired  
    17.   
  
  
  
  17.     @Qualifier("updateDataSource")  
    18.   
  
  
  
  18.     private DataSource updateDataSource;  
    19.   
  
  
  
  19.     /**  
    20.   
  
  
  
  20.      * 返回生效的數(shù)據(jù)源名稱  
    21.   
  
  
  
  21.      */  
    22.   
  
  
  
  22.     @Override  
    23.   
  
  
  
  23.     protected Object determineCurrentLookupKey() {  
    24.   
  
  
  
  24.         return DataSourceContextHolder.getDbType();  
    25.   
  
  
  
  25.     }  
    26.   
  
  
  
  26.     /**  
    27.   
  
  
  
  27.      * 配置數(shù)據(jù)源信息  
    28.   
  
  
  
  28.      */  
    29.   
  
  
  
  29.     @Override  
    30.   
  
  
  
  30.     public void afterPropertiesSet() {  
    31.   
  
  
  
  31.         Map map = new HashMap<>(16);  
    32.   
  
  
  
  32.         map.put("selectDataSource", selectDataSource);  
    33.   
  
  
  
  33.         map.put("updateDataSource", updateDataSource);  
    34.   
  
  
  
  34.         setTargetDataSources(map);  
    35.   
  
  
  
  35.         setDefaultTargetDataSource(updateDataSource);  
    36.   
  
  
  
  36.         super.afterPropertiesSet();  
    37.   
  
  
  
  37.     }  
    38.   
  
  
  
  38. } 
    39.

創(chuàng)建切面，動態(tài)設(shè)置數(shù)據(jù)源

 
 
 
 
    
  
  
  
  
  1. package com.muycode.itoolsimple.datasource;  
    2.   
  
  
  
  2. import org.aspectj.lang.JoinPoint;  
    3.   
  
  
  
  3. import org.aspectj.lang.annotation.Aspect;  
    4.   
  
  
  
  4. import org.aspectj.lang.annotation.Before;  
    5.   
  
  
  
  5. import org.springframework.context.annotation.Lazy;  
    6.   
  
  
  
  6. import org.springframework.core.annotation.Order;  
    7.   
  
  
  
  7. import org.springframework.stereotype.Component;  
    8.   
  
  
  
  8. @Aspect  
    9.   
  
  
  
  9. @Component  
    10.   
  
  
  
  10. @Lazy(false)  
    11.   
  
  
  
  11. @Order(0) // Order設(shè)定AOP執(zhí)行順序 使之在數(shù)據(jù)庫事務(wù)上先執(zhí)行  
    12.   
  
  
  
  12. public class DataSourceOptionAop {  
    13.   
  
  
  
  13.     /**  
    14.   
  
  
  
  14.      * 可讀數(shù)據(jù)源  
    15.   
  
  
  
  15.      */  
    16.   
  
  
  
  16.     private final static String DATASOURCE_TYPE_SELECT = "selectDataSource";  
    17.   
  
  
  
  17.     /**  
    18.   
  
  
  
  18.      * 可寫數(shù)據(jù)源  
    19.   
  
  
  
  19.      */  
    20.   
  
  
  
  20.     private final static String DATASOURCE_TYPE_UPDATE = "updateDataSource";  
    21.   
  
  
  
  21.     /**  
    22.   
  
  
  
  22.      * 創(chuàng)建切面，根據(jù)方法類型選擇不同的數(shù)據(jù)源  
    23.   
  
  
  
  23.      *  
    24.   
  
  
  
  24.      * @param joinPoint  
    25.   
  
  
  
  25.      */  
    26.   
  
  
  
  26.     @Before("execution(* com.muycode.itoolsimple.service.*.*(..))")  
    27.   
  
  
  
  27.     public void process(JoinPoint joinPoint) { 
    28.   
  
  
  
  28.          String methodName = joinPoint.getSignature().getName();  
    29.   
  
  
  
  29.         System.out.print("=========== " + methodName);  
    30.   
  
  
  
  30.         if (methodName.startsWith("get") || methodName.startsWith("count") || methodName.startsWith("find")  
    31.   
  
  
  
  31.                 || methodName.startsWith("list") || methodName.startsWith("select") || methodName.startsWith("check")  
    32.   
  
  
  
  32.                 || methodName.startsWith("query")) {  
    33.   
  
  
  
  33.             DataSourceContextHolder.setDbType(DATASOURCE_TYPE_SELECT);  
    34.   
  
  
  
  34.             System.out.println("-----------------使用selectDataSource數(shù)據(jù)源-------------------");  
    35.   
  
  
  
  35.         } else {  
    36.   
  
  
  
  36.             DataSourceContextHolder.setDbType(DATASOURCE_TYPE_UPDATE);  
    37.   
  
  
  
  37.             System.out.println("-----------------使用updateDataSource數(shù)據(jù)源-------------------");  
    38.   
  
  
  
  38.         }  
    39.   
  
  
  
  39.     }  
    40.   
  
  
  
  40. } 
    41.

輸出結(jié)果

 
 
 
 
    
  
  
  
  
  1. =========== getByUsername-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    2.   
  
  
  
  2. =========== getPermissionStringByUserId-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    3.   
  
  
  
  3. =========== getPermissionByUserId-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    4.   
  
  
  
  4. =========== getRolePermissionLinkByUserId-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    5.   
  
  
  
  5. =========== save-----------------使用updateDataSource數(shù)據(jù)源-------------------  
    6.   
  
  
  
  6. =========== queryByPage-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    7.   
  
  
  
  7. =========== save-----------------使用updateDataSource數(shù)據(jù)源-------------------  
    8.   
  
  
  
  8. =========== getPermissionAll-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    9.   
  
  
  
  9. =========== save-----------------使用updateDataSource數(shù)據(jù)源-------------------  
    10.   
  
  
  
  10. =========== getSysCodeAll-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    11.   
  
  
  
  11. =========== save-----------------使用updateDataSource數(shù)據(jù)源-------------------  
    12.   
  
  
  
  12. =========== getByRid-----------------使用selectDataSource數(shù)據(jù)源-------------------  
    13.

當(dāng)前名稱：SpringBoot整合MyCat實現(xiàn)讀寫分離
網(wǎng)頁URL：http://www.5511xx.com/article/coicced.html