AI导航网
微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

mysql 主从 Mycat读写分离 实践

分类：mycat作者：编程之家原文地址

 

 M1 my.cnf：

[MysqLd]
server-id = 1
log-bin = M1-log-bin
gtid_mode=ON
enforce-gtid-consistency=ON #服务器通过允许仅执行可以使用 GTID 安全记录的语句来实现 GTID 一致性

M2 my.cnf：

[MysqLd]
server-id = 2
log-bin = M2-log-bin
gtid_mode=ON
enforce-gtid-consistency=ON

S1 my.cnf：

[MysqLd]
server-id = 3
gtid_mode=ON
enforce-gtid-consistency=ON

schema.xml：

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYstem "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
        <schema name="test" checksqlschema="true" sqlMaxLimit="100" randomDatanode="test01" datanode="test01"></schema>  <!--逻辑库-->
        <datanode name="test01" dataHost="mall" database="test"></datanode>  <!--分片节点-->
        <dataHost name="mall" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="MysqL" dbDriver="native" switchType="1"  slaveThreshold="100">  <!--节点主机-->
                <heartbeat>show slave status</heartbeat>
                <writeHost host="M1" url="192.168.3.102:3306" user="root" password="root">
                        <readHost host="S1" url="192.168.3.102:3308" user="root" password="root"></readHost>
                </writeHost>
                <writeHost host="M2" url="192.168.3.102:3307" user="root" password="root"></writeHost>
        </dataHost>
</mycat:schema>

server.xml：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mycat:server SYstem "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
    <system>
    <property name="nonePasswordLogin">0</property>
    <property name="ignoreUnkNownCommand">0</property>
    <property name="useHandshakeV10">1</property>
    <property name="removeGraveAccent">1</property>
    <property name="usesqlStat">0</property> 
    <property name="useGlobleTableCheck">0</property> 
        <property name="sqlExecuteTimeout">300</property>
        <property name="sequnceHandlerType">1</property>
        <property name="sequnceHandlerPattern">(?:(\s*next\s+value\s+for\s*MYCATSEQ_(\w+))(,|\)|\s)*)+</property>
    <property name="subqueryRelationshipCheck">false</property> 
    <property name="sequenceHanlderClass">io.mycat.route.sequence.handler.HttpIncrSequenceHandler</property>
        <property name="processorBufferPoolType">0</property>
    <property name="serverPort">8066</property> 
    <property name="managerPort">9066</property> 
    <property name="bindIp">0.0.0.0</property>
        <property name="handledistributedTransactions">0</property>
        <property name="uSEOffheapForMerge">0</property>
        <property name="memoryPageSize">64k</property>
        <property name="spillsfilebufferSize">1k</property>
        <property name="useStreamOutput">0</property>
        <property name="systemReserveMemorySize">384m</property>
        <property name="useZKSwitch">false</property>
        <property name="strictTxIsolation">false</property>
        <property name="useZKSwitch">true</property>
        <property name="parallExecute">0</property>
    </system>
　　　　<!--上面都是默认配置文件只修改了<user>标签内容-->
    <user name="root" defaultAccount="true"> <!--用户和权限-->
        <property name="password">root</property> <!--密码-->
        <property name="schemas">test</property> <!--可访问的逻辑库-->
        <property name="defaultSchema">test</property><!--默认逻辑库-->
    </user>
</mycat:server>

docker-compose.yml：

