持久化通过记录服务器接收到的每个写命令来实现数据的持久化。

这样#xff0c;在

Redis

持久化通过记录服务器接收到的每个写命令来实现数据的持久化。

这样在

Redis

no。

推荐everyse因为它提供了较好的性能和数据安全性之间的平衡。

always:

fsync由操作系统决定何时同步到磁盘性能最好但数据安全性最低。

aof

/*指向实际处理该命令的函数。

这个函数会执行命令的具体逻辑。

示例:

SET

*proc;/*命令所需的参数个数。

如果命令可以接受可变数量的参数通常设置为

-N其中

arity;/*命令标志的字符串表示形式每个字符代表一个标志。

常见的标志包括w:

写操作r:

该命令被拒绝的次数例如由于权限问题。

failed_calls:

long

(ACL)。

连接能够执行给定命令的前提是连接关联的用户在允许命令的位图中有此命令的位。

*/int

id;

{set,setCommandImpl,3,wm,CMD_WRITE

CMD_DENYOOM,getKeysFromCommand,1,

firstkey1,

文件。

如果文件无法打开例如权限问题则记录警告日志并返回错误。

serverAssert

用于确保

open(server.aof_filename,O_WRONLY|O_APPEND|O_CREAT,0644);serverAssert(server.aof_state

AOF_OFF);if

getcwd(cwd,MAXPATHLEN);serverLog(LL_WARNING,Redis

needs

unknown,strerror(errno));return

C_ERR;}//

rewriteAppendOnlyFileBackground

触发后台

now.);killAppendOnlyChild();}if

(rewriteAppendOnlyFileBackground()

C_ERR)

