From c1e77b7e09ac9fa107c85c1335dd5f7450a52256 Mon Sep 17 00:00:00 2001 From: John Date: Sun, 3 Mar 2019 20:40:36 +0800 Subject: [PATCH] update example of gtcp --- geg/net/gtcp/server_client/gtcp_client.go | 23 ++++++++++++++++++++++ geg/net/gtcp/server_client/gtcp_server.go | 24 +++++++++++++++++++++++ 2 files changed, 47 insertions(+) create mode 100644 geg/net/gtcp/server_client/gtcp_client.go create mode 100644 geg/net/gtcp/server_client/gtcp_server.go 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