【Xamarin】使用WebSocket开发实时通信应用程序

WebSockets是一种双向通信协议，或TCP连接上的持久通信通道，由许多游戏，具有聊天功能的应用程序和实时应用程序（如股票行情）利用的非常强大的协议。

在这篇博文中，我们将讨论如何构建一个简单的Xamarin聊天室应用程序，该应用程序将利用并连接到ASP.NET Core WebSocket服务。

入门

1. 从GitHub下载服务器源代码()。
2. 在您的机器上安装dotnet core 2.0以运行服务器。从查找说明。
3. 一旦你进入源目录，在终端运行dotnet run。
4. 访问 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]);
    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，并在上下载完整的示例Xamarin.Forms应用程序。