java - 从连接池中逐出到集群中只读节点的连接

Question

我的应用程序连接到两个 MySQL 5.6(实际上是 Amazon Aurora)实例的故障转移集群。主动节点始终是可写访问的，而被动节点在 read_only 中运行模式(这不同于规范的 MySQL 故障转移集群，默认情况下所有从节点都是可写访问的)。 Amazon RDS 提供一个符号 DNS 名称，它始终指向 Activity MySQL 节点的 IP 地址。

在故障转移过程中，之前的主节点以read_only 模式重新启动，而之前的被动节点变为可写访问并提升为主节点。此外，DNS 记录已更改，因此集群的 DNS 名称现在指向新的主节点。

即使我在 Java 端完全禁用 DNS 缓存(通过 sun.net.inetaddr.ttl 或 networkaddress.cache.ttl)，操作系统特定的 DNS 缓存是仍然有效，所以在数据库故障转移之后，我的 DBCP 池中充满了到只读 MySQL 实例的连接。这些连接是 valid ， 一世。 e.它们是在故障转移完成之后但在 DNS 缓存过期之前获得的。此外，这些连接都没有 readOnly标志集，所以在我执行一些 DML 之前，我无法判断我是否正在与只读实例对话，这时 ER_OPTION_PREVENTS_STATEMENT带来所有的荣耀。即使我通过调用 setReadOnly(false) 明确地将连接设置为读写模式并设置 readOnlyPropagatesToServer标志，这只会导致驱动程序向服务器发送 SET SESSION TRANSACTION READ WRITE，这不会导致抛出任何异常。

我想尽可能少地影响应用程序逻辑来解决这个问题。如果有一种方法可以将与只读实例的连接视为无效/已关闭连接(即从池中逐出)，则可以实现这一点。

我可以要一个validation query吗？例如 SHOW GLOBAL VARIABLES LIKE 'read_only' 有附加的逻辑吗？是否有可能根据验证查询返回的标量值影响池的行为 w.r.t 连接？

Answer 1

可以使用以下验证查询:

select case when @@read_only = 0 then 1 else (select table_name from information_schema.tables) end as `1`

如果数据库以只读模式运行，查询将失败并显示

ERROR 1242 (21000): Subquery returns more than 1 row

由于 Amazon Aurora 在集群中的读取器端点上设置了 innodb_read_only 而不是 read_only ，验证查询可以重写为

select case when @@read_only + @@innodb_read_only = 0 then 1 else (select table_name from information_schema.tables) end as `1`

灵感来自 this回答。