Microsoft MVP성태의 닷넷 이야기
VC++: 42. 쓰기 전용 파일(예: 로그 파일)의 동기화 방법 [링크 복사], [링크+제목 복사],
조회: 28245
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

쓰기 전용 파일(예: 로그 파일)의 동기화 방법

서문 필요 없이 바로 코드로 설명해보면, 보통 로그 파일을 쓰기 위한 코드는 아래와 같이 작성됩니다.

HANDLE hFile = ::CreateFile(filePath, GENERIC_WRITE, 0, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
if (hFile != INVALID_HANDLE_VALUE)
{
    ::SetFilePointerEx(hFile, ..., FILE_END);
    ::WriteFile(hFile, ...);
    CloseHandle(hFile); 
}

그런데, 스레드가 끼어들면 - 여러분들은 어떻게 하셨는지 모르겠지만 - 제 경우에는 다음과 같이 꼭!!! 언제나 스레드 동기화를 해주었습니다.

EnterCriticalSection(...);

HANDLE hFile = ::CreateFile(filePath, GENERIC_WRITE, 0, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
if (hFile != INVALID_HANDLE_VALUE)
{
    ...
}

LeaveCriticalSection(...);

만약 스레드가 아니라, 프로세스 간에 하나의 파일에 로그를 쓰려고 하는 경우가 발생하면 뮤텍스로 동기화를 해주었습니다.

WaitForSingleObject(mutexHandle,  INFINITE); 

HANDLE hFile = ::CreateFile(filePath, GENERIC_WRITE, 0, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
if (hFile != INVALID_HANDLE_VALUE)
{
    ...
}

ReleaseMutex(mutexHandle);

그런데,,, 동기화 작업은 쓸데없는 코드에 불과했습니다. 이유는? ^^




최근에 정말 재미있게 읽고 있는 책인데요.

IT EXPERT 윈도우 디바이스 드라이버 (저자 : 이봉석)
; http://www.yes24.com/24/goods/3219701

아주 재미있는 것을 하나 배웠습니다. 바로, ReadFile/WriteFile은 그 동작 자체에 이미 "직렬화" 과정이 포함되어 있다는 것입니다.

사실, 그동안 제가 생각 없이 살았던 것이지요. 어쩌면 굳이 저 책을 읽지 않았어도 '상식적'인 수준에서 평소에도 알 수 있었을 만한 것입니다. 왜냐하면, WriteFile 요청이 2개가 전달되었을 때 하드 디스크에 하나씩 전달되어 처리가 되는 것이 맞을 것입니다. 그렇지 않고, 첫 번째 WriteFile 요청으로 전달된 바이트 배열의 일부만을 디스크에 기록하다가 두 번째로 전달된 WriteFile 요청을 처리한다는 것은 '상식적'으로 맞지 않는 동작 방식입니다.

아하... 정말 그렇다면, "하나의 EXE 프로세스"에서 생성된 "다중 스레드"들은 굳이 CriticalSection을 사용할 필요도 없고, 핸들을 모든 스레드 간에 공유해도 전혀 문제가 안됩니다.


HANDLE g_hFile;
void Main()
{
    g_hFile = ::CreateFile(filePath, GENERIC_WRITE, 0, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
}

DWORD WINAPI ThreadFunc1(LPVOID lpParam) 
{
    WriteFile(g_hFile, ...);
    ...
}

그런데, 핸들을 공유하지 않고 매번 파일을 열고 닫는 식으로 사용해야 한다면 CriticalSection을 사용해야 합니다. 왜냐하면, "쓰기" 작업 전에 파일 포인터를 끝으로 옮겨야 하는 동작까지를 하나의 atomic 작업으로 묶어주어야 하기 때문입니다. 대신 임계영역을 묶어주는 범위가 줄어듭니다.

DWORD WINAPI ThreadFunc1(LPVOID lpParam) 
{
    HANDLE hFile = ::CreateFile(filePath, GENERIC_WRITE, FILE_SHARE_WRITE, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
    if (hFile != INVALID_HANDLE_VALUE)
    {
        ::EnterCriticalSection(&critic);

        ::SetFilePointerEx(hFile, ..., FILE_END);
        ::WriteFile(hFile, ...);

        ::LeaveCriticalSection(&critic);
        CloseHandle(hFile); 
    }
}

그런데, 더욱 깔끔한 방법이 있습니다. SetFilePointerEx 작업을 생략하기 위해 파일 자체를 append 모드로 열면 되는데, 다음과 같이 FILE_APPEND_DATA 플래그가 이런 경우에 사용됩니다.

DWORD WINAPI ThreadFunc1(LPVOID lpParam) 
{
    HANDLE hFile = ::CreateFile(filePath, FILE_APPEND_DATA,
        FILE_SHARE_WRITE, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
    if (hFile != INVALID_HANDLE_VALUE)
    {
        ::WriteFile(hFile, ...);
        CloseHandle(hFile); 
    }
}




자,,, 그럼 2개 이상의 프로세스에서 하나의 파일에 대해 로그 작업을 남기는 경우라면 어떻게 될까요? 이 경우에는 FILE_APPEND_DATA를 쓰느냐/안쓰느냐에 따라서 달라집니다. 안 쓰는 경우에는 SetFilePointer/WriteFile 단위를 Mutex로 묶어주어야 합니다.

하지만, FILE_APPEND_DATA를 사용하게 되면 Mutex가 필요하지 않습니다. 즉, 단일 프로세스에서 로그 작업을 하는 것과 동일하게 다중 프로세스에서도 코드를 그대로 사용할 수 있습니다.

그럼, 간단히 아래와 같이 정리되었군요.

  • 동기화 작업을 하지 말고,
  • FILE_APPEND_DATA 모드로 파일을 연다.

여기까지는, Win32 API를 직접 사용한 경우의 이야기이고, 그렇다면 .NET Framework에서는 어떻게 될까요?

아쉽게도, .NET에서는 FileStream의 생성자에 FILE_APPEND_DATA와 동일한 기능을 하는 옵션을 줄 수가 없습니다. 이 때문에, P/Invoke로 직접 Win32 API의 CreateFile로 파일 핸들을 생성하고 그것을 FileStream에 전달해 주어야 합니다.

SafeFileHandle fileHandle = CreateFile(filePath, NativeFileAccess.FILE_APPEND_DATA, 
                NativeFileShare.FILE_SHARE_READ | NativeFileShare.FILE_SHARE_WRITE, 
                IntPtr.Zero, NativeFileMode.OPEN_ALWAYS, 
                NativeFileFlag.FILE_ATTRIBUTE_NORMAL, IntPtr.Zero);

using (file = new FileStream(fileHandle, FileAccess.Write))
{
    file.Write( ... );
}

첨부한 파일에는 위의 Win32 API와 .NET을 테스트한 예제 프로젝트가 들어 있습니다.

----------------

* 이래서... 공부는 끝이 없는 것 같습니다. ^^ 사실 이 맛에 또 공부하고!

* SetFilePointer(hFile, 0, 0, FILE_END);는 4GB가 넘는 파일에 대해서 정상적으로 파일 끝을 가리키지 못합니다. 대용량 파일을 다뤄야 할 필요가 있는 경우에는 필히 SetFilePointerEx를 사용하십시오. ^^




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







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

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

비밀번호

댓글 작성자
 




... 61  62  63  64  [65]  66  67  68  69  70  71  72  73  74  75  ...
NoWriterDateCnt.TitleFile(s)
12314정성태9/7/202019959오류 유형: 645. IIS HTTPERR - Timer_MinBytesPerSecond, Timer_ConnectionIdle 로그
12313정성태9/6/202019450개발 환경 구성: 509. Logstash - 사용자 정의 grok 패턴 추가를 이용한 IIS 로그 처리
12312정성태9/5/202026416개발 환경 구성: 508. Logstash 기본 사용법 [2]
12311정성태9/4/202018964.NET Framework: 937. C# - 간단하게 만들어 보는 리눅스의 nc(netcat), json_pp 프로그램 [1]
12310정성태9/3/202018276오류 유형: 644. Windows could not start the Elasticsearch 7.9.0 (elasticsearch-service-x64) service on Local Computer.
12309정성태9/3/202017495개발 환경 구성: 507. Elasticsearch 6.6부터 기본 추가된 한글 형태소 분석기 노리(nori) 사용법
12308정성태9/2/202019355개발 환경 구성: 506. Windows - 단일 머신에서 단일 바이너리로 여러 개의 ElasticSearch 노드를 실행하는 방법
12307정성태9/2/202020232오류 유형: 643. curl - json_parse_exception / Invalid UTF-8 start byte
12306정성태9/1/202017492오류 유형: 642. SQL Server 시작 오류 - error code 10013
12305정성태9/1/202019342Windows: 172. "Administered port exclusions"이 아닌 포트 범위 항목을 삭제하는 방법
12304정성태8/31/202017755개발 환경 구성: 505. 윈도우 - (네트워크 어댑터의 우선순위로 인한) 열거되는 IP 주소 순서를 조정하는 방법
12303정성태8/30/202018057개발 환경 구성: 504. ETW - 닷넷 프레임워크 기반의 응용 프로그램을 위한 명령행 도구 etrace 소개
12302정성태8/30/202018237.NET Framework: 936. C# - ETW 관련 Win32 API 사용 예제 코드 (5) - Private Logger파일 다운로드1
12301정성태8/30/202017815오류 유형: 641. error MSB4044: The "Fody.WeavingTask" task was not given a value for the required parameter "IntermediateDir".
12300정성태8/29/202018108.NET Framework: 935. C# - ETW 관련 Win32 API 사용 예제 코드 (4) CLR ETW Consumer파일 다운로드1
12299정성태8/27/202018836.NET Framework: 934. C# - ETW 관련 Win32 API 사용 예제 코드 (3) ETW Consumer 구현파일 다운로드1
12298정성태8/27/202018348오류 유형: 640. livekd - Could not resolve symbols for ntoskrnl.exe: MmPfnDatabase
12297정성태8/25/202017825개발 환경 구성: 503. SHA256 테스트 인증서 생성 방법
12296정성태8/24/202018927.NET Framework: 933. C# - ETW 관련 Win32 API 사용 예제 코드 (2) NT Kernel Logger파일 다운로드1
12295정성태8/24/202017812오류 유형: 639. Bitvise - Address is already in use; bind() in ListeningSocket::StartListening() failed: Windows error 10013: An attempt was made to access a socket ,,,
12293정성태8/24/202018772Windows: 171. "Administered port exclusions" 설명
12292정성태8/20/202021766.NET Framework: 932. C# - ETW 관련 Win32 API 사용 예제 코드 (1)파일 다운로드2
12291정성태8/15/202018721오류 유형: 638. error 1297: Device driver does not install on any devices, use primitive driver if this is intended.
12290정성태8/11/202019922.NET Framework: 931. C# - IP 주소에 따른 국가별 위치 확인 [8]파일 다운로드1
12289정성태8/6/202016883개발 환경 구성: 502. Portainer에 윈도우 컨테이너를 등록하는 방법
12288정성태8/5/202016012오류 유형: 637. WCF - The protocol 'net.tcp' does not have an implementation of HostedTransportConfiguration type registered.
... 61  62  63  64  [65]  66  67  68  69  70  71  72  73  74  75  ...