使用RxSwift进行长轮询
RxSwift是一个基于响应式编程的Swift框架，它提供了一种优雅的方式来处理异步事件流和数据流。使用RxSwift进行长轮询是一种常见的应用场景，可以实现实时更新数据的功能。
长轮询是一种客户端与服务器之间的通信方式，客户端发送一个请求到服务器，服务器在有新数据时立即返回响应，如果没有新数据，服务器会保持连接并等待新数据到达后再返回响应。这种方式可以实现实时更新数据的效果，适用于需要及时获取数据变化的场景，如聊天应用、实时监控等。
在使用RxSwift进行长轮询时，可以通过创建一个Observable来表示服务器的响应流。客户端可以订阅这个Observable来获取服务器的响应。当服务器有新数据时，Observable会发出一个事件，客户端可以在订阅的回调中处理这个事件，更新UI或执行其他操作。
为了实现长轮询，可以使用RxSwift提供的操作符和方法。例如，可以使用Observable.create方法创建一个Observable，然后在内部使用URLSession发送请求并接收服务器的响应。可以使用flatMap操作符将每个响应转换为一个Observable，然后使用retryWhen操作符来处理连接断开或其他错误的情况，保持连接并重新发送请求。
在腾讯云中，可以使用腾讯云的云服务器（CVM）作为服务器，使用腾讯云的消息队列（CMQ）来实现长轮询。具体步骤如下：
- 创建一个CVM实例作为服务器，配置好网络和安全组规则。
- 在CVM实例上安装并配置好所需的软件环境，包括RxSwift和其他依赖。
- 使用RxSwift创建一个Observable，发送长轮询请求到CMQ队列。
- 在Observable的订阅回调中处理服务器的响应，更新UI或执行其他操作。
- 使用
retryWhen操作符处理连接断开或其他错误的情况，保持连接并重新发送请求。
腾讯云相关产品和产品介绍链接地址：
- 云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 消息队列（CMQ）：https://cloud.tencent.com/product/cmq
请注意，以上答案仅供参考，具体实现方式可能因实际需求和环境而异。
相关·内容
Google Drive使用什么技术来实现实时？
当我输入多个用户正在访问的Google Drive文档时，Chrome Developer Tools Network选项卡显示没有WebSockets。
我发现两种最常见的AJAX调用类型要么是"bind?“还是“保存？”在URL中。“保存？”每次输入时都会发出POST请求，这是有意义的-正常的AJAX用于将更新发送到服务器。
当另一个用户键入时，最近的"bind?“GET调用保持打开状态，通过该连接传输的数据量会增加。周期性地，“绑定”被关闭，新的绑定被打开，逻辑似乎是持续时间和数据大小的函数。
这不是长轮询，因为当服务器发
浏览 7提问于2016-01-29得票数 50
回答已采纳
1回答
我正在尝试构建一个在连接的计算机上执行命令的互联网服务。命令是通过基于web的仪表板启动的。
我目前使用Laravel运行REST，并构建了前端仪表板应用程序。
我被困在如何将客户端连接到云服务上了。客户端将运行不同的OSs (Windows、Mac、Linux)。
我有一个部分构建的.NET核心桌面客户端，但我不确定如何将它连接回服务器，以允许服务器发送命令。我希望能使这种通信接近实时，并可扩展到1000 s的端点。它还需要安全传输。(可能是HTTPS)
我偶然发现的一些技术是gRPC、WCF、Websockets。还发现了其他一些可能行不通的反向隧道技术。
这很可能会在完成后托管在Azur
浏览 0提问于2018-05-20得票数 -2
回答已采纳
4回答
我正在实施一个需要实时更新的系统。我一直在考虑某些场景，其中包括Comet。实现这一点，我看不出这与传统的长轮询有什么不同。
在这两种情况下，您都必须发送一个请求，然后服务器发送回一个响应。在浏览器中，您解释响应，然后启动一个新请求。
如果在这两种情况下我都需要打开和关闭连接，那么我为什么要使用comet呢？
浏览 0提问于2010-04-03得票数 17
回答已采纳
1回答
Angular 2长轮询
、、、
我正在尝试基于特定的REST接口实现长轮询请求。
请求：
GET url/?hash=9014532 HTTP/1.1
响应：
{
....
"hash": 88144687,
"value": 0
}
这样，服务器只会在请求后值发生更改时立即响应。
这样的请求需要前一个响应中的最后一个已知哈希值作为查询字符串。服务器延迟响应，直到哈希码不再等于REST客户端提供的哈希码，或者长轮询请求的配置超时(默认情况下为30秒)。在超时到期的情况下，请求返回一个304状态代码(未修改)，没有任何内容。
我现在有的是：
// AppComponent.ts
浏览 1提问于2018-02-23得票数 0
1回答
Amazon支持对可用消息的两种轮询模式:短轮询和长轮询。对于长轮询，使用者指定等待可用消息的超时时间为1-20秒。
根据
默认情况下，Amazon使用短轮询，只查询其服务器的一个子集(基于加权随机分布)，以确定是否有任何消息可用于响应。长时间轮询具有以下好处：
通过允许Amazon在发送响应之前等待队列中的消息可用，消除空响应。除非连接超时，否则对ReceiveMessage请求的响应至少包含一条可用消息，以ReceiveMessage操作中指定的最大消息数为限。
通过查询所有(而不是)Amazon服务器的子集来消除错误的空响应。
消息一旦可用就立即返回。
上述特
浏览 1提问于2018-07-23得票数 35
回答已采纳
1回答
我学习了rxSwift，我想为c长轮询服务器与这个模拟永久连接的服务的交互做服务。这是我写的，但在我看来，这个决定不是可以做得更好吗？有没有可能以某种方式重复观察到的结果，而不考虑错误，并取决于longpoll服务器的响应。
任何人都可以分享这个解决方案吗？或者帮你提建议？如何更好地组织？我希望看到一个更好的解决方案，因为我刚刚开始学习rxswift。
class LongPollingService {
public var messageReciver: PublishSubject<EventProtocol> = PublishSubject<EventPr
浏览 0提问于2017-02-20得票数 0
我使用内部AngularJS SPA，基于REST，问题是一些REST请求持续很长时间(~5-10秒)。
它是脊椎动物，但这与它无关-服务器需要从不同的源获取大量数据，并在响应前一起计算数据。
很好的解决方案是向用户显示请求状态，下面是WebSockets。
向用户显示请求状态的示例
请求发出
接受请求
从DB1获取数据
从DB2获取数据
处理数据
准备反应
但也有很多问题。
目前尚不清楚如何获取哪个API用户发送通知其状态的请求。可能的解决方案是拥有字典“API客户端”--“Websocket连接”，但是它可以在每一个重新连接上爆炸，并导致内存泄漏。不是吗？
浏览 0提问于2016-09-29得票数 5
回答已采纳
1回答
我是RxSwift的新手，我在我的应用程序中使用Moya和RxSwift进行联网。对于给定的ProviderType，我有用于每个请求的以下函数。
open func request(for target: ProviderType) -> Observable<Response> {
return provider.rx.request(target)
.filterSuccessfulStatusCodes()
.asObservable()
.catchError { [weak self] error in
浏览 58提问于2020-05-24得票数 0
我试过读一些文章，但我对这些概念还不太清楚。
有人想向我解释一下这些技术是什么吗？
长轮询
服务器发送事件
Websockets
彗星
每次我遇到的一件事是，服务器保持连接打开，并将数据推送到客户端。连接是如何保持打开的，客户端如何获得被推送的数据？(客户端如何使用数据，也许一些代码可能会有所帮助？)
现在，我该用哪一个来做实时应用呢？我听说过很多关于websockets的事情( socket.io是一个node.js库)，但为什么不使用node.js呢？
浏览 3提问于2012-06-18得票数 1163
回答已采纳
我正在用Java编写我自己的SignalR客户端，我面临着一些麻烦。
首先，我想实现PersistentConnection逻辑。我的服务器代码取自示例：
public class Battle : PersistentConnection
{
protected override Task OnConnectedAsync(IRequest request, string connectionId)
{
return Connection.Broadcast("Connection " + connectionId + " connec
浏览 1提问于2012-10-31得票数 3
我想创建一个web应用程序，其中的UI实时更新(或接近实时，因为你将得到)。UI的数据来自服务器。
我不想使用传统的HTTP请求，在这种请求中，我不断地向服务器发送请求以获取新数据。我宁愿打开一个连接，让服务器将数据推送到客户端。
我相信这就是发布者/订阅者模式。
我听人提到过zeromq、React和使用Websockets。但从我看过的所有例子中，我真的找不到任何关于这方面的东西。例如，zeromq提供了展示服务器和客户端的示例。是否实现服务器，然后在UI端使用websockets作为客户端？
像这样的东西将如何实现？
浏览 0提问于2015-11-19得票数 0
1回答
我有一个相对简单的要求编写一个windows服务，它执行以下任务，并希望使用一些关于最简单和最好的设计模式的建议。
从存储的proc的SQL server返回X行数
将每一行转换为消息并发送到TCP服务器。
发送完所有消息后，返回到步骤1。
需要存在一种机制，该机制检测TCP连接是否已进入半开放/关闭状态，例如在发送每批消息后发送消息和从服务器接收响应。如果没有响应返回，我们将需要重新连接和重新发送currect批。必须将消息传递给服务器。我们将把上一次轮询消息的ID存储在数据库中，这样，如果服务出于任何原因需要sto/crash/重新启动，我们就可以从中断的位置重新启动。
浏览 3提问于2014-05-26得票数 0
6回答
如何使用XAJAX和PHP编写实时聊天？
换句话说，有没有办法将xajax响应从服务器发送到多个客户机？或者，在客户端每隔几秒钟检查一次新消息是唯一的可能吗？
浏览 4提问于2009-06-08得票数 7
回答已采纳
根据，发起握手以接收实时通知的客户端可以在请求体中包含一个通知。这个建议可以有一个超时(“从发送连接消息到从服务器响应之间的最长时间(毫秒)”)。一个间隔(“如果没有从客户端接收到下一个连接消息，服务器将关闭会话的时间段。”)。我不明白这些参数以及它们如何应用到我的长轮询连接中。
为什么服务器会对客户端用于连接调用的超时感兴趣？它应该在通知可用时立即发送通知(即“实时”)。的确如此，正如预期的那样。即使我指定了一个非常短的超时，但实际上对我的连接使用了更长的超时时间，那么我仍然会收到发生在这两个时间点之间的通知，而不会有任何问题。而且，当我指定一个长超时时，我无论如何都会立即收到通知。这对
浏览 7提问于2017-08-30得票数 1
2回答
我们有一个web服务器，一个客户端应用程序和一个服务器应用程序与之反应。下图描述了该结构。
系统的工作原理是这样的:用户在客户端应用程序上更改某些内容，例如更改书名。它将向服务器应用程序发送一个TCP/IP包。我期望的结果是，web浏览器中显示的书名应该总是自动更改的。据我所知，web浏览器应该与web服务器保持长轮询请求。我的问题是，服务器应用程序如何将更改通知Web服务器？我应该使用哪种技术？
所有的应用程序都是用Java编写的。
浏览 2提问于2012-08-26得票数 0
3回答
我正在实现一个具有长时间轮询的消息传递系统，以便为我的用户提供实时更新。这样做，我注意到，一些网站，如Hotmail使用也xhr请求，但它们似乎有点不同，我已经实现了。
如图中所示，在我的实现中，客户端发出请求，服务器保存请求，直到新的数据更新可用为止。然后发回有效载荷并关闭连接。一旦收到，javascript就会向web服务器发送一个新请求。
Hotmail会在打开连接的同时将请求发回。这怎麽可能？?我怎样才能自己实现这一点呢？最重要的是，有什么区别？
谢谢。
浏览 3提问于2015-10-10得票数 3
回答已采纳
3回答
长轮询怎么会有帮助呢？
、、、
我不明白，如果XMLHttpRequest不允许访问部分内容，长轮询怎么会有帮助呢？
在哪里等待没有区别，是在客户端还是在服务器上。只有在完成后才能显示响应。因此，短轮询和长轮询看起来是一样的。
例如，如果我正在编写聊天应用程序，我既可以发送普通动态服务的GET请求，也可以发送Comet服务的get请求--结果是相同的，因为在servel完成响应之前，我无法获得内容。
我的错误在哪里？
更新1。
因此，"comet“概念的唯一含义是servlet (例如)应该在回答之前尽可能多地等待，尝试永远不要说”没有数据“？
那么Tomcat API中的CometProcessor这样的接口存在的
浏览 1提问于2011-11-03得票数 0
回答已采纳
2回答
有没有一种方法可以在不破坏XHR对象的情况下清除XHR对象的responseText？
我需要保持与web服务器的持久连接，以便将实时数据提供给浏览器。问题是，有相对大量的数据通过(每秒持续几百K)，所以内存使用是一个大问题，因为这个连接必须保持打开至少几分钟。responseText很快就变得非常大，即使我发回的JSON已经被处理得尽可能小了。
由于服务器端应用程序的工作方式，如果我使用AJAX风格的短轮询，并在完成XHR对象后将其销毁，即使在解析响应、创建新的XHR并将其发送出去所需的几毫秒内，我也会丢失大量重要数据。我不能选择使用重叠请求，因为web服务器一次只接受一个连接。(不要问。)
浏览 1提问于2009-08-14得票数 5
回答已采纳
我有一个服务器运行在rackspace上，它承载了一个PHP web应用程序。
PHP应用程序将接受表单提交，然后需要根据表单字段条目执行任务。
这个任务(让我们称之为生成元数据任务)需要相当长的处理时间。我想知道如何允许表单提交直接保存到数据库，并在后台运行generate元数据任务时立即向用户显示成功页面。
我已经在同一个web应用程序中安装了使用composer的"aws/aws-sdk-php": "~3.11"。
我最初的计划是：
处理表单提交的代码。
$result = $model->save($_POST);
// this code wi
浏览 2提问于2015-12-16得票数 13
回答已采纳
1回答
我有一个简单的数据流，其工作方式如下：
客户端注册到事件创建者服务器，第三方向服务器发出post请求，然后服务器向所有侦听器(客户端)发送一个事件。
为了发送事件，我认为我应该使用服务器发送事件，但是我遇到了问题，因为发送事件的脚本并不总是在运行，所以任何试图连接到事件的人都会继续尝试连接，而当第三方发出帖子时，没有人会注册运行的脚本的事件。
如何使脚本始终运行？如果我这么做，这不会导致资源泄露吗？
有没有办法做到这一点，使您签署任何事件，“未来”脚本将创建？
浏览 2提问于2014-01-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
