Redis整合MySQL主從集群的示例代碼
Redis作為承擔緩存作用的數(shù)據(jù)庫，一般會應(yīng)用在高并發(fā)的場景里，而在這些高并發(fā)應(yīng)用場景的數(shù)據(jù)庫層面還會用到其他數(shù)據(jù)庫的組件或集群以提升性能，比如用MySQL主從集群實現(xiàn)讀寫分離效果、用MyCAT組件實現(xiàn)分庫分表的功能。另外，Redis本身會以集群的形式對外提供緩存服務(wù)。
1、用Docker搭建MySQL主從集群
這里用Docker容器搭建如下圖所示的MySQL主從集群。
- 在主MySQL服務(wù)器里操作的動作會自動同步到從nysql服務(wù)器，比如在主服務(wù)器里發(fā)起的“建數(shù)據(jù)庫”“通過insert語句插入數(shù)據(jù)”和“通過delete語句刪除數(shù)據(jù)”的動作都會同步到從服務(wù)器，并且這些操作都會在從服務(wù)器上被執(zhí)行。通過這種同步的動作能確保主從數(shù)據(jù)庫間的數(shù)據(jù)一致性。
- 在項目里，一般是向“主服務(wù)器”里寫數(shù)據(jù)，從“從服務(wù)器”里讀數(shù)據(jù)，用這種“讀寫分離”的操作方式提升數(shù)據(jù)庫性能。
具體搭建的步驟如下：
1.1 拉取mysql鏡像
開啟一個命令窗口，在其中運行docker pull mysql:latest,下載最新的mysql鏡像。下載完成后，通過docker images mysql能看到如下圖所示的鏡像i信息。
1.2 創(chuàng)建配置文件夾
新建/root/redisconf/masterMySQL/conf和/root/redisconf/masterMySQL/data兩個目錄，在其中將會保存主mysql服務(wù)器的配置信息和數(shù)據(jù)。同時新建/root/redisconf/slaveMySQL/conf和/root/redisconf/slaveMySQL/data兩個目錄，在其中將會保存從MySQL服務(wù)器的配置信息和數(shù)據(jù)。當然，目錄可自行更改。
1.3 編寫主服務(wù)器的配置文件信息
在/root/redisconf/masterMySQL/conf目錄里新建一個my.cnf文件，在其中編寫針對主mysql服務(wù)器的配置信息，主mysql服務(wù)器在啟動時會讀取其中的配置，具體代碼如下所示：
[mysqld] pid-file =/var/run/mysqld/mysqld.pid socket =/var/run/mysqld/mysqld.sock datadir =/var/lib/mysql server-id =1 log-bin=mysql-master-bin
第二行到第四行給出了MYSQL運行時的參數(shù)，在第五行里定義了該服務(wù)器的id(這個id需要和之后編寫的從MySQL服務(wù)器的server-id不一樣，否則會出錯)，在第6行里制定了二進制文件的名字(為了搭建主從集群，建議加上這行配置)
1.4 啟動mysql主服務(wù)器的容器
docker run -itd --privileged=true -p 3306:3306 \ --name myMasterMysql -e MYSQL_ROOT_PASSWORD=123456\ -v /root/redisconf/masterMySQL/conf:/etc/mysql/conf.d\ -v /root/redisconf/masterMySQL/data:/var/lib/mysql mysql:latest
-p3306：3306參數(shù)指定Docker容器里MySQL的工作端口3306映射到主機的3306端口
-itd參數(shù)指定該容器以后臺交互模式的方式啟動--name參數(shù)指定該容器的名字
通過-e MYSQL_ROOT_PASSWORD=123456參數(shù)指定該容器運行時的環(huán)境變量，具體到這個場景，配置以用戶名root登錄到MySQL服務(wù)器時所用到的密碼123456.
兩個-v參數(shù)指定外部主機和Docker容器間映射的目錄。由于在第三步把MySQL啟動時需要加載的my.cnf文件放在了/root/redisconf/masterMySQL/conf目錄里，因此這里需要把/root/redisconf/masterMySQL/conf目錄映射成容器內(nèi)部MYSQL服務(wù)器的相關(guān)路徑。
通過mysql:latest參數(shù)指定該容器是基于這個鏡像生成的。
查看啟動的容器：docker ps
由此能確認myMasterMysql啟動成功。
查看該Docker容器的IP地址：docker inspect myMasterMysql
可以看到，這里是172.17.0.2，這也是主mysql服務(wù)器所在的Ip地址。
1.5 觀察主服務(wù)器狀態(tài)
運行docker exec -it myMasterMysql /bin/bash命令后進入該myMasterMysql容器的命令行窗口，再運行mysql -u root -p命令，進入MYSQL服務(wù)器的命令行窗口，在這個Mysql命令里，以-u參數(shù)指定用戶名，隨后需要輸入密碼(剛才設(shè)置的123456).
進入mysql服務(wù)器之后，再運行show master status命令觀察主服務(wù)器的狀態(tài)。
可以看到，主從集群同步所用到的日志文件是mysql-master-bin.000003，當前同步的位置是156，每次運行這個命令看到的結(jié)果未必相同，請記住這兩個值，在設(shè)置從mysql服務(wù)器的主從同步關(guān)系時會用到。
1.6 配置mysql從服務(wù)器
在/root/redisconf/slaveMaster/conf目錄里，新建一個名為my.cnf的文件，編寫針對從MYSQL服務(wù)器的配置信息。同樣的，從Mysql服務(wù)器在啟動時也會讀取其中的配置，具體代碼如下所示。
[mysqld] pid-file=/var/run/mysqld/mysqld.pid socket=/var/run/mysqld/mysqld.sock datadir=/var/lib/mysql server-id=2 log-bin=mysql-slave-bin
該配置文件和第三步創(chuàng)建的主服務(wù)器的配置文件很相似，只不過在第5行更改了server-id(這里的取值不能和主mysql服務(wù)器的一致)。在第6行也是設(shè)置二進制文件的名字
1.7 啟動mysql從服務(wù)器
docker run -itd --privileged=true -p 3316:3306\ --name mySlaveMysql -e MYSQL_ROOT_PASSWORD=123456\ -v /root/redisconf/slaveMySQL/conf:/etc/mysql/conf.d\ -v /root/redisconf/slaveMySQL/data:/var/lib/mysql\ mysql:latest
這里在-p參數(shù)之后使用主機的3316端口映射Docker容器的3306端口，因為之前主mysql服務(wù)器的Docker容器已經(jīng)映射到了3306端口，其他的參數(shù)和之前創(chuàng)建myMasterMysql容器時很相似，就不再重復了。
隨后docker exec -it mySlaveMysql /bin/bash進入容器，進入后可以運行mysql -h 172.17.0.2 -u root -p命令，嘗試在這個容器里連接主MySQL服務(wù)器。其中172.17.0.2是主服務(wù)器的地址。隨后輸入root用戶的密碼123456，即可確認連接。
確認鏈接后，通過exit命令退出指向myMasterMysql的連接，再通過mysql -h 127.0.0.1 -u root -p命令連接到本Docker容器包含的從MySQL服務(wù)器上。
1.8 確認主從關(guān)系
change master to master_host='172.17.0.2',master_port=3306,\ master_user='root',master_password='123456',\ master_log_pos=156,\ master_log_file='mysql-master-bin.000003';
本命令運行在mySlaveMysql容器中的從Mysql服務(wù)器里，通過master_host和master_port指定主服務(wù)器的ip地址和端口號，通過master_user和master_password設(shè)置了連接所用的用戶名和密碼。
注意master_logpos和master_log_file兩個參數(shù)的值需要和第5步圖中的結(jié)果一致。
運行完成后，需要再運行start slave命令啟動主從復制的動作。運行后可以通過show slave status\G;命令查看主從復制的狀態(tài)，如果Slave_IO_Running和Slave_SQL_Running這兩項都是Yes,并且沒有其他異常，就說明配置主從復制成功。
此時如果再到主mysql服務(wù)器里運行create database redisDemo創(chuàng)建一個數(shù)據(jù)庫，那么從庫里雖然沒有運行命令，但是也能看到redisDemo數(shù)據(jù)庫，這說明已經(jīng)成功地搭建了MySQL主從復制集群。其中，主庫地IP地址和端口號是172.17.0.2:3306,從庫是172.17.0.3:3306.
主庫
從庫
2、準備數(shù)據(jù)
由于已經(jīng)成功地設(shè)置了主從復制模式，因此如下地建表和插入語句都只需要在主庫里運行。
2.1 創(chuàng)建數(shù)據(jù)庫
create database redisDemo
進入redisDemo數(shù)據(jù)庫use redisDemo
2.2 創(chuàng)建student數(shù)據(jù)表
create table student(
id int not null primary key,
name char(20),
age int,
score float
);
2.3 向student表插入幾條數(shù)據(jù)
insert into student(id,name,age,score) values(1,'Peter',18,100); insert into student(id,name,age,score) values(2,'Tom',17,98); insert into student(id,name,age,score) values(3,'John',17,99);
從庫里查看
3、用Java代碼讀寫MySQL集群和Redis
3.1 引入redis和mysql依賴
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.3.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.21</version>
</dependency>
Java應(yīng)用程序是向主mySQL服務(wù)器寫數(shù)據(jù)，這樣寫入地數(shù)據(jù)會自動同步到從mysql服務(wù)器上，而讀數(shù)據(jù)時會先從Redis緩存里讀，讀不到時再到從mysql里讀。以下用代碼實現(xiàn)
3.2 代碼整合
MySQLClusterDemo.java
import redis.clients.jedis.Jedis;
import java.sql.*;
public class MySQLClusterDemo {
//創(chuàng)建操作Redis和數(shù)據(jù)庫的對象
private Jedis jedis;
private Connection masterConn; //連接主庫的對象
private Connection slaveConn; //連接從庫的對象
PreparedStatement masterPs=null; //對主庫進行操作的對象
PreparedStatement slavePs=null; //對從庫進行操作的對象
//初始化環(huán)境
private void init(){
//MYSQL的連接參數(shù)
String mySQLDriver="com.mysql.cj.jdbc.Driver";
String masterUrl="jdbc:mysql://192.168.159.33:3306/redisDemo?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true";
String slaveUrl="jdbc:mysql://192.168.159.33:3316/redisDemo?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true";
String user="root";
String pwd="123456";
try{
Class.forName(mySQLDriver);
masterConn= DriverManager.getConnection(masterUrl,user,pwd);
slaveConn= DriverManager.getConnection(slaveUrl,user,pwd);
jedis=new Jedis("192.168.159.33",6379);
}catch (SQLException e){
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}
}
private void insertData(){
//是向主MySQL服務(wù)器插入數(shù)據(jù)
try{
masterPs=masterConn.prepareStatement("insert into student(id,name,age,score) values(10,'Frank',18,100)");
masterPs.executeUpdate();
}catch (SQLException e){
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}
}
private String getNameByID(String id){
String key="Stu"+id;
String name="";
//如果存在于Redis,就先從Redis里獲取
if(jedis.exists(key)){
System.out.println("ID:"+key+" exists in Redis");
name=jedis.get(key);
System.out.println("Name is :"+jedis.get(key));
return name;
}else{ //如果沒在Redis里，就到從MySQL里去讀
try {
slavePs=slaveConn.prepareStatement("select name from student where id=10");
ResultSet rs=slavePs.executeQuery();
if(rs.next()){
System.out.println("ID: "+key+" exists in Slave MySQL");
name=rs.getString("name");
System.out.println("Name is: "+name);
//放入Redis緩存
jedis.set(key,name);
}
return name;
}catch (SQLException e){
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}
}
return name;
}
public static void main(String[] args) {
MySQLClusterDemo tool=new MySQLClusterDemo();
tool.init();
tool.insertData();
//場景1 沒有從Redis中找到，就到從MySQL服務(wù)器中去讀
System.out.println(tool.getNameByID("10"));
//場景2，當前ID=10的數(shù)據(jù)已存在于Redis,所有直接讀緩存
System.out.println(tool.getNameByID("10"));
}
}
運行結(jié)果
4、MySQL主從集群整合Redis主從集群
上面的mysql主從集群至整合了一個Redis主機，在這種模式里如果Redis服務(wù)器失效了，那么整個緩存可能都會失效。可以在次基礎(chǔ)上引入Redis主從復制集群，以提升緩存的可用性以及性能，改進后的框架圖如下所示。
應(yīng)用程序同樣是向主mysql服務(wù)器里寫數(shù)據(jù)，這些數(shù)據(jù)同步到從mysql數(shù)據(jù)庫里。
應(yīng)用程序先到“從Redis服務(wù)器”里讀取緩存，如果找不到，就再到從mysql數(shù)據(jù)庫里去讀。
如果從“從mysql數(shù)據(jù)庫”里讀到數(shù)據(jù)，那么需要寫入“主Redis”,而根據(jù)Redis集群的主從復制機制，該數(shù)據(jù)會被寫入“從Redis服務(wù)器”。這種針對Redis集群的讀寫分離機制能提升讀寫緩存的性能。
4.1 搭建Redis主從復制集群
4.1.1 創(chuàng)建redis-master容器
docker run -itd --name redis-master -p 6379:6379 redis:latest
4.1.2 創(chuàng)建resis-slave容器
docker run -itd --name redis-slave -p 6380:6379 redis:latest
4.1.3 查看redis服務(wù)器的ip
docker inspect redis-master
可以看到，redis-master的ip地址為172.17.0.4
4.1.4 主從配置
在redis-slave容器的窗口里，通過docker exec -it redis-slave /bin/bash命令進入容器的命令行窗口。運行如下的slaveof命令，指定當前服務(wù)器為從服務(wù)器，該命令的格式是slaveof IP地址 端口號，這里指向172.17.0.2:6379所在的主服務(wù)器。
slaveof 172.17.0.4 6379
運行完該命令后，在redis-slave客戶端里再次運行info replication
可以看到，該redis-slave已經(jīng)成為從服務(wù)器，從屬于172.17.0.2:6379所在的Redis服務(wù)器。
4.2、代碼整合
MySQLClusterImprovedDemo.java
import redis.clients.jedis.Jedis;
import java.sql.*;
public class MySQLClusterImprovedDemo {
//創(chuàng)建操作Redis和數(shù)據(jù)庫的對象
private Jedis masterJedis; //指向主Redis服務(wù)器
private Jedis slaveJedis; //指向從Redis服務(wù)器
private Connection masterConn; //連接主庫的對象
private Connection slaveConn; //連接從庫的對象
PreparedStatement masterPs=null; //對主庫進行操作的對象
PreparedStatement slavePs=null; //對從庫進行操作的對象
private void init(){
//MYSQL的連接參數(shù)
String mySQLDriver="com.mysql.cj.jdbc.Driver";
String masterUrl="jdbc:mysql://192.168.159.33:3306/redisDemo?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true";
String slaveUrl="jdbc:mysql://192.168.159.33:3316/redisDemo?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true";
String user="root";
String pwd="123456";
try{
Class.forName(mySQLDriver);
masterConn= DriverManager.getConnection(masterUrl,user,pwd);
slaveConn= DriverManager.getConnection(slaveUrl,user,pwd);
masterJedis=new Jedis("192.168.159.33",6379);
slaveJedis=new Jedis("192.168.159.33",6380);
}catch (SQLException e){
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}
}
private void insertData(){
//是向主MySQL服務(wù)器插入數(shù)據(jù)
try{
masterPs=masterConn.prepareStatement("insert into student(id,name,age,score) values(10,'Frank',18,100)");
masterPs.executeUpdate();
}catch (SQLException e){
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}
}
private String getNameByID(String id){
String key="Stu"+id;
String name="";
//如果存在于Redis,就先從Redis里獲取
if(slaveJedis.exists(key)){ //到從Redis服務(wù)器去找
System.out.println("ID: "+key+" exists in Redis.");
name=slaveJedis.get(key);//找到后到從Redis里讀
System.out.println("Name is: "+slaveJedis.get(key));
return name;
}else{ //沒在Redis，就到從MySQL去讀
try{
slavePs=slaveConn.prepareStatement("select name from student where id=10");
ResultSet rs=slavePs.executeQuery();
if(rs.next())
{
System.out.println("ID: "+key+" exists in Slave MySQL");
name=rs.getString("name");
System.out.println("Name is: "+name);
//放入主Redis緩存
masterJedis.set(key,name);
}
return name;
}catch (SQLException e){
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}
}
return name;
}
public static void main(String[] args) {
MySQLClusterImprovedDemo tool=new MySQLClusterImprovedDemo();
tool.init();
tool.insertData();
//場景1 在主Redis中沒有讀到，則到從MySQL服務(wù)器中讀
System.out.println(tool.getNameByID("10"));
//場景2 當前ID=10已經(jīng)存在于Redis,所以直接讀緩存
System.out.println(tool.getNameByID("10"));
}
}
為了突出重點，這里我并沒有設(shè)置“緩存失效時間”和“防止緩存穿透”等方面的實施代碼，但是這些要點同樣重要。
到此這篇關(guān)于Redis整合MySQL主從集群的示例代碼的文章就介紹到這了,更多相關(guān)Redis整合MySQL主從集群內(nèi)容請搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！
版權(quán)聲明：本站文章來源標注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請保持原文完整并注明來源及原文鏈接。禁止復制或仿造本網(wǎng)站，禁止在非maisonbaluchon.cn所屬的服務(wù)器上建立鏡像，否則將依法追究法律責任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來，僅供學習參考，不代表本站立場，如有內(nèi)容涉嫌侵權(quán)，請聯(lián)系alex-e#qq.com處理。
關(guān)注官方微信