Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

由于gtcp.PoolConn继承于gtcp.Conn因此同时也可以使用gtcp.Conn的方法。

示例1,基本使用

package main

import (
    "fmt"
    "time"
    "github.com/gogf/gf/net/gtcp"
    "github.com/gogf/gf/os/glog"
    "github.com/gogf/gf/os/gtime"
)

func main() {
    // Server
    go gtcp.NewServer("127.0.0.1:8999", func(conn *gtcp.Conn) {
        defer conn.Close()
        for {
            data, err := conn.Recv(-1)
            if len(data) > 0 {
                if err := conn.Send(append([]byte("> "), data...)); err != nil {
                    fmt.Println(err)
                }
            }
            if err != nil {
                break
            }
        }
    }).Run()

    time.Sleep(time.Second)

    // Client
    for {
       if conn, err := gtcp.NewPoolConn("127.0.0.1:8999"); err == nil {
           if b, err := conn.SendRecv([]byte(gtime.Datetime()), -1); err == nil {
               fmt.Println(string(b), conn.LocalAddr(), conn.RemoteAddr())
           } else {
               fmt.Println(err)
           }
           conn.Close()
       } else {
           glog.Error(err)
       }
       time.Sleep(time.Second)
    }
}

...

可以看到,Client的端口一直未变,每一次通过gtcp.NewConn("127.0.0.1:8999")获得的都是同一个gtcp.Conn对象,且每一次conn.Close()时并不是真正的关闭连接,而是将该对象重新丢回到连接池里循环使用。

示例2,连接断开情况

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

...