GTS 今年双 11 的成绩 今年 2684 亿的背后,有一个默默支撑,低调到几乎被遗忘的中间件云产品——GTS(全局事务服务,Global Transaction Service),稳稳地通过了自 2014 年诞生以来的第 5 次“大考”。
因为TCP的三只握手等等原因,建立一个连接是一件成本比较高的行为。所以在一个需要多次与特定实体交互的程序中,就需要维持一个连接池,里面有可以复用的连接可供重复使用。 而维持一个连接池,最基本的要求就是要做到:thread safe(线程安全),尤其是在Golang这种特性是goroutine的语言中。 实现简单的连接池 type Pool struct { m sync.Mutex // 保证多个goroutine访问时候,closed的线程安全 res chan io.Closer //连接存储的chan factory func() (io.Closer,error) //新建连接的工厂方法 closed bool //连接池关闭标志 } https://juejin.im/post/5e58e3b7f265da57537eb7ed 这个简单的连接池,我们利用chan来存储池里的连接。而新建结构体的方法也比较简单: func New(fn func() (io.Closer, error), size uint) (*Pool, error) { if size <= 0 { return nil, errors.New(“size的值太小了。”) } return &Pool{ factory: fn, res: make(chan io.Closer, size), }, nil } 复制代码只需要提供对应的工厂函数和连接池的大小就可以了。 获取连接 那么我们要怎么从中获取资源呢?因为我们内部存储连接的结构是chan,所以只需要简单的select就可以保证线程安全: //从资源池里获取一个资源 func (p *Pool) Acquire() (io.Closer,error) { select { case r,ok := <-p.res: log.Println(“Acquire:共享资源”) if !ok { return nil,ErrPoolClosed } return r,nil default: log.Println(“Acquire:新生成资源”) return p.factory() } } 复制代码我们先从连接池的res这个chan里面获取,如果没有的话我们就利用我们早已经准备好的工厂函数进行构造连接。同时我们在从res获取连接的时候利用ok先确定了这个连接池是否已经关闭。如果已经关闭的话我们就返回早已经准备好的连接已关闭错误。 关闭连接池 那么既然提到关闭连接池,我们是怎么样关闭连接池的呢? //关闭资源池,释放资源 func (p *Pool) Close() { p.m.Lock() defer p.m.Unlock()
https://mp.weixin.qq.com/s/Knx1dQ8L6cBx4HRUJ-EAUQ 限流(Rate Limiting,即速率限制)通过限制每个用户调用API的频率来防止API被过度使用,这可以防止他们因疏忽或恶意导致的API滥用。在没有速率限制的情况下,每个用户可以随心所欲地请求,这可能会导致“峰值”请求,从而导致其他用户得不到响应。在启用速率限制之后,它们的请求将被限制为每秒固定的数量。
php扩展实践zend_execute_ex层获取实参 其实在实现的 php 函数里面是很容易获取到的,参考 php 的 builtin 函数 func_get_args() 就可以知道了。 void **p; int arg_count; int i; zend_execute_data *ex = EG(current_execute_data);