COMMON Archives - 91 중 3 번째 페이지

[C#/COMMON] ConfigurationManager 클래스 : OpenMappedExeConfiguration 정적 메소드를 사용해 App.config 파일 로드하기

■ ConfigurationManager 클래스의 OpenMappedExeConfiguration 정적 메소드를 사용해 App.config 파일을 로드하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Configuration;
using System.IO;
using System.Reflection;

string executinDirectoryPath = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);

Configuration configuration =  ConfigurationManager.OpenMappedExeConfiguration
(
    new ExeConfigurationFileMap()
    {
        ExeConfigFilename = Path.Combine(executinDirectoryPath, "App.config")
    },
    ConfigurationUserLevel.None
);

Console.WriteLine(configuration.FilePath);

using System;

using System.Configuration;

using System.IO;

using System.Reflection;

string executinDirectoryPath = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);

Configuration configuration = ConfigurationManager.OpenMappedExeConfiguration

(

new ExeConfigurationFileMap()

{

ExeConfigFilename = Path.Combine(executinDirectoryPath, "App.config")

ConfigurationUserLevel.None

);

Console.WriteLine(configuration.FilePath);

[C#/COMMON/.NET6] JavaScriptEncoder 클래스 : Encode 메소드를 사용해 자바 스크립트 인코딩하기

■ JavaScriptEncoder 클래스의 Encode 메소드를 사용해 자바 스크립트를 인코딩하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System.Text.Encodings.Web;

string source = @"function test(a, b)
{
    return a + b;
}
";

string target = JavaScriptEncoder.Default.Encode(source);

Console.WriteLine(target);

// function test(a, b)\r\n{\r\n    return a \u002B b;\r\n}\r\n

using System.Text.Encodings.Web;

string source = @"function test(a, b)

{

return a + b;

}

string target = JavaScriptEncoder.Default.Encode(source);

Console.WriteLine(target);

// function test(a, b)\r\n{\r\n return a \u002B b;\r\n}\r\n

[C#/COMMON/.NET6] 콘솔 폰트 설정하기

■ 콘솔 폰트를 설정하는 방법을 보여준다. ▶ FontInfo.cs


using System.Runtime.InteropServices;

namespace TestProject;

/// <summary>
/// 폰트 정보
/// </summary>
[StructLayout(LayoutKind.Sequential, CharSet = CharSet.Unicode)]
public struct FontInfo
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Field
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region Field

    /// <summary>
    /// 크기
    /// </summary>
    public int Size;

    /// <summary>
    /// 폰트 인덱스
    /// </summary>
    public int FontIndex;

    /// <summary>
    /// 폰트 너비
    /// </summary>
    public short FontWidth;

    /// <summary>
    /// 폰트 크기
    /// </summary>
    public short FontSize;

    /// <summary>
    /// 폰트 패밀리
    /// </summary>
    public int FontFamily;

    /// <summary>
    /// 폰트 가중치
    /// </summary>
    public int FontWeight;

    /// <summary>
    /// 폰트명
    /// </summary>
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 32)]
    public string FontName;

    #endregion
}

using System.Runtime.InteropServices;

namespace TestProject;

/// <summary>

/// 폰트 정보

/// </summary>

[StructLayout(LayoutKind.Sequential, CharSet = CharSet.Unicode)]

public struct FontInfo

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Public

#region Field

/// <summary>

/// 크기

/// </summary>

public int Size;

/// <summary>

/// 폰트 인덱스

/// </summary>

public int FontIndex;

/// <summary>

/// 폰트 너비

/// </summary>

public short FontWidth;

/// <summary>

/// 폰트 크기

/// </summary>

public short FontSize;

/// <summary>

/// 폰트 패밀리

/// </summary>

public int FontFamily;

/// <summary>

/// 폰트 가중치

/// </summary>

public int FontWeight;

/// <summary>

/// 폰트명

/// </summary>

[MarshalAs(UnmanagedType.ByValTStr, SizeConst = 32)]

public string FontName;

#endregion

}

▶ ConsoleHelper.cs


using System.ComponentModel;
using System.Runtime.InteropServices;

namespace TestProject;

/// <summary>
/// 콘솔 헬퍼
/// </summary>
public static class ConsoleHelper
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 표준 장치 핸들 구하기 - GetStdHandle(standardDevice)

    /// <summary>
    /// 표준 장치 핸들 구하기
    /// </summary>
    /// <param name="standardDevice">표준 장치</param>
    /// <returns>표준 장치 핸들</returns>
    [DllImport("kernel32", SetLastError = true)]
    private static extern IntPtr GetStdHandle(int standardDevice);

    #endregion
    #region 현재 콘솔 폰트 설정하기 (확장) - SetCurrentConsoleFontEx(consoleOutputHandle, maximumWindow, fontInfo)

    /// <summary>
    /// 현재 콘솔 폰트 설정하기 (확장)
    /// </summary>
    /// <param name="consoleOutputHandle">콘솔 출력 핸들</param>
    /// <param name="maximumWindow">최대 윈도우 여부</param>
    /// <param name="fontInfo">폰트 정보</param>
    /// <returns>처리 결과</returns>
    [return: MarshalAs(UnmanagedType.Bool)]
    [DllImport("kernel32", SetLastError = true, CharSet = CharSet.Unicode)]
    private static extern bool SetCurrentConsoleFontEx(IntPtr consoleOutputHandle, bool maximumWindow, ref FontInfo fontInfo);

    #endregion
    #region 현재 콘솔 폰트 구하기 (확장) - GetCurrentConsoleFontEx(consoleOutputHandle, maximumWindow, fontInfo)

    /// <summary>
    /// 현재 콘솔 폰트 구하기 (확장)
    /// </summary>
    /// <param name="consoleOutputHandle">콘솔 출력 핸들</param>
    /// <param name="maximumWindow">최대 윈도우 여부</param>
    /// <param name="fontInfo">폰트 정보</param>
    /// <returns>처리 결과</returns>
    [return: MarshalAs(UnmanagedType.Bool)]
    [DllImport("kernel32", SetLastError = true, CharSet = CharSet.Unicode)]
    private static extern bool GetCurrentConsoleFontEx(IntPtr consoleOutputHandle, bool maximumWindow, ref FontInfo fontInfo);

    #endregion

    //////////////////////////////////////////////////////////////////////////////////////////////////// Field
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region Field

    /// <summary>
    /// 콘솔 출력 핸들
    /// </summary>
    private static readonly IntPtr _consoleOutputHandle = GetStdHandle(STANDARD_OUTPUT_HANDLE);

    #endregion

    ////////////////////////////////////////////////////////////////////////////////////////// Instance
    //////////////////////////////////////////////////////////////////////////////// Private

    #region Field

    /// <summary>
    /// FIXED_WIDTH_TRUE_TYPE
    /// </summary>
    private const int FIXED_WIDTH_TRUE_TYPE = 54;

    /// <summary>
    /// STANDARD_OUTPUT_HANDLE
    /// </summary>
    private const int STANDARD_OUTPUT_HANDLE = -11;

    #endregion

    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Public

    #region 현재 폰트 설정하기 - SetCurrentFont(fontName, fontSize)

    /// <summary>
    /// 현재 폰트 설정하기
    /// </summary>
    /// <param name="fontName">폰트명</param>
    /// <param name="fontSize">폰트 크기</param>
    /// <returns>폰트 정보 배열</returns>
    public static FontInfo[] SetCurrentFont(string fontName, short fontSize = 0)
    {
        FontInfo currentFontInfo = new FontInfo { Size = Marshal.SizeOf<FontInfo>() };

        if(GetCurrentConsoleFontEx(_consoleOutputHandle, false, ref currentFontInfo))
        {
            FontInfo fontInfo = new FontInfo
            {
                Size       = Marshal.SizeOf<FontInfo>(),
                FontIndex  = 0,
                FontFamily = FIXED_WIDTH_TRUE_TYPE,
                FontName   = fontName,
                FontWeight = 400,
                FontSize   = fontSize > 0 ? fontSize : currentFontInfo.FontSize
            };

            if(!SetCurrentConsoleFontEx(_consoleOutputHandle, false, ref fontInfo))
            {
                int error = Marshal.GetLastWin32Error();

                throw new Win32Exception(error);
            }

            FontInfo fontInfoUpdated = new FontInfo { Size = Marshal.SizeOf<FontInfo>() };

            GetCurrentConsoleFontEx(_consoleOutputHandle, false, ref fontInfoUpdated);

            return new FontInfo[]
            {
                currentFontInfo,
                fontInfo,
                fontInfoUpdated
            };
        }
        else
        {
            int error = Marshal.GetLastWin32Error();

            throw new Win32Exception(error);
        }
    }

    #endregion
    #region 현재 폰트 정보 구하기 - GetCurrentFontInfo()

    /// <summary>
    /// 현재 폰트 정보 구하기
    /// </summary>
    /// <returns>현재 폰트 정보</returns>
    public static FontInfo GetCurrentFontInfo()
    {
        FontInfo fontInfo = new FontInfo
        {
            Size = Marshal.SizeOf<FontInfo>()
        };

        if(!GetCurrentConsoleFontEx(_consoleOutputHandle, false, ref fontInfo))
        {
            int error = Marshal.GetLastWin32Error();

            throw new Win32Exception(error);
        }

        return fontInfo;
    }

    #endregion
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

