mirror of https://github.com/qwqdanchun/nps.git
86 lines
2.3 KiB
Go
86 lines
2.3 KiB
Go
package connection
|
|
|
|
import (
|
|
"net"
|
|
"os"
|
|
"strconv"
|
|
|
|
"github.com/astaxie/beego"
|
|
"github.com/astaxie/beego/logs"
|
|
"github.com/cnlh/nps/lib/mux"
|
|
)
|
|
|
|
var pMux *mux.PortMux
|
|
var bridgePort string
|
|
var httpsPort string
|
|
var httpPort string
|
|
var webPort string
|
|
|
|
func InitConnectionService() {
|
|
bridgePort = beego.AppConfig.String("bridge_port")
|
|
httpsPort = beego.AppConfig.String("https_proxy_port")
|
|
httpPort = beego.AppConfig.String("http_proxy_port")
|
|
webPort = beego.AppConfig.String("web_port")
|
|
|
|
if httpPort == bridgePort || httpsPort == bridgePort || webPort == bridgePort {
|
|
port, err := strconv.Atoi(bridgePort)
|
|
if err != nil {
|
|
logs.Error(err)
|
|
os.Exit(0)
|
|
}
|
|
pMux = mux.NewPortMux(port, beego.AppConfig.String("web_host"))
|
|
}
|
|
}
|
|
|
|
func GetBridgeListener(tp string) (net.Listener, error) {
|
|
logs.Info("server start, the bridge type is %s, the bridge port is %s", tp, bridgePort)
|
|
var p int
|
|
var err error
|
|
if p, err = strconv.Atoi(bridgePort); err != nil {
|
|
return nil, err
|
|
}
|
|
if pMux != nil {
|
|
return pMux.GetClientListener(), nil
|
|
}
|
|
return net.ListenTCP("tcp", &net.TCPAddr{net.ParseIP(beego.AppConfig.String("bridge_ip")), p, ""})
|
|
}
|
|
|
|
func GetHttpListener() (net.Listener, error) {
|
|
if pMux != nil && httpPort == bridgePort {
|
|
logs.Info("start http listener, port is", bridgePort)
|
|
return pMux.GetHttpListener(), nil
|
|
}
|
|
logs.Info("start http listener, port is", httpPort)
|
|
return getTcpListener(beego.AppConfig.String("http_proxy_ip"), httpPort)
|
|
}
|
|
|
|
func GetHttpsListener() (net.Listener, error) {
|
|
if pMux != nil && httpsPort == bridgePort {
|
|
logs.Info("start https listener, port is", bridgePort)
|
|
return pMux.GetHttpsListener(), nil
|
|
}
|
|
logs.Info("start https listener, port is", httpsPort)
|
|
return getTcpListener(beego.AppConfig.String("http_proxy_ip"), httpsPort)
|
|
}
|
|
|
|
func GetWebManagerListener() (net.Listener, error) {
|
|
if pMux != nil && webPort == bridgePort {
|
|
logs.Info("Web management start, access port is", bridgePort)
|
|
return pMux.GetManagerListener(), nil
|
|
}
|
|
logs.Info("web management start, access port is", webPort)
|
|
return getTcpListener(beego.AppConfig.String("web_ip"), webPort)
|
|
}
|
|
|
|
func getTcpListener(ip, p string) (net.Listener, error) {
|
|
port, err := strconv.Atoi(p)
|
|
if err != nil {
|
|
logs.Error(err)
|
|
os.Exit(0)
|
|
}
|
|
if ip == "" {
|
|
ip = "0.0.0.0"
|
|
}
|
|
return net.ListenTCP("tcp", &net.TCPAddr{net.ParseIP(ip), port, ""})
|
|
}
|