草庐IT

ios - AFNetworking请求操作-创建 channel /瓶颈队列单例

coder 2024-01-24 原文

设置

我的程序中有两个区域-branch 1和branch 2-在其中每个区域一次异步发出1个并发GET请求的网络请求。每次发送1个请求，因为对于任何向服务器发出请求的用户，服务器的宽限期只有几毫秒。一次运行1个并发请求旨在帮助该宽限期。

进行此操作的目的是，如果在任何分支中任何请求失败，则可以再次重发该请求。

问题:

当我彼此分开运行这些分支时(即不同时运行)，服务器很高兴。但是，一旦我允许两个操作同时发生，服务器就会引发429错误，该错误是让用户知道there are too many requests coming in at any one time的错误。然后发生的是一半的请求失败，然后由于故障安全，请求再次发送以进行处理，直到全部完成为止。
代表用户的数据包浪费时间和资源。

场景
Branch 1发送10个请求(通常在数千个请求中，一次处理一个，但为简单起见，我们将其保持在10个)。
这10个请求将非常快地一次并发处理一次，并返回其适当的数据对象。

现在，如果我们再次运行branch 1操作-并发10个请求，然后添加branch 2's 10个请求，这将创建20个请求操作-数量增加一倍-移出服务器，这将导致分支1和2的大约一半请求失败，然后启用故障保护以重新发送那些请求操作。号泣。

问题

不管这两个分支位于我的应用程序中的什么位置，有没有一种方法可以将这些请求操作从我的应用程序中传递出去，以便我们可以控制和限制发送到服务器的请求操作，从而不会对服务器造成轰炸仅对于一半的请求失败？

可能的解决方案

我曾经想到的一个想法是创建一个单例，该单例将充当队列以及瓶颈，使我可以在代码库中的任何位置添加来自任何分支的请求操作-因此，为什么我认为单例是一个好主意为此-然后，一旦意识到请求操作已添加到队列中，然后使该队列一次运行1个并发请求。

我认为这对于我的目的将非常有用，我只是不知道如何处理请求的完成块，因为Branch 1的请求操作与Branch 2的请求操作的完成块不同。

您将如何处理？我们可以做些什么吗？

编辑1-我目前在做什么

在分支1中-使用AFHTTPOperation:

1)对于每个进程，我创建一个for循环，该循环迭代10次，将10 AFHTTPRequestOperation添加到名为NSMutableArray类型的名为multiOperations的本地数组中。

2)然后我将multipleOperations数组添加到batchOfRequestOperations方法中，如下所示:

NSArray *operations = [AFURLConnectionOperation batchOfRequestOperations:muiltipleOperations
                       progressBlock:^(NSUInteger numberOfFinishedOperations, NSUInteger totalNumberOfOperations){
//Do some stuff here for each iteration
} 
completionBlock:^(NSArray*operations){
//Call the method that repeats this process again.
}];

3)然后将操作添加到mainQueue中，如下所示
[[NSOperationQueue mainQueue] addOperations:operations waitUntilFinished:NO];

我现在想知道分支一中的此过程是否甚至将其设置为1并发，看不到它是:\

在分支2中使用NSURLSessionDataTask(刚刚实现，如果它们都使用相同的子类，会不会更容易？lol

我注意到我正在使用AFHTTPSessionManager创建NSURLSessionDataTasks ..该代码不会在for循环中运行，而是调用自己的方法，以便每次请求执行其自己的完成块时都会发出另一个请求。因此，分支2中的上一个请求完成后，它将永远永远保持自身调用。这就是我知道它一次仅运行1个请求的方式。这样很好。

无论如何，可以使它更清洁吗？

不，我在哪里使用HTTPRequestOperationManager :(有人可以告诉我如何正确完成操作吗？

谢谢。

最佳答案

根据您的编辑，我可以看到您可能需要更改的一些内容。首先，是的，如果您同时使用AFHTTPOperation或NSURLSessionDataTask，但不同时使用两者，则将更加容易。

如果要使用AFHTTPOperation，则不要对[NSOperationQueue mainQueue]进行操作排队。原因是那是主要的UI队列，您不希望网络操作阻止它。您应该做的是创建自己的NSOperationQueue并将其并发设置为1。

NSOperationQueue *networkQueue = [[NSOperationQueue alloc] init];
networkQueue.maxConcurrentOperationCount = 1;

使用您的单例想法将该队列存储在可以从应用程序中的任何位置访问的某个位置，这是确保您通过同一队列发送所有网络操作的好方法。

就是说，我建议将NSURLSessionDataTask与AFHTTPSessionManager一起使用而不是。 AFNetworking的文档状态:

针对iOS 7或Mac OS X 10.9或更高版本的开发人员
鼓励广泛使用Web服务进行子类化
AFHTTPSessionManager，提供一个返回共享的类方法
身份验证和其他配置可以在其上的单例对象
在整个应用程序中共享。

听起来这是完成所需内容的好方法。基本上，您将使用一个类方法创建AFHTTPSessionManager的子类，该方法创建一个用自定义NSURLSessionConfiguration初始化的实例。您可以配置NSURLSessionConfiguration，但是它适合您的应用程序，但是您对此特定问题感兴趣的主要属性是 HTTPMaximumConnectionsPerHost :

此属性确定最大并发数
session 中基于此任务的任务与每个主机建立的连接
组态。

将其设置为1，您可以让AFHTTPSessionManager(实际上是NSURLSession)担心确保在任何给定时间仅对您的服务器发出一个请求。

遵循以下原则:
@interface AppHTTPSessionManager : AFHTTPSessionManager

+ (instancetype)appSession;

@end

@implementation AppHTTPSessionManager

+ (instancetype)appSession {
    static AppHTTPSessionManager *_appSession = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        NSURLSessionConfiguration *configuration = [NSURLSessionConfiguration defaultSessionConfiguration];
        configuration.HTTPMaximumConnectionsPerHost = 1;
        _appSession = [[AppHTTPSessionManager alloc] initWithSessionConfiguration:configuration];
    });
    return _appSession;
}

