0

Сервер использует при запуске случайный порт:

public static IWebHostBuilder ConfigureBuilder(IWebHostBuilder builder, string ip = "*") =>
        builder.UseSerilog()
               .UseContentRoot(Directory.GetCurrentDirectory())
               .UseKestrel(x =>
               {
                   x.AllowSynchronousIO = true;
               })
               .UseUrls($"http://{ip}:0");

С клиента с помощью следующего кода хочу получить его путём пинга возможных портов:

private static int GetCurrentPort(IPAddress ip, IEnumerable<int> ports)
{
    using var client = new HttpClient();
    using var cts = new CancellationTokenSource();
    using var semaphore = new SemaphoreSlim(500);

    var availablePort = -1;

    ports.ToAsyncEnumerable().ForEachAsync(async port =>
    {
        await semaphore.WaitAsync();

        try
        {
            var response = await $"http://{ip}:{port}".AppendPathSegment("ping").GetAsync(cts.Token);
            if (response.StatusCode is 200)
            {
                availablePort = port;
                cts.Cancel();
            }
        }
        catch { }
        finally { semaphore.Release(); }
    }, cts.Token).Wait();

    if (availablePort == -1)
        throw new ApplicationException("Not found available server port");

    return availablePort;
}

Сервер при этом отвечает на запрос, но клиент всё равно выкидывает исключение ApplicationException. Будто не ожидает Wait()

Request starting HTTP/1.1 GET http://192.168.0.0:49983/ping - -
[2023-04-27 11:38:54.452 INF] Request:
Protocol: HTTP/1.1
Method: GET
Scheme: http
PathBase:
Path: /ping
Host: 192.168.0.0:49983
Accept-Encoding: gzip, deflate
[2023-04-27 11:38:54.479 INF] Response:
StatusCode: 200
Date: Thu, 27 Apr 2023 08:38:54 GMT
Server: Kestrel
Transfer-Encoding: chunked
[2023-04-27 11:38:54.481 INF] Request finished HTTP/1.1 GET http://192.168.0.0:49983/ping - - - 200 - - 44.8413ms

С помощью следующего кода получаю возможные порты:

public static IReadOnlyList<int> GetAvaliablePorts(ushort lowerPort = MIN_PORT, ushort upperport = MAX_PORT)
{
    var ipProperties = IPGlobalProperties.GetIPGlobalProperties();
    return Enumerable.Empty<int>()
                     .Concat(ipProperties.GetActiveTcpConnections().Select(x => x.LocalEndPoint.Port))
                     .Concat(ipProperties.GetActiveTcpListeners().Select(x => x.Port))
                     .Concat(ipProperties.GetActiveUdpListeners().Select(x => x.Port))
                     .Where(x => x >= lowerPort && x <= upperport)
                     .Sort().Distinct().ToList();
}

Использую библиотеки Flurl для отправки сообщений и System.Linq.Async для ToAsyncEnumerable

UPD:

Нашел реализацию и под свою проблему преобразовал её. Посмотрите, пожалуйста

private static async Task<int> GetCurrentPort(IPAddress ip, IEnumerable<int> ports)
{
    using var client = new HttpClient();
    using var cts = new CancellationTokenSource();
    using var semaphore = new SemaphoreSlim(500);

    var availablePort = -1;

    try
    {
        _ = ports.OrderDescending().WithCancellation(cts.Token).Select(async port =>
        {
            await semaphore.WaitAsync();

            try
            {
                var response = await $"http://{ip}:{port}".AppendPathSegment("ping").GetAsync(cts.Token);
                if (response.StatusCode is 200)
                {
                    cts.Cancel();
                    availablePort = port;
                }
            }
            catch { }
            finally
            {
                semaphore.Release();
            }
        }).ToList();
    }
    catch { }

    if (availablePort == -1)
        throw new ApplicationException("Not found available server port");

    return availablePort;
}

public static IEnumerable<T> WithCancellation<T>(this IEnumerable<T> en, CancellationToken token)
{
    foreach (var item in en)
    {
        token.ThrowIfCancellationRequested();
        yield return item;
    }
}
1
  • Если нашли решение, можно его ответом оформить
    – aepot
    Commented 27 апр. 2023 в 19:51

1 ответ 1

0
private static async Task<int> GetCurrentPort(IPAddress ip, IEnumerable<int> ports)
{
    using var client = new HttpClient();
    using var cts = new CancellationTokenSource();
    using var semaphore = new SemaphoreSlim(500);

    var availablePort = -1;

    try
    {
        _ = ports.OrderDescending().WithCancellation(cts.Token).Select(async port =>
        {
            await semaphore.WaitAsync();

            try
            {
                var response = await $"http://{ip}:{port}".AppendPathSegment("ping").GetAsync(cts.Token);
                if (response.StatusCode is 200)
                {
                    cts.Cancel();
                    availablePort = port;
                }
            }
            catch { }
            finally
            {
                semaphore.Release();
            }
        }).ToList();
    }
    catch { }

    if (availablePort == -1)
        throw new ApplicationException("Not found available server port");

    return availablePort;
}

public static IEnumerable<T> WithCancellation<T>(this IEnumerable<T> en, CancellationToken token)
{
    foreach (var item in en)
    {
        token.ThrowIfCancellationRequested();
        yield return item;
    }
}

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.