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

简介: WebSockets是一种双向通信协议,或TCP连接上的持久通信通道,由许多游戏,具有聊天功能的应用程序和实时应用程序(如股票行情)利用的非常强大的协议。 在这篇博文中,我们将讨论如何构建一个简单的Xamarin聊天室应用程序,该应用程序将利用并连接到ASP.NET Core WebSocket服务。

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

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

入门

  1. 从GitHub下载服务器源代码(这里)。
  2. 在您的机器上安装dotnet core 2.0以运行服务器。这里查找说明
  3. 一旦你进入源目录,在终端运行dotnet run。
  4. 访问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对象建立连接,此对象将随后用于与服务器通信

 

点击(此处)折叠或打开

  1. var client = new ClientWebSocket();
  2. ...
  3. async void ConnectToServerAsync()
  4. {
  5.     await client.ConnectAsync(new Uri("ws://10.0.2.2:5000"), cts.Token);
  6.     UpdateClientState();
  7.     await Task.Factory.StartNew(async () =>
  8.     {
  9.         while (true)
  10.         {
  11.             await ReadMessage();
  12.         }
  13.     }, cts.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default);
  14. }

注意我正在使用IP地址10.0.2.2使用ConnectAsync方法连接到服务器。 这是Android模拟器上的默认主机IP,我们不能使用localhost或默认的localhost IP。

在Mac上运行的iOS模拟器允许我们使用localhost,但是在iOS / Android设备上运行时,我们必须使用主机名/ IP地址。

阅读消息

使用服务器打开连接后,我们可以使用ReceiveAsync方法开始监听传入的消息。 在这种情况下,消息是UTF8编码的字节数组; 当我们收到消息时,我们必须将字节转换为可读字符串,并忽略不是文本的任何内容

 

点击(此处)折叠或打开

  1. async Task ReadMessage()
  2. {
  3.     WebSocketReceiveResult result;
  4.     var message = new ArraySegment(new byte[4096]);
  5.     do
  6.     {
  7.         result = await client.ReceiveAsync(message, cts.Token);
  8.         if (result.MessageType != WebSocketMessageType.Text)
  9.             break;
  10.         var messageBytes = message.Skip(message.Offset).Take(result.Count).ToArray();
  11.         string receivedMessage = Encoding.UTF8.GetString(messageBytes);
  12.         Console.WriteLine("Received: {0}", receivedMessage);
  13.     }
  14.     while (!result.EndOfMessage);
  15. }

发送消息

要发送消息,我们首先需要将文本转换为字节数组(使用UTF8编码)并调用SendAsync方法。 另外,SendAsync需要参数来标识消息类型,如果是消息的结尾。

 

点击(此处)折叠或打开

  1. async void SendMessageAsync(string message)
  2. {
  3.     if (!CanSendMessage(message))
  4.         return;
  5.     var byteMessage = Encoding.UTF8.GetBytes(message);
  6.     var segmnet = new ArraySegment(byteMessage);
  7.     await client.SendAsync(segmnet, WebSocketMessageType.Text, true, cts.Token);
  8. }

结束语

在这篇文章中,我们审查了使用Xamarin应用程序中的Web套接字实时连接,接收和发送消息的必要代码。 您可以在MSDN上详细了解可用的API,并在GitHub上下载完整的示例Xamarin.Forms应用程序。 

目录
相关文章
|
1月前
|
网络协议 JavaScript 前端开发
WebSocket:实现客户端与服务器实时通信的技术
WebSocket:实现客户端与服务器实时通信的技术
|
1月前
|
存储 设计模式 JavaScript
第六篇 再谈观察者模式的具体应用,如监听一个class其中一个属性,如websocket中onmessage的实现
第六篇 再谈观察者模式的具体应用,如监听一个class其中一个属性,如websocket中onmessage的实现
|
1月前
|
网络协议 Java Go
【Go语言专栏】Go语言中的WebSocket实时通信应用
【4月更文挑战第30天】Go语言(Golang)是Google开发的编程语言,适用于云计算、微服务等领域。本文介绍了WebSocket,一种实现浏览器与服务器全双工通信的协议,其特点是实时性、全双工和轻量级。在Go中实现WebSocket,可以使用gorilla/websocket库。示例展示了如何创建服务器端和客户端,实现消息的收发。WebSocket广泛应用于聊天、游戏、通知推送和实时数据同步等场景。学习Go语言中的WebSocket对于开发实时通信应用至关重要。
|
4天前
|
前端开发 JavaScript 安全
集成WebSocket在Spring Boot中可以用于实现实时的双向通信
集成WebSocket在Spring Boot中可以用于实现实时的双向通信
18 4
|
14天前
|
移动开发 监控 API
WebSocket API 详解与应用指南
WebSocket API 是HTML5的一种技术,它允许服务器与客户端建立持久的全双工连接,改变传统HTTP请求-响应模式,实现双向通信。API包括WebSocket构造函数、连接状态属性(如readyState)、方法(如send和close)及事件(如onopen和onmessage)。它简化了实时Web应用程序的开发,适用于在线聊天、实时数据监控等场景。
33 5
|
14天前
|
监控 网络协议 JavaScript
WebSocket技术详解与应用指南
WebSocket是全双工TCP协议,解决HTTP的单向通信问题,允许服务器主动推送信息。本文档介绍了WebSocket的基本概念、工作原理(基于HTTP握手,通过帧进行数据通信)、应用场景(实时聊天、在线游戏、数据监控等)和实现方法(客户端使用JavaScript API,服务器端有多种编程语言库支持)。学习WebSocket能提升Web应用的实时性和交互性。
24 1
|
23天前
|
负载均衡 安全 Java
Java一分钟之-WebSocket:实时通信协议
【6月更文挑战第1天】WebSocket是实现客户端与服务器长连接、双向通信的协议,简化实时数据传输。Java中的WebSocket实现基于JSR 356。本文涵盖WebSocket基础(持久连接、双向通信、低延迟)、工作流程、常见问题(安全、连接管理、数据编码)及Java实现示例,强调错误处理、心跳机制和资源管理的最佳实践。
56 6
|
1月前
|
监控 安全 API
WebSocket通过建立一个持久的连接实现实时双向通信
【5月更文挑战第2天】WebSocket通过建立一个持久的连接实现实时双向通信
32 4
|
1月前
|
JavaScript PHP UED
【PHP开发专栏】PHP与WebSocket实时通信
【4月更文挑战第30天】本文介绍了PHP实现WebSocket实时通信的原理、使用方法和实际案例。WebSocket是基于HTTP的全双工通信协议,PHP 5.4以上版本支持WebSocket,可通过内置函数或第三方库如Socket.io、PHP-WebSocket来实现。文章详细展示了创建WebSocket服务器和客户端的PHP代码示例,并提及在PHP中使用Socket.io库进行实时通信。
|
1月前
|
缓存 监控 前端开发
【Go 语言专栏】Go 语言中的 WebSocket 实时通信应用
【4月更文挑战第30天】本文探讨了Go语言在WebSocket实时通信中的应用。WebSocket作为全双工通信协议,允许持续的双向通信。Go语言凭借其高效和并发特性,适合构建实时应用。文中概述了在Go中实现WebSocket的基本步骤,包括服务器和客户端的建立与通信,并列举了实时聊天、数据监控和在线协作等应用案例。同时,强调了消息格式、并发处理、错误处理和安全性的注意事项。通过数据压缩、缓存管理和连接管理等策略可优化性能。Go语言还能与数据库和前端框架结合,提升用户体验。总之,Go语言为WebSocket实时通信提供了强大支持,有望在更多领域发挥作用。