健康檢查

通過(guò)創(chuàng)建到后端的連接實(shí)施健康檢查

main()

PgpoolMain()

processState = PERFORMING_HEALTH_CHECK;

do_health_check()

make_persistent_db_connection()

discard_persistent_db_connection()

如果連接創(chuàng)建失敗，會(huì)拋出異常，進(jìn)而跳轉(zhuǎn)到統(tǒng)一的異常處理點(diǎn),如果超過(guò)重試次數(shù)，將后端降級(jí),并最終調(diào)用pgpool.conf配置文件里設(shè)置的failover_command。

main()

PgpoolMain()

if(processState == PERFORMING_HEALTH_CHECK)

process_backend_health_check_failure()

degenerate_backend_set(&health_check_node_id,1)

degenerate_backend_set_ex()

register_node_operation_request(NODE_DOWN_REQUEST)

failover()

trigger_failover_command()

failover()的切換過(guò)程

再次確認(rèn)后端狀態(tài)，如無(wú)效更新后端的backend_status為CON_DOWN

獲取第一個(gè)狀態(tài)正常的后端作為new_master

kill所有子進(jìn)程(這是基于pgpool做HA的一個(gè)很大的優(yōu)勢(shì)，可以可靠的切斷所有來(lái)自客戶端的連接，隔離故障節(jié)點(diǎn))

對(duì)down掉的后端執(zhí)行pgpool.conf配置文件里設(shè)置的failover_command

如果down掉的是primary，搜索新的primary，即第一個(gè)"SELECT pg_is_in_recovery()"返回不是t的后端。

重啟所有子進(jìn)程

發(fā)送restart通知給worker進(jìn)程

通知PCP子進(jìn)程failover/failback完成

發(fā)送restart通知給pcp進(jìn)程

總結(jié)

以上是生活随笔為你收集整理的pgpool mysql_pgpool的健康检查和failover代码的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。