go socket simple

1. socket_server.go

package main

import (
    "net"

    "facework.im/share/logging"
)

func main() {
    listen, err := net.Listen("tcp", "localhost:1024")
    if err != nil {
        logging.Error("Net Listen | %v", err)
        return
    }
    defer listen.Close()

    logging.Debug("Waiting For Clients To Connection...")

    for {
        conn, err := listen.Accept()
        if err != nil {
            logging.Debug("Liston Accept | %v", err)
            continue
        }

        logging.Notice("%v Tcp Connect Success.", conn.RemoteAddr().String())

        handleConnection(conn)
    }
}

// 处理连接
func handleConnection(conn net.Conn) {
    buf := make([]byte, 2048)

    for {
        n, err := conn.Read(buf)
        if err != nil {
            return
        }

        logging.Debug("%v Receive Data: %v", conn.RemoteAddr().String(), string(buf[:n]))
    }
}

2. socket_client.go

package main

import (
    "bufio"
    "net"
    "os"

    "facework.im/share/logging"
)

func main() {
    server := "127.0.0.1:1024"
    addr, err := net.ResolveTCPAddr("tcp4", server)
    if err != nil {
        logging.Error("Net ResolveTCPAddr | %v", err)
        return
    }

    conn, err := net.DialTCP("tcp", nil, addr)
    if err != nil {
        logging.Error("Net DialTCP | %v", err)
        return
    }

    logging.Notice("Connect To Server Success.")

    sender(conn)
}

// 发送消息
func sender(conn net.Conn) {
    msgin := bufio.NewReader(os.Stdin)
    for {
        line, _, _ := msgin.ReadLine()
        msg := string(line)
        conn.Write([]byte(msg))
    }
}

3. 运行效果