Php/docs/mysqlnd-ms.quickstart.cache
Cache integration
Note:
版本需求、依赖性和状态
可以从 concepts section 获取更多的内容。
数据库群组可以设定不同的一致性级别。从 1.2.0 版本，我们建议插件仅仅从群组节点选择上 考虑使用的一致性级别。例如，如果使用异步的 MySQL 主从同步，他采用群组的最终一致性， 建议在任何时间通过 mysqlnd_ms_set_quos() 使用 Session 一致性。 这可以参考 服务级别与一致性
Example #1 Recap: quality of service to request read your writes
/* 设定采用 Session 一致性 */if (!mysqlnd_ms_set_qos($mysqli, MYSQLND_MS_QOS_CONSISTENCY_SESSION)) die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));
假设插件使用最终一致性服务级别，而不采用其他更高要求的一致性策略。那么插件可能使用 通过 TTL 失效策略控制的缓存来替代从数据库节点读取数据。数据库节点和缓存都采用 最终一致性策略，他们可能保存的不是最新的数据。
通过本地缓存替代数据库操作，可以有效的提升性能，降低数据库压力。 如果其他客户端比创建这个缓存条目的客户端更频繁使用他，那么数据库的访问就被降低下来， 从而降低数据库压力。并且，由于本地缓存的速度快于数据库查询，那么整体计算性能就被提升。
Example #2 Plugin config: no special entries for caching
{
"myapp": {
"master": {
"master_0": {
"host": "localhost",
"socket": "\/tmp\/mysql.sock"
}
},
"slave": {
"slave_0": {
"host": "127.0.0.1",
"port": "3306"
}
},
}
}
Example #3 Caching a slave request
<?php$mysqli = new mysqli("myapp", "username", "password", "database");if (!$mysqli) /* Of course, your error handling is nicer... */ die(sprintf("[%d] %s\n", mysqli_connect_errno(), mysqli_connect_error()));if (!$mysqli->query("DROP TABLE IF EXISTS test") || !$mysqli->query("CREATE TABLE test(id INT)") || !$mysqli->query("INSERT INTO test(id) VALUES (1)")) die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));/* 确认允许最终一致性，并且设定缓存有效期 (TTL <= 60 seconds) */if (false == mysqlnd_ms_set_qos($mysqli, MYSQLND_MS_QOS_CONSISTENCY_EVENTUAL, MYSQLND_MS_QOS_OPTION_CACHE, 60)) { die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));}/* 为了让范例工作，我们采用强制性的循环捕捉 slave 操作 */$attempts = 0;do { /* check if slave has the table */ if ($res = $mysqli->query("SELECT id FROM test")) { break; } else if ($mysqli->errno) { die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error)); } /* wait for slave to catch up */ usleep(200000);} while ($attempts++ < 10);/* Query has been run on a slave, result is in the cache */assert($res);var_dump($res->fetch_assoc());/* Served from cache */$res = $mysqli->query("SELECT id FROM test");?>
上面的范例说明如何使用缓存功能。通过 mysqlnd_ms_set_qos() 设定最终一致性服务器级别，并且允许使用缓存。然后任何只读的操作都会被放入 缓存中，存活时间通过 mysqlnd_ms_set_qos() 指定。
实际的 TTL 要比通过 mysqlnd_ms_set_qos() 设定的要小，设定值 是他的最大值。插件会在 TTL 上扣除 slave 同步延迟，用于计算实际的 TTL。在范例中， 如果 slave 的同步延迟是 10 秒，TTL 的最大值是 60 秒，那么计算的 TTL 值是 50 秒。 TTL 的计算，对于每一个缓存条目是独立的。
Example #4 Read your writes and caching combined
<?php$mysqli = new mysqli("myapp", "username", "password", "database");if (!$mysqli) /* Of course, your error handling is nicer... */ die(sprintf("[%d] %s\n", mysqli_connect_errno(), mysqli_connect_error()));if (!$mysqli->query("DROP TABLE IF EXISTS test") || !$mysqli->query("CREATE TABLE test(id INT)") || !$mysqli->query("INSERT INTO test(id) VALUES (1)")) die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));/* Explicitly allow eventual consistency and caching (TTL <= 60 seconds) */if (false == mysqlnd_ms_set_qos($mysqli, MYSQLND_MS_QOS_CONSISTENCY_EVENTUAL, MYSQLND_MS_QOS_OPTION_CACHE, 60)) { die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));}/* To make this example work, we must wait for a slave to catch up. Brute force style. */$attempts = 0;do { /* check if slave has the table */ if ($res = $mysqli->query("SELECT id FROM test")) { break; } else if ($mysqli->errno) { die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error)); } /* wait for slave to catch up */ usleep(200000);} while ($attempts++ < 10);assert($res);/* Query has been run on a slave, result is in the cache */var_dump($res->fetch_assoc());/* Served from cache */if (!($res = $mysqli->query("SELECT id FROM test"))) die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));var_dump($res->fetch_assoc());/* Update on master */if (!$mysqli->query("UPDATE test SET id = 2")) die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));/* Read your writes */if (false == mysqlnd_ms_set_qos($mysqli, MYSQLND_MS_QOS_CONSISTENCY_SESSION)) { die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));}/* Fetch latest data */if (!($res = $mysqli->query("SELECT id FROM test"))) die(sprintf("[%d] %s\n", $mysqli->errno, $mysqli->error));var_dump($res->fetch_assoc());?>
服务设定可以随时改变，用于屏蔽缓存的使用。如果需要，你可以变更为 Session 一致性策略， 这时缓存将不会被使用，并且被更新为最新的数据结果。
