tcp.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. package proxy
  2. import (
  3. "errors"
  4. "github.com/cnlh/nps/bridge"
  5. "github.com/cnlh/nps/lib/common"
  6. "github.com/cnlh/nps/lib/conn"
  7. "github.com/cnlh/nps/lib/file"
  8. "github.com/cnlh/nps/vender/github.com/astaxie/beego"
  9. "github.com/cnlh/nps/vender/github.com/astaxie/beego/logs"
  10. "net"
  11. "os"
  12. "path/filepath"
  13. "strings"
  14. )
  15. type TunnelModeServer struct {
  16. BaseServer
  17. process process
  18. listener *net.TCPListener
  19. }
  20. //tcp|http|host
  21. func NewTunnelModeServer(process process, bridge *bridge.Bridge, task *file.Tunnel) *TunnelModeServer {
  22. s := new(TunnelModeServer)
  23. s.bridge = bridge
  24. s.process = process
  25. s.task = task
  26. return s
  27. }
  28. //开始
  29. func (s *TunnelModeServer) Start() error {
  30. var err error
  31. s.listener, err = net.ListenTCP("tcp", &net.TCPAddr{net.ParseIP("0.0.0.0"), s.task.Port, ""})
  32. if err != nil {
  33. return err
  34. }
  35. for {
  36. c, err := s.listener.AcceptTCP()
  37. if err != nil {
  38. if strings.Contains(err.Error(), "use of closed network connection") {
  39. break
  40. }
  41. logs.Info(err)
  42. continue
  43. }
  44. if err := s.checkFlow(); err != nil {
  45. logs.Warn("client id %d task id %d error %s", s.task.Client.Id, s.task.Id, err.Error())
  46. c.Close()
  47. }
  48. if s.task.Client.GetConn() {
  49. logs.Trace("New tcp connection,client %d,remote address %s", s.task.Client.Id, c.RemoteAddr())
  50. go s.process(conn.NewConn(c), s)
  51. } else {
  52. logs.Info("Connections exceed the current client %d limit", s.task.Client.Id)
  53. c.Close()
  54. }
  55. }
  56. return nil
  57. }
  58. //close
  59. func (s *TunnelModeServer) Close() error {
  60. return s.listener.Close()
  61. }
  62. //web管理方式
  63. type WebServer struct {
  64. BaseServer
  65. }
  66. //开始
  67. func (s *WebServer) Start() error {
  68. p, _ := beego.AppConfig.Int("httpport")
  69. if p == 0 {
  70. stop := make(chan struct{})
  71. <-stop
  72. }
  73. if !common.TestTcpPort(p) {
  74. logs.Error("Web management port %d is occupied", p)
  75. os.Exit(0)
  76. }
  77. beego.BConfig.WebConfig.Session.SessionOn = true
  78. logs.Info("Web management start, access port is", p)
  79. beego.SetStaticPath("/static", filepath.Join(common.GetRunPath(), "web", "static"))
  80. beego.SetViewsPath(filepath.Join(common.GetRunPath(), "web", "views"))
  81. beego.Run()
  82. return errors.New("Web management startup failure")
  83. }
  84. func (s *WebServer) Close() error {
  85. return nil
  86. }
  87. //new
  88. func NewWebServer(bridge *bridge.Bridge) *WebServer {
  89. s := new(WebServer)
  90. s.bridge = bridge
  91. return s
  92. }
  93. type process func(c *conn.Conn, s *TunnelModeServer) error
  94. //tcp隧道模式
  95. func ProcessTunnel(c *conn.Conn, s *TunnelModeServer) error {
  96. return s.DealClient(c, s.task.Target, nil, common.CONN_TCP)
  97. }
  98. //http代理模式
  99. func ProcessHttp(c *conn.Conn, s *TunnelModeServer) error {
  100. _, addr, rb, err, r := c.GetHost()
  101. if err != nil {
  102. c.Close()
  103. logs.Info(err)
  104. return err
  105. }
  106. if r.Method == "CONNECT" {
  107. c.Write([]byte("HTTP/1.1 200 Connection Established\r\n"))
  108. rb = nil
  109. }
  110. if err := s.auth(r, c, s.task.Client.Cnf.U, s.task.Client.Cnf.P); err != nil {
  111. return err
  112. }
  113. return s.DealClient(c, addr, rb, common.CONN_TCP)
  114. }