using System.ComponentModel;

using System.Runtime.InteropServices;

namespace TestProject;

/// <summary>

/// 콘솔 헬퍼

/// </summary>

public static class ConsoleHelper

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 표준 장치 핸들 구하기 - GetStdHandle(standardDevice)

/// <summary>

/// 표준 장치 핸들 구하기

/// </summary>

/// <param name="standardDevice">표준 장치</param>

/// <returns>표준 장치 핸들</returns>

[DllImport("kernel32", SetLastError = true)]

private static extern IntPtr GetStdHandle(int standardDevice);

#endregion

#region 현재 콘솔 폰트 설정하기 (확장) - SetCurrentConsoleFontEx(consoleOutputHandle, maximumWindow, fontInfo)

/// <summary>

/// 현재 콘솔 폰트 설정하기 (확장)

/// </summary>

/// <param name="consoleOutputHandle">콘솔 출력 핸들</param>

/// <param name="maximumWindow">최대 윈도우 여부</param>

/// <param name="fontInfo">폰트 정보</param>

/// <returns>처리 결과</returns>

[return: MarshalAs(UnmanagedType.Bool)]

[DllImport("kernel32", SetLastError = true, CharSet = CharSet.Unicode)]

private static extern bool SetCurrentConsoleFontEx(IntPtr consoleOutputHandle, bool maximumWindow, ref FontInfo fontInfo);

#endregion

#region 현재 콘솔 폰트 구하기 (확장) - GetCurrentConsoleFontEx(consoleOutputHandle, maximumWindow, fontInfo)

/// <summary>

/// 현재 콘솔 폰트 구하기 (확장)

/// </summary>

/// <param name="consoleOutputHandle">콘솔 출력 핸들</param>

/// <param name="maximumWindow">최대 윈도우 여부</param>

/// <param name="fontInfo">폰트 정보</param>

/// <returns>처리 결과</returns>

[return: MarshalAs(UnmanagedType.Bool)]

[DllImport("kernel32", SetLastError = true, CharSet = CharSet.Unicode)]

private static extern bool GetCurrentConsoleFontEx(IntPtr consoleOutputHandle, bool maximumWindow, ref FontInfo fontInfo);

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// 콘솔 출력 핸들

/// </summary>

private static readonly IntPtr _consoleOutputHandle = GetStdHandle(STANDARD_OUTPUT_HANDLE);

#endregion

////////////////////////////////////////////////////////////////////////////////////////// Instance

//////////////////////////////////////////////////////////////////////////////// Private

#region Field

/// <summary>

/// FIXED_WIDTH_TRUE_TYPE

/// </summary>

private const int FIXED_WIDTH_TRUE_TYPE = 54;

/// <summary>

/// STANDARD_OUTPUT_HANDLE

/// </summary>

private const int STANDARD_OUTPUT_HANDLE = -11;

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region 현재 폰트 설정하기 - SetCurrentFont(fontName, fontSize)

/// <summary>

/// 현재 폰트 설정하기

/// </summary>

/// <param name="fontName">폰트명</param>

/// <param name="fontSize">폰트 크기</param>

/// <returns>폰트 정보 배열</returns>

public static FontInfo[] SetCurrentFont(string fontName, short fontSize = 0)

{

FontInfo currentFontInfo = new FontInfo { Size = Marshal.SizeOf<FontInfo>() };

if(GetCurrentConsoleFontEx(_consoleOutputHandle, false, ref currentFontInfo))

{

FontInfo fontInfo = new FontInfo

{

Size = Marshal.SizeOf<FontInfo>(),

FontIndex = 0,

FontFamily = FIXED_WIDTH_TRUE_TYPE,

FontName = fontName,

FontWeight = 400,

FontSize = fontSize > 0 ? fontSize : currentFontInfo.FontSize

};

if(!SetCurrentConsoleFontEx(_consoleOutputHandle, false, ref fontInfo))

{

int error = Marshal.GetLastWin32Error();

throw new Win32Exception(error);

}

FontInfo fontInfoUpdated = new FontInfo { Size = Marshal.SizeOf<FontInfo>() };

GetCurrentConsoleFontEx(_consoleOutputHandle, false, ref fontInfoUpdated);

return new FontInfo[]

{

currentFontInfo,

fontInfo,

fontInfoUpdated

};

}

else

{

int error = Marshal.GetLastWin32Error();

throw new Win32Exception(error);

}

#endregion

#region 현재 폰트 정보 구하기 - GetCurrentFontInfo()

/// <summary>

/// 현재 폰트 정보 구하기

/// </summary>

/// <returns>현재 폰트 정보</returns>

public static FontInfo GetCurrentFontInfo()

{

FontInfo fontInfo = new FontInfo

{

Size = Marshal.SizeOf<FontInfo>()

};

if(!GetCurrentConsoleFontEx(_consoleOutputHandle, false, ref fontInfo))

{

int error = Marshal.GetLastWin32Error();

throw new Win32Exception(error);

}

return fontInfo;

}

#endregion

}

▶ Program.cs


namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        FontInfo fontInfo = ConsoleHelper.GetCurrentFontInfo();

        Console.WriteLine($"{fontInfo.FontName} : {fontInfo.FontSize}");

        ConsoleHelper.SetCurrentFont("궁서", 16);

        Console.WriteLine();
        Console.WriteLine("가나다라마바사아자차카타파하");
        Console.WriteLine("가나다라마바사아자차카타파하");
        Console.WriteLine("가나다라마바사아자차카타파하");
    }

    #endregion
}

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

FontInfo fontInfo = ConsoleHelper.GetCurrentFontInfo();

Console.WriteLine($"{fontInfo.FontName} : {fontInfo.FontSize}");

ConsoleHelper.SetCurrentFont("궁서", 16);

Console.WriteLine();

Console.WriteLine("가나다라마바사아자차카타파하");

}

#endregion

}

TestProject.zip

[C#/COMMON/AVROCONVERT/.NET6] AvroConvert 클래스 : Avro2Json 정적 메소드를 사용해 JSON 문자열로 역직렬화하기

■ AvroConvert 클래스의 Avro2Json 정적 메소드를 사용해 JSON 문자열로 역직렬화하는 방법을 보여준다. ▶ Employee.cs


namespace TestProject;

/// <summary>
/// 직원
/// </summary>
public class Employee
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    public int ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    public string Name { get; set; }

    #endregion
}

namespace TestProject;

/// <summary>

/// 직원

/// </summary>

public class Employee

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public int ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

public string Name { get; set; }

#endregion

}

▶ Program.cs


using SolTechnology.Avro;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        List<Employee> sourceList = new List<Employee>();

        for(int i = 0; i < 100; i++)
        {
            sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });
        }

        byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

        Console.WriteLine("직렬화 데이터");
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine(Convert.ToBase64String(sourceByteArray));
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine();

        Console.WriteLine("JSON 문자열");
        Console.WriteLine("--------------------------------------------------");

        string json = AvroConvert.Avro2Json(sourceByteArray);

        Console.WriteLine(json);

        Console.WriteLine("--------------------------------------------------");
    }

    #endregion
}

using SolTechnology.Avro;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

List<Employee> sourceList = new List<Employee>();

for(int i = 0; i < 100; i++)

{

sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });

}

byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

Console.WriteLine("직렬화 데이터");

Console.WriteLine("--------------------------------------------------");

Console.WriteLine(Convert.ToBase64String(sourceByteArray));

Console.WriteLine("--------------------------------------------------");

Console.WriteLine();

Console.WriteLine("JSON 문자열");

Console.WriteLine("--------------------------------------------------");

string json = AvroConvert.Avro2Json(sourceByteArray);

Console.WriteLine(json);

Console.WriteLine("--------------------------------------------------");

}

#endregion

}

TestProject.zip

[C#/COMMON/AVROCONVERT/.NET6] AvroConvert 클래스 : GenerateModel 정적 메소드를 사용해 모델 소스 코드 생성하기

■ AvroConvert 클래스의 GenerateModel 정적 메소드를 사용해 모델 소스 코드를 생성하는 방법을 보여준다. ▶ Employee.cs


namespace TestProject;

/// <summary>
/// 직원
/// </summary>
public class Employee
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    public int ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    public string Name { get; set; }

    #endregion
}

namespace TestProject;

/// <summary>

/// 직원

/// </summary>

public class Employee

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public int ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

public string Name { get; set; }

#endregion

}

▶ Program.cs


