Mycat2【java提高】3

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: Mycat2【java提高】3

3、重新启动Mycat

[root@centos7-mysql-1 bin]# ./mycat restart
Stopping mycat2...
Stopped mycat2.
Starting mycat2...

4、 验证读写分离

#(1)在写主机数据库表mytbl中插入带系统变量数据,造成主从数据不一致

INSERT INTO mytbl VALUES(2,@@hostname) ;



(2)在Mycat里查询mytbl表,可以看到查询语句在主从两个主机间切换



3.2 双主双从

一个主机 m1 用于处理所有写请求, 它的从机 s1 和另一台主机 m2 还有它的从机 s2 负责所有读请求。当 m1 主机宕机后, m2 主机负责写请求, m1、 m2 互为备机。 架构图如下


编号 角色 IP地址 机器名
1 Master1 192.168.253.139 mysql1
2 Slavel 192.168.253.140 mysqlS1
3 Master2 . 192.168.253.141. mysql1-2
4 Slave2 . 192.168.253.142, mysqlS1-2

1、 搭建 MySQL 数据库主从复制(双主双从)

先结束一主一从

stop slave;
reset master;

删除dbtest

① 双主机配置

Master1配置

修改配置文件: vim /etc/my.cnf
#主服务器唯一ID
server-id=1
#启用二进制日志
log-bin=mysql-bin
# 设置不要复制的数据库(可设置多个)
binlog-ignore-db=mysql
binlog-ignore-db=information_schema
#设置需要复制的数据库 需要复制的主数据库名字(未创建的)
binlog-do-db=mydb1
#设置logbin格式
binlog_format=STATEMENT
# 在作为从数据库的时候, 有写入操作也要更新二进制日志文件
log-slave-updates
#表示自增长字段每次递增的量,指自增字段的起始值,其默认值是1, 取值范围是1 .. 65535
auto-increment-increment=2
# 表示自增长字段从哪个数开始,指字段一次递增多少,他的取值范围是1 .. 65535
auto-increment-offset=1

Master2配置

修改配置文件: vim /etc/my.cnf
#主服务器唯一ID
server-id=3
#启用二进制日志
log-bin=mysql-bin
# 设置不要复制的数据库(可设置多个)
binlog-ignore-db=mysql
binlog-ignore-db=information_schema
#设置需要复制的数据库
binlog-do-db=需要复制的主数据库名字
#设置logbin格式
binlog_format=STATEMENT
# 在作为从数据库的时候,有写入操作也要更新二进制日志文件
log-slave-updates
#表示自增长字段每次递增的量,指自增字段的起始值,其默认值是1,取值范围是1 .. 65535
auto-increment-increment=2
# 表示自增长字段从哪个数开始,指字段一次递增多少,他的取值范围是1 .. 65535
auto-increment-offset=2

② 双从机配置

Slave1配置

修改配置文件: vim /etc/my.cnf
#从服务器唯一ID
server-id=2
#启用中继日志
relay-log=mysql-relay

Slave2配置

修改配置文件: vim /etc/my.cnf
#从服务器唯一ID
server-id=4
#启用中继日志
relay-log=mysql-relay

③ 双主机、 双从机重启 mysql 服务

systemctl restart mysqld
systemctl status mysqld

④ 主机从机都关闭防火墙

 systemctl status firewalld

⑤ 在两台主机上建立帐户并授权 slave

#在主机MySQL里执行授权命令
CREATE USER 'slave2'@'%' IDENTIFIED BY '123456';
GRANT REPLICATION SLAVE ON *.* TO 'slave2'@'%';
#此语句必须执行。否则见下面。<
ALTER USER 'slave2'@'%' IDENTIFIED WITH mysql_native_password  BY '123456';
flush privileges;  
#查询Master1的状态
show master status;



#查询Master2的状态
show master status;


⑥ 在从机上配置需要复制的主机

Slava1 复制 Master1, Slava2 复制 Master2

从1

CHANGE MASTER TO MASTER_HOST='192.168.253.139',
MASTER_USER='slave2',
MASTER_PASSWORD='123456',
MASTER_LOG_FILE='mysql-bin.000002',MASTER_LOG_POS=156;


从2

CHANGE MASTER TO MASTER_HOST='192.168.253.141',
MASTER_USER='slave2',
MASTER_PASSWORD='123456',
MASTER_LOG_FILE='mysql-bin.000004',MASTER_LOG_POS=156;

mysql> start slave;
Query OK, 0 rows affected (0.00 sec)
mysql> show slave status\G;
             Slave_IO_Running: Yes
            Slave_SQL_Running: Yes

⑦ 两个主机互相复制

Master2 复制 Master1, Master1 复制 Master2

M1

