package main

import(
	"fmt"
	"net"
	"time"
)
func process(conn net.Conn){
	defer conn.Close()

	for{
		buf:=make([]byte, 1024)
		n,err:=conn.Read(buf)
		if err!=nil{
			fmt.Println("conn.Read failed ,err=",err)
			return
		}
		remoteaddr:=fmt.Sprintf("%v",conn.RemoteAddr())
		fmt.Print(remoteaddr+":")
		fmt.Println(string(buf[:n]))
	}
}
func main()  {
	listener,err:=net.Listen("tcp","127.0.0.1:1234")
	if err!=nil{
		fmt.Println("net.Listen failed,err=",err)
		return
	}
	defer listener.Close()

	for{
		conn,err:=listener.Accept()
		if err!=nil{
			fmt.Println("listener.Accept failed,err=",err)
			return
		}

		go process(conn)
		time.Sleep(time.Second)


	}
}