Microsoft MVP성태의 닷넷 이야기
.NET Framework: 416. System.Net.Sockets.NetworkStream이 Thread-safe할까? [링크 복사], [링크+제목 복사],
조회: 25675
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

System.Net.Sockets.NetworkStream이 Thread-safe할까?

socket 관련 thread-safe의 마지막 글입니다. ^^

System.Net.Sockets.Socket이 Thread-safe할까?
; https://www.sysnet.pe.kr/2/0/1469

Win32 socket이 Thread-safe할까?
; https://www.sysnet.pe.kr/2/0/1473

이번에는 Socket I/O를 Stream으로 감싼 System.Net.Sockets.NetworkStream 차례입니다. 아래의 문서에 보면,

NetworkStream Class
; https://docs.microsoft.com/en-us/dotnet/api/system.net.sockets.networkstream

NetworkStream 역시 일반 BCL과 마찬가지의 thread-safety 정책이 걸려 있습니다.

Thread Safety: Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.


그래서 지난번 글과 동일하게 테스트를 해보았는데,

static void Main(string[] args)
{
    Thread.Sleep(2000);

    string body = string.Empty;
    StringBuilder sb = new StringBuilder();

    Array.ForEach(Enumerable.Range(0, 10).ToArray(), (elem) => body += elem.ToString());
    for (int i = 0; i < 10000; i++)
    {
        sb.Append(body);
    }

    body = sb.ToString();

    int loopCount = 10000;
    int dot = (loopCount / (80 * 25));

    List<CommonPacket> packets = new List<CommonPacket>();

    using (TcpClient socket = new TcpClient("192.168.0.6", 11200))
    {
        // IPAddress target = IPAddress.Loopback; 
        IPAddress target = IPAddress.Parse("192.168.0.6");
        EndPoint serverEP = new IPEndPoint(target, 11200);

        NetworkStream ns = socket.GetStream();
        int instanceId = 0;

        byte[] instanceIdBuf = BitConverter.GetBytes(instanceId);
        ns.Write(instanceIdBuf, 0, 4);

        for (int i = 0; i < loopCount; i++)
        {
            CommonPacket packet = new CommonPacket(i);
            packet.AddData(body);

            packets.Add(packet);
        }

        List<Thread> threads = new List<Thread>();
        ThreadParam threadParam = new ThreadParam();
        threadParam.Packets = packets;
        threadParam.NetStream = ns;
        threadParam.Dot = dot;

        for (int i = 0; i < 20; i++)
        {
            Thread aThread = new Thread(sendBufferThread);
            aThread.IsBackground = true;
            aThread.Start(threadParam);

            threads.Add(aThread);
        }

        foreach (var item in threads)
        {
            item.Join();
        }

        socket.Close();
        Console.WriteLine("TCP Client socket: Closed");
        Console.WriteLine(loopCount + " times: data sent");
        Console.WriteLine((body.Length / 1024) + "KB / packet");

        Console.WriteLine();
        Console.WriteLine();

        Console.WriteLine("Press any key to exit");
        Console.ReadLine();
    }
}

private static void sendBufferThread(object obj)
{
    ThreadParam threadParam = (ThreadParam)obj;

    while (true)
    {
        CommonPacket packet = null;

        lock (threadParam.Packets)
        {
            if (threadParam.Packets.Count == 0)
            {
                break;
            }

            packet = threadParam.Packets[0];
            threadParam.Packets.RemoveAt(0);
            threadParam.Sent++;

            if (threadParam.Sent % threadParam.Dot == 0)
            {
                Console.Write(".");
            }
        }

        byte[] dataBuf = packet.GetBuffer();
        MustSendBuffer(threadParam.NetStream, dataBuf, dataBuf.Length);
    }
}

private static bool MustSendBuffer(NetworkStream ns, byte[] dataBuf, int mustSend)
{
    ns.Write(dataBuf, 0, mustSend);
    return true;
}

결과는 thread-safe했습니다. 이상하군요. 그런대로 충돌이 날 만한데요. 이에 대해서는 NetworkStream.Write 메서드를 .NET Reflector를 통해 보면 짐작할 수 있습니다.

public override void Write(byte[] buffer, int offset, int size)
{
    bool canWrite = this.CanWrite;
    if (this.m_CleanedUp)
    {
        throw new ObjectDisposedException(base.GetType().FullName);
    }
    if (!canWrite)
    {
        throw new InvalidOperationException(SR.GetString("net_readonlystream"));
    }
    if (buffer == null)
    {
        throw new ArgumentNullException("buffer");
    }
    if ((offset < 0) || (offset > buffer.Length))
    {
        throw new ArgumentOutOfRangeException("offset");
    }
    if ((size < 0) || (size > (buffer.Length - offset)))
    {
        throw new ArgumentOutOfRangeException("size");
    }
    Socket streamSocket = this.m_StreamSocket;
    if (streamSocket == null)
    {
        throw new IOException(SR.GetString("net_io_writefailure", new object[] { SR.GetString("net_io_connectionclosed") }));
    }
    try
    {
        streamSocket.Send(buffer, offset, size, SocketFlags.None);
    }
    catch (Exception exception)
    {
        if (((exception is ThreadAbortException) || (exception is StackOverflowException)) || (exception is OutOfMemoryException))
        {
            throw;
        }
        throw new IOException(SR.GetString("net_io_writefailure", new object[] { exception.Message }), exception);
    }
}