using SolTechnology.Avro;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        List<Employee> sourceList = new List<Employee>();

        for(int i = 0; i < 100; i++)
        {
            sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });
        }

        byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

        Console.WriteLine("직렬화 데이터");
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine(Convert.ToBase64String(sourceByteArray));
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine();

        Console.WriteLine("모델 생성");
        Console.WriteLine("--------------------------------------------------");

        string modelSourceCode = AvroConvert.GenerateModel(sourceByteArray);

        Console.WriteLine(modelSourceCode);

        Console.WriteLine("--------------------------------------------------");
    }

    #endregion
}

using SolTechnology.Avro;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

List<Employee> sourceList = new List<Employee>();

for(int i = 0; i < 100; i++)

{

sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });

}

byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

Console.WriteLine("직렬화 데이터");

Console.WriteLine("--------------------------------------------------");

Console.WriteLine(Convert.ToBase64String(sourceByteArray));

Console.WriteLine("--------------------------------------------------");

Console.WriteLine();

Console.WriteLine("모델 생성");

Console.WriteLine("--------------------------------------------------");

string modelSourceCode = AvroConvert.GenerateModel(sourceByteArray);

Console.WriteLine(modelSourceCode);

Console.WriteLine("--------------------------------------------------");

}

#endregion

}

유튜브 업로드 파일

[C#/COMMON/AVROCONVERT/.NET6] AvroConvert 클래스 : OpenDeserializer 정적 메소드를 사용해 데이터 컬렉션에서 데이터를 순차 역직렬화하기

■ AvroConvert 클래스의 OpenDeserializer 정적 메소드를 사용해 데이터 컬렉션에서 데이터를 순차 역직렬화하는 방법을 보여준다. ▶ Employee.cs


namespace TestProject;

/// <summary>
/// 직원
/// </summary>
public class Employee
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    public int ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    public string Name { get; set; }

    #endregion
}

namespace TestProject;

/// <summary>

/// 직원

/// </summary>

public class Employee

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public int ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

public string Name { get; set; }

#endregion

}

▶ Program.cs —————————————————————————————————- using SolTechnology.Avro;

[C#/COMMON/AVROCONVERT/.NET6] AvroConvert 클래스 : GetSchema 정적 메소드를 직렬화 데이터 스키마 구하기

■ AvroConvert 클래스의 GetSchema 정적 메소드를 직렬화 데이터의 스키마를 구하는 방법을 보여준다. ▶ Student.cs


namespace TestProject;

/// <summary>
/// 직원
/// </summary>
public class Employee
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    public int ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    public string Name { get; set; }

    #endregion
}

namespace TestProject;

/// <summary>

/// 직원

/// </summary>

public class Employee

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public int ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

public string Name { get; set; }

#endregion

}

▶ Program.cs


using SolTechnology.Avro;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        List<Employee> sourceList = new List<Employee>();

        for(int i = 0; i < 100; i++)
        {
            sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });
        }

        byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

        Console.WriteLine("직렬화 데이터");
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine(Convert.ToBase64String(sourceByteArray));
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine();

        string schema = AvroConvert.GetSchema(sourceByteArray);

        Console.WriteLine("스키마");
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine(schema);
        Console.WriteLine("--------------------------------------------------");
    }

    #endregion
}

using SolTechnology.Avro;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

List<Employee> sourceList = new List<Employee>();

for(int i = 0; i < 100; i++)

{

sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });

}

byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

Console.WriteLine("직렬화 데이터");

Console.WriteLine("--------------------------------------------------");

Console.WriteLine(Convert.ToBase64String(sourceByteArray));

Console.WriteLine("--------------------------------------------------");

Console.WriteLine();

string schema = AvroConvert.GetSchema(sourceByteArray);

Console.WriteLine("스키마");

Console.WriteLine("--------------------------------------------------");

Console.WriteLine(schema);

Console.WriteLine("--------------------------------------------------");

}

#endregion

}

TestProject.zip

[C#/COMMON/AVROCONVERT/.NET6] AvroConvert 클래스 : Serialize/Deserialize 정적 메소드를 사용해 데이터 직렬화/역직렬화하기

■ AvroConvert 클래스의 Serialize/Deserialize 정적 메소드를 사용해 데이터를 직렬화/역직렬화하는 방법을 보여준다. ▶ Employee.cs


namespace TestProject;

/// <summary>
/// 직원
/// </summary>
public class Employee
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    public int ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    public string Name { get; set; }

    #endregion
}

namespace TestProject;

/// <summary>

/// 직원

/// </summary>

public class Employee

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public int ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

public string Name { get; set; }

#endregion

}

▶ Program.cs


using SolTechnology.Avro;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        List<Employee> sourceList = new List<Employee>();

        for(int i = 0; i < 100; i++)
        {
            sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });
        }

        byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

        Console.WriteLine("직렬화 데이터");
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine(Convert.ToBase64String(sourceByteArray));
        Console.WriteLine("--------------------------------------------------");
        Console.WriteLine();

        List<Employee> targetList = AvroConvert.Deserialize<List<Employee>>(sourceByteArray);

        Console.WriteLine("역직렬화 데이터");
        Console.WriteLine("--------------------------------------------------");

        for(int i = 0; i < 100; i++)
        {
            Employee employee = targetList[i];

            Console.WriteLine($"{employee.ID}, {employee.Name}");
        }

        Console.WriteLine("--------------------------------------------------");
    }

    #endregion
}

using SolTechnology.Avro;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

List<Employee> sourceList = new List<Employee>();

for(int i = 0; i < 100; i++)

{

sourceList.Add(new Employee { ID= i + 1, Name = $"직원{i + 1:d3}" });

}

byte[] sourceByteArray = AvroConvert.Serialize(sourceList);

Console.WriteLine("직렬화 데이터");

Console.WriteLine("--------------------------------------------------");

Console.WriteLine(Convert.ToBase64String(sourceByteArray));

Console.WriteLine("--------------------------------------------------");

Console.WriteLine();

List<Employee> targetList = AvroConvert.Deserialize<List<Employee>>(sourceByteArray);

Console.WriteLine("역직렬화 데이터");

Console.WriteLine("--------------------------------------------------");

for(int i = 0; i < 100; i++)

{

Employee employee = targetList[i];

Console.WriteLine($"{employee.ID}, {employee.Name}");

}

Console.WriteLine("--------------------------------------------------");

}

#endregion

}

TestProject.zip

[C#/COMMON/AVROCONVERT/.NET6] AvroConvert 누겟 설치하기

■ AvroConvert 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.

[C#/COMMON/.NET6] OperatingSystem 클래스 : 운영체제명 구하기

■ OperatingSystem 클래스를 사용해 운영체제명을 구하는 방법을 보여준다. ▶ Program.cs


namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 운영체제명 구하기 - GetOperatingSystemName(platformID, majorVersion, minorVersion)

    /// <summary>
    /// 운영체제명 구하기
    /// </summary>
    /// <param name="platformID">플랫폼 ID</param>
    /// <param name="majorVersion">메이저 버전</param>
    /// <param name="minorVersion">마이너 버전</param>
    /// <returns>운영체제명</returns>
    private static string GetOperatingSystemName(PlatformID platformID, int majorVersion, int minorVersion)
    {
        if(platformID == PlatformID.Win32NT)
        {
            if(majorVersion == 4)
            {
                if(minorVersion == 0)
                {
                    return "Windows NT 4.0";
                }
            }
            else if(majorVersion == 5)
            {
                if(minorVersion == 0)
                {
                    return "Windows 2000";
                }
                else if(minorVersion == 1)
                {
                    return "Windows XP";
                }
            }
            else if(majorVersion == 6)
            {
                if(minorVersion == 0)
                {
                    return "Windows Vista";
                }
                else if(minorVersion == 1)
                {
                    return "Windows 7";
                }
                else if(minorVersion == 2)
                {
                    return "Windows 8";
                }
                else if(minorVersion == 3)
                {
                    return "Windows 8.1";
                }
            }
            else if(majorVersion == 10)
            {
                if(minorVersion == 0)
                {
                    return "Windows 10";
                }
            }
        }

        return null;
    }

    #endregion
    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        OperatingSystem operatingSystem = Environment.OSVersion;

        PlatformID platformID   = operatingSystem.Platform;
        int        majorVersion = operatingSystem.Version.Major;
        int        minorVersion = operatingSystem.Version.Minor;

        Console.WriteLine($"플랫폼 ID   : {platformID  }");
        Console.WriteLine($"메이저 버전 : {majorVersion}");
        Console.WriteLine($"마이너 버전 : {minorVersion}");
        Console.WriteLine($"운영체제명  : {GetOperatingSystemName(platformID, majorVersion, minorVersion)}");
    }

    #endregion
}

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 운영체제명 구하기 - GetOperatingSystemName(platformID, majorVersion, minorVersion)

/// <summary>

/// 운영체제명 구하기

/// </summary>

/// <param name="platformID">플랫폼 ID</param>

/// <param name="majorVersion">메이저 버전</param>

