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

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

新聞中心

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

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

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

說(shuō)明

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

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

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

master上開(kāi)啟log_bin

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

登錄mysql，測(cè)試log_bin是否成功開(kāi)啟

 
 
 
 
    
  
  
  
  
  1. $ mysql -u root -p  
    2.   
  
  
  
  2.   Root@123  
    3.   
  
  
  
  3. // log_bin ON表示開(kāi)啟成功，OFF表示開(kāi)啟失敗  
    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.

新增備份賬戶(hù)

 
 
 
 
    
  
  
  
  
  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ù)庫(kù)，進(jìn)入到一個(gè)合適的文件夾  
    13.   
  
  
  
  13. $ mysqldump -u root -p itools_simple > itools_simple.txt  
    14.   
  
  
  
  14. // 把生成的文件導(dǎo)出到本機(jī)  
    15.   
  
  
  
  15. $ sz itools_simple.txt  
    16.   
  
  
  
  16. // 在window本機(jī)打開(kāi)cmd，登錄slave本機(jī)mysql數(shù)據(jù)庫(kù)，導(dǎo)入數(shù)據(jù)庫(kù)  
    17.   
  
  
  
  17. $ .\mysql -u root -p -hlocalhost mycat_master < .\itools_simple.txt 
    18.

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

配置 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ù)庫(kù)

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

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

 
 
 
 
    
  
  
  
  
  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)下面兩個(gè)說(shuō)明配置正確  
    27.   
  
  
  
  27.  Slave_IO_Running: Yes  
    28.   
  
  
  
  28. Slave_SQL_Running: Yes 
    29.

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

 
 
 
 
    
  
  
  
  
  1. mysql> unlock tables; 
    2.

存儲(chǔ)引擎

InnoDB特性

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

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

MyISAM特性

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

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

 
 
 
 
    
  
  
  
  
  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.

修改表存儲(chǔ)引擎

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

更換存儲(chǔ)引擎遇到的問(wèn)題

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 被支持。

如果我們開(kāi)啟了 bin-log, 我們就必須為我們的function指定一個(gè)參數(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個(gè) utf8=3bytes
  3.  (索引長(zhǎng)度總和) * 3 > 1000。

解決方案

  1.  修改DB engine 至 innodb
  2.  更改字符集
  3.  減小字段長(zhǎng)度

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

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

Mycat基于MySQL的讀寫(xiě)分離

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

安裝Mycat

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

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

 
 
 
 
    
  
  
  
  
  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（主機(jī)名）  
    10.   
  
  
  
  10. // 查看是否配置主機(jī)  
    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ù)庫(kù)中添加user1（寫(xiě)）、user2（只讀）兩個(gè)賬戶(hù)，并配置權(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，增加兩個(gè)用戶(hù)

 
 
 
 
    
  
  
  
  
  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.

啟動(dòng)Mycat

啟動(dòng)mycat

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

查看啟動(dòng)日志

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

使用客戶(hù)端連接mycat

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

使用Navicat連接

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

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

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

添加依賴(lài)

 
 
 
 
    
  
  
  
  
  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)建可寫(xiě)數(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ù)源類(lèi)型  
    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ù)源類(lèi)型  
    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.

返回?cái)?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ù)源名稱(chēng)  
    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)建切面，動(dò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ù)庫(kù)事務(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.      * 可寫(xiě)數(shù)據(jù)源  
    19.   
  
  
  
  19.      */  
    20.   
  
  
  
  20.     private final static String DATASOURCE_TYPE_UPDATE = "updateDataSource";  
    21.   
  
  
  
  21.     /**  
    22.   
  
  
  
  22.      * 創(chuàng)建切面，根據(jù)方法類(lèi)型選擇不同的數(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實(shí)現(xiàn)讀寫(xiě)分離
文章網(wǎng)址：http://m.5511xx.com/article/coicced.html