一般遠(yuǎn)程接口調(diào)用的服務(wù)都是基于客戶端主動(dòng)調(diào)用服務(wù)端，由服務(wù)端來提供相關(guān)的接口服務(wù)；在新版本的XRPC中引入了一個(gè)新的功能，即接口雙向通訊，組件提供服務(wù)創(chuàng)建客戶會(huì)話的接口代理并調(diào)用客戶提供的接口服務(wù)。接下來介紹如何通過XRPC來使用接口雙向通訊的應(yīng)用，并實(shí)現(xiàn)服務(wù)端調(diào)用WFP/WINFROM這些客戶端的本地方法。

引用組件

組件提供兩個(gè)包分別是:BeetleX.XRPC和BeetleX.XRPC.Clients；前者是在.net core上使用，而后者則提供給WFP/WINFROM使用.在0.8.2.3版本開始支持接口雙向調(diào)用功能。

使用

組件是以接口作為基礎(chǔ)通訊單元，所以必須以接口的方式來描述服務(wù)調(diào)用邏輯。接下來實(shí)現(xiàn)一個(gè)簡(jiǎn)單的接口，客戶端向服務(wù)調(diào)用注冊(cè)方法，服務(wù)端在接受客戶注冊(cè)后創(chuàng)建一個(gè)會(huì)話代理并調(diào)用獲取客戶端的時(shí)間。接口定義如下:

public interface IUser{Task Login(string name);Task<DateTime> GetTime();}

接口比較簡(jiǎn)單分別是Login和GetTime，接下來會(huì)分別在服務(wù)端和客戶端實(shí)現(xiàn)這一接口，并進(jìn)行一個(gè)雙向調(diào)用。

服務(wù)端實(shí)現(xiàn)

[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 Task<DateTime> 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.GetClient<IUser>(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;}}

代碼比較簡(jiǎn)單，在登陸方法中創(chuàng)建一個(gè)異步方法，并在方法中創(chuàng)建一個(gè)IUser針對(duì)當(dāng)前會(huì)話的一個(gè)代理，然后循環(huán)調(diào)用客戶端方法獲取相應(yīng)的時(shí)間。

客戶端實(shí)現(xiàn)

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.Register<IUser>(new Program());var user = client.Create<IUser>();user.Login("henry");System.Threading.Thread.Sleep(-1);}public Task<DateTime> GetTime(){return Task.FromResult(DateTime.Now);}public Task Login(string name){return Task.CompletedTask;}}

比起服務(wù)端，客戶端所需要的代碼就更簡(jiǎn)單了；通過XRPCClient.Create注冊(cè)相關(guān)接口的本地實(shí)現(xiàn)類。客戶端調(diào)用user.Login("henry");后服務(wù)端就是不停地向客戶獲取時(shí)間。通過運(yùn)行程序可以看到以下運(yùn)行結(jié)果:

以上完整代碼可以從以下連接獲取:?https://github.com/IKende/BeetleX-Samples/tree/master/XRPC.InterfaceTwoWay

聊天服務(wù)

上面已經(jīng)描述了接口雙向調(diào)用的便利性，接下來通過接口雙向調(diào)用快速地實(shí)現(xiàn)一個(gè)聊天服務(wù)。

public interface IUser{Task Login(string name);Task Talk(string name, string message);Task Exit(string name);}

以上是一個(gè)用戶聊天的行為接口，分別是登陸、退出和發(fā)送消息。接下來通過服務(wù)端和客戶端實(shí)現(xiàn)這一接口即可完成一個(gè)簡(jiǎn)單的聊天服務(wù)。

服務(wù)端實(shí)現(xiàn)

[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.GetClient<IUser>(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.GetClient<IUser>(session);user.Talk(session.Name, message);}}return Task.CompletedTask;}}

服務(wù)端主要實(shí)現(xiàn)了兩個(gè)方法，分別是登陸和發(fā)送消息；兩個(gè)方法的都基本一樣，在方法調(diào)用里面獲取所有會(huì)話的IUser代理，并執(zhí)行相關(guān)方法即可。為什么Exit這個(gè)方法沒有實(shí)現(xiàn)呢，主要是服務(wù)通過監(jiān)聽連接斷開事件進(jìn)行處理，代碼如下:

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.GetClient<IUser>(session);user.Exit(e.Session.Name);}}};},typeof(Program).Assembly);});builder.Build().Run();}

這樣一個(gè)簡(jiǎn)單的聊天服務(wù)就完成，接下來看一下客戶端同樣實(shí)現(xiàn)這一接口來完成功能。

客戶端實(shí)現(xiàn)

/// <summary>/// MainWindow.xaml 的交互邏輯/// </summary>public 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.Register<IUser>(this);mUser = mClient.Create<IUser>();txtMessages.Document.Blocks.Clear();}private async void CmdLogin_Click(object sender, RoutedEventArgs e){try{if (string.IsNullOrEmpty(txtName.Text)){MessageBox.Show("請(qǐng)輸入登錄名稱!");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);}}}

以上是一個(gè)WPF窗體的實(shí)現(xiàn)，代碼功能是不是很簡(jiǎn)單，通過遠(yuǎn)程方法調(diào)用，服務(wù)端可以直接調(diào)用客戶端窗體的方法代碼。接下來看一下實(shí)際運(yùn)行效果：

這樣一個(gè)簡(jiǎn)單了聊天服務(wù)就完成了，看上去是不是非常簡(jiǎn)單；如果需要下載示例的完整代碼可以訪問: https://github.com/IKende/BeetleX-Samples/tree/master/XRPC.WFPChat

通過接口雙向調(diào)用的功能，你可以實(shí)現(xiàn)更簡(jiǎn)單的通訊應(yīng)用開發(fā)，因?yàn)槟阍僖膊恍枰x消息標(biāo)記來區(qū)分處理行為，可以大大地提高開發(fā)效率。

總結(jié)

以上是生活随笔為你收集整理的XRPC接口双向调用的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。