/// <param name="minorVersion">마이너 버전</param>

/// <returns>운영체제명</returns>

private static string GetOperatingSystemName(PlatformID platformID, int majorVersion, int minorVersion)

{

if(platformID == PlatformID.Win32NT)

{

if(majorVersion == 4)

{

if(minorVersion == 0)

{

return "Windows NT 4.0";

}

else if(majorVersion == 5)

{

if(minorVersion == 0)

{

return "Windows 2000";

}

else if(minorVersion == 1)

{

return "Windows XP";

}

else if(majorVersion == 6)

{

if(minorVersion == 0)

{

return "Windows Vista";

}

else if(minorVersion == 1)

{

return "Windows 7";

}

else if(minorVersion == 2)

{

return "Windows 8";

}

else if(minorVersion == 3)

{

return "Windows 8.1";

}

else if(majorVersion == 10)

{

if(minorVersion == 0)

{

return "Windows 10";

}

return null;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

OperatingSystem operatingSystem = Environment.OSVersion;

PlatformID platformID = operatingSystem.Platform;

int majorVersion = operatingSystem.Version.Major;

int minorVersion = operatingSystem.Version.Minor;

Console.WriteLine($"플랫폼 ID : {platformID }");

Console.WriteLine($"메이저 버전 : {majorVersion}");

Console.WriteLine($"마이너 버전 : {minorVersion}");

Console.WriteLine($"운영체제명 : {GetOperatingSystemName(platformID, majorVersion, minorVersion)}");

}

#endregion

}

TestProject.zip

[C#/COMMON/.NET6] IDataReader 인터페이스 : 레코드를 객체로 변환하기

■ IDataReader 인터페이스에서 레코드를 객체로 변환하는 방법을 보여준다. ▶ Sample.cs


namespace TestProject
{
    /// <summary>
    /// 샘플
    /// </summary>
    public class Sample
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region ID - ID

        /// <summary>
        /// ID
        /// </summary>
        public long ID { get; set; }

        #endregion
        #region 성명 - Name

        /// <summary>
        /// 성명
        /// </summary>
        public string Name { get; set; }

        #endregion
        #region 점수 - Score

        /// <summary>
        /// 점수
        /// </summary>
        public long Score { get; set; }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 문자열 구하기 - ToString()

        /// <summary>
        /// 문자열 구하기
        /// </summary>
        /// <returns>문자열</returns>
        public override string ToString()
        {
            return $"ID={ID}|성명={Name}|점수={Score}";
        }

        #endregion
    }
}

namespace TestProject

{

/// <summary>

/// 샘플

/// </summary>

public class Sample

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

public long ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

public string Name { get; set; }

#endregion

#region 점수 - Score

/// <summary>

/// 점수

/// </summary>

public long Score { get; set; }

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 문자열 구하기 - ToString()

/// <summary>

/// 문자열 구하기

/// </summary>

/// <returns>문자열</returns>

public override string ToString()

{

return $"ID={ID}|성명={Name}|점수={Score}";

}

#endregion

}

▶ Program.cs


using System.Data;
using System.Data.SQLite;
using System.Reflection;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 리스트 구하기 - GetList<TData>(reader)

    /// <summary>
    /// 리스트 구하기
    /// </summary>
    /// <typeparam name="TData">데이터 타입</typeparam>
    /// <param name="reader">데이터 리더</param>
    /// <returns>리스트</returns>
    private static List<TData> GetList<TData>(IDataReader reader) where TData : new()
    {
        List<TData> list = new List<TData>();

        while(reader.Read())
        {
            TData data = new TData();

            for(int i = 0; i < reader.FieldCount; i++)
            {
                string fieldName = reader.GetName(i);

                object value = reader.GetValue(i);

                PropertyInfo propertyInfo = data.GetType().GetProperty(fieldName);

                if(propertyInfo != null && value != DBNull.Value)
                {
                    propertyInfo.SetValue(data, value);
                }
            }

            list.Add(data);
        }

        return list;
    }

    #endregion
    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        string connectionString = "URI=file:test.db";

        using(SQLiteConnection connection = new SQLiteConnection(connectionString))
        {
            connection.Open();

            SQLiteCommand command = new SQLiteCommand();

            command.Connection  = connection;
            command.CommandType = CommandType.Text;
            command.CommandText = "SELECT * FROM Sample";

            using(SQLiteDataReader reader = command.ExecuteReader())
            {
                List<Sample> sampleList = GetList<Sample>(reader);

                foreach(Sample sample in sampleList)
                {
                    Console.WriteLine(sample);
                }
            }
        }
    }

    #endregion
}

using System.Data;

using System.Data.SQLite;

using System.Reflection;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 리스트 구하기 - GetList<TData>(reader)

/// <summary>

/// 리스트 구하기

/// </summary>

/// <typeparam name="TData">데이터 타입</typeparam>

/// <param name="reader">데이터 리더</param>

/// <returns>리스트</returns>

private static List<TData> GetList<TData>(IDataReader reader) where TData : new()

{

List<TData> list = new List<TData>();

while(reader.Read())

{

TData data = new TData();

for(int i = 0; i < reader.FieldCount; i++)

{

string fieldName = reader.GetName(i);

object value = reader.GetValue(i);

PropertyInfo propertyInfo = data.GetType().GetProperty(fieldName);

if(propertyInfo != null && value != DBNull.Value)

{

propertyInfo.SetValue(data, value);

}

list.Add(data);

}

return list;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

string connectionString = "URI=file:test.db";

using(SQLiteConnection connection = new SQLiteConnection(connectionString))

{

connection.Open();

SQLiteCommand command = new SQLiteCommand();

command.Connection = connection;

command.CommandType = CommandType.Text;

command.CommandText = "SELECT * FROM Sample";

using(SQLiteDataReader reader = command.ExecuteReader())

{

List<Sample> sampleList = GetList<Sample>(reader);

foreach(Sample sample in sampleList)

{

Console.WriteLine(sample);

}

#endregion

}

TestProject.zip

[C#/COMMON/.NET6] ArraySegment 구조체 : 배열 참조하기

■ ArraySegment 구조체를 사용해 배열을 참조하는 방법을 보여준다. ▶ Program.cs


namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        int[] valueArray = { 10, 20, 30, 40, 50 };

        ArraySegment<int> valueArraySegment = new ArraySegment<int>(valueArray, 1, 3);

        valueArraySegment[0] = 25;

        foreach(int value in valueArraySegment)
        {
            Console.WriteLine(value);
        }
    }

    #endregion
}

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

int[] valueArray = { 10, 20, 30, 40, 50 };

ArraySegment<int> valueArraySegment = new ArraySegment<int>(valueArray, 1, 3);

valueArraySegment[0] = 25;

foreach(int value in valueArraySegment)

{

Console.WriteLine(value);

}

#endregion

}

TestProject.zip

[C#/COMMON/CSVHELPER/.NET6] CsvWriter 클래스 : WriteRecords 메소드를 사용해 CSV 파일에 데이터 추가하기

■ CsvWriter 클래스의 WriteRecords 메소드를 사용해 CSV 파일에 데이터를 추가하는 방법을 보여준다. ▶ Student.cs


using CsvHelper.Configuration.Attributes;

namespace TestProject;

/// <summary>
/// 학생
/// </summary>
public class Student
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    [Name("ID")]
    public string ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    [Name("성명")]
    public string Name { get; set; }

    #endregion
    #region 점수 - Score

    /// <summary>
    /// 점수
    /// </summary>
    [Name("점수")]
    public int Score { get; set; }

    #endregion
}

using CsvHelper.Configuration.Attributes;

namespace TestProject;

/// <summary>

/// 학생

/// </summary>

public class Student

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

[Name("ID")]

public string ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

[Name("성명")]

public string Name { get; set; }

#endregion

#region 점수 - Score

/// <summary>

/// 점수

/// </summary>

[Name("점수")]

public int Score { get; set; }

#endregion

}

▶ Program.cs


using System.Globalization;

using CsvHelper;
using CsvHelper.Configuration;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        List<Student> sourceList = new List<Student>
        {
            new Student { ID = "ID004", Name = "김동수", Score = 80 }
        };

        CsvConfiguration csvConfiguration = new CsvConfiguration(CultureInfo.InvariantCulture);

        csvConfiguration.HasHeaderRecord = false;

        using(FileStream fileStream = File.Open("source.csv", FileMode.Append))
        {
            using(StreamWriter streamWriter = new StreamWriter(fileStream))
            {
                using(CsvWriter csvWriter = new CsvWriter(streamWriter, csvConfiguration))
                {
                    csvWriter.WriteRecords(sourceList);
                }
            }
        }
    }

    #endregion
}

using System.Globalization;

using CsvHelper;

using CsvHelper.Configuration;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

List<Student> sourceList = new List<Student>

{

new Student { ID = "ID004", Name = "김동수", Score = 80 }

};

