WebSockets是一种双向通信协议,或TCP连接上的持久通信通道,由许多游戏,具有聊天功能的应用程序和实时应用程序(如股票行情)利用的非常强大的协议。
在这篇博文中,我们将讨论如何构建一个简单的Xamarin聊天室应用程序,该应用程序将利用并连接到ASP.NET Core WebSocket服务。
入门
- 从GitHub下载服务器源代码(这里)。
- 在您的机器上安装dotnet core 2.0以运行服务器。从这里查找说明。
- 一旦你进入源目录,在终端运行dotnet run。
- 访问http://locahosthost:5000 or http://(IP/Hostname):5000, 并确保您在网页上看到简单的聊天(Easy chat)服务消息。
构建移动客户端
我们开始创建一个利用共享项目(也可以使用.NET标准库)的空白Xamarin.Forms应用程序,并将其称为EasyChat。我们将在我们的移动应用程序中使用System.Net.WebSockets.Client NuGet包来和服务器进行通信。
一旦创建项目,我们可以使用MainPage.xaml作为一个简单的登录页面,从中我们将导航到聊天室。
接下来,我们可以为聊天室添加一个新页面,ChatPage.xaml,以及一个名为ChatPageViewModel.cs的非常简单的View Model来处理WebSocket的客户端代码。 在这个视图模型中,我们有代码连接到服务器并发送和接收消息。
连接到插座Socket
使用System.Net.WebSockets.ClietWebSocket对象建立连接,此对象将随后用于与服务器通信。
点击(此处)折叠或打开
- var client = new ClientWebSocket();
- ...
- async void ConnectToServerAsync()
- {
- await client.ConnectAsync(new Uri("ws://10.0.2.2:5000"), cts.Token);
- UpdateClientState();
- await Task.Factory.StartNew(async () =>
- {
- while (true)
- {
- await ReadMessage();
- }
- }, cts.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default);
- }
注意我正在使用IP地址10.0.2.2使用ConnectAsync方法连接到服务器。 这是Android模拟器上的默认主机IP,我们不能使用localhost或默认的localhost IP。
在Mac上运行的iOS模拟器允许我们使用localhost,但是在iOS / Android设备上运行时,我们必须使用主机名/ IP地址。
阅读消息
使用服务器打开连接后,我们可以使用ReceiveAsync方法开始监听传入的消息。 在这种情况下,消息是UTF8编码的字节数组; 当我们收到消息时,我们必须将字节转换为可读字符串,并忽略不是文本的任何内容。
点击(此处)折叠或打开
- async Task ReadMessage()
- {
- WebSocketReceiveResult result;
- var message = new ArraySegment(new byte[4096]);
- do
- {
- result = await client.ReceiveAsync(message, cts.Token);
- if (result.MessageType != WebSocketMessageType.Text)
- break;
- var messageBytes = message.Skip(message.Offset).Take(result.Count).ToArray();
- string receivedMessage = Encoding.UTF8.GetString(messageBytes);
- Console.WriteLine("Received: {0}", receivedMessage);
- }
- while (!result.EndOfMessage);
- }
发送消息
要发送消息,我们首先需要将文本转换为字节数组(使用UTF8编码)并调用SendAsync方法。 另外,SendAsync需要参数来标识消息类型,如果是消息的结尾。
点击(此处)折叠或打开
- async void SendMessageAsync(string message)
- {
- if (!CanSendMessage(message))
- return;
- var byteMessage = Encoding.UTF8.GetBytes(message);
- var segmnet = new ArraySegment(byteMessage);
- await client.SendAsync(segmnet, WebSocketMessageType.Text, true, cts.Token);
- }
结束语
在这篇文章中,我们审查了使用Xamarin应用程序中的Web套接字实时连接,接收和发送消息的必要代码。 您可以在MSDN上详细了解可用的API,并在GitHub上下载完整的示例Xamarin.Forms应用程序。