????????在之前的文章中已經(jīng)介紹如何使用Beetlex.XRCP組件進(jìn)行接口/委托遠(yuǎn)程調(diào)用；由于組件BeetleX.XRPC.Clients支持.NETStandard2，因此Xamarin同樣可以使用它來實(shí)現(xiàn)基于接口/委托的數(shù)據(jù)交互通訊。

????????接下來通過Xamarin實(shí)現(xiàn)一個簡單的移動程序，并通過XRPC的功能基于遠(yuǎn)程接口調(diào)用的方式登陸到服務(wù)端，然后再通過委托遠(yuǎn)程調(diào)用的方式來相互獲取對方的系統(tǒng)和時間信息。

服務(wù)端定義

????????服務(wù)主要定義一個用戶接口并實(shí)現(xiàn)登陸方法，然后注冊一個委托用于返回服務(wù)信息和時間給客戶端。

class Program {static void Main(string[] args){var builder = new HostBuilder().ConfigureServices((hostContext, services) =>{//開services.UseXRPC(s =>{s.ServerOptions.LogLevel = BeetleX.EventArgs.LogType.Info;s.ServerOptions.DefaultListen.Port = 9090;s.ServerOptions.DefaultListen.SSL = true;//開啟SSLs.ServerOptions.DefaultListen.CertificateFile = "test.pfx";s.ServerOptions.DefaultListen.CertificatePassword = "123456";s.RPCOptions.ParameterFormater = new JsonPacket();//default messagepack},s =>{//綁定一個委托s.AddDelegate<Func<Task<string>>>(() =>{return Task.FromResult($"{Environment.OSVersion} {DateTime.Now}");});}, typeof(Program).Assembly);});builder.Build().Run();} } //定義登陸接口 public interface IUser {Task<string> Login(string name, string pwd); }[Service(typeof(IUser))] public class HelloImpl : IUser {//實(shí)現(xiàn)登陸方法public Task<string> Login(string name, string pwd){var context = XRPCServer.EventToken;GetClientTime(context.Server, context.Session);Console.WriteLine($"{name} login at {context.Session.RemoteEndPoint}");return $"{name} login {DateTime.Now}".ToTask();}//定時從登陸客戶端獲取系統(tǒng)和時間信息并打印private async Task GetClientTime(XRPCServer server, BeetleX.ISession session){//創(chuàng)建對應(yīng)session的遠(yuǎn)程委托代理var action = server.Delegate<Func<Task<string>>>(session);while (true){//調(diào)用委托var result = await action();Console.WriteLine($"{result}@{session.RemoteEndPoint}");await Task.Delay(1000);}} }

以上服務(wù)使用了TLS作為基礎(chǔ)安全通訊。啟動服務(wù)后會顯示以下日志

客戶端定義

??????? Xamarin下使用XRPC只需要引用BeetleX.XRPC.Clients即可，引用完成后可以定義XRPCClient對象來進(jìn)行通訊。

public partial class MainPage : ContentPage {public MainPage(){InitializeComponent();//定義XRPC客戶端mClient = new BeetleX.XRPC.Clients.XRPCClient("192.168.1.18", 9090, "beetlex");mClient.CertificateValidationCallback = (s, certificate, chain, sslPolicyErrors) => true;mClient.Options.ParameterFormater = new JsonPacket();//創(chuàng)建接口遠(yuǎn)程接口代理mUser = mClient.Create<IUser>();//定義委托給服務(wù)端調(diào)用mClient.AddDelegate<Func<Task<string>>>(() =>{return Task.FromResult($"{Environment.OSVersion} {DateTime.Now}");});//創(chuàng)建對應(yīng)服務(wù)端的遠(yuǎn)程委托代理mGetTime = mClient.Delegate<Func<Task<string>>>();}private Func<Task<string>> mGetTime;private static IUser mUser;private static BeetleX.XRPC.Clients.XRPCClient mClient;private async void Button_Clicked(object sender, EventArgs e){try{if (string.IsNullOrEmpty(userName.Text)){await DisplayAlert("Error", "Enter you name!", "OK");return;}//登陸var result = await mUser.Login(userName.Text, userPwd.Text);this.layoutGrid.IsVisible = false;this.cmdLogin.IsVisible = false;OnGetTime();}catch (Exception e_){await DisplayAlert("Error", e_.Message, "OK");}}private async Task OnGetTime(){try{//定時獲取服務(wù)和時間信息while (true){var result = await mGetTime();txtResult.Text = result;await Task.Delay(1000);}}catch (Exception e_){await DisplayAlert("Error", e_.Message, "OK");this.layoutGrid.IsVisible = true;this.cmdLogin.IsVisible = true;}} }

BeetleX

開源跨平臺通訊框架(支持TLS)
輕松實(shí)現(xiàn)高性能:tcp、http、websocket、redis、rpc和網(wǎng)關(guān)等服務(wù)應(yīng)用

https://beetlex.io

如果你想了解某方面的知識或文章可以把想法發(fā)送到

henryfan@msn.com|admin@beetlex.io

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的Xamarin使XRPC实现接口/委托远程调用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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