Как работает данный код?

Question

[lookingfor2]

Меня интересует структура HTTPServer, зачем так расширяем http.Server, что в ней *l*, и как допустим используя данный код, поднять http сервер на 3001 порту

type HTTPServer struct {
	srv *http.Server
	l   net.Listener
}

type Server struct {
	servers []*HTTPServer
}

type HTTPServer struct {
	srv *http.Server
	l   net.Listener
}

// Serve starts listening for inbound requests.
func (s *HTTPServer) Serve() error {
	return s.srv.Serve(s.l)
}

// Close closes the HTTPServer from listening for the inbound requests.
func (s *HTTPServer) Close() error {
	return s.l.Close()
}

func (s *Server) Accept(addr string, listeners ...net.Listener) {
	for _, listener := range listeners {
		httpServer := &HTTPServer{
			srv: &http.Server{
				Addr: addr,
			},
			l: listener,
		}
		s.servers = append(s.servers, httpServer)
	}
}
func (s *Server) Close() {
	for _, srv := range s.servers {
		if err := srv.Close(); err != nil {
			s.logger.Error(err)
		}
	}
}

func (s *Server) createMux() http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		err := json.NewEncoder(w).Encode("test")
		if err != nil {
			return
		}
	})
}
func (s *Server) serveAPI() error {
	var chErrors = make(chan error, len(s.servers))
	for _, srv := range s.servers {
		srv.srv.Handler = s.createMux()
		go func(srv *HTTPServer) {
			var err error
			logrus.Infof("API listen on %s", srv.l.Addr())
			if err = srv.Serve(); err != nil && strings.Contains(err.Error(), "use of closed network connection") {
				err = nil
			}
			chErrors <- err
		}(srv)
	}
	for range s.servers {
		err := <-chErrors
		if err != nil {
			return err
		}
	}
	return nil
}

Comments

[Евгений Мамонов]

l - это интерфейс https://pkg.go.dev/net#Listener тут же есть и пример использования.
Для чего вам нужно использовать именно этот код?
Скорее всего будет лучше использовать для этого пакет net/http

[lookingfor2]

Евгений Мамонов, интерфейс подписывается через утиную типизацию. Получается мы в структуру должны передать l у которой будут данные 3 метода, извините сложно понять.

Я так понимаю, сервер поднимается данным методом.

// Serve starts listening for inbound requests.
func (s *HTTPServer) Serve() error {
  return s.srv.Serve(s.l)
}

Как для примера можно заполнить данную структуру?
srv например будет
httpServer := &http.Server{
Addr: a.configs.Port,
Handler: a.router,
ReadTimeout: 10 * time.Second,
WriteTimeout: 10 * time.Second,
MaxHeaderBytes: 1 << 20,
}
Почему не поднимают через httpServer.ListenAndServe()
Зачем s.srv.Serve(s.l)

type HTTPServer struct {
  srv *http.Server
  l   net.Listener
}

[Евгений Мамонов]

Скорее все инициализировать этот код нужно будет как то так

s := Server{servers: []*HTTPServer{}}

// После чего нужно добавить "слушателей".
l := net.Listen("tcp", ":3001")
s.Accept(":3001", l)
// после чего вызывать
s.serveAPI()

Подозреваю что задача того, кто писал этот код была в том, чтобы запускать сервера на разных IP, портах.
Если задача стоит такая - то вот простой и понятный вариант

package main

import (
    "net/http"
    "fmt"
    "log"
)

func main() {

    handler := http.NewServeMux()
    handler.HandleFunc("/", handlerFunc)

    // первый сервер
    go func() {
        http.ListenAndServe("localhost:3001", handler)
    }()

    // второй сервер
    go func() {
        http.ListenAndServe("localhost:3001", handler)
    }()

    // последний сервер
    http.ListenAndServe("localhost:3002", handler)
}

func handlerFunc(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "Got new request")
}

[lookingfor2]

Евгений Мамонов, понял спасибо