CHANGE MASTER TO MASTER_HOST='192.168.253.141',
MASTER_USER='slave2',
MASTER_PASSWORD='123456',
MASTER_LOG_FILE='mysql-bin.000004',MASTER_LOG_POS=156;
mysql> start slave;
Query OK, 0 rows affected (0.00 sec)
mysql> show slave status\G;

M2

CHANGE MASTER TO MASTER_HOST='192.168.253.139',
MASTER_USER='slave2',
MASTER_PASSWORD='123456',
MASTER_LOG_FILE='mysql-bin.000002',MASTER_LOG_POS=156;
mysql> start slave;
Query OK, 0 rows affected (0.00 sec)
mysql> show slave status\G;

⑨ 如何停止从服务复制功能

stop slave;
stop slave;
reset master;

⑧ Master1 主机新建库、新建表、 insert 记录, Master2 和从机复制

M1

mysql> create database mydb1;
Query OK, 1 row affected (0.00 sec)
mysql> use mydb1;
Database changed
mysql> create table mytbl(id int,name varchar(50));
Query OK, 0 rows affected (0.02 sec)
mysql> insert into mytbl values (1,'zhang3');
Query OK, 1 row affected (0.02 sec)
mysql> 

其他

mysql> show databases;
+----------------------+
| Database             |
+----------------------+
| atguigu_master_slave |
| atguigudb1           |
| atguigudb2           |
| atguigudb3           |
| atguigudb33          |
| dbtest1              |
| dbtest2              |
| information_schema   |
| mycat                |
| mydb1                |
| mysql                |
| performance_schema   |
| sys                  |
| testdb               |
+----------------------+
14 rows in set (0.41 sec)
mysql> use mydb1;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -A
Database changed
mysql> select * from mytbl;
+------+--------+
| id   | name   |
+------+--------+
|    1 | zhang3 |
+------+--------+
1 row in set (0.01 sec)
mysql> 

2、 修改 Mycat 的集群配置实现多种主从

Mycat2.0的特点把集群概念凸显了出来,和mysql主从复制、集群配合实现多节点读写分离

(1)->双主双从集群角色划分
*m1:主机

*m2:备机,也负责读

*s1,s2:从机

(3)增加两个数据源

使用注解方式添加数据源

#登录Mycat,注解方式添加数据源,指向从机
/*+ mycat:createDataSource { "name" :" rwSepw2" ,"url" :"jdbc:mysql://192.168.253.141:3306/mydb1?useSSL=false&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true" , "user" "root", "password":"123456"}*/ ;
/*+ mycat:createDataSource { "name" : "rwSepr2" ,"ur1" :"jdbc:mysql://192.168.253.142:3306/mydb1?useSSL=false&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true" , "user":"root", "password":"123456"}·*/ ;
#查询配置数据源结果
/*+·mycat:showDataSources {0}*/ ;

手动配置

/usr/local/mycat/conf/datasources

{
  "dbType":"mysql",
  "idleTimeout":60000,
  "initSqls":[],
  "initSqlsGetConnection":true,
  "instanceType":"READ_WRITE",
  "maxCon":1000,
  "maxConnectTimeout":3000,
  "maxRetryCount":5,
  "minCon":1,
  "name":"rwSepw2",  #一定要看好
  "password":"123456",
  "type":"JDBC",
  "url":"jdbc:mysql://192.168.253.141:3306/mydb1?useUnicode=true&serverTimezone=Asia/Shanghai&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true",
  "user":"root",
  "weight":0
}

更新集群信息,添加dr0从节点.实现读写分离

#更新集群信息,添加dr0从节点.-
/*! mycat:createCluster{"name" :"prototype","masters" :["rwSepw"],"replicas":["rwSepr"]}  */ ;
#查看配置集群信息(
/*+ mycat:showClusters {} */;
#查看集群配置文件
vim /usr/local/mvcat/conf/clusters/prototype.clust

手动配置

/usr/local/mycat/conf/clusters

{
  "clusterType":"MASTER_SLAVE",
  "heartbeat":{
    "heartbeatTimeout":1000,
    "maxRetry":3,
    "minSwitchTimeInterval":300,
    "slaveThreshold":0
  },
  "masters":[
    "rwSepw","rwSepw2"
  ],
  "maxCon":200,
  "name":"prototype",
  "readBalanceType":"BALANCE_ALL",
  "replicas":[
    "rwSepw2","rwSepr","rwSepr2"
  ],
  "switchType":"SWITCH"
}

3、重新启动Mycat

[root@centos7-mysql-1 bin]# ./mycat restart
Stopping mycat2...
Stopped mycat2.
Starting mycat2...

4、 验证读写分离

