1. socket_server.go

 1 package main
 2 
 3 import (
 4     "net"
 5 
 6     "facework.im/share/logging"
 7 )
 8 
 9 func main() {
10     listen, err := net.Listen("tcp", "localhost:1024")
11     if err != nil {
12         logging.Error("Net Listen | %v", err)
13         return
14     }
15     defer listen.Close()
16 
17     logging.Debug("Waiting For Clients To Connection...")
18 
19     for {
20         conn, err := listen.Accept()
21         if err != nil {
22             logging.Debug("Liston Accept | %v", err)
23             continue
24         }
25 
26         logging.Notice("%v Tcp Connect Success.", conn.RemoteAddr().String())
27 
28         handleConnection(conn)
29     }
30 }
31 
32 // 处理连接
33 func handleConnection(conn net.Conn) {
34     buf := make([]byte, 2048)
35 
36     for {
37         n, err := conn.Read(buf)
38         if err != nil {
39             return
40         }
41 
42         logging.Debug("%v Receive Data: %v", conn.RemoteAddr().String(), string(buf[:n]))
43     }
44 }
View Code

相关文章: