diff --git a/geg/net/gtcp/server_client/gtcp_client.go b/geg/net/gtcp/server_client/gtcp_client.go new file mode 100644 index 000000000..ad401b6de --- /dev/null +++ b/geg/net/gtcp/server_client/gtcp_client.go @@ -0,0 +1,23 @@ +package main + +import ( + "github.com/gogf/gf/g/net/gtcp" + "github.com/gogf/gf/g/os/glog" + "github.com/gogf/gf/g/util/gconv" + "time" +) + +func main() { + // Client + conn, err := gtcp.NewConn("127.0.0.1:8999") + if err != nil { + panic(err) + } + defer conn.Close() + for i := 0; i < 3; i++ { + if err := conn.Send([]byte(gconv.String(i))); err != nil { + glog.Error(err) + } + time.Sleep(time.Second) + } +} \ No newline at end of file diff --git a/geg/net/gtcp/server_client/gtcp_server.go b/geg/net/gtcp/server_client/gtcp_server.go new file mode 100644 index 000000000..00c52a5d9 --- /dev/null +++ b/geg/net/gtcp/server_client/gtcp_server.go @@ -0,0 +1,24 @@ +package main + +import ( + "fmt" + "github.com/gogf/gf/g/net/gtcp" +) + +func main() { + // Server + gtcp.NewServer("127.0.0.1:8999", func(conn *gtcp.Conn) { + defer conn.Close() + for { + data, err := conn.Recv(-1) + if len(data) > 0 { + fmt.Println(string(data)) + } + if err != nil { + // client closed, err will be: EOF + fmt.Println(err) + break + } + } + }).Run() +} \ No newline at end of file