💻[C#]IPC 통신탐구 (Named Pipe)-3

📚 개발 환경

• VisualStudio 2022
• .NET 6
• Console APP

📑 NamedPipeServerStream

NamedPipeServerStream 먼저 NamePipe의 Server 부분의 생성자를 보면

public NamedPipeServerStream (string pipeName, System.IO.Pipes.PipeDirection direction);

• string pipeName : 파이프의 이름
• System.IO.Pipes.PipeDirection direction : 파이프의 방향

방향의 열거 값에는 총 3가지가 있으며

Field	Description
In	파이프 방향을 안쪽으로 지정함
InOut	파이프 방향을 양쪽으로 지정함
Out	파이프 방향을 바깥쪽으로 지정함

여기서 Server 쪽에는 Out을 쓸것이다. 해당 파이프가 서버에서 클라이언트로 데이터를 보내기 위해 Out으로 지정하며 쓰기전용이기도 하다.

---

📑 NamedPipeClientStream

NamedPipeClientStream

NamePipe 의 Cline 부분의 생성자를 살펴보면

public NamedPipeClientStream (string serverName, string pipeName, System.IO.Pipes.PipeDirection direction);

• string serverName : 서버 이름
• string pipeName : 파이프의 이름
• System.IO.Pipes.PipeDirection direction : 파이프의 방향

NamedPipeServerStream의 생성자와 다르게 string serverName 라는 변수가 있는데 서버가 로컬 컴퓨터에 있는경우에는 ”.” 으로 넣어도 무방하다! string pipeName 에는 서버와 같은 파이프의 이름을 가지고 있어야 하며 System.IO.Pipes.PipeDirection direction은 In으로 파이프가 읽기 전용으로 설정이 되며 읽기 전용이기도 합니다.

---

🖥️ Named Pipe 구현

Naed Pipe Write Server

public class NamedPipeWriter
{
    public void WriteToPipe(string data)
    {
        using (NamedPipeServerStream pipeServer = new NamedPipeServerStream("Cat", PipeDirection.Out))
        {
            Console.WriteLine("Named Pipe 서버가 클라이언트를 기다립니다...");
            pipeServer.WaitForConnection();

            using (StreamWriter writer = new StreamWriter(pipeServer))
            {
                writer.AutoFlush = true;
                writer.WriteLine(data);
                Console.WriteLine("Named Pipe 서버가 데이터를 전송했습니다.");
            }
        }
    }
}

Named Pipe Read Client

public class NamedPipeReader
{
    public string ReadFromPipe()
    {
        using (NamedPipeClientStream pipeClient = new NamedPipeClientStream(".", "Cat", PipeDirection.In))
        {
            Console.WriteLine("Named Pipe 클라이언트가 서버에 연결 중...");
            pipeClient.Connect();

            using (StreamReader reader = new StreamReader(pipeClient))
            {
                string data = reader.ReadLine();
                Console.WriteLine("Named Pipe 클라이언트가 데이터를 수신했습니다.");
                return data;
            }
        }
    }
}

쓰고/ 읽는 클래스가 있으니 이제 사용할 클래스를 만들자면

Program class

class Program
{
    static void Main()
    {
        NamedPipeWriter writer = new NamedPipeWriter();
        NamedPipeReader reader = new NamedPipeReader();

        // 새로운 스레드에서 Named Pipe 서버를 시작합니다.
        Task.Run(() =>
        {
            writer.WriteToPipe("Night Mo 데이터 저장!");
        });

        // Named Pipe 클라이언트가 데이터를 읽습니다.
        string data = reader.ReadFromPipe();
        Console.WriteLine($"Received from pipe: {data}");
    }
}

결과