version: "3.9"
services:

  MysqL-M1:
    image: MysqL:5.7
    container_name: MysqL-M1
    environment:
      - MysqL_ROOT_PASSWORD=root
    ports:
      - '3306:3306'
    volumes:
      - /db/MysqL-M1/data:/var/lib/MysqL
      - /db/MysqL-M1/conf:/etc/MysqL/conf.d

  MysqL-M2:
    image: MysqL:5.7
    container_name: MysqL-M2
    environment:
      - MysqL_ROOT_PASSWORD=root
    ports:
      - '3307:3306'
    volumes:
      - /db/MysqL-M2/data:/var/lib/MysqL
      - /db/MysqL-M2/conf:/etc/MysqL/conf.d

  MysqL-S1:
    image: MysqL:5.7
    container_name: MysqL-S1
    environment:
      - MysqL_ROOT_PASSWORD=root
    ports:
      - '3308:3306'
    volumes:
      - /db/MysqL-S1/data:/var/lib/MysqL
      - /db/MysqL-S1/conf:/etc/MysqL/conf.d

  mycat-01:
    image: mycat:1.6.7.6
    container_name: mycat-01
    ports:
      - '8066:8066'
      - '9066:9066'
    volumes:
      - /db/mycat-01/log:/usr/local/mycat/logs
      - /db/mycat-01/conf:/usr/local/mycat/conf

  mycat-02:
    image: mycat:1.6.7.6
    container_name: mycat-02
    ports:
      - '8067:8066'
      - '9067:9066'
    volumes:
      - /db/mycat-02/log:/usr/local/mycat/logs
      - /db/mycat-02/conf:/usr/local/mycat/conf

#启动前先放置好MysqL和mycat的配置文件  启动执行以下命令:

docker-compose up -d

查看：#基于二进制的话就要记下“File”和"Position" 供后续使用

 

 

 

创建用于复制的用户：

MysqL> CREATE USER 'repl'@'%.example.com' IDENTIFIED BY 'password';
MysqL> GRANT REPLICATION SLAVE ON *.* TO 'repl'@'%.example.com';

此案例使用的是下面用户和权限
CREATE USER 'root'@'%' IDENTIFIED BY 'root';
GRANT ALL ON *.* TO 'root'@'%';

在从节点执行 更改主声明：

#基于GITD

CHANGE MASTER TO MASTER_HOST='IP',MASTER_USER='账号',MASTER_PASSWORD='密码',MASTER_PORT=端口,MASTER_AUTO_POSITION=1;

#基于二进制

CHANGE MASTER TO MASTER_HOST='IP',MASTER_USER='账号',MASTER_PASSWORD='密码',MASTER_PORT=端口 MASTER_LOG_POS = 位置，MASTER_LOG_FILE = '二进制文件名 ';

检查：双YES即可

 

 

 分别M1 M2互为主从 S1为M1的从操作

有可能需要用到的命令

START SLAVE;    #启动从
STOP SLAVE;     #停从
reset slave all;   #重置从
SHOW SLAVE STATUS \G  #查看从状态
RESET MASTER; #重置主

验证：



登录【主服务器】
MysqL> CREATE DATABASE test; #创建test数据库
MysqL> USE test; #进库


CREATE TABLE `user` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL,
  `age` tinyint(3) unsigned NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;  #创建user表


INSERT INTO user (id, name, age) VALUES (2, 'zhangsan', 18); #插数据


SELECT * FROM user; 查看




 


 


登录 【从服务器】查看有没有即可


use test;


SELECT * FROM user;



 


--------------------------------------------------------------------------------------------


mycat


制作镜像 可参考官网



cd /db
tar -zxvf mycat1.6.7.6.tar.gz -C /db/ mycat/conf 
mv mycat mycat-01
cp -r  mycat-01 mycat-02
编辑或替换成启动配置文件
mycat01和mycat-02配置一样的

因记录搭建实践所以还修改了wrapper.conf调低资源消耗
wrapper.java.additional.9=-Xmx512M
wrapper.java.additional.10=-xms256M



--------------------------------------------------------------------------------------------


keepalived+LVS 


主  keepalived.conf



! Configuration File for keepalived

global_defs {
   router_id lvs01
   vrrp_skip_check_adv_addr
}
vrrp_instance API {
    state MASTER
    interface ens32
    virtual_router_id 51
    priority 100
    advert_int 1
    authentication {
        auth_type PASS
        auth_pass 1111
    }
    virtual_ipaddress {
        192.168.3.200/24
    }
    notify_master "/etc/keepalived/notify.sh master"
    notify_backup "/etc/keepalived/notify.sh backup"
    notify_fault  "/etc/keepalived/notify.sh fault"
}
virtual_server 192.168.3.200 8066 {
    delay_loop 6
    lb_algo rr
    lb_kind DR
    persistence_timeout 50
    protocol TCP
    real_server 192.168.3.102 8066 {
        weight 1
        TCP_CHECK {
                connect_timeout 10  
                retry 3             
                delay_before_retry 3
                connect_port 8066
            }
        }
    real_server 192.168.3.102 8067 {
        weight 1
        TCP_CHECK {
                connect_timeout 10  
                retry 3             
                delay_before_retry 3
                connect_port 8067
            }
        }
}



