27
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，这将有所帮助，因为它可以处理任何事情。如果您使用发布/订阅而不是推/拉，那么将允许丢弃响应。无论采用哪种方式，您都必须编写客户端以了解过时的响应
27
4
0
我正在尝试将抓取的 xml 输出写入 json。由于项目不可序列化，抓取失败。 从这个问题来看，它建议您需要构建一个管道，未提供的答案超出了问题 SO scrapy serializer 的范围。 所
有没有一种方法可以通过重载函数来区分参数是在编译时可评估还是仅在运行时可评估？ 假设我有以下功能: std::string lookup(int x) { return table::va
我正在使用 MVVM 模式编写一个应用程序。我通过将 View 的 DataContext 属性设置为 ViewModel 的实例来向 View 提供数据。一般来说，我只是从那里使用 Binding
对于一个项目，我正在使用带有简单 python module 的传感器收集多个红外命令。 . 我收到如下字节字符串: commando1= b'7g4770CQfwCTVT9bQDAzVEBMagGR
我有一个计算方法，可以在用户使用 Cartridge 作为我的商店框架结账时计算税费。 税 = 税 * 小数(str(settings.SHOP_DEFAULT_TAX_RATE)) 计算工作正常。然
我正在用 pygame 制作一个绘图程序，我想在其中为用户提供一个选项来保存程序的确切状态，然后在稍后重新加载它。在这一点上，我保存了我的全局字典的副本，然后遍历， pickle 每个对象。 pyga
在 C++11 之前，我可以使用它来使类不可复制: private: MyClass(const MyClass&); MyClass& operator=(const MyClass&); 使用 C
大家好 :) 我在我的 VC++ 项目中使用 1.5.4-all (2014-10-22)(适用于 x86 平台的 Microsoft Visual C++ 编译器 18.00.21005.1)。 我
我有一个 python 文件:analysis.py: def svm_analyze_AHE(file_name): # obtain abp file testdata = pd.
这个问题已经有答案了: How to serialize SqlAlchemy result to JSON? (37 个回答) 已关闭 4 年前。 我正在编写小查询来从 mysql 获取数据数据库，
我是 Python 初学者，我在 JSON 方面遇到了一些问题。在我正在使用的教程中有两个函数: def read_json(filename): data = [] if os.pa
我目前正在开发一个针对 iPad 的基于 HTML5 Canvas/JavaScript 的小型绘图应用程序。它在 Safari 中运行。到目前为止，除了一件事之外，一切都进展顺利。 如果我旋转设备，
以下代码无法使用 Visual Studio 2013 编译: #include struct X { X() = default; X(const X&) = delete;
嗨，我制作了一个文本分类分类器，我在其中使用了它，它返回一个数组，我想返回 jsonresponse，但最后一行代码给我错误 'array(['cycling'], dtype =object) 不可
我使用 Flask 和 Flask-Login 进行用户身份验证。 Flask-Sqlalchemy 将这些模型存储在 sqlite 数据库中: ROLE_USER = 0 ROLE_ADMIN =
如果您尝试发送不可 JSON 序列化的对象(列表、字典、整数等以外的任何对象)，您会收到以下错误消息: "errorMessage": "Object of type set is not JSON
我在尝试 move std::vector 时遇到崩溃其中 T显然是不可 move 的(没有定义 move 构造函数/赋值运算符，它包含内部指针) 但为什么 vector 的 move 函数要调用 T
我尝试在用户成功登录后将 token 返回给他们，但不断收到以下错误: 类型错误:“字节”类型的对象不可 JSON 序列化 我该如何解决这个问题？这是我到目前为止的代码: if user:
我是一名优秀的程序员,十分优秀！