package zinterface

type IServer interface{
    Start()
    Stop()
    Server()
}

package znet

import (
    "fmt"
    "log"
    "net"
    "zinx/zinterface"
)

type Server struct {
    Name      string
    IP        string
    IPversion string
    Port      int
}

func (s *Server) Start() {
    log.Printf("%s %s:%d start...\n", s.Name, s.IP, s.Port)
    addr, err := net.ResolveTCPAddr(s.IPversion, fmt.Sprintf("%s:%d", s.IP, s.Port))
    if err != nil {
        log.Println("resolve tcp addr err ", err)
        return
    }
    listener, err := net.ListenTCP(s.IPversion, addr)
    if err != nil {
        log.Println("listen tcp err ", err)
        return
    }
    go func() {
        for {
            conn, err := listener.AcceptTCP()
            if err != nil {
                log.Println("accept tcp err ", err)
                continue
            }
            go func() {

                for {
                    b := make([]byte, 512)
                    len, err := conn.Read(b)
                    if err != nil {
                        log.Println("read tcp err ", err)
                        continue
                    }
                    if _, err := conn.Write(b[:len]); err != nil {
                        log.Println("write tcp err ", err)
                        continue
                    }
                }
            }()
        }
    }()

}
func (s *Server) Stop() {

}
func (s *Server) Server() {
    s.Start()
    select{}
}
func NewServer(name string) zinterface.IServer {
    s := &Server{
        Name:      name,
        IP:        "0.0.0.0",
        IPversion: "tcp4",
        Port:      8999,
    }
    return s
}

package main

import (
    "zinx/znet"
)
func main()  {
    server:=znet.NewServer("[zinx]")
    server.Server()
}