Redis整合MySQL主从集群的示例代码_Redis_

Redis作为承担缓存作用的数据库，一般会应用在高并发的场景里，而在这些高并发应用场景的数据库层面还会用到其他数据库的组件或集群以提升性能，比如用MySQL主从集群实现读写分离效果、用MyCAT组件实现分库分表的功能。另外，Redis本身会以集群的形式对外提供缓存服务。

1、用Docker搭建MySQL主从集群

这里用Docker容器搭建如下图所示的MySQL主从集群。

• 在主MySQL服务器里操作的动作会自动同步到从nysql服务器，比如在主服务器里发起的“建数据库”“通过insert语句插入数据”和“通过delete语句删除数据”的动作都会同步到从服务器，并且这些操作都会在从服务器上被执行。通过这种同步的动作能确保主从数据库间的数据一致性。
• 在项目里，一般是向“主服务器”里写数据，从“从服务器”里读数据，用这种“读写分离”的操作方式提升数据库性能。

具体搭建的步骤如下：

1.1 拉取mysql镜像

  开启一个命令窗口，在其中运行docker pull mysql:latest,下载最新的mysql镜像。下载完成后，通过docker images mysql能看到如下图所示的镜像i信息。

1.2 创建配置文件夹

新建/root/redisconf/masterMySQL/conf和/root/redisconf/masterMySQL/data两个目录，在其中将会保存主mysql服务器的配置信息和数据。同时新建/root/redisconf/slaveMySQL/conf和/root/redisconf/slaveMySQL/data两个目录，在其中将会保存从MySQL服务器的配置信息和数据。当然，目录可自行更改。

1.3 编写主服务器的配置文件信息

  在/root/redisconf/masterMySQL/conf目录里新建一个my.cnf文件，在其中编写针对主mysql服务器的配置信息，主mysql服务器在启动时会读取其中的配置，具体代码如下所示：

 [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运行时的参数，在第五行里定义了该服务器的id(这个id需要和之后编写的从MySQL服务器的server-id不一样，否则会出错)，在第6行里制定了二进制文件的名字(为了搭建主从集群，建议加上这行配置)

1.4 启动mysql主服务器的容器

 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参数指定Docker容器里MySQL的工作端口3306映射到主机的3306端口
-itd参数指定该容器以后台交互模式的方式启动
--name参数指定该容器的名字
通过-e MYSQL_ROOT_PASSWORD=123456参数指定该容器运行时的环境变量，具体到这个场景，配置以用户名root登录到MySQL服务器时所用到的密码123456.
两个-v参数指定外部主机和Docker容器间映射的目录。由于在第三步把MySQL启动时需要加载的my.cnf文件放在了/root/redisconf/masterMySQL/conf目录里，因此这里需要把/root/redisconf/masterMySQL/conf目录映射成容器内部MYSQL服务器的相关路径。
通过mysql:latest参数指定该容器是基于这个镜像生成的。

查看启动的容器：docker ps

由此能确认myMasterMysql启动成功。
查看该Docker容器的IP地址：docker inspect myMasterMysql

可以看到，这里是172.17.0.2，这也是主mysql服务器所在的Ip地址。

1.5 观察主服务器状态

  运行docker exec -it myMasterMysql /bin/bash命令后进入该myMasterMysql容器的命令行窗口，再运行mysql -u root -p命令，进入MYSQL服务器的命令行窗口，在这个Mysql命令里，以-u参数指定用户名，随后需要输入密码(刚才设置的123456).

进入mysql服务器之后，再运行show master status命令观察主服务器的状态。

可以看到，主从集群同步所用到的日志文件是mysql-master-bin.000003，当前同步的位置是156，每次运行这个命令看到的结果未必相同，请记住这两个值，在设置从mysql服务器的主从同步关系时会用到。

1.6 配置mysql从服务器

  在/root/redisconf/slaveMaster/conf目录里，新建一个名为my.cnf的文件，编写针对从MYSQL服务器的配置信息。同样的，从Mysql服务器在启动时也会读取其中的配置，具体代码如下所示。

 [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 

  该配置文件和第三步创建的主服务器的配置文件很相似，只不过在第5行更改了server-id(这里的取值不能和主mysql服务器的一致)。在第6行也是设置二进制文件的名字

1.7 启动mysql从服务器

 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参数之后使用主机的3316端口映射Docker容器的3306端口，因为之前主mysql服务器的Docker容器已经映射到了3306端口，其他的参数和之前创建myMasterMysql容器时很相似，就不再重复了。

  随后docker exec -it mySlaveMysql /bin/bash进入容器，进入后可以运行mysql -h 172.17.0.2 -u root -p命令，尝试在这个容器里连接主MySQL服务器。其中172.17.0.2是主服务器的地址。随后输入root用户的密码123456，即可确认连接。

  确认链接后，通过exit命令退出指向myMasterMysql的连接，再通过mysql -h 127.0.0.1 -u root -p命令连接到本Docker容器包含的从MySQL服务器上。

1.8 确认主从关系

 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服务器里，通过master_host和master_port指定主服务器的ip地址和端口号，通过master_user和master_password设置了连接所用的用户名和密码。
  注意master_logpos和master_log_file两个参数的值需要和第5步图中的结果一致。

  运行完成后，需要再运行start slave命令启动主从复制的动作。运行后可以通过show slave status\G;命令查看主从复制的状态，如果Slave_IO_Running和Slave_SQL_Running这两项都是Yes,并且没有其他异常，就说明配置主从复制成功。

  此时如果再到主mysql服务器里运行create database redisDemo创建一个数据库，那么从库里虽然没有运行命令，但是也能看到redisDemo数据库，这说明已经成功地搭建了MySQL主从复制集群。其中，主库地IP地址和端口号是172.17.0.2:3306,从库是172.17.0.3:3306.

主库

从库

2、准备数据

  由于已经成功地设置了主从复制模式，因此如下地建表和插入语句都只需要在主库里运行。

2.1 创建数据库

 create database redisDemo

进入redisDemo数据库use redisDemo

2.2 创建student数据表

 create table student( id int not null primary key, name char(20), age int, score float ); 

2.3 向student表插入几条数据

 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依赖

redis.clientsjedis3.3.0mysqlmysql-connector-java8.0.21

  Java应用程序是向主mySQL服务器写数据，这样写入地数据会自动同步到从mysql服务器上，而读数据时会先从Redis缓存里读，读不到时再到从mysql里读。以下用代码实现

3.2 代码整合

MySQLClusterDemo.java

 import redis.clients.jedis.Jedis; import java.sql.*; public class MySQLClusterDemo { //创建操作Redis和数据库的对象 private Jedis jedis; private Connection masterConn; //连接主库的对象 private Connection slaveConn; //连接从库的对象 PreparedStatement masterPs=null; //对主库进行操作的对象 PreparedStatement slavePs=null; //对从库进行操作的对象 //初始化环境 private void init(){ //MYSQL的连接参数 String mySQLDriver="com.mysql.cj.jdbc.Driver"; String masterUrl="jdbc:mysql://192.168.159.33:3306/redisD
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：面试常问：如何保证Redis缓存和数据库的数据一致性_Redis_
                                                                
下一篇：基于Redis结合SpringBoot的秒杀案例详解_Redis_