Собственный Redis

На этом этапе вы добавите приём команды PSYNC от реплики.

Напоминание о рукопожатии

При рукопожатии ведущий получает:

1. PING от реплики.
2. Дважды REPLCONF от реплики.
3. PSYNC от реплики.

После двух REPLCONF реплика отправляет ведущему команду PSYNC с аргументами ? -1:

• Идентификатор репликации равен ?, поскольку реплика ещё не знает идентификатор ведущего.
• Смещение равно -1, поскольку данных от ведущего ещё нет.

Полученная команда будет выглядеть примерно так:

*3\r\n$5\r\nPSYNC\r\n$1\r\n?\r\n$2\r\n-1\r\n

Это ["PSYNC", "?", "-1"], закодированный как массив RESP.

Ведущий должен ответить +FULLRESYNC <REPL_ID> 0\r\n — строкой FULLRESYNC <REPL_ID> 0 в формате простой строки. Значение ответа:

• FULLRESYNC означает, что ведущий не может выполнить инкрементальное обновление реплики и начнёт полную повторную синхронизацию.
• <REPL_ID> — идентификатор репликации ведущего.
• 0 — смещение репликации ведущего.

Например, для идентификатора 8371b4fb1155b71f4a04d3e1bc3e18c4a990aeeb ответ будет:

+FULLRESYNC 8371b4fb1155b71f4a04d3e1bc3e18c4a990aeeb 0\r\n

Тесты

Тестирующая программа запустит вашу программу так:

./your_program.sh --port <PORT>

Затем подключится к TCP-серверу как реплика и отправит:

1. PING — ожидается +PONG\r\n.
2. REPLCONF listening-port <PORT> — ожидается +OK\r\n.
3. REPLCONF capa psync2 — ожидается +OK\r\n.
4. PSYNC ? -1 — ожидается +FULLRESYNC <REPL_ID> 0\r\n.

Примечания

• Вместо <REPL_ID> подставьте идентификатор репликации ведущего, инициализированный ранее.