26
4
I have a 1 client to 1 server model, let's say the client will emit 100 req/s, but the server can only handle 50 req/s.
The client side is very tolerant. It says okay, I don't care about you dropping some of my requests, just process the latest one. What pattern should be applied in this situation?
我有一个1客户对1服务器的模型，假设客户端会发出100个请求/S，但服务器只能处理50个请求/S，客户端非常宽容。它说好吧，我不在乎你放弃我的一些请求，只要处理最新的请求即可。在这种情况下，应该采用什么模式？
个人中心
文章发布
退出Timeline ('<' denotes the server is processing the latest requests):
client: 1 -- 2 -- 3 -- 4 -- 5 -- 6 -- 7 -- 8 -- 9 -- 10
server: <<<<<<<<<< 1 <<<<<<< 3 <<<<<<<<<<<< 5 <<<<<<< (processing 8)
You probably want something like PUB/SUB with a low high water mark client to server, something like PUSH/PULL server to client, and something (like a GUID or serial number) in your requests that will be added to responses so that the client can work out what request a return from the server pertains to.
您可能想要具有低高水位线的发布/订阅、服务器到客户端的推送/拉入之类的内容，以及将添加到响应中的请求中的某些内容(例如GUID或序列号)，以便客户端可以确定从服务器返回的请求与哪些请求有关。
The PUB/SUB is useful because it will drop messages in the PUBlisher if there are no SUBscribers. Having a the high water mark set to a low value (1) means that it won't stash a load of old messages until the server can absorb them. The PUSH/PULL for replies from the server to the client won't drop anything, so the replies will certainly get through.
发布/订阅非常有用，因为如果没有订阅服务器，它将丢弃发布服务器中的消息。将高水位线设置为低值(1)意味着它不会隐藏大量旧消息，直到服务器能够吸收它们。从服务器到客户端的回复的推送/拉入不会丢弃任何内容，因此回复肯定会通过。
This way the server can take it's own sweet time receiving requests on its SUB socket, and get a reply back on the PUSH socket.
这样，服务器就可以从容不迫地在其子套接字上接收请求，并在推送套接字上得到回复。
Note that we're not really using the PUB/SUB or PUSH/PULL patterns here - we're just using them for point-to-point connections with differing policies on what to do if things start bottling up. PUB/SUB drops messages, PUSH/PULL does not.
请注意，我们在这里并没有真正使用发布/订阅或推送/拉入模式-我们只是将它们用于点对点连接，并使用不同的策略来处理事情开始堵塞时该如何做。发布/订阅丢弃消息，推送/拉入不会。
That may be what you're looking for!
这可能就是你要找的东西！
For the server reply to client, is PUSH/PULL necessary? Because if the client side accidentally down for a short period, it will receive several stale responses when reconnect back.
对于服务器回复客户端，是否需要推送/拉取？因为如果客户端在短时间内意外停机，重新连接时会收到几个过时的响应。
@LQsLLDB I think that would depend on what happens to the state of the client, if it's accidentally down. If it's going to remember what it did, then the response is still going to make sense. If the client is going to be restarted with no knowledge of what had happened before, then the responses that make no sense could simply be discarded. That would be helped if the request response tag was a GUID / UUID, as that would cope with anything. If you used PUB/SUB instead of PUSH/PULL, that'd allow responses to be dropped. Either way, you'd have to write the client to be aware of stale responses
@LQsLLDB我认为这取决于客户端的状态会发生什么，如果它意外停机的话。如果它会记住它做了什么，那么它的反应仍然是有意义的。如果在不知道以前发生了什么的情况下重新启动客户端，则可以简单地丢弃没有意义的响应。如果请求响应标记是GUID/UUID，这将有所帮助，因为它可以处理任何事情。如果您使用发布/订阅而不是推/拉，那么将允许丢弃响应。无论采用哪种方式，您都必须编写客户端以了解过时的响应
26
4
0
我有带皮肤的 DNN。我的 head 标签有 runat="server"所以我尝试在 head 标签内添加一个标签 "> 在后面的代码中，我在属性中设置了 var GoogleAPIkey。问题是它
我在 Node.JS 中有一个导出模块 exports.doSomethingImportant= function(req, res) { var id = req.params.id; Demo.
我是 F# 的新手，我一直在阅读 F# for Fun and Profit。在为什么使用 F#？ 系列中，有一个 post描述异步代码。我遇到了 Async.StartChild函数，我不明白为什么
File 中有一堆相当方便的方法类，如 ReadAll***/WriteAll***/AppendAll***。 我遇到过很多情况，当我需要它们的异步对应物时，但它们根本不存在。 为什么？有什么陷阱吗
我最近开始做一个 Node 项目，并且一直在使用 async 库。我有点困惑哪个选项会更快。在某些数据上使用 async.map 并获取其结果，或使用 async.each 迭代一组用户并将他们的相应
您好，我正在试用 Springs 异步执行器，发现您可以使用 @Async。我想知道是否有可能在 @Async 中使用 @Async，要求是需要将任务委托(delegate)给 @Async 方法在第
我需要支持取消一个函数，该函数返回一个可以在启动后取消的对象。在我的例子中，requester 类位于我无法修改的第 3 方库中。 actor MyActor { ... func d
假设 asyncSendMsg不返回任何内容，我想在另一个异步块中启动它，但不等待它完成，这之间有什么区别: async { //(...async stuff...) for msg
我想用 Mocha 测试异步代码. 我跟着这个教程testing-promises-with-mocha .最后，它说最好的方法是 async/await。 以下是我的代码，我打算将 setTimeo
正如我有限(甚至错误)的理解，Async.StartImmediate 和 Async.RunSynchronously 在当前线程上启动异步计算。那么这两个功能究竟有什么区别呢？谁能帮忙解释一下？
我有一行使用await fetch() 的代码。我正在使用一些调用 eval("await fetch ...etc...") 的脚本注入(inject)，但问题是 await 在执行时不会执行从ev
我正在尝试使用 nodeJS 构建一个网络抓取工具，它在网站的 HTML 中搜索图像，缓存图像源 URL，然后搜索最大尺寸的图像。 我遇到的问题是 deliverLargestImage() 在循环遍
我想结合使用 async.each 和 async.series，但得到了意想不到的结果。 async.each([1, 2], function(item, nloop) { async.s
我的代码有问题吗？我使用 async.eachSeries 但我的结果总是抛出 undefined。 这里是我的代码: async.eachSeries([1,2,3], function(data,
我想在 trait 中编写异步函数，但是因为 async fn in traits 还不被支持，我试图找到等效的方法接口(interface)。这是我在 Rust nightly (2019-01-0
async setMyPhotos() { const newPhotos = await Promise.all(newPhotoPromises); someOtherPromise();
async.js 中 async.each 与 async.every 的区别？似乎两者都相同，只是 async.every 返回结果。纠正我，我错了。 最佳答案 每个异步 .each(coll, i
我正在尝试对一组项目运行 async.each。 对于每个项目，我想运行一个 async.waterfall。请参阅下面的代码。 var ids = [1, 2]; async.each(ids,
我的目标是测试 API 调用，将延迟考虑在内。我的灵感来自 this post . 我设计了一个沙箱，其中模拟 API 需要 1000 毫秒来响应和更改全局变量 result 的值。测试检查 500
async.each 是否作为异步数组迭代工作？ async.eachSeries 是否作为同步数组迭代工作？(它实际上等待响应) 我问这些是因为两者都有回调，但 async.each 的工作方式类似
我是一名优秀的程序员,十分优秀！