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

C# - 값 형식(Blittable)을 메모리 복사를 이용해 바이트 배열로 직렬화/역직렬화

아래의 동영상을 보면,

고성능 데이터 직렬화 라이브러리 MemoryPack 소개 with 최흥배
; https://youtu.be/D2DSXJHoQJo

흥미로운 코드가 나오는데요, 바로 값 형식(좀 더 정확한 제약으로는 ref struct를 만족할 수 있는 타입)에 대한 직렬화/역직렬화하는 코드입니다.

// .NET 5부터 사용 가능
public static byte[] SerializeBlittable<T>(in T? value)
{
    if (!RuntimeHelpers.IsReferenceOrContainsReferences<T>())
    {
        var buffer = GC.AllocateUninitializedArray<byte>(Unsafe.SizeOf<T>());
        Unsafe.WriteUnaligned(ref MemoryMarshal.GetArrayDataReference(buffer), value);
        return buffer;
    }

    return Array.Empty<byte>();
}

private static void DeserializeBlittable<T>(byte[] buffer, out T value)
{
    if (!RuntimeHelpers.IsReferenceOrContainsReferences<T>())
    {
        value = Unsafe.ReadUnaligned<T>(ref MemoryMarshal.GetArrayDataReference(buffer));
        return;
    }

    value = default!;
}

사용은 대충 이렇게 할 수 있습니다.

{
    var value = new TestStruct { A = 1, B = 2 };
    var bytes = SerializeBlittable(value);
    Console.WriteLine(BitConverter.ToString(bytes)); // 출력 결과: 01-00-00-00-02-00-00-00

    value = new TestStruct { A = 0, B = 0 };
    DeserializeBlittable(bytes, out value);
    Console.WriteLine(value); // 출력 결과: A: 1, B: 2
}

internal struct TestStruct
{
    public int A { get; set; }
    public int B { get; set; }

    public override string ToString() => $"A: {A}, B: {B}";
}

별다른 직렬화 코드 없이 메모리 상태를 그대로 복사하는 것이기 때문에 고속일 수밖에 없습니다. MemoryPack 패키지가 괜히 빠른 게 아니겠지요. ^^

단지, 메모리 직렬화이기 때문에 Endian이 CPU를 따라간다는 점만 유의하시면 되겠습니다.




참고로, 위의 코드에서 AllocateUninitializedArray 메서드가 .NET 5부터 지원되고 있어 최소 런타임 기준으로 닷넷 5라고 주석을 단 것인데요, 사실 이런 코드를 예전에도 unsafe 구문과 섞어 사용할 수는 있었습니다.

// .NET Framework에서도 가능

public static byte[] SerializePtr<T>(T* pValue) where T : unmanaged
{
    int size = Marshal.SizeOf(*pValue);
    byte[] buffer = new byte[size];

    fixed (byte* pBuffer = buffer)
    {
        Buffer.MemoryCopy(pValue, pBuffer, size, size);
    }

    return buffer;
}

public static void DeserializePtr<T>(byte[] buffer, out T value) where T : unmanaged
{
    int size = Marshal.SizeOf<T>();
    fixed(T* pValue = &value)
    fixed (byte* pBuffer = buffer)
    {
        Buffer.MemoryCopy(pBuffer, pValue, size, size);
    }
}

사용 방법도 역시 별반 다르지 않습니다.

{
    var value = new TestStruct { A = 1, B = 2 };
    var bytes = SerializePtr(&value);
    Console.WriteLine(BitConverter.ToString(bytes)); // 출력 결과: 01-00-00-00-02-00-00-00

    value = new TestStruct { A = 0, B = 0 };
    DeserializePtr(bytes, out value);
    Console.WriteLine(value); // 출력 결과: A: 1, B: 2
}

