Как можно реализовать ограничение на одновременное скачивание файлов?

Question

[loosername]

Есть сервис, который отдает пользователям видео файлы, реализован метод для скачивания файла, который отдает файл через метод File

[HttpGet("file/{guid}/download")]
        [ProducesResponseType(StatusCodes.Status200OK)]
        public async Task<IActionResult> DownloadFile([FromRoute] Guid guid)
        {
            var file = await _mediaContentService.DownloadFile(guid);

            return File(file.Stream, file.ContentType, file.FileName);
        }

Можно ли каким-либо образом реализовать ограничение на скачивание файла, чтобы, например, в единицу времени не больше N пользователей качало файл.
Пробовал реализовать через semaphore, но после возврата из метода он освобождается, а файл еще докачивается

[HttpGet("file/{guid}/download")]
        [ProducesResponseType(StatusCodes.Status200OK)]
        public async Task<IActionResult> DownloadFile([FromRoute] Guid guid)
        {
            try
            {
                await _semaphore.WaitAsync();
                var file = await _mediaContentService.DownloadFile(guid);

                return File(file.Stream, file.ContentType, file.FileName);
            }
            finally
            {
                _semaphore.Release();
            }
            
        }

, соответственно, ограничение не работает.
Может быть, кто-то реализовывал такой функционал и поможет советом?
P.S. S3 хранилище использовать не можем

Comments

[Akina]

ограничение на скачивание файла, чтобы, например, в единицу времени не больше N пользователей качало файл.

А смысл? наоборот, чем больше народу качает из одного и того же кэша, тем меньше нагрузка на дисковую подсистему.

[Nik Faraday]

Читаем правило 3.8

[#]

Nik Faraday, loosername, часто сайты типа https://jsfiddle.net/ удобны для демонстрации, тем более можно что то попробовать ))
... но меня смущают примеры на js (а тега нет) и тег c# (а кода нет)...

[#]

loosername, глянул историю изменений...
вы уже определитесь с вопросом то? а то сейчас вообще ни в куда выходит..

[Sergey В.]

Нет способа определить, что пользователь завершил скачивание файла.
Поэтому (возможно) есть смысл разрешать скачивание нового файла не чаще чем раз в 10 секунд.
Для записи timestamp последней выполненной загрузки можно использовать
HttpContext.Session.SetString(key_name, value);
для проверки:
var timestamp = HttpContext.Session.GetString(key_name);

[MVV]

_semaphore где определен и как создается?
Если это поле класса контроллера, и в конструкторе семафор создается в нем заново (ну, или внедряется через сервис с времинем жизни Transient/Scoped), то для каждого запроса создается свой экземпляр контроллера, а значит - и свой семафор.
В таких случаях _semaphore должен быть для всех общим: статическое поле, сервис-Singleton и т.п. Только вот так он будет влиять на все файлы,а чтобы для каждого файла был свой семафор - тут вам думать дополнительно надо будет.

Answer 1

[Сергей Соловьев]

Проблема с методом File - он возвращает ленивый ответ. Т.е. он не читает весь поток сразу, а ждет пока будет вызван метод от IActionResult, поэтому семафор берется и сразу же отпускается.
Чтобы эту проблему решить надо знать, когда файл точно отправлен.
Предлагаю сделать декоратор специальный. Например:

[ApiController]
[Route("[controller]")]
public class SampleController : ControllerBase
{
    private readonly IRateLimiter _rateLimiter;

    public SampleController(IRateLimiter rateLimiter)
    {
        _rateLimiter = rateLimiter;
    }

    [HttpGet("connection")]
    public async Task<IActionResult> DownLoadFile(Guid file)
    {
        var stream = await GetFileStream(file);
        return new RateLimiterFileActionResult(File(stream, "content/type", "sample.txt"), _rateLimiter);
    }
}

class RateLimiterFileActionResult : IActionResult
{
    private readonly IActionResult _actionResultImplementation;
    private readonly IRateLimiter _rateLimiter;

    public RateLimiterFileActionResult(IActionResult actionResultImplementation, IRateLimiter rateLimiter)
    {
        _actionResultImplementation = actionResultImplementation;
        _rateLimiter = rateLimiter;
    }

    public async Task ExecuteResultAsync(ActionContext context)
    {
        try
        {
            await _rateLimiter.ObtainAsync(context.HttpContext.RequestAborted);
            await _actionResultImplementation.ExecuteResultAsync(context);
        }
        finally
        {
            await _rateLimiter.ReleaseAsync(context.HttpContext.RequestAborted);
        }
    }
}

public interface IRateLimiter
{
    public Task ObtainAsync(CancellationToken token);
    public Task ReleaseAsync(CancellationToken token);
}

Здесь используется не семафор, а специальный интерфейс, хотя разницы особо нет.
Также, стоит заметить, что блокировка берется внутри метода декоратора, а не в методе контроллера - например, пользователь отменит запрос и тогда надо будет думать как семафор отпустить - в этой реализации думать не надо.

Comments

[loosername]

Большое спасибо за предложенный подход!