メモリストアデータ構造設計のベストプラクティス

ソートされたマップのシャーディング
-- メモリストアサービスを初期化
local MemoryStoreService = game:GetService("MemoryStoreService")

-- ソートされたマップバケットを作成
local sm_AtoG = MemoryStoreService:GetSortedMap("AtoG")
local sm_HtoM = MemoryStoreService:GetSortedMap("HtoM")
local sm_NtoT = MemoryStoreService:GetSortedMap("NtoT")
local sm_UtoZ = MemoryStoreService:GetSortedMap("UtoZ")

-- アイテムキーから正しいバケットを取得するヘルパー関数
local function getSortedMapBucket(itemKey)
	if (itemKey >= "a" and itemKey < "h") then
		return sm_AtoG
	elseif (itemKey < "n") then
		return sm_HtoM
	elseif (itemKey < "u") then
		return sm_NtoT
	else
		return sm_UtoZ
	end
end

-- デフォルト値0でプレイヤーの名前を初期化
for _, player in game:GetService("Players"):GetPlayers() do
	local bucket = getSortedMapBucket(player)
	bucket:SetAsync(player, 0, 600)
end

-- プレイヤーの値を取得
local player = "myPlayer"
local bucket = getSortedMapBucket(player)
local playerScore = bucket:GetAsync(player)
print(playerScore)

キューのシャーディング
-- メモリストアサービスを初期化
local MemoryStoreService = game:GetService("MemoryStoreService")

-- キューを作成
local q1 = MemoryStoreService:GetQueue("q1")
local q2 = MemoryStoreService:GetQueue("q2")
local q3 = MemoryStoreService:GetQueue("q3")
local q4 = MemoryStoreService:GetQueue("q4")

-- 配列にキューを追加
local queueArr = { q1, q2, q3, q4 }

-- 読み取りキューと追加キューのインデックスを表す2つのポインタを作成
local readIndex = 1
local addIndex = 1

-- インデックスを適切に更新するローカル関数を作成
local function rotateIndex(index, n)
	return (index + n - 1) % 4 + 1
end

-- キューから n アイテムを読み取るローカル関数を作成
local function readFromQueue(count, allOrNothing, waitTimeout)
	local endIndex = count % 4
	local countPerQueue = count // 4
	local items = {}
	local ids = {}

	-- 各キューをループ
	for i = 1, 4, 1 do
		-- このキューが追加のアイテムを読み取るかどうかを決定
		local diff = i - readIndex
		if diff < 0 then
			diff += 4
		end

		local queue = queueArr[i]

		-- 各キューからアイテムを読み取ります
		-- 追加の読み取り基準が一致する場合は +1 アイテム
		if diff < endIndex then
			items[i], ids[i] = queue:ReadAsync(countPerQueue + 1, allOrNothing,waitTimeout)
		else
			items[i], ids[i] = queue:ReadAsync(countPerQueue, allOrNothing,waitTimeout)
		end
	end

	readIndex = rotateIndex(readIndex, count)

	return items, ids
end

-- キューから n アイテムを削除するローカル関数を作成
local function removeFromQueue(ids)
	for i = 1, 4, 1 do
		local queue = queueArr[readIndex]
		queue:RemoveAsync(ids[i])
	end
end

-- キューにアイテムを追加するローカル関数を作成
local function addToQueue(itemKey, expiration, priority)
	local queue = queueArr[readIndex]
	queue:AddAsync(itemKey, expiration, priority)
	addIndex = rotateIndex(addIndex, 1)
end

-- コードを書きます！

for _, player in game:GetService("Players"):GetPlayers() do
	addToQueue(player, 600, 0)
end

local players, ids = readFromQueue(20, true, -1)
removeFromQueue(ids)