CsvConfiguration csvConfiguration = new CsvConfiguration(CultureInfo.InvariantCulture);

csvConfiguration.HasHeaderRecord = false;

using(FileStream fileStream = File.Open("source.csv", FileMode.Append))

{

using(StreamWriter streamWriter = new StreamWriter(fileStream))

{

using(CsvWriter csvWriter = new CsvWriter(streamWriter, csvConfiguration))

{

csvWriter.WriteRecords(sourceList);

}

#endregion

}

TestProject.zip

[C#/COMMON/CSVHELPER/.NET6] CsvReader 클래스 : GetRecords 메소드를 사용해 CSV 파일 로드하기

■ CsvReader 클래스의 GetRecords 메소드를 사용해 CSV 파일을 로드하는 방법을 보여준다. ▶ Student.cs


using CsvHelper.Configuration.Attributes;

namespace TestProject;

/// <summary>
/// 학생
/// </summary>
public class Student
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    [Name("ID")]
    public string ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    [Name("성명")]
    public string Name { get; set; }

    #endregion
    #region 점수 - Score

    /// <summary>
    /// 점수
    /// </summary>
    [Name("점수")]
    public int Score { get; set; }

    #endregion
}

using CsvHelper.Configuration.Attributes;

namespace TestProject;

/// <summary>

/// 학생

/// </summary>

public class Student

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

[Name("ID")]

public string ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

[Name("성명")]

public string Name { get; set; }

#endregion

#region 점수 - Score

/// <summary>

/// 점수

/// </summary>

[Name("점수")]

public int Score { get; set; }

#endregion

}

▶ Program.cs


using System.Globalization;

using CsvHelper;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        using(StreamReader streamReader = new StreamReader("source.csv"))
        {
            using(CsvReader csvReader = new CsvReader(streamReader, CultureInfo.InvariantCulture))
            {
                List<Student> resultList = csvReader.GetRecords<Student>().ToList();

                foreach(Student student in resultList)
                {
                    Console.WriteLine($"{student.ID}, {student.Name}, {student.Score}");
                }
            }
        }
    }

    #endregion
}

using System.Globalization;

using CsvHelper;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

using(StreamReader streamReader = new StreamReader("source.csv"))

{

using(CsvReader csvReader = new CsvReader(streamReader, CultureInfo.InvariantCulture))

{

List<Student> resultList = csvReader.GetRecords<Student>().ToList();

foreach(Student student in resultList)

{

Console.WriteLine($"{student.ID}, {student.Name}, {student.Score}");

}

#endregion

}

TestProject.zip

[C#/COMMON/CSVHELPER/.NET6] CsvWriter 클래스 : WriteRecords 메소드를 사용해 CSV 파일 생성하기

■ CsvWriter 클래스의 WriteRecords 메소드를 사용해 CSV 파일을 생성하는 방법을 보여준다. ▶ Student.cs


using CsvHelper.Configuration.Attributes;

namespace TestProject;

/// <summary>
/// 학생
/// </summary>
public class Student
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region ID - ID

    /// <summary>
    /// ID
    /// </summary>
    [Name("ID")]
    public string ID { get; set; }

    #endregion
    #region 성명 - Name

    /// <summary>
    /// 성명
    /// </summary>
    [Name("성명")]
    public string Name { get; set; }

    #endregion
    #region 점수 - Score

    /// <summary>
    /// 점수
    /// </summary>
    [Name("점수")]
    public int Score { get; set; }

    #endregion
}

using CsvHelper.Configuration.Attributes;

namespace TestProject;

/// <summary>

/// 학생

/// </summary>

public class Student

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region ID - ID

/// <summary>

/// ID

/// </summary>

[Name("ID")]

public string ID { get; set; }

#endregion

#region 성명 - Name

/// <summary>

/// 성명

/// </summary>

[Name("성명")]

public string Name { get; set; }

#endregion

#region 점수 - Score

/// <summary>

/// 점수

/// </summary>

[Name("점수")]

public int Score { get; set; }

#endregion

}

▶ Program.cs


using System.Globalization;

using CsvHelper;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        List<Student> sourceList = new List<Student>
        {
            new Student { ID = "ID001", Name = "홍길동", Score = 90  },
            new Student { ID = "ID002", Name = "김철수", Score = 100 },
            new Student { ID = "ID003", Name = "이영희", Score = 80  }
        };

        using(StreamWriter streamWriter = new StreamWriter("d:\\result.csv"))
        {
            using(CsvWriter csvWriter = new CsvWriter(streamWriter, CultureInfo.InvariantCulture))
            {
                csvWriter.WriteRecords(sourceList);
            }
        }
    }

    #endregion
}

using System.Globalization;

using CsvHelper;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

List<Student> sourceList = new List<Student>

{

new Student { ID = "ID001", Name = "홍길동", Score = 90 },

new Student { ID = "ID002", Name = "김철수", Score = 100 },

new Student { ID = "ID003", Name = "이영희", Score = 80 }

};

using(StreamWriter streamWriter = new StreamWriter("d:\\result.csv"))

{

using(CsvWriter csvWriter = new CsvWriter(streamWriter, CultureInfo.InvariantCulture))

{

csvWriter.WriteRecords(sourceList);

}

#endregion

}

TestProject.zip