@end

然后，每当要进行网络 call 时，请确保从NSURLSessionDataTask创建[AppHTTPSessionManager appSession]。如果这样做，这些任务应该自动被限制为一次向服务器发出一个请求。

关于ios - AFNetworking请求操作-创建 channel /瓶颈队列单例，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26689177/

AFNetworkingchannelcodebrstrongiosobjective-cios7nsoperation

有关ios - AFNetworking请求操作-创建 channel /瓶颈队列单例的更多相关文章

  1. ruby - 如何在 Ruby 中顺序创建 PI - 2

    出于纯粹的兴趣，我很好奇如何按顺序创建PI，而不是在过程结果之后生成数字，而是让数字在过程本身生成时显示。如果是这种情况，那么数字可以自行产生，我可以对以前看到的数字实现垃圾收集，从而创建一个无限系列。结果只是在Pi系列之后每秒生成一个数字。这是我通过互联网筛选的结果:这是流行的计算机友好算法，类机器算法:defarccot(x,unity)xpow=unity/xn=1sign=1sum=0loopdoterm=xpow/nbreakifterm==0sum+=sign*(xpow/n)xpow/=x*xn+=2sign=-signendsumenddefcalc_pi(digits

  2. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声？ - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。

  3. ruby - 使用 Vim Rails，您可以创建一个新的迁移文件并一次性打开它吗？ - 2

    使用带有Rails插件的vim，您可以创建一个迁移文件，然后一次性打开该文件吗？textmate也可以这样吗？ 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件，这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails，您可以创建一个新的迁移文件并一次性打开它吗？，我们在StackOverflow上找到一个类似的问题： https://sta

  4. ruby-on-rails - 无法使用 Rails 3.2 创建插件？ - 2

    我对最新版本的Rails有疑问。我创建了一个新应用程序(railsnewMyProject)，但我没有脚本/生成，只有脚本/rails，当我输入ruby./script/railsgeneratepluginmy_plugin"Couldnotfindgeneratorplugin.".你知道如何生成插件模板吗？没有这个命令可以创建插件吗？PS:我正在使用Rails3.2.1和ruby​​1.8.7[universal-darwin11.0] 最佳答案 随着Rails3.2.0的发布，插件生成器已经被移除。查看变更日志here.现在

  5. ruby - 如何使用 RSpec::Core::RakeTask 创建 RSpec Rake 任务？ - 2

    如何使用RSpec::Core::RakeTask初始化RSpecRake任务？require'rspec/core/rake_task'RSpec::Core::RakeTask.newdo|t|#whatdoIputinhere?endInitialize函数记录在http://rubydoc.info/github/rspec/rspec-core/RSpec/Core/RakeTask#initialize-instance_method没有很好的记录；它只是说:-(RakeTask)initialize(*args,&task_block)AnewinstanceofRake

  6. ruby-on-rails - Rails HTML 请求渲染 JSON - 2

    在我的Controller中，我通过以下方式在我的index方法中支持HTML和JSON:respond_todo|format|format.htmlformat.json{renderjson:@user}end在浏览器中拉起它时，它会自然地以HTML呈现。但是，当我对/user资源进行内容类型为application/json的curl调用时(因为它是索引方法)，我仍然将HTML作为响应。如何获取JSON作为响应？我还需要说明什么？ 最佳答案 您应该将.json附加到请求的url，提供的格式在routes.rb的路径中定义。这

  7. ruby - 为什么 SecureRandom.uuid 创建一个唯一的字符串？ - 2

    关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗？通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串？SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复？

  8. ruby - 如何验证 IO.copy_stream 是否成功 - 2

    这里有一个很好的答案解释了如何在Ruby中下载文件而不将其加载到内存中:https://stackoverflow.com/a/29743394/4852737require'open-uri'download=open('http://example.com/image.png')IO.copy_stream(download,'~/image.png')我如何验证下载文件的IO.copy_stream调用是否真的成功——这意味着下载的文件与我打算下载的文件完全相同，而不是下载一半的损坏文件？documentation说IO.copy_stream返回它复制的字节数，但是当我还没有下

  9. ruby - 有人可以帮助解释类创建的 post_initialize 回调吗 (Sandi Metz) - 2

    我正在阅读SandiMetz的POODR，并且遇到了一个我不太了解的编码原则。这是代码:classBicycleattr_reader:size,:chain,:tire_sizedefinitialize(args={})@size=args[:size]||1@chain=args[:chain]||2@tire_size=args[:tire_size]||3post_initialize(args)endendclassMountainBike此代码将为其各自的属性输出1,2,3,4,5。我不明白的是查找方法。当一辆山地自行车被实例化时，因为它没有自己的initialize方法

  10. Ruby 文件 IO 定界符？ - 2

    我正在尝试解析一个文本文件，该文件每行包含可变数量的单词和数字，如下所示:foo4.500bar3.001.33foobar如何读取由空格而不是换行符分隔的文件？有什么方法可以设置File("file.txt").foreach方法以使用空格而不是换行符作为分隔符？ 最佳答案 接受的答案将slurp文件，这可能是大文本文件的问题。更好的解决方案是IO.foreach.它是惯用的，将按字符流式传输文件:File.foreach(filename,""){|string|putsstring}包含“thisisanexample”结果的

随机推荐