using System;
using System.IO;
using System.IO.Pipes;
using System.Diagnostics;
using System.Threading.Tasks;
using System.Linq;
using System.Threading;

class PipeServer
{
    static void Main()
    {
        StartServer();
        Thread.Sleep(1000);

        //Client
        var client = new NamedPipeClientStream("PipesOfPiece");
        client.Connect();
        StreamReader reader = new StreamReader(client);
        StreamWriter writer = new StreamWriter(client);

        while (true)
        {
            string input = Console.ReadLine();
            if (String.IsNullOrEmpty(input)) break;
            writer.WriteLine(input);
            writer.Flush();
            Console.WriteLine(reader.ReadLine());
        }

    }

    static void StartServer()
    {
        Task.Factory.StartNew(() =>
        {
            var server = new NamedPipeServerStream("PipesOfPiece");
            server.WaitForConnection();
            StreamReader reader = new StreamReader(server);
            StreamWriter writer = new StreamWriter(server);
            while (true)
            {
                var line = reader.ReadLine();
                writer.WriteLine("server recieved:" + line);
                writer.Flush();
            }
        });
    }

}

 

相关文章:

  • 2021-05-30
  • 2022-01-24
  • 2021-11-27
  • 2021-08-06
  • 2022-12-23
  • 2022-12-23
  • 2021-08-16
猜你喜欢
  • 2021-04-14
  • 2022-12-23
  • 2022-12-23
  • 2022-02-22
  • 2021-10-29
  • 2021-07-25
相关资源
相似解决方案