{close(newfd);serverLog(LL_WARNING,Redis

needs

AOF_WAIT_REWRITE;server.aof_last_fsync

newfd;/*

aof_bio_fsync_status;atomicGet(server.aof_bio_fsync_status,

C_ERR)

job);atomicSet(server.aof_bio_fsync_status,C_OK);}/*

AOF

error.);server.aof_last_write_status

C_OK;}return

缓冲区的关键函数。

这个函数确保所有对数据库的修改操作都被记录到

AOF

*//*如果当前命令的目标数据库与上一个命令不同则需要插入一个

SELECT

以反映当前选中的数据库。

server.aof_selected_db

为文件中没有加载数据库*/if

seldb[64];snprintf(seldb,sizeof(seldb),%d,dictid);buf

sdscatprintf(buf,*2\r\n$6\r\nSELECT\r\n$%lu\r\n%s\r\n,(unsigned

long)strlen(seldb),seldb);server.aof_selected_db

(cmd-proc

catAppendOnlyExpireAtCommand(buf,cmd,argv[1],argv[2]);//处理包含过期时间的SET命令

else

strtoll(millisecond-ptr,NULL,10);when

mstime();decrRefCount(millisecond);robj

argv[0];newargs[1]

createStringObjectFromLongLong(when);buf

catAppendOnlyGenericCommand(buf,5,newargs);decrRefCount(newargs[4]);}

else

catAppendOnlyGenericCommand(buf,argc,argv);}//其他命令}

else

catAppendOnlyGenericCommand(buf,argc,argv);}/*

Append

sdscatlen(server.aof_buf,buf,sdslen(buf));/*

background

CHILD_TYPE_AOF)aofRewriteBufferAppend((unsigned

buf

缓冲区中以便稍后写入磁盘。

该函数还处理了数据库选择命令、过期命令和

SET

重写它还会将命令追加到重写缓冲区中以便在重写完成后应用这些新命令。

rewriteAppendOnlyFileBackground

rewriteAppendOnlyFileBackground

Redis

文件该文件只包含重建当前数据集所需的最少命令。

这个过程是在后台进行的以避免阻塞主进程。

int

rewriteAppendOnlyFileBackground(void)

{pid_t

*/redisSetProcTitle(redis-aof-rewrite);redisSetCpuAffinity(server.aof_rewrite_cpulist);snprintf(tmpfile,256,temp-rewriteaof-bg-%d.aof,

(int)

(rewriteAppendOnlyFile(tmpfile)

C_OK)

{sendChildCowInfo(CHILD_INFO_TYPE_AOF_COW_SIZE,

AOF

%s,strerror(errno));aofClosePipes();return

C_ERR;}serverLog(LL_NOTICE,Background

append

childpid);server.aof_rewrite_scheduled

0;server.aof_rewrite_time_start

time(NULL);/*

-1;replicationScriptCacheFlush();return

C_OK;}return

文件的核心函数。

该函数负责将当前内存中的数据集以最小的命令集合形式写入一个新的

AOF

rewriteAppendOnlyFileBackground()

function.

*//*生成一个临时文件名并尝试打开它。

如果打开失败记录警告日志并返回错误。

*/snprintf(tmpfile,256,temp-rewriteaof-%d.aof,

(int)

sdsempty();rioInitWithFile(aof,fp);//

Rio

(server.aof_rewrite_incremental_fsync)rioSetAutoSync(aof,REDIS_AUTOSYNC_BYTES);//开始保存操作startSaving(RDBFLAGS_AOF_PREAMBLE);/*如果启用了

RDB

(rdbSaveRio(aof,error,RDBFLAGS_AOF_PREAMBLE,NULL)

C_ERR)

(aeWait(server.aof_pipe_read_data_from_parent,

AE_READABLE,

(write(server.aof_pipe_write_ack_to_parent,!,1)

goto

(anetNonBlock(NULL,server.aof_pipe_read_ack_from_parent)

ANET_OK)goto

(syncRead(server.aof_pipe_read_ack_from_parent,byte,1,5000)

||byte

werr;serverLog(LL_NOTICE,Parent

agreed

*/serverLog(LL_NOTICE,Concatenating

%.2f

sdslen(server.aof_child_diff);const

char

{sendChildInfo(CHILD_INFO_TYPE_CURRENT_INFO,

key_count,

strerror(errno));unlink(tmpfile);stopSaving(0);return

C_ERR;}serverLog(LL_NOTICE,SYNC

append

performed);stopSaving(1);return

C_OK;werr:serverLog(LL_WARNING,Write

error

fclose(fp);unlink(tmpfile);stopSaving(0);return

C_ERR;

文件的核心函数。

该函数通过遍历每个数据库db中的键值对并生成相应的

Redis

{/*获取当前数据库。

如果数据库为空则跳过。

获取字典迭代器。

*/char

selectcmd[]

(rioWrite(aof,selectcmd,sizeof(selectcmd)-1)

goto

expiretime;/*获取键和对应的值。

初始化静态字符串对象

dictGetKey(de);o

dictGetVal(de);initStaticStringObject(key,keystr);expiretime

getExpire(db,key);/*

(rioWrite(aof,cmd,sizeof(cmd)-1)

goto

(rewriteSortedSetObject(aof,key,o)

goto

(rewriteStreamObject(aof,key,o)

goto

(rewriteModuleObject(aof,key,o)

goto

cmd[]*3\r\n$9\r\nPEXPIREAT\r\n;if

(rioWrite(aof,cmd,sizeof(cmd)-1)

goto

(rioWriteBulkLongLong(aof,expiretime)

goto

processedAOF_READ_DIFF_INTERVAL_BYTES)

{processed

aof-processed_bytes;aofReadDiffFromParent();}/*

Update

{sendChildInfo(CHILD_INFO_TYPE_CURRENT_INFO,

key_count,

now;}}}dictReleaseIterator(di);di

NULL;}return

定期保存内存中的数据到磁盘。

文件紧凑适合备份和灾难恢复。

恢复速度快但可能丢失最后一次快照之后的数据。

AOF

策略来平衡性能和数据安全性。

数据更完整但文件较大恢复速度较慢。

AOF