备  keepalived.conf：



! Configuration File for keepalived

global_defs {
   router_id lvs02
   vrrp_skip_check_adv_addr
}
vrrp_instance API {
    state BACKUP
    interface ens32
    virtual_router_id 51
    priority 50
    advert_int 1
    authentication {
        auth_type PASS
        auth_pass 1111
    }
    virtual_ipaddress {
        192.168.3.200/24
    }
    notify_master "/etc/keepalived/notify.sh master"
    notify_backup "/etc/keepalived/notify.sh backup"
    notify_fault  "/etc/keepalived/notify.sh fault"
}
virtual_server 192.168.3.200 8066 {
    delay_loop 6
    lb_algo rr
    lb_kind DR
    persistence_timeout 50
    protocol TCP
    real_server 192.168.3.102 8066 {
        weight 1
        TCP_CHECK {
                connect_timeout 10  
                retry 3             
                delay_before_retry 3
                connect_port 8066
            }
        }
    real_server 192.168.3.102 8067 {
        weight 1
        TCP_CHECK {
                connect_timeout 10  
                retry 3             
                delay_before_retry 3
                connect_port 8067
            }
        }
}



RS上使用的绑定VIP脚本 realserver.sh：



#!/bin/bash
#description: Config realserver

VIP=192.168.3.200

 
case "$1" in
start)
       /sbin/ifconfig lo:0 $VIP netmask 255.255.255.255 broadcast $VIP
       /sbin/route add -host $VIP dev lo:0
       echo "1" >/proc/sys/net/ipv4/conf/lo/arp_ignore
       echo "2" >/proc/sys/net/ipv4/conf/lo/arp_announce
       echo "1" >/proc/sys/net/ipv4/conf/all/arp_ignore
       echo "2" >/proc/sys/net/ipv4/conf/all/arp_announce
       sysctl -p >/dev/null 2>&1
       echo "RealServer Start OK"
       ;;
stop)
       /sbin/ifconfig lo:0 down
       /sbin/route del $VIP >/dev/null 2>&1
       echo "0" >/proc/sys/net/ipv4/conf/lo/arp_ignore
       echo "0" >/proc/sys/net/ipv4/conf/lo/arp_announce
       echo "0" >/proc/sys/net/ipv4/conf/all/arp_ignore
       echo "0" >/proc/sys/net/ipv4/conf/all/arp_announce
       echo "RealServer Stoped"
       ;;
*)
       echo "Usage: $0 {start|stop}"
       exit 1
esac
 
exit 0



主备切换通知邮件脚本 notify.sh: 前提需要配下mail.rc才发的出去



#!/bin/bash
#
contact='502[email protected]'
notify() {
local mailsubject="$(hostname) to be $1, vip floating"
local mailbody="$(date +'%F %T'): vrrp transition, $(hostname) changed to be $1"
echo "$mailbody" | mail -s "$mailsubject" $contact
}

case $1 in
master)
        notify master
        ;;
backup)
        notify backup
        ;;
fault)
        notify fault
        ;;
*)
        echo "Usage: $(basename $0) {master|backup|fault}"
        exit 1
        ;;
esac



mail.rc：



#vim /etc/mail.rc #添加如下内容
set [email protected]
set smtp=smtp.126.com
set [email protected]
set smtp-auth-password=xxx
set smtp-auth=login
#---说明
#from：对方收到邮件时显示的发件人
#smtp：指定第三方发邮件的smtp服务器地址
#set smtp-auth-user：第三方发邮件的用户名
#set smtp-auth-password：用户名对应的密码,有些邮箱填的是授权码
#smtp-auth：SMTP的认证方式，默认是login，也可以改成CRAM-MD5或PLAIN方式



