1
0

udp.go 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. package proxy
  2. import (
  3. "net"
  4. "strings"
  5. "ehang.io/nps/bridge"
  6. "ehang.io/nps/lib/common"
  7. "ehang.io/nps/lib/conn"
  8. "ehang.io/nps/lib/file"
  9. "github.com/astaxie/beego/logs"
  10. )
  11. type UdpModeServer struct {
  12. BaseServer
  13. listener *net.UDPConn
  14. }
  15. func NewUdpModeServer(bridge *bridge.Bridge, task *file.Tunnel) *UdpModeServer {
  16. s := new(UdpModeServer)
  17. s.bridge = bridge
  18. s.task = task
  19. return s
  20. }
  21. //开始
  22. func (s *UdpModeServer) Start() error {
  23. var err error
  24. if s.task.ServerIp == "" {
  25. s.task.ServerIp = "0.0.0.0"
  26. }
  27. s.listener, err = net.ListenUDP("udp", &net.UDPAddr{net.ParseIP(s.task.ServerIp), s.task.Port, ""})
  28. if err != nil {
  29. return err
  30. }
  31. buf := common.BufPoolUdp.Get().([]byte)
  32. for {
  33. n, addr, err := s.listener.ReadFromUDP(buf)
  34. if err != nil {
  35. if strings.Contains(err.Error(), "use of closed network connection") {
  36. break
  37. }
  38. continue
  39. }
  40. logs.Trace("New udp connection,client %d,remote address %s", s.task.Client.Id, addr)
  41. go s.process(addr, buf[:n])
  42. }
  43. return nil
  44. }
  45. func (s *UdpModeServer) process(addr *net.UDPAddr, data []byte) {
  46. if err := s.CheckFlowAndConnNum(s.task.Client); err != nil {
  47. logs.Warn("client id %d, task id %d,error %s, when udp connection", s.task.Client.Id, s.task.Id, err.Error())
  48. return
  49. }
  50. defer s.task.Client.AddConn()
  51. link := conn.NewLink(common.CONN_UDP, s.task.Target.TargetStr, s.task.Client.Cnf.Crypt, s.task.Client.Cnf.Compress, addr.String(), s.task.Target.LocalProxy)
  52. if clientConn, err := s.bridge.SendLinkInfo(s.task.Client.Id, link, s.task); err != nil {
  53. return
  54. } else {
  55. target := conn.GetConn(clientConn, s.task.Client.Cnf.Crypt, s.task.Client.Cnf.Compress, nil, true)
  56. defer target.Close()
  57. s.task.Flow.Add(int64(len(data)), 0)
  58. buf := common.BufPoolUdp.Get().([]byte)
  59. defer common.BufPoolUdp.Put(buf)
  60. target.Write(data)
  61. s.task.Flow.Add(int64(len(data)), 0)
  62. if n, err := target.Read(buf); err != nil {
  63. logs.Warn(err)
  64. return
  65. } else {
  66. s.listener.WriteTo(buf[:n], addr)
  67. s.task.Flow.Add(0, int64(n))
  68. }
  69. }
  70. }
  71. func (s *UdpModeServer) Close() error {
  72. return s.listener.Close()
  73. }