[C#/COMMON/CSVHELPER/.NET6] CsvHelper 누겟 설치하기

■ CsvHelper 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.

[C#/COMMON/PROTO.ACTOR/.NET6] Props 클래스 : WithReceiverMiddleware/WithSenderMiddleware 메소드를 사용해 미들웨어 설정하기

■ Props 클래스의 WithReceiverMiddleware/WithSenderMiddleware 메소드를 사용해 미들웨어를 설정하는 방법을 보여준다. ▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        MessageHeader messageHeader = new MessageHeader
        (
            new Dictionary<string, string>
            {
                { "TraceID", Guid.NewGuid().ToString() },
                { "SpanID" , Guid.NewGuid().ToString() }
            }
        );

        ActorSystem actorSystem = new ActorSystem();

        RootContext rootContext = new RootContext
        (
            actorSystem,
            messageHeader,
            next => async (context, target, envelope) =>
            {
                MessageEnvelope newEnvelope = envelope
                    .WithHeader("TraceID"     , context.Headers.GetOrDefault("TraceID"))
                    .WithHeader("SpanID"      , Guid.NewGuid().ToString())
                    .WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

                Console.WriteLine("  1 루트 컨텍스트 발송자 미들웨어 진입");
                Console.WriteLine("  1 TraceID      : " + newEnvelope.Header.GetOrDefault("TraceID"     ));
                Console.WriteLine("  1 SpanID       : " + newEnvelope.Header.GetOrDefault("SpanID"      ));
                Console.WriteLine("  1 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

                await next(context, target, newEnvelope);

                Console.WriteLine("  1 루트 컨텍스트 발송자 미들웨어 이탈 - 송신은 비동기식입니다. 설계상 순서가 잘못되었습니다.");
            }
        );

        Props props = Props.FromFunc
        (
            context =>
            {
                if(context.Message is string)
                {
                    Console.WriteLine( "      3 액터 진입");
                    Console.WriteLine($"      3 TraceID      : {context.Headers.GetOrDefault("TraceID"     )}");
                    Console.WriteLine($"      3 SpanID       : {context.Headers.GetOrDefault("SpanID"      )}");
                    Console.WriteLine($"      3 ParentSpanID : {context.Headers.GetOrDefault("ParentSpanID")}");
                    Console.WriteLine($"      3 액터 수신    : {context.Message.GetType()}:{context.Message}");

                    context.Respond("세계!");

                    Console.WriteLine( "      3 액터 이탈");
                }

                return Task.CompletedTask;
            }
        )
        .WithReceiverMiddleware
        (
            receiver => async (context, envelope) =>
            {
                if(envelope.Message is string)
                {
                    MessageEnvelope newEnvelope = envelope
                        .WithHeader("TraceID"     , envelope.Header.GetOrDefault("TraceID"))
                        .WithHeader("SpanID"      , Guid.NewGuid().ToString())
                        .WithHeader("ParentSpanID", envelope.Header.GetOrDefault("SpanID"));

                    Console.WriteLine("    2 액터 수신자 미들웨어 진입");
                    Console.WriteLine("    2 TraceID      : " + newEnvelope.Header.GetOrDefault("TraceID"     ));
                    Console.WriteLine("    2 SpanID       : " + newEnvelope.Header.GetOrDefault("SpanID"      ));
                    Console.WriteLine("    2 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

                    await receiver(context, newEnvelope);

                    Console.WriteLine("    2 액터 수신자 미들웨어 이탈");
                }
                else
                {
                    await receiver(context, envelope);
                }
            }
        )
        .WithSenderMiddleware
        (
            sender => async (context, target, envelope) =>
            {
                MessageEnvelope newEnvelope = envelope
                    .WithHeader("TraceID"     , context.Headers.GetOrDefault("TraceID"))
                    .WithHeader("SpanID"      , Guid.NewGuid().ToString())
                    .WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

                Console.WriteLine("        4 액터 발송자 미들웨어 진입");
                Console.WriteLine("        4 TraceID      : " + newEnvelope.Header.GetOrDefault("TraceID"     ));
                Console.WriteLine("        4 SpanID       : " + newEnvelope.Header.GetOrDefault("SpanID"      ));
                Console.WriteLine("        4 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

                await sender(context, target, envelope);

                Console.WriteLine("        4 액터 발송자 미들웨어 이탈");
            }
        );

        PID pid = rootContext.Spawn(props);

        Task.Delay(500).Wait();

        Console.WriteLine("0 TraceID      : " + rootContext.Headers.GetOrDefault("TraceID"     ));
        Console.WriteLine("0 SpanID       : " + rootContext.Headers.GetOrDefault("SpanID"      ));
        Console.WriteLine("0 ParentSpanID : " + rootContext.Headers.GetOrDefault("ParentSpanID"));

        string result = rootContext.RequestAsync<string>(pid, "안녕하세요").Result;

        Console.WriteLine("결과 : " + result);

        Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

        Console.ReadKey(false);
    }

    #endregion
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

using Proto;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

MessageHeader messageHeader = new MessageHeader

(

new Dictionary<string, string>

{

{ "TraceID", Guid.NewGuid().ToString() },

{ "SpanID" , Guid.NewGuid().ToString() }

}

);

ActorSystem actorSystem = new ActorSystem();

RootContext rootContext = new RootContext

(

actorSystem,

messageHeader,

next => async (context, target, envelope) =>

{

MessageEnvelope newEnvelope = envelope

.WithHeader("TraceID" , context.Headers.GetOrDefault("TraceID"))

.WithHeader("SpanID" , Guid.NewGuid().ToString())

.WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

Console.WriteLine(" 1 루트 컨텍스트 발송자 미들웨어 진입");

Console.WriteLine(" 1 TraceID : " + newEnvelope.Header.GetOrDefault("TraceID" ));

Console.WriteLine(" 1 SpanID : " + newEnvelope.Header.GetOrDefault("SpanID" ));

Console.WriteLine(" 1 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

await next(context, target, newEnvelope);

Console.WriteLine(" 1 루트 컨텍스트 발송자 미들웨어 이탈 - 송신은 비동기식입니다. 설계상 순서가 잘못되었습니다.");

}

);

Props props = Props.FromFunc

(

context =>

{

if(context.Message is string)

{

Console.WriteLine( " 3 액터 진입");

Console.WriteLine($" 3 TraceID : {context.Headers.GetOrDefault("TraceID" )}");

Console.WriteLine($" 3 SpanID : {context.Headers.GetOrDefault("SpanID" )}");

Console.WriteLine($" 3 ParentSpanID : {context.Headers.GetOrDefault("ParentSpanID")}");

Console.WriteLine($" 3 액터 수신 : {context.Message.GetType()}:{context.Message}");

context.Respond("세계!");

Console.WriteLine( " 3 액터 이탈");

}

return Task.CompletedTask;

}

)

.WithReceiverMiddleware

(

receiver => async (context, envelope) =>

{

if(envelope.Message is string)

{

MessageEnvelope newEnvelope = envelope

.WithHeader("TraceID" , envelope.Header.GetOrDefault("TraceID"))

.WithHeader("SpanID" , Guid.NewGuid().ToString())

.WithHeader("ParentSpanID", envelope.Header.GetOrDefault("SpanID"));

Console.WriteLine(" 2 액터 수신자 미들웨어 진입");

Console.WriteLine(" 2 TraceID : " + newEnvelope.Header.GetOrDefault("TraceID" ));

Console.WriteLine(" 2 SpanID : " + newEnvelope.Header.GetOrDefault("SpanID" ));

Console.WriteLine(" 2 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

await receiver(context, newEnvelope);

Console.WriteLine(" 2 액터 수신자 미들웨어 이탈");

}

else

{

await receiver(context, envelope);

}

)

.WithSenderMiddleware

(

sender => async (context, target, envelope) =>

{

MessageEnvelope newEnvelope = envelope

.WithHeader("TraceID" , context.Headers.GetOrDefault("TraceID"))

.WithHeader("SpanID" , Guid.NewGuid().ToString())

.WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

Console.WriteLine(" 4 액터 발송자 미들웨어 진입");

Console.WriteLine(" 4 TraceID : " + newEnvelope.Header.GetOrDefault("TraceID" ));

Console.WriteLine(" 4 SpanID : " + newEnvelope.Header.GetOrDefault("SpanID" ));

Console.WriteLine(" 4 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

await sender(context, target, envelope);

Console.WriteLine(" 4 액터 발송자 미들웨어 이탈");

}

);

PID pid = rootContext.Spawn(props);

Task.Delay(500).Wait();

Console.WriteLine("0 TraceID : " + rootContext.Headers.GetOrDefault("TraceID" ));

Console.WriteLine("0 SpanID : " + rootContext.Headers.GetOrDefault("SpanID" ));

Console.WriteLine("0 ParentSpanID : " + rootContext.Headers.GetOrDefault("ParentSpanID"));

string result = rootContext.RequestAsync<string>(pid, "안녕하세요").Result;

Console.WriteLine("결과 : " + result);

Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] MessageHeader 클래스 : 메시지 헤더에서 데이터 전파하기

■ MessageHeader 클래스를 사용해 메시지 헤더에서 데이터를 전파하는 방법을 보여준다. ▶ CustomMessage.cs


namespace TestProject;

/// <summary>
/// 커스텀 메시지
/// </summary>
/// <param name="Message">메시지</param>
public record CustomMessage(string Message);

namespace TestProject;

/// <summary>

/// 커스텀 메시지

/// </summary>

/// <param name="Message">메시지</param>

public record CustomMessage(string Message);

▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 헤더 전파하기 - PropagateHeader(sender)

    /// <summary>
    /// 헤더 전파하기
    /// </summary>
    /// <param name="sender">발송자</param>
    /// <returns>발송자</returns>
    private static Sender PropagateHeader(Sender sender)
    {
        return (context, target, envelope) => sender(context, target, envelope.WithHeader(context.Headers));
    }

    #endregion
    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        MessageHeader messageHeader = MessageHeader
            .Empty
            .With("UserID"  , "사용자1")
            .With("Language", "한국어");

        ActorSystem actorSystem = new ActorSystem
        (
            ActorSystemConfig.Setup() with
            {
                ConfigureRootContext = context => context.WithHeaders(messageHeader)
            }
        );

        Props props = Props.FromFunc
        (
            context =>
            {
                if(context.Message is CustomMessage message)
                {
                    Console.WriteLine($"메시지 : {message.Message}");

                    foreach((string key, string value) in context.Headers)
                    {
                        Console.WriteLine($"  키 : {key}, 값 : {value}");
                    }
                }

                return Task.CompletedTask;
            }
        );

        PID pid = actorSystem.Root.Spawn(props);

        IRootContext rootContext = actorSystem
            .Root
            .WithSenderMiddleware(PropagateHeader);

        rootContext.Send(pid, new CustomMessage("메시지1"));

        Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

        Console.ReadKey(false);
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 헤더 전파하기 - PropagateHeader(sender)

/// <summary>

/// 헤더 전파하기

/// </summary>

/// <param name="sender">발송자</param>

/// <returns>발송자</returns>

private static Sender PropagateHeader(Sender sender)

{

return (context, target, envelope) => sender(context, target, envelope.WithHeader(context.Headers));

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

MessageHeader messageHeader = MessageHeader

.Empty

.With("UserID" , "사용자1")

.With("Language", "한국어");

ActorSystem actorSystem = new ActorSystem

(

ActorSystemConfig.Setup() with

{

ConfigureRootContext = context => context.WithHeaders(messageHeader)

}

);

Props props = Props.FromFunc

(

context =>

{

if(context.Message is CustomMessage message)

{

Console.WriteLine($"메시지 : {message.Message}");

foreach((string key, string value) in context.Headers)

{

Console.WriteLine($" 키 : {key}, 값 : {value}");

}

return Task.CompletedTask;

}

);

PID pid = actorSystem.Root.Spawn(props);

IRootContext rootContext = actorSystem

.Root

.WithSenderMiddleware(PropagateHeader);

rootContext.Send(pid, new CustomMessage("메시지1"));

Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] EventStream 클래스 : Subscribe 메소드에서 특정 주제에 일치하는 경우만 처리하기

■ EventStream 클래스의 Subscribe 메소드에서 특정 주제에 일치하는 경우만 처리하는 방법을 보여준다. ▶ ITopicMessage.cs


namespace TestProject;

/// <summary>
/// 주제 메시지 인터페이스
/// </summary>
public interface ITopicMessage
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 주제 - Topic

    /// <summary>
    /// 주제
    /// </summary>
    string Topic { get; }

    #endregion
}

namespace TestProject;

/// <summary>

/// 주제 메시지 인터페이스

/// </summary>

public interface ITopicMessage

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 주제 - Topic

/// <summary>

/// 주제

/// </summary>

string Topic { get; }

#endregion

}

▶ TopicMessage.cs


namespace TestProject;

/// <summary>
/// 커스텀 메시지
/// </summary>
/// <param name="Name">명칭</param>
/// <param name="Topic">주제</param>
public record TopicMessage(string Name, string Topic) : ITopicMessage;

namespace TestProject;

/// <summary>

/// 커스텀 메시지

/// </summary>

/// <param name="Name">명칭</param>

/// <param name="Topic">주제</param>

public record TopicMessage(string Name, string Topic) : ITopicMessage;

▶ EventStreamExtension.cs


using Microsoft.VisualBasic;
using Microsoft.VisualBasic.CompilerServices;

using Proto;

namespace TestProject;

/// <summary>
/// 이벤트 스트림 확장
/// </summary>
public static class EventStreamExtension
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Public

    #region 주제에 구독하기 - SubscribeToTopic<T>(eventStream, topic, action)

    /// <summary>
    /// 주제에 구독하기
    /// </summary>
    /// <typeparam name="T">주제 메시지 인터페이스</typeparam>
    /// <param name="eventStream">이벤트 스트림</param>
    /// <param name="topic">주제</param>
    /// <param name="action">액션</param>
    /// <returns>이벤트 스트림 구독</returns>
    public static EventStreamSubscription<object> SubscribeToTopic<T>(this EventStream eventStream, string topic, Action<T> action) where T : ITopicMessage
    {
        return eventStream.Subscribe<T>
        (
            x =>
            {
                if(!LikeOperator.LikeString(x.Topic, topic, CompareMethod.Binary))
                {
                    return;
                }

                action(x);
            }
        );
    }

    #endregion
}

using Microsoft.VisualBasic;

using Microsoft.VisualBasic.CompilerServices;

using Proto;

namespace TestProject;

/// <summary>

/// 이벤트 스트림 확장

/// </summary>

public static class EventStreamExtension

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region 주제에 구독하기 - SubscribeToTopic<T>(eventStream, topic, action)

/// <summary>

/// 주제에 구독하기

/// </summary>

/// <typeparam name="T">주제 메시지 인터페이스</typeparam>

/// <param name="eventStream">이벤트 스트림</param>

/// <param name="topic">주제</param>

/// <param name="action">액션</param>

/// <returns>이벤트 스트림 구독</returns>

public static EventStreamSubscription<object> SubscribeToTopic<T>(this EventStream eventStream, string topic, Action<T> action) where T : ITopicMessage

{

return eventStream.Subscribe<T>

(

x =>

{

if(!LikeOperator.LikeString(x.Topic, topic, CompareMethod.Binary))

{

return;

}

action(x);

}

);

}

#endregion

}

▶

[C#/COMMON/PROTO.ACTOR/.NET6] 액터의 수신 타임 아웃 처리하기

■ 액터가 수신 타임 아웃을 처리하는 방법을 보여준다. ▶ NoInfluenceMessage.cs


using Proto;

namespace TestProject;

/// <summary>
/// 영향을 주지 않는 메시지
/// </summary>
public class NoInfluenceMessage : INotInfluenceReceiveTimeout
{
}

using Proto;

namespace TestProject;

/// <summary>

/// 영향을 주지 않는 메시지

/// </summary>

public class NoInfluenceMessage : INotInfluenceReceiveTimeout

{

}

▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        RootContext rootContext = new RootContext(new ActorSystem());

        int count = 0;

        Props props = Props.FromFunc
        (
            context =>
            {
                switch(context.Message)
                {
                    case Started _ :

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 시작");

                        context.SetReceiveTimeout(TimeSpan.FromSeconds(1));

                        break;

                    case ReceiveTimeout _ :

                        count++;

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 수신 타임아웃 : {count}");

                        break;

                    case NoInfluenceMessage _ :

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 영향을 주지 않는 메시지 수신");

                        break;

                    case string message :

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 메시지 수신 : {message}");

                        break;
                }

                return Task.CompletedTask;
            }
        );

        PID pid = rootContext.Spawn(props);

        for(int i = 0; i < 6; i++)
        {
            rootContext.Send(pid, "안녕하세요.");

            Thread.Sleep(500);
        }

        Console.WriteLine("영향을 주지 않는 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

        Console.ReadLine();

        for(int i = 0; i < 6; i++)
        {
            rootContext.Send(pid, new NoInfluenceMessage());

            Thread.Sleep(500);
        }

        Console.WriteLine("타임아웃을 취소하기 위한 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

        Console.ReadLine();

        rootContext.Send(pid, "취소");

        Console.WriteLine("종료하기 위해서 RETURN 키를 눌러 주세요.");

        Console.ReadLine();
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

RootContext rootContext = new RootContext(new ActorSystem());

int count = 0;

Props props = Props.FromFunc

(

context =>

{

switch(context.Message)

{

case Started _ :

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 시작");

context.SetReceiveTimeout(TimeSpan.FromSeconds(1));

break;

case ReceiveTimeout _ :

count++;

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 수신 타임아웃 : {count}");

break;

case NoInfluenceMessage _ :

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 영향을 주지 않는 메시지 수신");

break;

case string message :

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 메시지 수신 : {message}");

break;

}

return Task.CompletedTask;

}

);

PID pid = rootContext.Spawn(props);

for(int i = 0; i < 6; i++)

{

rootContext.Send(pid, "안녕하세요.");

Thread.Sleep(500);

}

Console.WriteLine("영향을 주지 않는 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

Console.ReadLine();

for(int i = 0; i < 6; i++)

{

rootContext.Send(pid, new NoInfluenceMessage());

Thread.Sleep(500);

}

Console.WriteLine("타임아웃을 취소하기 위한 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

Console.ReadLine();

rootContext.Send(pid, "취소");

Console.WriteLine("종료하기 위해서 RETURN 키를 눌러 주세요.");

Console.ReadLine();

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] ActorSystemConfig 레코드 : WithDeadLetterThrottleInterval/WithDeadLetterThrottleCount 메소드를 사용해 데드 레터 쓰로틀링 만들기

■ ActorSystemConfig 레코드의 WithDeadLetterThrottleInterval/WithDeadLetterThrottleCount 메소드를 사용해 데드 레터 쓰로틀링을 만드는 방법을 보여준다. ▶ Program.cs


using Proto;
using Proto.Extensions;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    /// <returns></returns>
    private static async Task Main()
    {
        ActorSystem actorSystem = new ActorSystem
        (
            new ActorSystemConfig()
                .WithDeadLetterThrottleInterval(TimeSpan.FromSeconds(1))
                .WithDeadLetterThrottleCount(3)
        );

        actorSystem.EventStream.Subscribe<DeadLetterEvent>
        (
            deadLetter => Console.WriteLine
            (
                $"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"
            )
        );

        Props props = Props.FromFunc(context => Task.CompletedTask);

        PID pid = actorSystem.Root.Spawn(props);

        await actorSystem.Root.StopAsync(pid);

        for(int i = 0; i < 1000; i++)
        {
            actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));
        }

        await Task.Delay(TimeSpan.FromSeconds(2));

        for(int i = 0; i < 1000; i++)
        {
            actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));
        }
    }

    #endregion
}

using Proto;

using Proto.Extensions;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

/// <returns></returns>

private static async Task Main()

{

ActorSystem actorSystem = new ActorSystem

(

new ActorSystemConfig()

.WithDeadLetterThrottleInterval(TimeSpan.FromSeconds(1))

.WithDeadLetterThrottleCount(3)

);

actorSystem.EventStream.Subscribe<DeadLetterEvent>

(

deadLetter => Console.WriteLine

(

$"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"

)

);

Props props = Props.FromFunc(context => Task.CompletedTask);

PID pid = actorSystem.Root.Spawn(props);

await actorSystem.Root.StopAsync(pid);

for(int i = 0; i < 1000; i++)

{

actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));

}

await Task.Delay(TimeSpan.FromSeconds(2));

for(int i = 0; i < 1000; i++)

{

actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] ActorSystem 클래스 : EventStream 속성을 사용해 메시지 구독/발행하기

■ ActorSystem 클래스의 EventStream 속성을 사용해 메시지를 구독/발행하는 방법을 보여준다. ▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 테스트 메시지
/// </summary>
/// <param name="Text">텍스트</param>
public record TestMessage(string Text);

/// <summary>
/// 프로그램
/// </summary>
static class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        ActorSystem actorSystem = new ActorSystem();

        actorSystem.EventStream.Subscribe<TestMessage>(message => Console.WriteLine($"구독 메시지 : {message.Text}"));

        actorSystem.EventStream.Publish(new TestMessage("메시지1"));
        actorSystem.EventStream.Publish(new TestMessage("메시지2"));

        Console.ReadKey(false);
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 테스트 메시지

/// </summary>

/// <param name="Text">텍스트</param>

public record TestMessage(string Text);

/// <summary>

/// 프로그램

/// </summary>

static class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

ActorSystem actorSystem = new ActorSystem();

actorSystem.EventStream.Subscribe<TestMessage>(message => Console.WriteLine($"구독 메시지 : {message.Text}"));

actorSystem.EventStream.Publish(new TestMessage("메시지1"));

actorSystem.EventStream.Publish(new TestMessage("메시지2"));

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] IActor 인터페이스 : ReceiveAsync 메소드를 사용해 액터 수명주기 이벤트 처리하기

■ IActor 인터페이스의 ReceiveAsync 메소드를 사용해 액터 수명주기 이벤트를 처리하는 방법을 보여준다. ▶ HelloMessage.cs


using TestProject;

/// <summary>
/// 헬로우 메시지
/// </summary>
public class HelloMessage
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Field
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region Field

    /// <summary>
    /// 이름
    /// </summary>
    public string Name;

    #endregion
}

