Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

C# - ASP.NET Core 프로젝트에서 서버 Socket을 직접 생성하는 방법

excludedportrange로 인해,

"Administered port exclusions" 설명
; https://www.sysnet.pe.kr/2/0/12293

간혹 비주얼 스튜디오에서 생성한 웹 애플리케이션을 실행하는 경우에서조차도,

Visual Studio - 웹 애플리케이션 실행 시 "Unable to connect to web server 'IIS Express'." 오류 발생
; https://www.sysnet.pe.kr/2/0/12265

포트 충돌이 발생하곤 합니다. 이런 문제를 해결하려면, 우리도 사용해야 할 포트를 excludedportrange로 등록한 후 Socket.IOControl로 연결하면 된다고 설명했는데요,

C# - 소켓 포트를 미리 시스템에 등록/예약해 사용하는 방법(Port Exclusion Ranges)
; https://www.sysnet.pe.kr/2/0/13439

혹시, 그럼 저걸 이용해서 ASP.NET Core 웹 프로젝트를 실행할 때의 포트 충돌 문제를 해결할 수 있을까요? ^^




그러려면 가장 중요한 것이, ASP.NET Core 프레임워크에서 Socket을 사용자 정의할 수 있어야 합니다. 다행히, 이 기능이 .NET 6+부터 SocketTransportOptions을 통해 지원하기 시작했는데요, 코드는 간단하게 다음과 같이 나옵니다.

using System.Net.Sockets;
using Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets;

namespace WebApplication1
{
    public class Program
    {
        public static void Main(string[] args)
        {
            var builder = WebApplication.CreateBuilder(args);

            builder.Services.Configure<SocketTransportOptions>(options =>
            {
                options.CreateBoundListenSocket = endpoint =>
                {
                    Socket socket = SocketTransportOptions.CreateDefaultBoundListenSocket(endpoint);
                    return socket;
                };
            });

            // Add services to the container.
            builder.Services.AddRazorPages();

            var app = builder.Build();

            // Configure the HTTP request pipeline.
            if (!app.Environment.IsDevelopment())
            {
                app.UseExceptionHandler("/Error");
            }
            app.UseStaticFiles();

            app.UseRouting();

            app.UseAuthorization();

            app.MapRazorPages();

            app.Run();
        }
    }
}

SocketTransportOptions가 구현한 CreateDefaultBoundListenSocket의 소스 코드는 이런 식인데요,

