package server import ( "errors" "github.com/cnlh/nps/bridge" "github.com/cnlh/nps/lib/common" "github.com/cnlh/nps/lib/file" "github.com/cnlh/nps/server/proxy" "github.com/cnlh/nps/server/tool" "github.com/cnlh/nps/vender/github.com/astaxie/beego" "github.com/cnlh/nps/vender/github.com/astaxie/beego/logs" "github.com/shirou/gopsutil/cpu" "github.com/shirou/gopsutil/load" "github.com/shirou/gopsutil/mem" "github.com/shirou/gopsutil/net" "math" "os" "strconv" "time" ) var ( Bridge *bridge.Bridge RunList map[int]interface{} //运行中的任务 serverStatus []map[string]interface{} ) func init() { RunList = make(map[int]interface{}) serverStatus = make([]map[string]interface{}, 0, 1500) go getSeverStatus() } //从csv文件中恢复任务 func InitFromCsv() { //Add a public password if vkey := beego.AppConfig.String("publicVkey"); vkey != "" { c := file.NewClient(vkey, true, true) file.GetCsvDb().NewClient(c) RunList[c.Id] = nil } //Initialize services in server-side files for _, v := range file.GetCsvDb().Tasks { if v.Status { AddTask(v) } } } func DealBridgeTask() { for { select { case t := <-Bridge.OpenTask: AddTask(t) case id := <-Bridge.CloseClient: DelTunnelAndHostByClientId(id) file.GetCsvDb().DelClient(id) case s := <-Bridge.SecretChan: logs.Trace("New secret connection, addr", s.Conn.Conn.RemoteAddr()) if t := file.GetCsvDb().GetTaskByMd5Password(s.Password); t != nil { if !t.Client.GetConn() { logs.Info("Connections exceed the current client %d limit", t.Client.Id) s.Conn.Close() } else if t.Status { go proxy.NewBaseServer(Bridge, t).DealClient(s.Conn, t.Target, nil, common.CONN_TCP) } else { s.Conn.Close() logs.Trace("This key %s cannot be processed,status is close", s.Password) } } else { logs.Trace("This key %s cannot be processed", s.Password) s.Conn.Close() } } } } //start a new server func StartNewServer(bridgePort int, cnf *file.Tunnel, bridgeType string) { Bridge = bridge.NewTunnel(bridgePort, bridgeType, common.GetBoolByStr(beego.AppConfig.String("ipLimit")), RunList) if err := Bridge.StartTunnel(); err != nil { logs.Error("start server bridge error", err) os.Exit(0) } else { logs.Info("Server startup, the bridge type is %s, the bridge port is %d", bridgeType, bridgePort) } if p, err := beego.AppConfig.Int("p2pPort"); err == nil { logs.Info("start p2p server port", p) go proxy.NewP2PServer(p).Start() } go DealBridgeTask() if svr := NewMode(Bridge, cnf); svr != nil { if err := svr.Start(); err != nil { logs.Error(err) } RunList[cnf.Id] = svr } else { logs.Error("Incorrect startup mode %s", cnf.Mode) } } //new a server by mode name func NewMode(Bridge *bridge.Bridge, c *file.Tunnel) proxy.Service { var service proxy.Service switch c.Mode { case "tcp", "file": service = proxy.NewTunnelModeServer(proxy.ProcessTunnel, Bridge, c) case "socks5": service = proxy.NewSock5ModeServer(Bridge, c) case "httpProxy": service = proxy.NewTunnelModeServer(proxy.ProcessHttp, Bridge, c) case "udp": service = proxy.NewUdpModeServer(Bridge, c) case "webServer": InitFromCsv() t := &file.Tunnel{ Port: 0, Mode: "httpHostServer", Target: "", Status: true, } AddTask(t) service = proxy.NewWebServer(Bridge) case "httpHostServer": service = proxy.NewHttp(Bridge, c) } return service } //stop server func StopServer(id int) error { if v, ok := RunList[id]; ok { if svr, ok := v.(proxy.Service); ok { if err := svr.Close(); err != nil { return err } logs.Info("stop server id %d", id) } if t, err := file.GetCsvDb().GetTask(id); err != nil { return err } else { t.Status = false file.GetCsvDb().UpdateTask(t) } delete(RunList, id) return nil } return errors.New("task is not running") } //add task func AddTask(t *file.Tunnel) error { if t.Mode == "secret" || t.Mode == "p2p" { logs.Info("secret task %s start ", t.Remark) RunList[t.Id] = nil return nil } if b := tool.TestServerPort(t.Port, t.Mode); !b && t.Mode != "httpHostServer" { logs.Error("taskId %d start error port %d open failed", t.Id, t.Port) return errors.New("the port open error") } if minute, err := beego.AppConfig.Int("flowStoreInterval"); err == nil && minute > 0 { go flowSession(time.Minute * time.Duration(minute)) } if svr := NewMode(Bridge, t); svr != nil { logs.Info("tunnel task %s start mode:%s port %d", t.Remark, t.Mode, t.Port) RunList[t.Id] = svr go func() { if err := svr.Start(); err != nil { logs.Error("clientId %d taskId %d start error %s", t.Client.Id, t.Id, err) delete(RunList, t.Id) return } }() } else { return errors.New("the mode is not correct") } return nil } //start task func StartTask(id int) error { if t, err := file.GetCsvDb().GetTask(id); err != nil { return err } else { AddTask(t) t.Status = true file.GetCsvDb().UpdateTask(t) } return nil } //delete task func DelTask(id int) error { if _, ok := RunList[id]; ok { if err := StopServer(id); err != nil { return err } } return file.GetCsvDb().DelTask(id) } //get task list by page num func GetTunnel(start, length int, typeVal string, clientId int) ([]*file.Tunnel, int) { list := make([]*file.Tunnel, 0) var cnt int for _, v := range file.GetCsvDb().Tasks { if (typeVal != "" && v.Mode != typeVal) || (typeVal == "" && clientId != v.Client.Id) { continue } cnt++ if _, ok := Bridge.Client[v.Client.Id]; ok { v.Client.IsConnect = true } else { v.Client.IsConnect = false } if start--; start < 0 { if length--; length > 0 { if _, ok := RunList[v.Id]; ok { v.RunStatus = true } else { v.RunStatus = false } list = append(list, v) } } } return list, cnt } //获取客户端列表 func GetClientList(start, length int) (list []*file.Client, cnt int) { list, cnt = file.GetCsvDb().GetClientList(start, length) dealClientData(list) return } func dealClientData(list []*file.Client) { for _, v := range list { if _, ok := Bridge.Client[v.Id]; ok { v.IsConnect = true } else { v.IsConnect = false } v.Flow.InletFlow = 0 v.Flow.ExportFlow = 0 for _, h := range file.GetCsvDb().Hosts { if h.Client.Id == v.Id { v.Flow.InletFlow += h.Flow.InletFlow v.Flow.ExportFlow += h.Flow.ExportFlow } } for _, t := range file.GetCsvDb().Tasks { if t.Client.Id == v.Id { v.Flow.InletFlow += t.Flow.InletFlow v.Flow.ExportFlow += t.Flow.ExportFlow } } } return } //根据客户端id删除其所属的所有隧道和域名 func DelTunnelAndHostByClientId(clientId int) { var ids []int for _, v := range file.GetCsvDb().Tasks { if v.Client.Id == clientId { ids = append(ids, v.Id) } } for _, id := range ids { DelTask(id) } for _, v := range file.GetCsvDb().Hosts { if v.Client.Id == clientId { file.GetCsvDb().DelHost(v.Id) } } } //关闭客户端连接 func DelClientConnect(clientId int) { Bridge.DelClient(clientId, false) } func GetDashboardData() map[string]interface{} { data := make(map[string]interface{}) data["hostCount"] = len(file.GetCsvDb().Hosts) data["clientCount"] = len(file.GetCsvDb().Clients) - 1 //Remove the public key client list := file.GetCsvDb().Clients dealClientData(list) c := 0 var in, out int64 for _, v := range list { if v.IsConnect { c += 1 } in += v.Flow.InletFlow out += v.Flow.ExportFlow } data["clientOnlineCount"] = c data["inletFlowCount"] = int(in) data["exportFlowCount"] = int(out) var tcp, udp, secret, socks5, p2p, http int for _, v := range file.GetCsvDb().Tasks { switch v.Mode { case "tcp": tcp += 1 case "socks5": udp += 1 case "httpProxy": http += 1 case "udp": udp += 1 case "p2p": p2p += 1 case "secret": secret += 1 } } data["tcpC"] = tcp data["udpCount"] = udp data["socks5Count"] = socks5 data["httpProxyCount"] = http data["secretCount"] = secret data["p2pCount"] = p2p data["bridgeType"] = beego.AppConfig.String("bridgeType") data["httpProxyPort"] = beego.AppConfig.String("httpProxyPort") data["httpsProxyPort"] = beego.AppConfig.String("httpsProxyPort") data["ipLimit"] = beego.AppConfig.String("ipLimit") data["flowStoreInterval"] = beego.AppConfig.String("flowStoreInterval") data["serverIp"] = beego.AppConfig.String("serverIp") data["p2pPort"] = beego.AppConfig.String("p2pPort") data["logLevel"] = beego.AppConfig.String("logLevel") tcpCount := 0 for _, v := range file.GetCsvDb().Clients { tcpCount += v.NowConn } data["tcpCount"] = tcpCount cpuPercet, _ := cpu.Percent(0, true) var cpuAll float64 for _, v := range cpuPercet { cpuAll += v } loads, _ := load.Avg() data["load"] = loads.String() data["cpu"] = math.Round(cpuAll / float64(len(cpuPercet))) swap, _ := mem.SwapMemory() data["swap_mem"] = math.Round(swap.UsedPercent) vir, _ := mem.VirtualMemory() data["virtual_mem"] = math.Round(vir.UsedPercent) conn, _ := net.ProtoCounters(nil) io1, _ := net.IOCounters(false) time.Sleep(time.Millisecond * 500) io2, _ := net.IOCounters(false) if len(io2) > 0 && len(io1) > 0 { data["io_send"] = (io2[0].BytesSent - io1[0].BytesSent) * 2 data["io_recv"] = (io2[0].BytesRecv - io1[0].BytesRecv) * 2 } for _, v := range conn { data[v.Protocol] = v.Stats["CurrEstab"] } //chart var fg int if len(serverStatus) >= 10 { fg = len(serverStatus) / 10 for i := 0; i <= 9; i++ { data["sys"+strconv.Itoa(i+1)] = serverStatus[i*fg] } } return data } func flowSession(m time.Duration) { ticker := time.NewTicker(m) for { select { case <-ticker.C: file.GetCsvDb().StoreHostToCsv() file.GetCsvDb().StoreTasksToCsv() } } } func getSeverStatus() { for { if len(serverStatus) < 10 { time.Sleep(time.Second) } else { time.Sleep(time.Minute) } cpuPercet, _ := cpu.Percent(0, true) var cpuAll float64 for _, v := range cpuPercet { cpuAll += v } m := make(map[string]interface{}) loads, _ := load.Avg() m["load1"] = loads.Load1 m["load5"] = loads.Load5 m["load15"] = loads.Load15 m["cpu"] = math.Round(cpuAll / float64(len(cpuPercet))) swap, _ := mem.SwapMemory() m["swap_mem"] = math.Round(swap.UsedPercent) vir, _ := mem.VirtualMemory() m["virtual_mem"] = math.Round(vir.UsedPercent) conn, _ := net.ProtoCounters(nil) io1, _ := net.IOCounters(false) time.Sleep(time.Millisecond * 500) io2, _ := net.IOCounters(false) if len(io2) > 0 && len(io1) > 0 { m["io_send"] = (io2[0].BytesSent - io1[0].BytesSent) * 2 m["io_recv"] = (io2[0].BytesRecv - io1[0].BytesRecv) * 2 } t := time.Now() m["time"] = strconv.Itoa(t.Hour()) + ":" + strconv.Itoa(t.Minute()) + ":" + strconv.Itoa(t.Second()) for _, v := range conn { m[v.Protocol] = v.Stats["CurrEstab"] } if len(serverStatus) >= 1440 { serverStatus = serverStatus[1:] } serverStatus = append(serverStatus, m) } }