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();
}
}
}
页面更新:2024-05-15
本站资料均由网友自行发布提供,仅用于学习交流。如有版权问题,请与我联系,QQ:4156828
© CopyRight 2008-2024 All Rights Reserved. Powered By bs178.com 闽ICP备11008920号-3
闽公网安备35020302034844号