如何做网站竞品分析,网页设计html代码大全宽度代码,室内平面图在线制作网站,网站后台英文流水线和复用 糟糕的时间浪费。现代的计算机以惊人的速度产生大量的数据#xff0c;而且高速网络通道(通常在重要的服务器之间同时存在多个链路)提供了很高的带宽#xff0c;但是计算机花费了大量的时间在 等待数据 上面#xff0c;这也是造成使用持久性链接的编程方式越来越… 流水线和复用 糟糕的时间浪费。现代的计算机以惊人的速度产生大量的数据而且高速网络通道(通常在重要的服务器之间同时存在多个链路)提供了很高的带宽但是计算机花费了大量的时间在 等待数据 上面这也是造成使用持久性链接的编程方式越来越流行的原因之一。常规的编码方式: string a db.StringGet(a);
string b db.StringGet(b); 就步骤而言它看起来像下面这样 [req1] # client: the client library constructs request 1[cs] # network: request one is sent to the server[server] # server: the server processes request 1[sc] # network: response one is sent back to the client[resp1] # client: the client library parses response 1[req2][cs][server][sc][resp2] 高亮 client 端正在做的事情: [req1][waiting][resp1][req2][waiting][resp2] 如果按照时间缩放的话就会看到大部分的时间都耗在了 等待 上面。 Pipelining 由于上述的原因很多 redis 客户端允许使用 pipelining; 这是一种可以一次性通过管道发送多条消息的方式而不用一条一条的发送等.待而且可以在等到回复时一并处理他们. .NET 的异步方法。 举例来说 var aPending db.StringGetAsync(a);
var bPending db.StringGetAsync(b);
var a db.Wait(aPending);
var b db.Wait(bPending); 在这里使用 db.Wait 可以自动采用配置的超时时间 但也可以使用 aPending.Wait() 或者 Task.WaitAll(aPending, bPending);的方式根据你自己的喜好来. 这样一来 20 个请求可能合并为一个请求。 Fire and Forget pipelining 的一种特殊场景是我们并不关心某个操作的返回结果这样的话我们的代码可以马上接着往下执行而那个放入到队列中的操作将会在后台执行. 通常来说这意味我们可以把并行的操作放到一个单独的 caller 的连接上执行. 这种情况下 我们可以使用 flags 参数达到这样的目的. // sliding expiration
db.KeyExpire(key, TimeSpan.FromMinutes(5), flags: CommandFlags.FireAndForget);
var value (string)db.StringGet(key); FireAndForget 标志使得client library 正常的把要做的事情的排成队列 但是会马上返回一个默认的值这个默认值没有任何的实用意义. 这也适用于 *Async 方法会返回一个已经完成的 TaskT. Multiplexing 多路复用 pipelining 已经很好了但是很多情况下一个代码块只需要一个单独的值 (或许这个代码块希望执行一些简单的操作但是这些操作是相互依赖的). 这也就是说我们仍然会消耗大量的时间在client和server之间交互等待. 假如有一个业务繁忙的应用 或许是一个网站服务器. 这些应用往往都是并发的 所以如果有20个并行的应用请求数据你可能采用建立20个链接的方式或者异步使用同一个链接(最后一个请求需要等之前19个完成). 或者做个让步 使用一个拥有5个链接的程序池 - 但是不管你怎么做都会有大量的等待发生。StackExchange.Redis 没有做以上的事情 它只是尽可能的充分复用一个链接. 当被不同的调用者同时调用时它会 自动地将不同的请求放到队列中 所以无论请求使用同步或者异步的方式要做的事情都会放到队列中. 所以我们可能有10个或者20个 get a and b 的场景他们都会尽快的获取链接执行命令. 鉴于以上的原因StackExchange.Redis 没有( 将来也不会 )提供 blocking pops (BLPOP, BRPOP and BRPOPLPUSH). 因为这会使得一个单独的调用者减慢整个的多路复用环境堵塞其他所有的调用者. 唯一的例外 StackExchange.Redis 需要验证事务的先决条件时需要保证工作的时间. 这也是StackExchange.Redis 将这些条件包装在 Condition 的实例中. Read more about transactions here 如果真的想用 blocking pops, 这里墙裂建议你使用pub/sub的方式替代. sub.Subscribe(channel, delegate {string work db.ListRightPop(key);if (work ! null) Process(work);
});
//...
db.ListLeftPush(key, newWork, flags: CommandFlags.FireAndForget);
sub.Publish(channel, ); 这实现了相同的目的而不需要阻塞操作: data 没有通过 pub/sub 的方式发送; pub/sub 只是用来通知worker去检查队列是否有数据如果没有worker新的item 会存在list里面; 这项工作也不算是完全失败一个worker 只能 pop 一个值; 就算有很多的 consumer 消费这个队列其中的一些 consumer 被通知到也拿不到值去做接下来的事情当你重启一个worker时你应该假定队列中有 work 这样可以消费积压的work但除此之外语义与 blocking pops相同StackExchange.Redis的复用特性使得使用普通的简单代码时在一个连接上达到极高的吞吐量成为可能。. Concurrency pipeline / multiplexer / future-value 只会在 continuation-based 的异步代码上起到较好的作用 string value await db.StringGetAsync(key);
if (value null) {value await ComputeValueFromDatabase(...);db.StringSet(key, value, flags: CommandFlags.FireAndForget);
}
return value; 转发请标注本文链接地址:(https://www.cnblogs.com/ArvinZhao/p/6825870.html) 转载于:https://www.cnblogs.com/ArvinZhao/p/6825870.html
