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应用程序。