制作网站的软件什么好用,沥林行业网站建设,上海建企业网站,网络推广专员任职要求一般远程接口调用的服务都是基于客户端主动调用服务端#xff0c;由服务端来提供相关的接口服务#xff1b;在新版本的XRPC中引入了一个新的功能#xff0c;即接口双向通讯#xff0c;组件提供服务创建客户会话的接口代理并调用客户提供的接口服务。接下来介绍如何通过XRPC… 一般远程接口调用的服务都是基于客户端主动调用服务端由服务端来提供相关的接口服务在新版本的XRPC中引入了一个新的功能即接口双向通讯组件提供服务创建客户会话的接口代理并调用客户提供的接口服务。接下来介绍如何通过XRPC来使用接口双向通讯的应用并实现服务端调用WFP/WINFROM这些客户端的本地方法。引用组件组件提供两个包分别是:BeetleX.XRPC和BeetleX.XRPC.Clients前者是在.net core上使用而后者则提供给WFP/WINFROM使用.在0.8.2.3版本开始支持接口双向调用功能。使用组件是以接口作为基础通讯单元所以必须以接口的方式来描述服务调用逻辑。接下来实现一个简单的接口客户端向服务调用注册方法服务端在接受客户注册后创建一个会话代理并调用获取客户端的时间。接口定义如下: public interface IUser{Task Login(string name);TaskDateTime GetTime();}接口比较简单分别是Login和GetTime接下来会分别在服务端和客户端实现这一接口并进行一个双向调用。服务端实现 [Service(typeof(IUser))]public class Program : IUser{static void Main(string[] args){var builder new HostBuilder().ConfigureServices((hostContext, services) {services.UseXRPC(s {s.ServerOptions.LogLevel BeetleX.EventArgs.LogType.Warring;s.ServerOptions.DefaultListen.Port 9090;s.RPCOptions.ParameterFormater new JsonPacket();//default messagepack},typeof(Program).Assembly);});builder.Build().Run();}public TaskDateTime GetTime(){return DateTime.Now.ToTask();}public Task Login(string name){Console.WriteLine(${name} login);var token XRPCServer.EventToken;Task.Run(async () {IUser user token.Server.GetClientIUser(token.Session);while (true){var time await user.GetTime();Console.WriteLine(${name}[{token.Session.RemoteEndPoint}] time is:{time});//await Task.Delay(1000);}});return Task.CompletedTask;}}代码比较简单在登陆方法中创建一个异步方法并在方法中创建一个IUser针对当前会话的一个代理然后循环调用客户端方法获取相应的时间。客户端实现 class Program : IUser{static XRPCClient client;static void Main(string[] args){client new XRPCClient(192.168.2.18, 9090);client.PingTimeout 5;client.Options.ParameterFormater new JsonPacket();client.RegisterIUser(new Program());var user client.CreateIUser();user.Login(henry);System.Threading.Thread.Sleep(-1);}public TaskDateTime GetTime(){return Task.FromResult(DateTime.Now);}public Task Login(string name){return Task.CompletedTask;}}比起服务端客户端所需要的代码就更简单了通过XRPCClient.Create注册相关接口的本地实现类。客户端调用user.Login(henry);后服务端就是不停地向客户获取时间。通过运行程序可以看到以下运行结果:以上完整代码可以从以下连接获取: https://github.com/IKende/BeetleX-Samples/tree/master/XRPC.InterfaceTwoWay聊天服务上面已经描述了接口双向调用的便利性接下来通过接口双向调用快速地实现一个聊天服务。 public interface IUser{Task Login(string name);Task Talk(string name, string message);Task Exit(string name);}以上是一个用户聊天的行为接口分别是登陆、退出和发送消息。接下来通过服务端和客户端实现这一接口即可完成一个简单的聊天服务。服务端实现 [EventNext.Service(typeof(IUser))]public class UserImpl : IUser{public Task Exit(string name){return Task.CompletedTask;}public Task Login(string name){var token XRPCServer.EventToken;token.Session.Name name;foreach (var session in token.Server.Server.GetOnlines()){if (!string.IsNullOrEmpty(session.Name)){IUser user token.Server.GetClientIUser(session);user.Login(name);}}return Task.CompletedTask;}public Task Talk(string name, string message){var token XRPCServer.EventToken;if (string.IsNullOrEmpty(token.Session.Name)){throw new Exception(登陆无效);}foreach (var session in token.Server.Server.GetOnlines()){if (!string.IsNullOrEmpty(session.Name)){IUser user token.Server.GetClientIUser(session);user.Talk(session.Name, message);}}return Task.CompletedTask;}}服务端主要实现了两个方法分别是登陆和发送消息两个方法的都基本一样在方法调用里面获取所有会话的IUser代理并执行相关方法即可。为什么Exit这个方法没有实现呢主要是服务通过监听连接断开事件进行处理代码如下: static void Main(string[] args){var builder new HostBuilder().ConfigureServices((hostContext, services) {services.UseXRPC(s {s.ServerOptions.LogLevel BeetleX.EventArgs.LogType.Debug;s.ServerOptions.DefaultListen.Port 9090;s.RPCOptions.ParameterFormater new JsonPacket();//default messagepacks.RPCDisconnect (o, e) {foreach (var session in e.Server.GetOnlines()){if (session ! e.Session !string.IsNullOrEmpty(session.Name)){IUser user s.GetClientIUser(session);user.Exit(e.Session.Name);}}};},typeof(Program).Assembly);});builder.Build().Run();}这样一个简单的聊天服务就完成接下来看一下客户端同样实现这一接口来完成功能。客户端实现 /// summary/// MainWindow.xaml 的交互逻辑/// /summarypublic partial class MainWindow : Window, IUser{public MainWindow(){InitializeComponent();}public Task Login(string name){AddMessage(name, login);return Task.CompletedTask;}public Task Exit(string name){AddMessage(name, exit);return Task.CompletedTask;}public Task Talk(string name, string message){AddMessage(name, message);return Task.CompletedTask;}private BeetleX.XRPC.Clients.XRPCClient mClient;private IUser mUser;private void Window_Loaded(object sender, RoutedEventArgs e){mClient new BeetleX.XRPC.Clients.XRPCClient(192.168.2.18, 9090);mClient.Options.ParameterFormater new JsonPacket();mClient.RegisterIUser(this);mUser mClient.CreateIUser();txtMessages.Document.Blocks.Clear();}private async void CmdLogin_Click(object sender, RoutedEventArgs e){try{if (string.IsNullOrEmpty(txtName.Text)){MessageBox.Show(请输入登录名称!);return;}await mUser.Login(txtName.Text);MessageBox.Show(登陆成功!);}catch (Exception e_){MessageBox.Show(e_.Message);}}private async void CmdTalk_Click(object sender, RoutedEventArgs e){try{await mUser.Talk(null, txtTalk.Text);}catch (Exception e_){MessageBox.Show(e_.Message);}}}以上是一个WPF窗体的实现代码功能是不是很简单通过远程方法调用服务端可以直接调用客户端窗体的方法代码。接下来看一下实际运行效果这样一个简单了聊天服务就完成了看上去是不是非常简单如果需要下载示例的完整代码可以访问: https://github.com/IKende/BeetleX-Samples/tree/master/XRPC.WFPChat通过接口双向调用的功能你可以实现更简单的通讯应用开发因为你再也不需要定义消息标记来区分处理行为可以大大地提高开发效率。
