• 欢迎访问开心洋葱网站,在线教程,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站,欢迎加入开心洋葱 QQ群
  • 为方便开心洋葱网用户,开心洋葱官网已经开启复制功能!
  • 欢迎访问开心洋葱网站,手机也能访问哦~欢迎加入开心洋葱多维思维学习平台 QQ群
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏开心洋葱吧~~~~~~~~~~~~~!
  • 由于近期流量激增,小站的ECS没能经的起亲们的访问,本站依然没有盈利,如果各位看如果觉着文字不错,还请看官给小站打个赏~~~~~~~~~~~~~!

GO语言实现的简单TCP服务代码

go 水墨上仙 2216次浏览

GO语言实现的简单TCP服务代码

package main
import (
"net"
"fmt"
)
var (   maxRead = 1100
	msgStop   = []byte("cmdStop")
	msgStart  = []byte("cmdContinue")
    )
func main() {
	hostAndPort := "localhost:54321"
	listener := initServer(hostAndPort)
	for {
		conn, err := listener.Accept()
		checkError(err, "Accept: ")
		go connectionHandler(conn)
	}
}
func initServer(hostAndPort string) *net.TCPListener {
	serverAddr, err := net.ResolveTCPAddr("tcp", hostAndPort)
	checkError(err, "Resolving address:port failed: '" + hostAndPort + "'")
	listener, err := net.ListenTCP("tcp", serverAddr)
	checkError(err, "ListenTCP: ")
	println("Listening to: ", listener.Addr().String())
	return listener
}
func connectionHandler(conn net.Conn) {
	connFrom := conn.RemoteAddr().String()
	println("Connection from: ", connFrom)
	talktoclients(conn)
	for {
		var ibuf []byte = make([]byte, maxRead + 1)
		length, err := conn.Read(ibuf[0:maxRead])
	    ibuf[maxRead] = 0 // to prevent overflow
	switch err {
	case nil:
	    handleMsg(length, err, ibuf)
	default:
	    goto DISCONNECT
	}
	}
	DISCONNECT:
	err := conn.Close()
	println("Closed connection:" , connFrom)
	checkError(err, "Close:" )
	}
func talktoclients(to net.Conn) {
	wrote, err := to.Write(msgStart)
	checkError(err, "Write: wrote " + string(wrote) + " bytes.")
}
func handleMsg(length int, err error, msg []byte) {
	if length > 0 {
		
		for i := 0; ; i++ {
			if msg[i] == 0 {
				break
			}
		}
		fmt.Printf("Received data: %v", string(msg[0:length]))
		fmt.Println("   length:",length)
	}
}
func checkError(error error, info string) {
	if error != nil {
panic("ERROR: " + info + " " + error.Error()) // terminate program
}
}


开心洋葱 , 版权所有丨如未注明 , 均为原创丨未经授权请勿修改 , 转载请注明GO语言实现的简单TCP服务代码
喜欢 (0)
加载中……