StreamJsonRpc使用TCP数据流通讯

　　StreamJsonRpc  是微软维护的开源 JSON-RPC  的 .NET  库使用非常方便，常用的操作方式是服务器端通过 JsonRpc  的 Attach  静态函数与一个本地类实例实现对外接口，客户端通过 Attach  方法附加到一个 Stream  ，然后调用 Invoke  或 InvokeAsync  函数实现函数的基本操作，详细介绍可参阅https://www.cnblogs.com/willick/p/13233704.html 精致码农  相关文章。 服务器端
　　此代码在 精致码农  示例基础上进行修改，通过示例可以看到使用 .NET  的 Tcp  模式建立服务器也是很方便的，因为 JsonRpc  的 Attach  函数的形参为 Stream  对象，只需要在收到客户端连接后获取客户端对象的 Stream  传入函数即可。 using StreamJsonRpc; using System; using System.IO.Pipes; using System.Net.Sockets; using System.Threading.Tasks;  namespace StreamSample.Server {     class Program     {         static async Task Main(string[] args)         {             int clientId = 1;              TcpListener listener = new TcpListener(System.Net.IPAddress.Any, 6600);             listener.Start();              while (true)             {                 Console.WriteLine(＂等待客户端连接...＂);                 TcpClient client = await listener.AcceptTcpClientAsync();                 NetworkStream stream = client.GetStream();                 Console.WriteLine(#34;已与客户端 #{clientId} 建立连接＂);                  _ = TcpResponseAsync(stream, clientId);                  clientId++;             }         }          static async Task TcpResponseAsync(NetworkStream stream, int clientId)         {             var jsonRpc = JsonRpc.Attach(stream, new GreeterServer());             await jsonRpc.Completion;             Console.WriteLine(#34;客户端 #{clientId} 的已断开连接＂);             jsonRpc.Dispose();             await stream.DisposeAsync();         }          static async Task ResponseAsync(NamedPipeServerStream stream, int clientId)         {             var jsonRpc = JsonRpc.Attach(stream, new GreeterServer());             await jsonRpc.Completion;             Console.WriteLine(#34;客户端 #{clientId} 的已断开连接＂);             jsonRpc.Dispose();             await stream.DisposeAsync();         }     }      public class GreeterServer     {         public string SayHello(string name)         {             Console.WriteLine(#34;收到【{name}】的问好，并回复了他＂);             return #34;您好，{name}！＂;         }     } }客户端
　　与服务器端相似，我们在连接到服务器后获取 TcpClient  对象的 Stream  传入 Attach  函数即可，具体代码如下： using StreamJsonRpc; using System; using System.IO.Pipes; using System.Net; using System.Net.Sockets; using System.Threading.Tasks;  namespace StreamSample.Client {     class Program     {         static string GetMachineNameFromIPAddress(string ipAddress)         {             string machineName = null;             try             {                 IPHostEntry hostEntry = Dns.GetHostEntry(ipAddress);                 machineName = hostEntry.HostName;             }             catch (Exception ex)             {                 System.Console.WriteLine(ex.Message);             }             return machineName;         }          static string GetIPAddressFromMachineName(string machineName)         {             string ipAdress = string.Empty;             try             {                 IPAddress[] ipAddresses = Dns.GetHostAddresses(machineName);                  IPAddress ip = ipAddresses[1];                  ipAdress = ip.ToString();             }             catch (Exception ex)             {                 System.Console.WriteLine(ex.Message);             }             return ipAdress;         }          static async Task Main(string[] args)         {             TcpClient tcpClient = new TcpClient(＂192.168.31.67＂, 6600);             var stream = tcpClient.GetStream();              Console.WriteLine(＂正在连接服务器...＂);             Console.WriteLine(＂已建立连接！＂);              Console.WriteLine(＂我是精致码农，开始向服务端问好...＂);             var jsonRpc = JsonRpc.Attach(stream);             var message = await jsonRpc.InvokeAsync(＂SayHello＂, ＂精致码农＂);             Console.WriteLine(#34;来自服务端的响应：{message}＂);              Console.ReadKey();         }     } } 程序运行效果
　　服务器端
　　客户端