server.go 1.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. package streamserver
  2. import (
  3. "fmt"
  4. "net"
  5. libnet "github.com/fatedier/frp/pkg/util/net"
  6. "github.com/fatedier/frp/test/e2e/pkg/rpc"
  7. )
  8. type Type string
  9. const (
  10. TCP Type = "tcp"
  11. UDP Type = "udp"
  12. Unix Type = "unix"
  13. )
  14. type Server struct {
  15. netType Type
  16. bindAddr string
  17. bindPort int
  18. respContent []byte
  19. l net.Listener
  20. }
  21. type Option func(*Server) *Server
  22. func New(netType Type, options ...Option) *Server {
  23. s := &Server{
  24. netType: netType,
  25. bindAddr: "127.0.0.1",
  26. }
  27. for _, option := range options {
  28. s = option(s)
  29. }
  30. return s
  31. }
  32. func WithBindAddr(addr string) Option {
  33. return func(s *Server) *Server {
  34. s.bindAddr = addr
  35. return s
  36. }
  37. }
  38. func WithBindPort(port int) Option {
  39. return func(s *Server) *Server {
  40. s.bindPort = port
  41. return s
  42. }
  43. }
  44. func WithRespContent(content []byte) Option {
  45. return func(s *Server) *Server {
  46. s.respContent = content
  47. return s
  48. }
  49. }
  50. func (s *Server) Run() error {
  51. if err := s.initListener(); err != nil {
  52. return err
  53. }
  54. go func() {
  55. for {
  56. c, err := s.l.Accept()
  57. if err != nil {
  58. return
  59. }
  60. go s.handle(c)
  61. }
  62. }()
  63. return nil
  64. }
  65. func (s *Server) Close() error {
  66. if s.l != nil {
  67. return s.l.Close()
  68. }
  69. return nil
  70. }
  71. func (s *Server) initListener() (err error) {
  72. switch s.netType {
  73. case TCP:
  74. s.l, err = net.Listen("tcp", fmt.Sprintf("%s:%d", s.bindAddr, s.bindPort))
  75. case UDP:
  76. s.l, err = libnet.ListenUDP(s.bindAddr, s.bindPort)
  77. case Unix:
  78. s.l, err = net.Listen("unix", s.bindAddr)
  79. default:
  80. return fmt.Errorf("unknown server type: %s", s.netType)
  81. }
  82. return err
  83. }
  84. func (s *Server) handle(c net.Conn) {
  85. defer c.Close()
  86. for {
  87. buf, err := rpc.ReadBytes(c)
  88. if err != nil {
  89. return
  90. }
  91. if len(s.respContent) > 0 {
  92. buf = s.respContent
  93. }
  94. rpc.WriteBytes(c, buf)
  95. }
  96. }
  97. func (s *Server) BindAddr() string {
  98. return s.bindAddr
  99. }
  100. func (s *Server) BindPort() int {
  101. return s.bindPort
  102. }