가만 보면, 요즘 닷넷 런타임 변화의 트렌드 중 하나가 unsafe 예약어 사용이 필요 없는 방향으로 움직이는 듯합니다. 기존의 unsafe 사용은 잘 사용한다고 해도 어쨌든 managed 환경의 제어를 받지 못하므로, 최대한 관리 영역으로 끌어내 프로그램의 동작을 안정적으로 유지하려는 노력이 나름 기특한 것 같습니다. ^^

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





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







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

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)
12315정성태9/7/202019842개발 환경 구성: 510. Logstash - FileBeat을 이용한 IIS 로그 처리 [2]
12314정성태9/7/202020054오류 유형: 645. IIS HTTPERR - Timer_MinBytesPerSecond, Timer_ConnectionIdle 로그
12313정성태9/6/202019549개발 환경 구성: 509. Logstash - 사용자 정의 grok 패턴 추가를 이용한 IIS 로그 처리
12312정성태9/5/202026504개발 환경 구성: 508. Logstash 기본 사용법 [2]
12311정성태9/4/202019084.NET Framework: 937. C# - 간단하게 만들어 보는 리눅스의 nc(netcat), json_pp 프로그램 [1]
12310정성태9/3/202018398오류 유형: 644. Windows could not start the Elasticsearch 7.9.0 (elasticsearch-service-x64) service on Local Computer.
12309정성태9/3/202017583개발 환경 구성: 507. Elasticsearch 6.6부터 기본 추가된 한글 형태소 분석기 노리(nori) 사용법
12308정성태9/2/202019445개발 환경 구성: 506. Windows - 단일 머신에서 단일 바이너리로 여러 개의 ElasticSearch 노드를 실행하는 방법
12307정성태9/2/202020325오류 유형: 643. curl - json_parse_exception / Invalid UTF-8 start byte
12306정성태9/1/202017580오류 유형: 642. SQL Server 시작 오류 - error code 10013
12305정성태9/1/202019444Windows: 172. "Administered port exclusions"이 아닌 포트 범위 항목을 삭제하는 방법
12304정성태8/31/202017886개발 환경 구성: 505. 윈도우 - (네트워크 어댑터의 우선순위로 인한) 열거되는 IP 주소 순서를 조정하는 방법
12303정성태8/30/202018150개발 환경 구성: 504. ETW - 닷넷 프레임워크 기반의 응용 프로그램을 위한 명령행 도구 etrace 소개
12302정성태8/30/202018324.NET Framework: 936. C# - ETW 관련 Win32 API 사용 예제 코드 (5) - Private Logger파일 다운로드1
12301정성태8/30/202017864오류 유형: 641. error MSB4044: The "Fody.WeavingTask" task was not given a value for the required parameter "IntermediateDir".
12300정성태8/29/202018219.NET Framework: 935. C# - ETW 관련 Win32 API 사용 예제 코드 (4) CLR ETW Consumer파일 다운로드1
12299정성태8/27/202018863.NET Framework: 934. C# - ETW 관련 Win32 API 사용 예제 코드 (3) ETW Consumer 구현파일 다운로드1
12298정성태8/27/202018409오류 유형: 640. livekd - Could not resolve symbols for ntoskrnl.exe: MmPfnDatabase
12297정성태8/25/202017920개발 환경 구성: 503. SHA256 테스트 인증서 생성 방법
12296정성태8/24/202019079.NET Framework: 933. C# - ETW 관련 Win32 API 사용 예제 코드 (2) NT Kernel Logger파일 다운로드1
12295정성태8/24/202017921오류 유형: 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/202018868Windows: 171. "Administered port exclusions" 설명
12292정성태8/20/202021849.NET Framework: 932. C# - ETW 관련 Win32 API 사용 예제 코드 (1)파일 다운로드2
12291정성태8/15/202018773오류 유형: 638. error 1297: Device driver does not install on any devices, use primitive driver if this is intended.
12290정성태8/11/202020051.NET Framework: 931. C# - IP 주소에 따른 국가별 위치 확인 [8]파일 다운로드1
12289정성태8/6/202017000개발 환경 구성: 502. Portainer에 윈도우 컨테이너를 등록하는 방법
... 61  62  63  64  [65]  66  67  68  69  70  71  72  73  74  75  ...