日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

?gtcp?模塊實現(xiàn)簡便易用、輕量級的?TCPServer?服務(wù)端。

使用方式：

import "github.com/GOgf/gf/v2/net/gtcp"

接口文檔： https://pkg.go.dev/github.com/gogf/gf/v2/net/gtcp

type Server
    func GetServer(name ...interface{}) *Server
    func NewServer(address string, handler func(*Conn), name ...string) *Server
    func NewServerKeyCrt(address, crtFile, keyFile string, handler func(*Conn), name ...string) *Server
    func NewServerTLS(address string, tlsConfig *tls.Config, handler func(*Conn), name ...string) *Server
    func (s *Server) Close() error
    func (s *Server) Run() (err error)
    func (s *Server) SetAddress(address string)
    func (s *Server) SetHandler(handler func(*Conn))
    func (s *Server) SetTLSConfig(tlsConfig *tls.Config)
    func (s *Server) SetTLSKeyCrt(crtFile, keyFile string) error

其中，?GetServer?使用單例模式通過給定一個唯一的名稱獲取/創(chuàng)建一個單例?Server?，后續(xù)可通過?SetAddress?和?SetHandler?方法動態(tài)修改?Server?屬性；?NewServer?則直接根據(jù)給定參數(shù)創(chuàng)建一個?Server?對象，并可指定名稱。

我們通過實現(xiàn)一個簡單的?echo?服務(wù)器來演示?TCPServer?的使用：

package main

import (
    "fmt"
    "github.com/gogf/gf/v2/net/gtcp"
)

func main() {
    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()
}

在這個示例中我們使用了?Send?和?Recv?來發(fā)送和接收數(shù)據(jù)。其中?Recv?方法會通過阻塞方式接收數(shù)據(jù)，直到客戶端”發(fā)送完畢一條數(shù)據(jù)”(執(zhí)行一次?Send?，底層?Socket?通信不帶緩沖實現(xiàn))，或者關(guān)閉鏈接。

執(zhí)行之后我們使用?telnet?工具來進行測試：

john@home:~$ telnet 127.0.0.1 8999
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
hello
> hello
hi there
> hi there

每一個客戶端發(fā)起的?TCP?鏈接，?TCPServer?都會創(chuàng)建一個?goroutine?進行處理，直至?TCP?鏈接斷開。由于?goroutine?比較輕量級，因此可以支撐很高的并發(fā)量。

網(wǎng)站名稱：創(chuàng)新互聯(lián)GoFrame教程：GoFrameTCP組件-基本介紹
網(wǎng)站路徑：http://www.dlmjj.cn/article/djoceoc.html