使用方式:

    方法列表:
    godoc.org/github.com/johng-cn/gf/g/net/gtcp#PoolConn

    1. type PoolConn
    2. func NewPoolConn(addr string, timeout ...int) (*PoolConn, error)
    3. func (c *PoolConn) Close() error
    4. func (c *PoolConn) Recv(length int, retry ...Retry) ([]byte, error)

    示例1,基本使用

    在这个示例中,Server创建新的goroutine异步运行,Client在main goroutine中执行。Server端是一个回显服务器,Client每隔1秒向Server端发送当前的时间,经过Server端回显返回后,在Client端打印出双方的连接端口信息。

    执行后,结果如下:

    1. > 2018-07-11 23:29:54 127.0.0.1:55876 127.0.0.1:8999
    2. > 2018-07-11 23:29:56 127.0.0.1:55876 127.0.0.1:8999
    3. > 2018-07-11 23:29:57 127.0.0.1:55876 127.0.0.1:8999
    4. > 2018-07-11 23:29:58 127.0.0.1:55876 127.0.0.1:8999

    示例2,连接断开情况

    这个例子是为了展示当服务端关闭连接后,该连接对象还是否有效的处理。

    执行后,输出结果如下:

    1. > 2018-07-20 12:56:15 127.0.0.1:59368 127.0.0.1:8999
    2. EOF
    3. > 2018-07-20 12:56:17 127.0.0.1:59376 127.0.0.1:8999
    4. > 2018-07-20 12:56:19 127.0.0.1:59378 127.0.0.1:8999
    5. ...

    连接对象的IO复用涉及到十分微妙的连接状态变化问题,由于点对点网络通信本身是比较复杂的环境,连接对象的状态随时可能被动发生着变化,因此,在使用gtcp连接池特性时,需要注意当通信错误产生时的连接对象重建机制,一旦产生错误,立即丢弃(Close)该对象(gtcp.PoolConn)并重建(gtcp.NewPoolConn)。