【Xamarin】使用WebSocket开发实时通信应用程序-白红宇

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。我们将在我们的移动应用程序中使用 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]);

{

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，并在上下载完整的示例Xamarin.Forms应用程序。