package main
import (
"context"
"fmt"
"github.com/iamxvbaba/server/server"
"github.com/iamxvbaba/server/upgrader"
"time"
)
func main() {
server.Run(New())
}
type Server struct {
}
func New() *Server{
return &Server{}
}
func (s *Server) Name() string {
return "test_server"
}
func (s *Server) Version() string {
return "v0.0.2"
}
func (s *Server) Initialize(ctx context.Context, upg *upgrader.Upgrader) error {
server.Log.Println("app Initialize")
return nil
}
func (s *Server) Serve(ctx context.Context, upg *upgrader.Upgrader) {
server.Log.Println("app Serve!!!!")
ln, err := upg.Fds.Listen("tcp", "0.0.0.0:18541")
if err != nil {
server.Log.Fatalln("Can't listen:", err)
}
defer ln.Close()
server.Log.Printf("listening on %s", ln.Addr())
for {
c, err := ln.Accept()
if err != nil {
server.Log.Printf("listening error:%v", err)
continue
}
go func() {
for {
_, e := c.Write([]byte(fmt.Sprintf("response at %s\n",time.Now().Format("2006-01-02 15:04:04"))))
if e != nil {
return
}
time.Sleep(3*time.Second)
}
}()
go func() {
data := make([]byte,128)
_,e := c.Read(data)
if e != nil {
server.Log.Println("断开：",e)
return
}
server.Log.Printf("client data:%s",data)
}()
}
}
func (s *Server) Destroy() {
server.Log.Println("app Destroy")
}
func (s *Server) Daemon() bool {
return true
}