using TestProject;

/// <summary>

/// 헬로우 메시지

/// </summary>

public class HelloMessage

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Public

#region Field

/// <summary>

/// 이름

/// </summary>

public string Name;

#endregion

}

▶ HelloActor.cs


using Proto;

namespace TestProject;

/// <summary>
/// 헬로우 액터
/// </summary>
public class HelloActor : IActor
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 수신하기 (비동기) - ReceiveAsync(context)

    /// <summary>
    /// 수신하기 (비동기)
    /// </summary>
    /// <param name="context">컨텍스트</param>
    /// <returns>태스크</returns>
    public Task ReceiveAsync(IContext context)
    {
        switch(context.Message)
        {
            case HelloMessage helloMessage :

                Console.WriteLine($"안녕하세요, {helloMessage.Name}");

                break;

            case Started _ :

                Console.WriteLine("시작했습니다, 여기서 액터를 초기화합니다.");

                break;

            case Stopping _ :

                Console.WriteLine("중단중입니다, 액터가 곧 셧 다운됩니다.");

                break;

            case Stopped _ :

                Console.WriteLine("중단했습니다, 액터와 그 자식들이 중단되었습니다.");

                break;

            case Restarting _ :

                Console.WriteLine("재시작하고 있습니다, 액터가 곧 재시작됩니다.");

                break;
        }

        return Task.CompletedTask;
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 헬로우 액터

/// </summary>

public class HelloActor : IActor

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 수신하기 (비동기) - ReceiveAsync(context)

/// <summary>

/// 수신하기 (비동기)

/// </summary>

/// <param name="context">컨텍스트</param>

/// <returns>태스크</returns>

public Task ReceiveAsync(IContext context)

{

switch(context.Message)

{

case HelloMessage helloMessage :

Console.WriteLine($"안녕하세요, {helloMessage.Name}");

break;

case Started _ :

Console.WriteLine("시작했습니다, 여기서 액터를 초기화합니다.");

break;

case Stopping _ :

Console.WriteLine("중단중입니다, 액터가 곧 셧 다운됩니다.");

break;

case Stopped _ :

Console.WriteLine("중단했습니다, 액터와 그 자식들이 중단되었습니다.");

break;

case Restarting _ :

Console.WriteLine("재시작하고 있습니다, 액터가 곧 재시작됩니다.");

break;

}

return Task.CompletedTask;

}

#endregion

}