#(1)在写主机数据库表mytbl中插入带系统变量数据,造成主从数据不一致

INSERT INTO mytbl VALUES(2,@@hostname) ;

(2)在Mycat里查询mytbl表,可以看到查询语句在主从两个主机间切换

mysql> select * from mytbl;
+------+-----------------+
| id   | name            |
+------+-----------------+
|    1 | zhang3          |
|    2 | centos7-mysql-1 |
+------+-----------------+
2 rows in set (0.01 sec)
mysql> select * from mytbl;
+------+--------------------+
| id   | name               |
+------+--------------------+
|    1 | zhang3             |
|    2 | centos7-mysql-S1-2 |
+------+--------------------+
2 rows in set (0.01 sec)
mysql> select * from mytbl;
+------+------------------+
| id   | name             |
+------+------------------+
|    1 | zhang3           |
|    2 | centos7-mysql-S1 |
+------+------------------+
2 rows in set (0.01 sec)
相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
SQL 算法 Java
Mycat2【java提高】5
Mycat2【java提高】5
216 0
|
存储 算法 Java
Mycat2【java提高】4
Mycat2【java提高】4
183 0
|
负载均衡 关系型数据库 MySQL
Mycat2【java提高】2
Mycat2【java提高】2
209 0
|
Java 中间件 关系型数据库
Mycat2【java提高】1
Mycat2【java提高】1
189 0
|
3天前
|
监控 Java
java异步判断线程池所有任务是否执行完
通过上述步骤,您可以在Java中实现异步判断线程池所有任务是否执行完毕。这种方法使用了 `CompletionService`来监控任务的完成情况,并通过一个独立线程异步检查所有任务的执行状态。这种设计不仅简洁高效,还能确保在大量任务处理时程序的稳定性和可维护性。希望本文能为您的开发工作提供实用的指导和帮助。
39 17
|
14天前
|
Java
Java—多线程实现生产消费者
本文介绍了多线程实现生产消费者模式的三个版本。Version1包含四个类:`Producer`(生产者)、`Consumer`(消费者)、`Resource`(公共资源)和`TestMain`(测试类)。通过`synchronized`和`wait/notify`机制控制线程同步,但存在多个生产者或消费者时可能出现多次生产和消费的问题。 Version2将`if`改为`while`,解决了多次生产和消费的问题,但仍可能因`notify()`随机唤醒线程而导致死锁。因此,引入了`notifyAll()`来唤醒所有等待线程,但这会带来性能问题。
Java—多线程实现生产消费者
|
16天前
|
安全 Java Kotlin
Java多线程——synchronized、volatile 保障可见性
Java多线程中,`synchronized` 和 `volatile` 关键字用于保障可见性。`synchronized` 保证原子性、可见性和有序性,通过锁机制确保线程安全;`volatile` 仅保证可见性和有序性,不保证原子性。代码示例展示了如何使用 `synchronized` 和 `volatile` 解决主线程无法感知子线程修改共享变量的问题。总结:`volatile` 确保不同线程对共享变量操作的可见性,使一个线程修改后,其他线程能立即看到最新值。
|
16天前
|
消息中间件 缓存 安全
Java多线程是什么
Java多线程简介:本文介绍了Java中常见的线程池类型,包括`newCachedThreadPool`(适用于短期异步任务)、`newFixedThreadPool`(适用于固定数量的长期任务)、`newScheduledThreadPool`(支持定时和周期性任务)以及`newSingleThreadExecutor`(保证任务顺序执行)。同时,文章还讲解了Java中的锁机制,如`synchronized`关键字、CAS操作及其实现方式,并详细描述了可重入锁`ReentrantLock`和读写锁`ReadWriteLock`的工作原理与应用场景。
|
16天前
|
安全 Java 编译器
深入理解Java中synchronized三种使用方式:助您写出线程安全的代码
`synchronized` 是 Java 中的关键字,用于实现线程同步,确保多个线程互斥访问共享资源。它通过内置的监视器锁机制,防止多个线程同时执行被 `synchronized` 修饰的方法或代码块。`synchronized` 可以修饰非静态方法、静态方法和代码块,分别锁定实例对象、类对象或指定的对象。其底层原理基于 JVM 的指令和对象的监视器,JDK 1.6 后引入了偏向锁、轻量级锁等优化措施,提高了性能。
42 3
|
16天前
|
存储 安全 Java
Java多线程编程秘籍:各种方案一网打尽,不要错过!
Java 中实现多线程的方式主要有四种:继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点,适用于不同的场景。继承 Thread 类最简单,实现 Runnable 接口更灵活,Callable 接口支持返回结果,线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外,还介绍了多线程相关的常见面试问题及答案,涵盖线程概念、线程安全、线程池等知识点。
99 2