보시는 바와 같이 Write(및 Read) 메서드 안에서 인스턴스 멤버에 대한 조작을 하는 코드가 없습니다. 하부 단의 "Socket streamSocket" 멤버는 Socket 자체가 thread-safe하기 때문에 상관없고!

물론 NetworkStream 타입의 멤버가 thread-safe하지 않다고 되어 있으므로 향후 내부적으로 인스턴스 멤버를 조작하는 코드가 추가되는 경우 오동작을 할 여지가 있습니다. 따라서, 성능에 크게 영향이 없다면 NetworkStream을 사용하는 경우에는 lock을 적절하게 걸어주는 것이 권장됩니다.

(첨부파일은 위의 동작을 테스트한 코드를 담고 있습니다.)




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







[최초 등록일: ]
[최종 수정일: 7/17/2021]

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

비밀번호

댓글 작성자
 




... [151]  152  153  154  155  156  157  158  159  160  161  162  163  164  165  ...
NoWriterDateCnt.TitleFile(s)
1320정성태7/30/201231059Math: 10. C# - (타)원 영역의 마우스 클릭 판단파일 다운로드1
1319정성태7/26/201229020개발 환경 구성: 159. Azure - 네트워크 포트 여는 방법 [1]
1317정성태7/24/201228295오류 유형: 159. SpeechRecognitionEngine.SetInputToDefaultAudioDevice 호출 시 System.InvalidOperationException 예외 발생
1316정성태7/18/201286782개발 환경 구성: 158. .NET 응용 프로그램에서 Oracle XE 11g 사용
1315정성태7/17/201231538개발 환경 구성: 157. Azure - Virtual Machine 구성 [2]
1314정성태7/16/201226039개발 환경 구성: 156. Azure - 2개 이상의 서비스 계정을 가지고 있을 때 프로젝트를 배포하는 방법
1313정성태7/16/201238625오류 유형: 158. Hyper-V 설치 후 VM 시작이 안되는 경우
1312정성태7/15/201238684Math: 9. 황금비율 증명
1311정성태7/15/201231095Math: 8. C# - 피보나치 수열의 사각형과 황금 나선(Golden spiral) 그리기파일 다운로드1
1310정성태7/13/201234451Math: 7. C# - 펜타그램(Pentagram) 그리기파일 다운로드1
1309정성태7/13/201232657개발 환경 구성: 155. 윈도우 운영체제에서 기본적으로 사용할 수 있는 압축 해제 방법
1308정성태7/3/201227945.NET Framework: 330. IEnumerator는 언제나 읽기 전용일까?파일 다운로드1
1307정성태6/30/201230467개발 환경 구성: 154. Sysnet, Azure를 만나다. [5]
1306정성태6/29/201230751제니퍼 .NET: 22. 눈으로 확인하는 connectionManagement의 maxconnection 설정값 [4]
1305정성태6/28/201229148오류 유형: 157. IIS 6 - WCF svc 호출 시 404 Not Found 발생
1304정성태6/27/201229965개발 환경 구성: 153. sysnet 첨부 파일을 Azure Storage에 마이그레이션 [3]파일 다운로드1
1303정성태6/26/201229587개발 환경 구성: 152. sysnet DB를 SQL Azure 데이터베이스로 마이그레이션
1302정성태6/25/201231563개발 환경 구성: 151. Azure 웹 사이트에 사용자 도메인 네임 연결하는 방법
1301정성태6/20/201227880오류 유형: 156. KB2667402 윈도우 업데이트 실패 및 마이크로소프트 Answers 웹 사이트 대응
1300정성태6/20/201234700.NET Framework: 329. C# - Rabin-Miller 소수 생성방법을 이용하여 RSACryptoServiceProvider의 개인키를 직접 채워보자 [1]파일 다운로드2
1299정성태6/18/201234999제니퍼 .NET: 21. 제니퍼 닷넷 - Ninject DI 프레임워크의 성능 분석 [2]파일 다운로드2
1298정성태6/14/201236602VS.NET IDE: 72. Visual Studio에서 pfx 파일로 서명한 경우, 암호는 어디에 저장될까? [2]
1297정성태6/12/201233112VC++: 63. 다른 프로세스에 환경 변수 설정하는 방법파일 다운로드1
1296정성태6/5/201229554.NET Framework: 328. 해당 DLL이 Managed인지 / Unmanaged인지 확인하는 방법 - 두 번째 이야기 [4]파일 다운로드1
1295정성태6/5/201226927.NET Framework: 327. RSAParameters와 System.Numerics.BigInteger 이야기파일 다운로드1
1294정성태5/27/201251410.NET Framework: 326. 유니코드와 한글 - 유니코드와 닷넷을 이용한 한글 처리 [7]파일 다운로드2
... [151]  152  153  154  155  156  157  158  159  160  161  162  163  164  165  ...