ui做网站实例,seo优化心得,展示型网站案例,网站开启伪静态GPDB - 高可用 - 流复制状态 GPDB的高可用基于流复制#xff0c;通过FTS进行自动故障切换。自动故障切换需要根据primary-mirror流复制的各种状态进行判断。本节就聊聊primary-mirror流复制的各种状态。同样适用于PgSQL 1、WalSndState typedef enum WalSndState
{WALSNDSTATE… GPDB - 高可用 - 流复制状态 GPDB的高可用基于流复制通过FTS进行自动故障切换。自动故障切换需要根据primary-mirror流复制的各种状态进行判断。本节就聊聊primary-mirror流复制的各种状态。同样适用于PgSQL 1、WalSndState typedef enum WalSndState
{WALSNDSTATE_STARTUP 0,WALSNDSTATE_BACKUP,WALSNDSTATE_CATCHUP,WALSNDSTATE_STREAMING,WALSNDSTATE_STOPPING
} WalSndState; WalSndState保存的是wal sender进程的状态信息变量值如上代码。 WALSNDSTATE_STARTUP表示启动状态 WALSNDSTATE_BACKUP表示备份状态 WALSNDSTATE_CATCHUP表示追赶状态 WALSNDSTATE_STREAMING表示流复制状态 WALSNDSTATE_STOPPING表示wal sender即将退出 2、什么时候切换到WALSNDSTATE_STOPPING 1集群shutdown有三种方式smart、fast、immediate 三种标记值分别为 #define SmartShutdown 1
#define FastShutdown 2
#define ImmediateShutdown 3 Smart shutdown不允许有新连接待已有连接全部结束后关闭数据库 Fast shutdown不允许新连接向所有活跃的服务进程发送SIGTERM信号让他们立即退出之后等待所有子进程退出并关闭数据库 Immediate shutdown不允许新连接主进程postgres向所有子进程发送SIGQUIT信号并立即退出所有子进程也会立即退出。下次启动会回放WAL日志进行恢复。 2如果shutdown模式不为immediate则集群shutdown的时候postgres主进程会向checkpoint进程发送SIGUSR2信号 3checkpoint进程的SIGUSR2信号处理函数为ReqShutdownHandler从上图的代码逻辑可见ReqShutdownHandler会将shutdown_requested置为true并唤醒MyLatch。 4checkpoint进程接着调用ShutdownXLog然后proc_exit(0)退出checkpoint进程。 5ShutdownXLog函数调用WalSndInitStopping向所有sender进程发送SIGUSR1信号然后调用WalSndWaitStopping等待所有sender进程退出每个10ms判断一次。 6sender进程SIGUSR1信号处理函数procsignal_sigusr1_handler检查信号来自PROCSIG_WALSND_INIT_STOPPING然后将got_STOPPING置为true 7流复制的sender处理完SIGUSR1信号后继续返回信号前处理流程。Sender的发送日志函数为XLogSendPhysical此时got_STOOPING已为true所以调用WalSndSetState将walsnd-state切换到WALSNDSTATE_STOPPING状态然后调用FTSReplicationStatusUpdateForWalState更新WAL复制状态 8另外当sender进程从WalSndLoop退出后replication_active置为false这个时候Wal sender进程才接收到信号HandleWalSndInitStopping中也可以看到会向自己发送SIGTERM信号信号处理函数die即退出进程因为流复制终止了不必管它了。 9若sender进程还没从WalSndLoop退出replication_active置为true这个时候Wal sender进程接收到信号HandleWalSndInitStopping中也可以看到他会设置got_STOPPING为true让WAL sender进程发送完WAL后退出WalSndLoop循环后调用proc_exit自行退出。 2、sender进程什么时候退出 书接上文产生个问题WalSndLoop何时退出若没有shutdown何时再发起流复制 Wal sender进程接收到mirror发来的start replication命令后进入StartReplication开始流复制。 1WalSndLoop循环中通过XLogSendPhysical函数不断发送WAL 2XLogSendPhysical函数发送WAL达到一个时间线的末尾节点位置时向mirror的receiver进程发送CopyDone消息即开头为‘c’的消息并将streamingDoneSending变量改为true 3receiver进程的入口函数WalReceiverMain通过walrcv_receive::libpqrcv_receive不断接收WAL日志和消息。当接收到发来的CopyDone消息后返回-1 4接着返回到WalReceiverMain函数中当walrcv_receive返回-1后一路下来会退出接收消息和日志的循环并进入walrcv_endstreaming再向primary发送个CopyDone消息 5primary的ProcessRepliesIfAny处理mirror发来的消息当接收到CopyDone消息后将streamingDoneReceiving改为true 6返回WalSndLoop循环当streamingDoneSending和streamingDoneReceiving都为true时退出循环 总结一句话primary发完一个时间线内的WAL切换下一个时间线时会退出发送WAL日志的循环stop streaming当然mirror的receiver进程发起下一个时间线的日志拉取即再次调用libpqrcv_startstreaming函数向primary发送START_REPLICATION命令后primary仍旧会再次进入WalSndLoop循环发送WAL日志。 3、什么时候进入WALSNDSTATE_BACKUP exec_replication_command进行基础备份的时候 exec_replication_command进行基础备份的时候switch (cmd_node-type){case T_BaseBackupCmd:PreventInTransactionBlock(true, BASE_BACKUP);SendBaseBackup((BaseBackupCmd *) cmd_node);| parse_basebackup_options(cmd-options, opt);| WalSndSetState(WALSNDSTATE_BACKUP);| perform_base_backup(opt);break;...} 进行基础备份也就是构建mirror的时候进入该状态。 4、什么时候进入WALSNDSTATE_STARTUP 1sender进程刚fork出来InitWalSenderSlot初始化的时候 2WalSndLoop进程退出后又进入startup状态因为下个时间线的复制即将开始 3sender进程遇到ERROR故障跳回到PostgresMain回退操作处回退事务后进入WalSndErrorCleanup若没有stop则重新设置为startup状态等待接收start replication命令重新开始复制。 PostgresMainif (am_walsender)InitWalSender();//sender进程的初始化|-- InitWalSenderSlot|-- for (i 0; i max_wal_senders; i){| WalSnd *walsnd WalSndCtl-walsnds[i];| SpinLockAcquire(walsnd-mutex);| if (walsnd-pid ! 0){| //找一个空闲的slot| SpinLockRelease(walsnd-mutex);| continue;| }else{| walsnd-pid MyProcPid;| walsnd-state WALSNDSTATE_STARTUP;| ...| break;| }| }|-- on_shmem_exit(WalSndKill, 0); StartReplication:sender的WalSndLoop退出后又进入startup状态WalSndLoop(XLogSendLogical);...if (got_STOPPING)proc_exit(0);WalSndSetState(WALSNDSTATE_STARTUP);EndCommand(COPY 0, DestRemote); PostgresMain//sender进程遇到ERROR报错,sender进程需要再次start replication才能进入传输walif (sigsetjmp(local_sigjmp_buf, 1) ! 0){AbortCurrentTransaction();if (am_walsender)WalSndErrorCleanup();|-- if (got_STOPPING || got_SIGUSR2)| proc_exit(0);|-- WalSndSetState(WALSNDSTATE_STARTUP);...for (;;){firstchar ReadCommand(input_message);switch (firstchar){case Q:{if (am_walsender){if (!exec_replication_command(query_string))exec_simple_query(query_string);}else if (am_ftshandler)HandleFtsMessage(query_string);else if (am_faulthandler)HandleFaultMessage(query_string);elseexec_simple_query(query_string);send_ready_for_query true;break;}case M: ...}} 5、什么时候进入WALSNDSTATE_CATCHUP 开始流复制前设置成catchup状态。 StartReplication:开始流复制前WalSndSetState(WALSNDSTATE_CATCHUP);/* Send a CopyBothResponse message, and start streaming */pq_beginmessage(buf, W);pq_sendbyte(buf, 0);pq_sendint16(buf, 0);pq_endmessage(buf);pq_flush();WalSndLoop(XLogSendLogical);... 6、什么时候进入WALSNDSTATE_STREAMING 当前时间线内没有要发送的日志了并且没有下一个时间线需要切换发送日志则将其改为streaming状态。 WalSndLoopfor (;;){if (!pq_is_send_pending())send_data();elseWalSndCaughtUp false;...//现在没有要发送的了if (WalSndCaughtUp !pq_is_send_pending()){if (MyWalSnd-state WALSNDSTATE_CATCHUP)WalSndSetState(WALSNDSTATE_STREAMING);}...}
