Гарантировать доставку сообщения Exactly Once (ровно один раз) — одна из самых сложных задач в распределённых системах, особенно при записи в файл. Для этого обычно применяют комбинацию следующих подходов:

Идемпотентность операций — сделать так, чтобы повторная запись одного и того же сообщения не приводила к дублированию. Например, хранить уникальный идентификатор сообщения и проверять его перед записью.
Транзакционность — использовать механизмы, которые обеспечивают атомарность записи. В случае с файлами можно применять журналирование (write-ahead log) или временные файлы с последующим переименованием.
Подтверждения и повторные попытки — отправитель должен получать подтверждение успешной записи и повторять отправку только при отсутствии подтверждения.
Использование специализированных систем — например, брокеров сообщений с поддержкой Exactly Once (Kafka с транзакциями), которые гарантируют, что сообщение будет обработано ровно один раз.

Пример упрощённого подхода на Java:

import java.io.*;
import java.util.HashSet;
import java.util.Set;

public class ExactlyOnceWriter {
    private Set<String> processedIds = new HashSet<>();
    private File file;

    public ExactlyOnceWriter(File file) {
        this.file = file;
        // загрузить processedIds из файла или БД при старте
    }

    public synchronized void writeMessage(String messageId, String message) throws IOException {
        if (processedIds.contains(messageId)) {
            // Сообщение уже записано
            return;
        }
        try (FileWriter fw = new FileWriter(file, true)) {
            fw.write(message + "\n");
            fw.flush();
            processedIds.add(messageId);
            // сохранить processedIds в надежное хранилище
        }
    }
}

Таким образом, ключ — хранить состояние о том, какие сообщения уже обработаны, и использовать атомарные операции записи.

Как обеспечить гарантию доставки Exactly Once (каждое сообщение попадает в файл ровно один раз)?