MessageStream 1.2.1

MessageStream Library

C# Channel 기반의 간단하고 강력한 스레드 간 데이터 통신 라이브러리입니다.

🎯 기본 사용법

1. 기본 읽기/쓰기

using Threading.Messaging;

// Producer 스레드
var producer = Task.Run(async () =>
{
    using var hub = MessageStream.Open("channel1");
    await hub.WriteAsync<string>("Hello World!");
    await hub.WriteAsync<int>(42);
});

// Consumer 스레드
var consumer = Task.Run(async () =>
{
    using var hub = MessageStream.Open("channel1");
    var message = await hub.ReadAsync<string>();
    var number = await hub.ReadAsync<int>();
    
    Console.WriteLine($"Message: {message}, Number: {number}");
});

await Task.WhenAll(producer, consumer);

2. 타임아웃 설정

// 2초 타임아웃 설정
using var hub = MessageStream.Open("channel1", timeout: 2000);

try
{
    await hub.WriteAsync<string>("Data");
    var result = await hub.ReadAsync<string>();
}
catch (TimeoutException ex)
{
    Console.WriteLine($"작업 시간 초과: {ex.Message}");
}

3. Non-blocking 읽기

using var hub = MessageStream.Open("channel1");

// 즉시 읽기 시도 (블로킹 없음)
if (hub.TryRead<string>(out var result))
{
    Console.WriteLine($"읽은 데이터: {result}");
}
else
{
    Console.WriteLine("읽을 수 있는 데이터가 없습니다.");
}

🏗️ 고급 사용법

1. 여러 스레드에서 동일 채널 공유

// 여러 Producer
var producers = Enumerable.Range(0, 3).Select(i => 
    Task.Run(async () =>
    {
        using var hub = MessageStream.Open("shared-channel");
        await hub.WriteAsync<int>(i);
        Console.WriteLine($"Producer {i} 완료");
    })
).ToArray();

// 단일 Consumer
var consumer = Task.Run(async () =>
{
    using var hub = MessageStream.Open("shared-channel");
    for (int i = 0; i < 3; i++)
    {
        var value = await hub.ReadAsync<int>();
        Console.WriteLine($"받은 값: {value}");
    }
});

await Task.WhenAll(producers.Concat(new[] { consumer }));

2. 순차적 채널 사용

// 첫 번째 사용
using (var hub1 = MessageStream.Open("sequential"))
{
    await hub1.WriteAsync<string>("First message");
}

// 두 번째 사용 (같은 채널)
using (var hub2 = MessageStream.Open("sequential"))
{
    await hub2.WriteAsync<string>("Second message");
}

// 읽기 (같은 채널)
using (var hub3 = MessageStream.Open("sequential"))
{
    var msg1 = await hub3.ReadAsync<string>();
    var msg2 = await hub3.ReadAsync<string>();
    Console.WriteLine($"Messages: {msg1}, {msg2}");
}

3. TryPeek을 이용한 데이터 처리 흐름

var stream = MessageStream.Open("test");
await stream.WriteAsync("첫번째");
await stream.WriteAsync("두번째");
await stream.WriteAsync("세번째");

// TryPeek - 데이터를 제거하지 않고 확인만
if (stream.TryPeek<string>(out var peeked))
{
    Console.WriteLine($"다음 메시지: {peeked}"); // "첫번째" 출력
}

// 다시 Peek 해도 같은 데이터
if (stream.TryPeek<string>(out var peeked2))
{
    Console.WriteLine($"여전히: {peeked2}"); // 또다시 "첫번째" 출력
}
// 실제로 읽어야 데이터가 제거됨
var actual = await stream.ReadAsync<string>(); // "첫번째" 반환하고 제거

// 이제 Peek하면 다음 데이터가 보임
if (stream.TryPeek<string>(out var peeked3))
{
    Console.WriteLine($"이제 다음: {peeked3}"); // "두번째" 출력
}

🛡️ 예외 처리

using var hub = MessageStream.Open("error-channel", timeout: 1000);

try
{
    await hub.WriteAsync<string>("test");
    var result = await hub.ReadAsync<int>(); // 타입 불일치
}
catch (TimeoutException)
{
    Console.WriteLine("작업 시간 초과");
}
catch (InvalidCastException)
{
    Console.WriteLine("타입 캐스팅 실패");
}
catch (ObjectDisposedException)
{
    Console.WriteLine("이미 해제된 MessageStream 사용");
}
catch (InvalidOperationException)
{
    Console.WriteLine("채널이 완료됨");
}

📋 API 레퍼런스

MessageStream 클래스

예외 타입

💡 모범 사례

✅ 권장사항

// 1. using 문 사용
using var hub = MessageStream.Open("channel1");

// 2. 타임아웃 설정
using var hub = MessageStream.Open("channel1", timeout: 2000);

// 3. 예외 처리
try
{
    var cts = new CancellationTokenSource();
    var data = await hub.ReadAsync<string>(cts.Token);
}
catch (TimeoutException)
{
    // 타임아웃 처리
}

❌ 피해야 할 사항

// 1. using 없이 사용 (메모리 누수 위험)
var hub = MessageStream.Open("channel1"); // ❌

// 2. 타입 불일치
await hub.WriteAsync<string>("hello");
var number = await hub.ReadAsync<int>(); // ❌ InvalidCastException

// 3. 너무 짧은 타임아웃
using var hub = MessageStream.Open("channel1", timeout: 1); // ❌

🚨 주의사항

• 채널 공유: 같은 이름의 채널은 모든 스레드에서 공유됩니다.
• 타입 안전성: 쓰기와 읽기 시 타입이 일치해야 합니다.
• 순서 보장: 데이터는 FIFO(First In, First Out) 순서로 처리됩니다.
• 메모리 관리: using 문을 사용하여 자동 리소스 해제를 권장합니다.