gtcp模块实现简便易用、轻量级的TCPServer服务端。

    使用方式

    1. import "github.com/gogf/gf/g/net/gtcp"

    接口文档https://godoc.org/github.com/gogf/gf/g/net/gtcp

    1. type Server
    2. func GetServer(name ...interface{}) *Server
    3. func NewServer(address string, handler func(*Conn), name ...string) *Server
    4. func NewServerKeyCrt(address, crtFile, keyFile string, handler func(*Conn), name ...string) *Server
    5. func NewServerTLS(address string, tlsConfig *tls.Config, handler func(*Conn), name ...string) *Server
    6. func (s *Server) Close() error
    7. func (s *Server) Run() (err error)
    8. func (s *Server) SetAddress(address string)
    9. func (s *Server) SetHandler(handler func(*Conn))
    10. func (s *Server) SetTLSConfig(tlsConfig *tls.Config)
    11. func (s *Server) SetTLSKeyCrt(crtFile, keyFile string) error

    其中,GetServer使用单例模式通过给定一个唯一的名称获取/创建一个单例Server,后续可通过SetAddressSetHandler方法动态修改Server属性;NewServer则直接根据给定参数创建一个Server对象,并可指定名称。

    我们通过实现一个简单的echo服务器来演示TCPServer的使用:

    1. package main
    2. import (
    3. "fmt"
    4. "github.com/gogf/gf/g/net/gtcp"
    5. )
    6. func main() {
    7. gtcp.NewServer("127.0.0.1:8999", func(conn *gtcp.Conn) {
    8. defer conn.Close()
    9. for {
    10. data, err := conn.Recv(-1)
    11. if len(data) > 0 {
    12. if err := conn.Send(append([]byte("> "), data...)); err != nil {
    13. fmt.Println(err)
    14. }
    15. }
    16. if err != nil {
    17. break
    18. }
    19. }
    20. }).Run()
    21. }

    在这个示例中我们使用了SendRecv来发送和接收数据。其中Recv方法会通过阻塞方式接收数据,直到客户端”发送完毕一条数据”(执行一次Send,底层Socket通信不带缓冲实现),或者关闭链接。关于其中的链接对象gtcp.Conn的介绍,请继续阅读后续章节。

    执行之后我们使用telnet工具来进行测试:

    1. john@home:~$ telnet 127.0.0.1 8999
    2. Trying 127.0.0.1...
    3. Connected to 127.0.0.1.
    4. Escape character is '^]'.
    5. hello
    6. > hello
    7. hi there
    8. > hi there

    每一个客户端发起的TCP链接,TCPServer都会创建一个goroutine进行处理,直至TCP链接断开。由于goroutine比较轻量级,因此可以支撑很高的并发量。