The highest tagged major version is
README
¶
Client Dial using connections pool Example
这个是什么
这个是一个客户端的连接池。其原理就是建立一个简单的线程安全队列，提前建立好MIN_SIZE（默认128个）个连接，当调用Read()或者Write()函数的时候，会从队列中取一个，然后写入或者读取，然后再放回队列中，方便下一次复用。只有当你调用Close()函数，建立的连接才能被安全的关闭。
为什么要这么设计
1.允许在不同goroutine中对TCP连接进行Read，Write。也就是说，你不必再拘束于一个TCP连接，你可以同时写入多个或者读取多个，而且这是线程安全的。（为什么？因为每个连接都是独立的，互不影响）
2.上述并发读写很美妙，但是会出现一个问题，当goroutine太多，超过系统HARD LIMIT/SOFT LIMIT时候，触发Too many open files等错误，为解决此问题，连接池会限制最大连接数，当池子中已经没有可用连接，会等候连接入队进行重利用，当超过TIMEOUT时间后，仍没有入队连接，会尝试建立连接。
Documentation
¶
Index ¶
- Constants
- func GetSysMax() int32
- func Wrapper(p *Pool) net.Conn
- type Conn
- func (cn *Conn) Close() error
- func (cn *Conn) LocalAddr() net.Addr
- func (cn *Conn) Read(b []byte) (n int, err error)
- func (cn *Conn) RemoteAddr() net.Addr
- func (cn *Conn) SetDeadline(t time.Time) error
- func (cn *Conn) SetReadDeadline(t time.Time) error
- func (cn *Conn) SetWriteDeadline(t time.Time) error
- func (cn *Conn) Write(b []byte) (n int, err error)
- type Opts
- type Pool
Constants ¶
View Source
const (
MIN_SIZE = 128
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Conn ¶
type Conn struct {
// contains filtered or unexported fields
}
func (*Conn) RemoteAddr ¶
type Opts ¶
type Opts []interface{}
func DefaultOpts ¶
func DefaultOpts() Opts
func (Opts) WithContext ¶
func (Opts) WithDialer ¶
func (Opts) WithMinSize ¶
func (Opts) WithTimeout ¶
type Pool ¶
type Pool struct {
Deadline struct {
// contains filtered or unexported fields
}
// contains filtered or unexported fields
}
func (*Pool) Get ¶
Get one TCP connection from the pool.
If the connection reaches the max limit, poll until one enqueue during TIMEOUT.
If not, set up a new one
func (*Pool) SetDeadline ¶
func (*Pool) SetReadDeadline ¶
func (*Pool) SetWriteDeadline ¶
Source Files
Click to show internal directories.
Click to hide internal directories.