就是数据怎么清理的意思
…
2022年2月10日下午1:36，Lei Zhang @.***> 写道：老化处理是什么意思？ — Reply to this email directly, view it on GitHub <#732 (comment)>, or unsubscribe https://github.com/notifications/unsubscribe-auth/ANVDS4QFTZDHKSOHW6XWXTTU2NFFJANCNFSM5NMM3IZA. Triage notifications on the go with GitHub Mobile for iOS https://apps.apple.com/app/apple-store/id1477376905?ct=notification-email&mt=8&pt=524675 or Android https://play.google.com/store/apps/details?id=com.github.android&referrer=utm_campaign%3Dnotification-email%26utm_medium%3Demail%26utm_source%3Dgithub. You are receiving this because you modified the open/close state.

actor 在停止后会调用以下方法清理 Redis 中的数据和快照

servicecomb-pack/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java

Lines 458 to 459 in 441a6ad

    
           deleteMessages(lastSequenceNr()); 
        
           deleteSnapshot(snapshotSequenceNr());

但是 highestSequenceNr 不会自动清理，你可以看这个注释（我在注释里提供了一个 Lua 脚本用来清理）

servicecomb-pack/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/SagaActor.java

Lines 419 to 457 in 441a6ad

    
           //  已经停止的Actor使用以下两个命令清理，但是 highestSequenceNr 不会被删除，需要手工清理 
        
           //  以下基于 journal-redis 说明: 
        
           //    假设 globalTxId=ed2cdb9c-e86c-4b01-9f43-8e34704e7694, 那么在 Redis 中会生成三个 key 
        
           //    journal:persistenceIds 
        
           //    journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694 
        
           //    journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694:highestSequenceNr 
        
           // 
        
           //    1. journal:persistenceIds 是 set 类型, 记录了所有的 globalTxId, 使用 smembers journal:persistenceIds 可以看到 
        
           //    2. journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694 是 zset 类型, 记录了这个事务的所有事件 
        
           //       使用 zrange journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694 1 -1 可以看到 
        
           //    3. journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694:highestSequenceNr 是 string 类型, 里面记录这序列号 
        
           // 
        
           //    何如清理: 
        
           //      通过 deleteMessages 和 deleteSnapshot 可以清理部分数据，但是 highestSequenceNr 还是无法自动删除，需要定期手动清理 
        
           //      遍历 journal:persistenceIds 集合，用每一条数据item拼接成key journal:persisted:item 和 journal:persisted:item:highestSequenceNr 
        
           //      如果没有成对出现就说明是已经终止的actor 那么可以将 journal:persisted:item 从 journal:persistenceIds 删除 
        
           //      并删除 journal:persisted:item:highestSequenceNr 
        
           // 
        
           //  目前可以看到的解释是 https://github.com/akka/akka/issues/21181 
        
           // 
        
           //  Lua script akka-persistence-redis-clean.lua 
        
           //  local ids = redis.call('smembers','journal:persistenceIds'); 
        
           //  local delkeys = {}; 
        
           //  for k, v in pairs(ids) do 
        
           //    local jpid = 'journal:persisted:' .. v; 
        
           //    local jpidnr = 'journal:persisted:' .. v .. ':highestSequenceNr'; 
        
           //    local hasjpid  = redis.call('exists',jpid); 
        
           //    if(hasjpid == 0) 
        
           //    then 
        
           //      local hasjpidnr  = redis.call('exists',jpidnr); 
        
           //      if(hasjpidnr == 1) 
        
           //      then 
        
           //        redis.call('del',jpidnr); 
        
           //        table.insert(delkeys,jpid); 
        
           //      end 
        
           //    end 
        
           //  end 
        
           //  return delkeys;

ES 中的数据你可以根据事务数据持久化中的数据样例了解JSON 接口，可以使用 ES API 自行删除不需要的数据

	deleteMessages(lastSequenceNr());
	deleteSnapshot(snapshotSequenceNr());

	// 已经停止的Actor使用以下两个命令清理，但是 highestSequenceNr 不会被删除，需要手工清理
	// 以下基于 journal-redis 说明:
	// 假设 globalTxId=ed2cdb9c-e86c-4b01-9f43-8e34704e7694, 那么在 Redis 中会生成三个 key
	// journal:persistenceIds
	// journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694
	// journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694:highestSequenceNr
	//
	// 1. journal:persistenceIds 是 set 类型, 记录了所有的 globalTxId, 使用 smembers journal:persistenceIds 可以看到
	// 2. journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694 是 zset 类型, 记录了这个事务的所有事件
	// 使用 zrange journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694 1 -1 可以看到
	// 3. journal:persisted:ed2cdb9c-e86c-4b01-9f43-8e34704e7694:highestSequenceNr 是 string 类型, 里面记录这序列号
	//
	// 何如清理:
	// 通过 deleteMessages 和 deleteSnapshot 可以清理部分数据，但是 highestSequenceNr 还是无法自动删除，需要定期手动清理
	// 遍历 journal:persistenceIds 集合，用每一条数据item拼接成key journal:persisted:item 和 journal:persisted:item:highestSequenceNr
	// 如果没有成对出现就说明是已经终止的actor 那么可以将 journal:persisted:item 从 journal:persistenceIds 删除
	// 并删除 journal:persisted:item:highestSequenceNr
	//
	// 目前可以看到的解释是 https://github.com/akka/akka/issues/21181
	//
	// Lua script akka-persistence-redis-clean.lua

	// local ids = redis.call('smembers','journal:persistenceIds');
	// local delkeys = {};
	// for k, v in pairs(ids) do
	// local jpid = 'journal:persisted:' .. v;
	// local jpidnr = 'journal:persisted:' .. v .. ':highestSequenceNr';
	// local hasjpid = redis.call('exists',jpid);
	// if(hasjpid == 0)
	// then
	// local hasjpidnr = redis.call('exists',jpidnr);
	// if(hasjpidnr == 1)
	// then
	// redis.call('del',jpidnr);
	// table.insert(delkeys,jpid);
	// end
	// end
	// end
	// return delkeys;

Uh oh!

alpha的akka模式下，事务条目是否有写入redis #732

Description

Metadata

Metadata

Assignees

Labels

Type

Fields

Projects

Milestone

Relationships

Development

Issue actions