看看效果启备再启主；启动命令：systemctl start keepalived.service




 


 还可以通过 ip a 查看VIP在谁那


测试：通过VIP进入




 


 


这样整体就完成了MysqL+mycat+keepalived+LVS的高可用负载均衡读写分离的方案


--------------------------------------------------------------


 

                
                                 
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。

                            

                    

                

                

                    

                        

                            
相关推荐

                            

                                 
5分钟带你快速了解Mycat是什么？Mycat原理讲解教程

                                
Mycat是什么？MyCat是一个开源的分布式数据库系统，是一个实现了MySQL协议的服务器，前端用户可以把它看作是一个数据库代理，用MySQL客户端工具和命令行访问，而其后端可以用MySQL原生协议与多个MySQL服务器通信，也...

                  
                                
                            

                                 
MyCat数据库中间件入门

                                
转自：https://www.cnblogs.com/ivictor/p/5111495.html参考：https://www.cnblogs.com/damumu/p/7320258.htmlMyCAT是mysql中间件，前身是阿里大名鼎鼎的Cobar，Cobar在开源了一段时间后，不了了之。于是MyCAT扛起了...

                  
                                
                            

                                 
mycat 的基本搭建

                                
1.在数据库做好主从同步的情况下搭建mycat。下载mycat，解压。修改server.xml文件，修改schema.xml待完善启动mycat。参考文章：https://blog.csdn.net/yelllowcong/article/details/79063546https://www.cnblogs.com...

                  
                                
                            

                                 
06mycat使用haproxy进行负载均衡

                                
集群的服务器列表在10.11.0.210和10.11.0.216中部署mycat和haproxy(因为实验机器性能有限，实际生产环境中需要单独用服务做haproxy反向代理) 两台机器的Mycat配置和haproxy保持一致即haproxyàmycatàpxc集群àmysq...

                  
                                
                            

                                 
详解Mycat核心概念和名词

                                
Mycat是什么？·一个彻底开源的，面向企业应用开发的大数据库集群·支持事务、ACID、可以替代MySQL的加强版数据库·一个可以视为MySQL集群的企业级数据库，用来替代昂贵的Oracle集群·一个融合内存缓存技术、NoSQL技...

                  
                                
                            

                                 
Mycat配置文件server.xml，常用参数说明

                                
<system>配置Mycat系统参数 <system>  <propertyname="serverPort">3306</property><!--mycat服务端口-->  <propertyname="managerPort">9066</pr...

                  
                                
                            

                                 
数据库中间件mycat配置

                                
数据库中间件：mycat逻辑库：即mycat服务上的数据库，并非实际mysql服务上的数据库。逻辑表：与逻辑库同理。数据节点：是mycat逻辑表与mysql物理表的对应关系，mycat服务上某个库中的某个表的数据可能是由不同mysql服...

                  
                                
                            

                                 
MyCat安装及启动

                                
MyCat的官方网站：http://www.mycat.org.cn/下载地址：https://github.com/MyCATApache/Mycat-download第一步：下载wget http://dl.mycat.io/1.6-RELEASE/Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz 并...

                  
                                
                            

                                 
MyCat 9066管理端口常用命令

                                
show@@sql;Emptyset(0.01sec)一直查不出数据查看在Mycat中执行过的SQL语句，需要确认server.xml配置文件中的<propertyname="useSqlStat">1</property>刚开始一直出不来数据，最后发现是没开启...

                  
                                
                            

                                 
mysql大型分布式集群 mysql分布式部署 Mycat分库分表 mycat读写分离 MySQL集群与优化 高可用数据架构 mysql分布式事务教程

                                
Mysql分布式集群部署mycat分库分表系列（共三套）系列一：《分布式集群+分库分表实战教程》本套课程将通过分布式集群和分库分表两部分内容进行讲解1、主要解决针对大型网站架构中持久化部分中，大量数据存储以及高并...

                  
                                
                            

                    



            

            

              
          

            

              




              

            

          

          
           
          

            

              

                
    
              
    
            
    
          
    
          
          
          
    
            
    
              
    
                
                
    pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native