mysql读写分离与proxysql的结合
上一篇文章介绍了mysql如何设置成主从复制模式，而主从复制的目的，是为了读写分离。
读写分离，拿spring boot项目来说，可以有2种方式：
1）设置2个数据源，读和写分开使用
2）使用中间件，如proxysql。它会根据sql语句自动匹配到主、从库
方式一好处是灵活，可控，缺点是需要自己写一点代码，已有的项目修改可能比较大；proxysql的话，还是跟之前一样，只有一个数据源，代码好像也不用改。问题是，我用了一下，感觉有一些坑。也许是还不懂得怎么使用的缘故。
以下是步骤和一些坑：
一、安装proxysql
proxysql是一个中间件，需要安装。安装好了之后，可以把它看作一个mysql，因为它是一个伪装成mysql的中介。你看看，这个”“mysql数据源”：
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://192.168.10.249:6033/testdb?characterEncoding=utf-8&useSSL=false&serverTimezone=Hongkong&allowPublicKeyRetrieval=true
username: work
password: 123456 # 你的数据库密码
其中 192.168.10.249:6033 就是proxysql的地址。简直了。
1、安装
还是跑在docker里。拉取 ProxySQL Docker 镜像
sudo docker pull proxysql/proxysql
目前由于不可描述的原因，各种镜像源大都不可用，令人无语。费了九牛二虎之力，才下载到一个镜像。中国程序员真难啊。方法可参考拙作：修改centos7的dns解决docker拉取镜像超时问题
2、在mysql主库中创建监控用户
sudo docker exec -it mysql-1 /bin/bash
mysql -uroot -pdata2025
--监控账号与默认保持一致最保险（monitor/monitor)
create user 'monitor' identified WITH mysql_native_password by 'monitor';
-- 授予监控用户必要的权限
GRANT USAGE ON *.* TO monitor@'%';
-- 刷新权限
FLUSH PRIVILEGES;
3、准备配置文件
mkdir /home/admin/proxysql
然后在该文件夹下创建配置文件：proxysql.cnf
admin_variables = {
admin_credentials = "admin:admin"
mysql_ifaces = "0.0.0.0:6032"
}
mysql_variables = {
threads = 4
max_connections = 2048
default_query_delay = 0
default_query_timeout = 36000000
have_compress = true
poll_timeout = 2000
interfaces = "0.0.0.0:6033"
default_schema = "information_schema"
stacksize = 1048576
server_version = "8.0.23"
monitor_history=60000
monitor_connect_interval=200000
monitor_ping_interval=200000
}
mysql_servers = (
{ address = "mysql-1", port = 3306, hostgroup = 0,weight=1, max_connections = 1000 },
{ address = "mysql-2", port = 3306, hostgroup = 1, weight=1,max_connections = 1000 }
)
mysql_users = (
{ username = "work", password = "123456", default_hostgroup = 0, active = 1 }
)
mysql_query_rules = (
{ rule_id = 1, active = 1, match_digest = "^SELECT.*", destination_hostgroup = 1, apply = 1 },
{ rule_id = 2, active = 1, match_digest = "^(INSERT|UPDATE|DELETE|REPLACE).*", destination_hostgroup = 0, apply = 1 }
)
4、创建 docker 容器
跟mysql的主库、从库共用一个docker网络：mysql-tier。详见上一篇《设置mysql的主从复制模式》
sudo docker run -d \
--name proxysql \
--network mysql-tier \
-p 6032:6032 \
-p 6033:6033 \
-v /home/admin/proxysql/proxysql.cnf:/etc/proxysql.cnf \
-v /home/admin/proxysql/data:/var/lib/proxysql \
proxysql/proxysql \
proxysql --initial -f -c /etc/proxysql.cnf
5、操作连接
可读可写，very good。
但是，可别高兴得太早。我在里面遇到了一些坑：
二、遇到的坑
1、监控账号
proxysql为了监控mysql，需要mysql提供一个监控账号，该账号权限不用太多，据说只需USAGE即可（见前面脚本）。问题是，这个监控账号，最好是与默认保持一致，即账号名和密码都是monitor。如果改成其他，真不知道在哪里设置。豆包信誓旦旦地说在配置文件里设置，而通义千问则说配置文件里设不了，应该在命令行里写。结果两个都无效，proxysql总是提示无法连接mysql。搞来搞去，我只好将monitor账号的密码改为"monitor"，与默认保持一致，就好了。
2、mysql版本问题
配置文件中，对标mysql的版本号（mysql_variables:server_version）一定要写对。比如我的mysql是mysql8，但配置文件内容是从网上抄过来的，里面写的是5.0.9，结果运行的时候就报错了：unknown system variable ‘query_cache_size’。这是因为
mysql8之后，取消了"query_cache_size"这个属性，由于配置文件指明是mysql5，proxysql仍然使用了这个属性，所以就报错了。把配置文件提交给AI，它也看不出问题所在。
3、一个库故障后整个proxysql无法使用
在主库、从库都正常的情况下，用了一下，好像没啥问题。
但为了测试，我手动将从库关停后，结果整个proxysql都没办法使用了。proxysql其实已经检测到某个库出了问题，但不知道为什么，它没有将该库的状态设为离线或停止，仍然显示为"ONLINE"。
我在AI上问来问去，通义千问也，豆包也，chatGPT也，都问不出一个子丑寅卯。它们总喜欢穷举一些原因，我不得不一再强调，网络没有问题，在主从库都正常的情况下一切正常，然后它就说，既然如此，那问题很有可能出在proxysql的配置上，巴拉巴拉巴拉，吐出一大堆文字。并且不是一下子吐出，而是装叉地一行一行地输出，以为在拍黑客电影。
革命尚未成功，先记录下来。
三、附录 proxysql配置文件模板
proxysql最大的问题，根本不知道它的配置文件应该怎么写，怎么设置参数，官网上也找不到一个例子。好不容易从github上找到一个模板：
#file proxysql.cfg
# This config file is parsed using libconfig , and its grammar is described in:
# http://www.hyperrealm.com/libconfig/libconfig_manual.html#Configuration-File-Grammar
# Grammar is also copied at the end of this file
datadir="/var/run/proxysql"
admin_variables=
{
admin_credentials="admin:admin"
mysql_ifaces="127.0.0.1:6032;/tmp/proxysql_admin.sock"
# refresh_interval=2000
# debug=true
}
mysql_variables=
{
threads=4
max_connections=2048
default_query_delay=0
default_query_timeout=36000000
have_compress=true
poll_timeout=2000
interfaces="0.0.0.0:6033;/tmp/proxysql.sock"
default_schema="information_schema"
stacksize=1048576
server_version="5.1.30"
connect_timeout_server=10000
monitor_history=60000
monitor_connect_interval=200000
monitor_ping_interval=200000
ping_interval_server=10000
ping_timeout_server=200
commands_stats=true
sessions_sort=true
}
# defines all the MySQL servers
mysql_servers =
(
# {
# address = "127.0.0.1" # no default, required . If port is 0 , address is interpred as a Unix Socket Domain
# port = 3306 # no default, required . If port is 0 , address is interpred as a Unix Socket Domain
# hostgroup = 0 # no default, required
# status = "ONLINE" # default: ONLINE
# weight = 1 # default: 1
# compression = 0 # default: 0
# max_replication_lag = 10 # default 0 . If greater than 0 and replication lag passes such threshold, the server is shunned
# },
# {
# address = "/var/lib/mysql/mysql.sock"
# port = 0
# hostgroup = 0
# },
# {
# address="127.0.0.1"
# port=21891
# hostgroup=0
# max_connections=200
# },
# { address="127.0.0.2" , port=3306 , hostgroup=0, max_connections=5 },
# { address="127.0.0.1" , port=21892 , hostgroup=1 },
# { address="127.0.0.1" , port=21893 , hostgroup=1 }
# { address="127.0.0.2" , port=3306 , hostgroup=1 },
# { address="127.0.0.3" , port=3306 , hostgroup=1 },
# { address="127.0.0.4" , port=3306 , hostgroup=1 },
# { address="/var/lib/mysql/mysql.sock" , port=0 , hostgroup=1 }
)
# defines all the MySQL users
mysql_users:
(
# {
# username = "username" # no default , required
# password = "password" # default: ''
# default_hostgroup = 0 # default: 0
# active = 1 # default: 1
# },
# {
# username = "root"
# password = ""
# default_hostgroup = 0
# max_connections=1000
# default_schema="test"
# active = 1
# },
# { username = "user1" , password = "password" , default_hostgroup = 0 , active = 0 }
)
#defines MySQL Query Rules
mysql_query_rules:
(
# {
# rule_id=1
# active=1
# match_pattern="^SELECT .* FOR UPDATE$"
# destination_hostgroup=0
# apply=1
# },
# {
# rule_id=2
# active=1
# match_pattern="^SELECT"
# destination_hostgroup=1
# apply=1
# }
)
# http://www.hyperrealm.com/libconfig/libconfig_manual.html#Configuration-File-Grammar
#
# Below is the BNF grammar for configuration files. Comments and include directives are not part of the grammar, so they are not included here.
#
# configuration = setting-list | empty
#
# setting-list = setting | setting-list setting
#
# setting = name (":" | "=") value (";" | "," | empty)
#
# value = scalar-value | array | list | group
#
# value-list = value | value-list "," value
#
# scalar-value = boolean | integer | integer64 | hex | hex64 | float
# | string
#
# scalar-value-list = scalar-value | scalar-value-list "," scalar-value
#
# array = "[" (scalar-value-list | empty) "]"
#
# list = "(" (value-list | empty) ")"
#
# group = "{" (setting-list | empty) "}"
#
# empty =