▶ Program.cs


using Proto;
using Proto.Extensions;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
static class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 시작하기 - Main()

    /// <summary>
    /// 시작하기
    /// </summary>
    /// <returns>태스크</returns>
    private static async Task Main()
    {
        ActorSystem actorSystem = new ActorSystem();

        actorSystem.EventStream.Subscribe<DeadLetterEvent>
        (
            deadLetter => Console.WriteLine
            (
                $"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"
            )
        );

        RootContext rootContext = new RootContext(actorSystem);

        Props helloProps = Props.FromProducer(() => new HelloActor());

        PID helloActorPID = rootContext.Spawn(helloProps);

        rootContext.Send(helloActorPID, new HelloMessage { Name = "홍길동" });

        await actorSystem.Root.PoisonAsync(helloActorPID);
    }

    #endregion
}

using Proto;

using Proto.Extensions;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

static class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 시작하기 - Main()

/// <summary>

/// 시작하기

/// </summary>

/// <returns>태스크</returns>

private static async Task Main()

{

ActorSystem actorSystem = new ActorSystem();

actorSystem.EventStream.Subscribe<DeadLetterEvent>

(

deadLetter => Console.WriteLine

(

$"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"

)

);

RootContext rootContext = new RootContext(actorSystem);

Props helloProps = Props.FromProducer(() => new HelloActor());

PID helloActorPID = rootContext.Spawn(helloProps);

rootContext.Send(helloActorPID, new HelloMessage { Name = "홍길동" });

await actorSystem.Root.PoisonAsync(helloActorPID);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTOBUF/.NET6] 프로토콜 버퍼를 사용해 데이터 직렬화/역직렬화하기

■ 프로토콜 버퍼를 사용해 데이터를 직렬화/역직렬화하는 방법을 보여준다. ▶ Message.cs


using ProtoBuf;

namespace TestProject;

/// <summary>
/// 메시지
/// </summary>
[ProtoContract]
public class Message
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 메시지 ID - MessageID

    /// <summary>
    /// 메시지 ID
    /// </summary>
    [ProtoMember(1)]
    public string MessageID { get; set; }

    #endregion
    #region 우선 순위 - Priority

    /// <summary>
    /// 우선 순위
    /// </summary>
    [ProtoMember(2)]
    public int Priority { get; set; }

    #endregion
    #region 텍스트 - Text

    /// <summary>
    /// 텍스트
    /// </summary>
    [ProtoMember(3)]
    public string Text { get; set; }

    #endregion
}

using ProtoBuf;

namespace TestProject;

/// <summary>

/// 메시지

/// </summary>

[ProtoContract]

public class Message

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 메시지 ID - MessageID

/// <summary>

/// 메시지 ID

/// </summary>

[ProtoMember(1)]

public string MessageID { get; set; }

#endregion

#region 우선 순위 - Priority

/// <summary>

/// 우선 순위

/// </summary>

[ProtoMember(2)]

public int Priority { get; set; }

#endregion

#region 텍스트 - Text

/// <summary>

/// 텍스트

/// </summary>

[ProtoMember(3)]

public string Text { get; set; }

#endregion

}

▶ Program.cs


using ProtoBuf;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        Message sourceMessage = new Message
        {
            MessageID = "A49EC1E0-5F84-4DBA-9DF3-A8605407770F",
            Priority  = 100,
            Text      = "텍스트 문자열 입니다."
        };

        Console.WriteLine("소스 메시지");
        Console.WriteLine($"{sourceMessage.MessageID}, {sourceMessage.Priority}, {sourceMessage.Text}");
        Console.WriteLine();

        MemoryStream serializingStream = new MemoryStream();

        Serializer.Serialize<Message>(serializingStream, sourceMessage);

        byte[] serializedByteArray = serializingStream.ToArray();

        Console.WriteLine("직렬화 바이트 배열");
        Console.WriteLine($"{BitConverter.ToString(serializedByteArray)}");
        Console.WriteLine();

        MemoryStream deserializingStream = new MemoryStream(serializedByteArray);

        Message deserializedMessage = Serializer.Deserialize<Message>(deserializingStream);

        Console.WriteLine("역직렬화 메시지");
        Console.WriteLine($"{deserializedMessage.MessageID}, {deserializedMessage.Priority}, {deserializedMessage.Text}");
        Console.WriteLine();

        Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

        Console.ReadKey(false);
    }

    #endregion
}

using ProtoBuf;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

Message sourceMessage = new Message

{

MessageID = "A49EC1E0-5F84-4DBA-9DF3-A8605407770F",

Priority = 100,

Text = "텍스트 문자열 입니다."

};

Console.WriteLine("소스 메시지");

Console.WriteLine($"{sourceMessage.MessageID}, {sourceMessage.Priority}, {sourceMessage.Text}");

Console.WriteLine();

MemoryStream serializingStream = new MemoryStream();

Serializer.Serialize<Message>(serializingStream, sourceMessage);

byte[] serializedByteArray = serializingStream.ToArray();

Console.WriteLine("직렬화 바이트 배열");

Console.WriteLine($"{BitConverter.ToString(serializedByteArray)}");

Console.WriteLine();

MemoryStream deserializingStream = new MemoryStream(serializedByteArray);

Message deserializedMessage = Serializer.Deserialize<Message>(deserializingStream);

Console.WriteLine("역직렬화 메시지");

Console.WriteLine($"{deserializedMessage.MessageID}, {deserializedMessage.Priority}, {deserializedMessage.Text}");

Console.WriteLine();

Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTOBUF/.NET6] protobuf-net 누겟 설치하기

■ protobuf-net 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.