public static Socket CreateDefaultBoundListenSocket(EndPoint endpoint)
{
    Socket listenSocket;
    switch (endpoint)
    {
        case FileHandleEndPoint fileHandle:
            listenSocket = new Socket(
                new SafeSocketHandle((IntPtr)fileHandle.FileHandle, ownsHandle: true)
            );
            break;
        case UnixDomainSocketEndPoint unix:
            listenSocket = new Socket(unix.AddressFamily, SocketType.Stream, ProtocolType.Unspecified);
            break;
        case IPEndPoint ip:
            listenSocket = new Socket(ip.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

            if (ip.Address.Equals(IPAddress.IPv6Any))
            {
                listenSocket.DualMode = true;
            }

            break;
        default:
            listenSocket = new Socket(endpoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
            break;
    }

    if (!(endpoint is FileHandleEndPoint))
    {
        listenSocket.Bind(endpoint);
    }

    return listenSocket;
}

따라서 우리는 저 코드를 이용해 다음과 같은 식으로 만들면 됩니다.

builder.Services.Configure<SocketTransportOptions>(options =>
{
    options.CreateBoundListenSocket = endpoint =>
    {
        return CreateSocketFromExcludedPortRange(endpoint);
    };
});

private static Socket CreateSocketFromExcludedPortRange(EndPoint endpoint)
{
    switch (endpoint)
    {
        case FileHandleEndPoint:
        case UnixDomainSocketEndPoint:
            return SocketTransportOptions.CreateDefaultBoundListenSocket(endpoint);
    }
            
    Socket socket = // ...[생략: Port Exclusion Ranges를 고려한 소켓 생성]...
    return socket;
}

간단하죠? ^^




그런데, 정작 구현하다 보면 이게 그렇게 간단하게 끝나지 않습니다. 왜냐하면 Port Exclusion을 이용한 IOControl 코드는 관리자 권한에서만 동작하기 때문에, 반드시 비주얼 스튜디오 프로세스부터 관리자 권한으로 띄워 두어야 합니다.

그리고 이러한 동작은 대개의 경우 개발자 머신에서만 유효할 것입니다. 실제 현업에 배포할 때는 대개의 경우 80/443 포트를 점유하거나, Reverse Proxy나 Container 환경에서 미리 정의한 바로 그 포트로만 서비스를 할 것이기 때문에 딱히 Port Exclusion을 사용할 필요가 없습니다.

따라서 이런 것을 고려했을 때, 대충 다음과 같은 식으로 코드를 작성해 볼 수 있습니다.

using Microsoft.AspNetCore.Connections;
using Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets;
using System.Net;
using System.Net.Sockets;
using System.Runtime.InteropServices;
using System.Security.Principal;

namespace WebApplication1
{
    public class Program
    {
#if DEBUG
        [DllImport("Iphlpapi.dll")]
        internal static extern uint CreatePersistentTcpPortReservation(ushort startPort, ushort numberOfPorts, out long token);

        [DllImport("Iphlpapi.dll")]
        internal static extern uint LookupPersistentTcpPortReservation(ushort startPort, ushort numberOfPorts, out long token);

        const int ERROR_NOT_FOUND = 1168;
        const int ERROR_INVALID_PARAMETER = 87;
        const int SIO_ASSOCIATE_PORT_RESERVATION = -1744830362;
        const int WSAEACCES = 10013;
#endif

        public static void Main(string[] args)
        {
            var builder = WebApplication.CreateBuilder(args);

#if DEBUG
            builder.Services.Configure<SocketTransportOptions>(options =>
            {
                options.CreateBoundListenSocket = endpoint =>
                {
                    return CreateSocketFromExcludedPortRange(endpoint);
                };
            });
#endif

            // Add services to the container.
            builder.Services.AddRazorPages();

            var app = builder.Build();

            // Configure the HTTP request pipeline.
            if (!app.Environment.IsDevelopment())
            {
                app.UseExceptionHandler("/Error");
            }
            app.UseStaticFiles();

            app.UseRouting();

            app.UseAuthorization();

            app.MapRazorPages();

            app.Run();
        }

#if DEBUG
        // ClickOnce - 관리자 권한 상승하는 방법
        // https://www.sysnet.pe.kr/2/0/950

        public static bool IsAdministrator()
        {
            WindowsIdentity identity = WindowsIdentity.GetCurrent();

            if (null != identity)
            {
                WindowsPrincipal principal = new WindowsPrincipal(identity);
                return principal.IsInRole(WindowsBuiltInRole.Administrator);
            }

            return false;
        }

        private static Socket CreateSocketFromExcludedPortRange(EndPoint endpoint)
        {
            if (IsAdministrator() == false)
            {
                return SocketTransportOptions.CreateDefaultBoundListenSocket(endpoint);
            }

            switch (endpoint)
            {
                case FileHandleEndPoint:
                case UnixDomainSocketEndPoint:
                    return SocketTransportOptions.CreateDefaultBoundListenSocket(endpoint);
            }

            Socket listenSocket;

            switch (endpoint)
            {
                case IPEndPoint ip:
                    listenSocket = new Socket(ip.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

                    if (ip.Address.Equals(IPAddress.IPv6Any))
                    {
                        listenSocket.DualMode = true;
                    }
                    break;

                default:
                    listenSocket = new Socket(endpoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
                    break;
            }

            endpoint = DetermineEndpoint(listenSocket, endpoint);

            listenSocket.Bind(endpoint);
            return listenSocket;
        }

        private static EndPoint DetermineEndpoint(Socket socket, EndPoint endpoint)
        {
            IPEndPoint? ip = endpoint as IPEndPoint;
            if (ip == null)
            {
                return endpoint;
            }

            ushort startPort = (ushort)ip.Port;
            long token = 0;

            for (ushort i = startPort; i <= ushort.MaxValue; i++)
            {
                ushort port = (ushort)IPAddress.HostToNetworkOrder((short)i);

                uint status = LookupPersistentTcpPortReservation(port, 1, out token);

                if (status == ERROR_NOT_FOUND)
                {
                    status = CreatePersistentTcpPortReservation((ushort)port, 1, out token);
                }

                if (status == 0)
                {
                    byte[] resToken = BitConverter.GetBytes(token);

                    try
                    {
                        int result = socket.IOControl(SIO_ASSOCIATE_PORT_RESERVATION, resToken, null);
                        if (result == 0)
                        {
                            return new IPEndPoint(ip.Address, i);
                        }
                    }
                    catch (SocketException)
                    {
                    }
                }
            }

            return endpoint;
        }
#endif

    }
}

그런데, 여러분들이 해결해야 할 문제가 정말 저 코드를 사용해가면서까지 필요한 것인가? 라는 질문을 해야 합니다. 그러니까, 단순히 로컬에서 디버깅 실행 중 포트 충돌이 나는 귀찮음을 피하기 위해 저런 더 귀찮은 코드를 넣어야 하는 것이 바람직하냐는 것입니다.

사실 저 정도의 처리는 Port Exclusion 없이도 그냥 Bind를 무작정 시켜 예외가 나는 것을 catch하는 식으로,

builder.Services.Configure<SocketTransportOptions>(options =>
{
    options.CreateBoundListenSocket = endpoint =>
    {
        return CreateServerSocket(endpoint);
    };
});

private static Socket CreateServerSocket(EndPoint endpoint)
{
    switch (endpoint)
    {
        case FileHandleEndPoint:
        case UnixDomainSocketEndPoint:
            return SocketTransportOptions.CreateDefaultBoundListenSocket(endpoint);
    }

    Socket listenSocket = new Socket(endpoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

    IPEndPoint? ip = endpoint as IPEndPoint;
    if (ip == null)
    {
        listenSocket.Bind(endpoint);
        return listenSocket;
    }

    if (ip.Address.Equals(IPAddress.IPv6Any))
    {
        listenSocket.DualMode = true;
    }

    Exception? lastException = null;
    int portNumber = ip.Port;

    for (int i = portNumber; i < ushort.MaxValue; i++)
    {
        IPEndPoint ep = new IPEndPoint(ip.Address, i);

        try
        {
            listenSocket.Bind(ep);
            Console.WriteLine($"Binding: {ep}");
            return listenSocket;
        }
        catch (SocketException ex)
        {
            lastException = ex;
        }
    }

    throw lastException;
}

처리하는 것이 더 단순해서 좋습니다. ^^ 하지만, 여전히 의문이군요. 1) 비주얼 스튜디오를 관리자 권한으로 실행시키고 2) 저 코드를 넣어서 처리하느니, 저라면 그냥 설정에서 포트 번호를 다른 것으로 바꾸고 말겠습니다.




참고로, .NET 6+부터 저렇게 서버 소켓을 사용자 정의할 수 있게 되었는데요, 마찬가지로 웹 서버에 접속한 클라이언트와의 통신을 담당하는 소켓도 IConnectionSocketFeature로 구하는 것이 가능해졌습니다.

따라서, 요청 중에 다음과 같이 구할 수 있습니다.

using Microsoft.AspNetCore.Connections.Features;
using Microsoft.AspNetCore.Mvc.RazorPages;
using System.Net.Sockets;

namespace WebApplication1.Pages
{
    public class IndexModel : PageModel
    {
        private readonly ILogger<IndexModel> _logger;

        public IndexModel(ILogger<IndexModel> logger)
        {
            _logger = logger;
        }

        public void OnGet()
        {
            var socketFeature = this.HttpContext.Features.Get<IConnectionSocketFeature>();
            Socket clntSock = socketFeature.Socket;
            Console.WriteLine($"{clntSock.RemoteEndPoint} - {clntSock.LocalEndPoint}");
        }
    }
}

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddRazorPages();

var app = builder.Build();

app.Use(next =>
{
    return async context =>
    {
        var socketFeature = context.Features.Get<IConnectionSocketFeature>();
        Socket clntSock = socketFeature.Socket;
        Console.WriteLine($"{clntSock.RemoteEndPoint} - {clntSock.LocalEndPoint}");
        await next(context);
    };
});

(첨부 파일은 이 글의 예제 코드를 포함합니다.)




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 11/12/2023]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




1  2  3  4  5  6  7  8  9  10  11  12  13  14  [15]  ...
NoWriterDateCnt.TitleFile(s)
13486정성태12/15/20236369개발 환경 구성: 695. Nuget config 파일에 값 설정/삭제 방법
13485정성태12/15/20236083오류 유형: 883. dotnet build/restore - error : Root element is missing
13484정성태12/14/20236319개발 환경 구성: 694. Windows 디렉터리 경로를 WSL의 /mnt 포맷으로 구하는 방법
13483정성태12/14/20236876닷넷: 2184. C# - 하나의 resource 파일을 여러 프로그램에서 (AOT 시에도) 사용하는 방법파일 다운로드1
13482정성태12/13/20237899닷넷: 2183. C# - eFriend Expert OCX 예제를 .NET Core/5+ Console App에서 사용하는 방법 [2]파일 다운로드1
13481정성태12/13/20236787개발 환경 구성: 693. msbuild - .NET Core/5+ 프로젝트에서 resgen을 이용한 리소스 파일 생성 방법파일 다운로드1
13480정성태12/12/20237916개발 환경 구성: 692. Windows WSL 2 + Chrome 웹 브라우저 설치
13479정성태12/11/20236552개발 환경 구성: 691. WSL 2 (Ubuntu) + nginx 환경 설정
13477정성태12/8/20237237닷넷: 2182. C# - .NET 7부터 추가된 Int128, UInt128 [1]파일 다운로드1
13476정성태12/8/20236760닷넷: 2181. C# - .NET 8 JsonStringEnumConverter의 AOT를 위한 개선파일 다운로드1
13475정성태12/7/20236739닷넷: 2180. .NET 8 - 함수 포인터에 대한 Reflection 정보 조회파일 다운로드1
13474정성태12/6/20236514개발 환경 구성: 690. 닷넷 코어/5+ 버전의 ilasm/ildasm 실행 파일 구하는 방법 - 두 번째 이야기
13473정성태12/5/20236895닷넷: 2179. C# - 값 형식(Blittable)을 메모리 복사를 이용해 바이트 배열로 직렬화/역직렬화파일 다운로드1
13472정성태12/4/20236551C/C++: 164. Visual C++ - InterlockedCompareExchange128 사용 방법
13471정성태12/4/20236934Copilot - To enable GitHub Copilot, authorize this extension using GitHub's device flow
13470정성태12/2/20237443닷넷: 2178. C# - .NET 8부터 COM Interop에 대한 자동 소스 코드 생성 도입 [1]파일 다운로드1
13469정성태12/1/20237175닷넷: 2177. C# - (Interop DLL 없이) CoClass를 이용한 COM 개체 생성 방법파일 다운로드1
13468정성태12/1/20236381닷넷: 2176. C# - .NET Core/5+부터 달라진 RCW(Runtime Callable Wrapper) 대응 방식파일 다운로드1
13467정성태11/30/20237069오류 유형: 882. C# - Unhandled exception. System.Runtime.InteropServices.COMException (0x800080A5)파일 다운로드1
13466정성태11/29/20237210닷넷: 2175. C# - DllImport 메서드의 AOT 지원을 위한 LibraryImport 옵션
13465정성태11/28/20236767개발 환경 구성: 689. MSBuild - CopyToOutputDirectory가 "dotnet publish" 시에는 적용되지 않는 문제파일 다운로드1
13464정성태11/28/20236793닷넷: 2174. C# - .NET 7부터 UnmanagedCallersOnly 함수 export 기능을 AOT 빌드에 통합파일 다운로드1
13463정성태11/27/20236575오류 유형: 881. Visual Studio - NU1605: Warning As Error: Detected package downgrade
13462정성태11/27/20236936오류 유형: 880. Visual Studio - error CS0246: The type or namespace name '...' could not be found
13461정성태11/26/20236559닷넷: 2173. .NET Core 3/5+ 기반의 COM Server를 registry 등록 없이 사용하는 방법파일 다운로드1
13460정성태11/26/20236808닷넷: 2172. .NET 6+ 기반의 COM Server 내에 Type Library를 내장하는 방법파일 다운로드1
1  2  3  4  5  6  7  8  9  10  11  12  13  14  [15]  ...