hub.go 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. package agent_server
  2. import "nginx-ui/server/models"
  3. // Hub maintains the set of active clients and broadcasts messages to the
  4. // clients.
  5. type Hub struct {
  6. // Registered clients.
  7. clientMap map[string]*WsClient
  8. // Inbound messages from the clients.
  9. broadcast chan []byte
  10. // Register requests from the clients.
  11. register chan *WsClient
  12. // Unregister requests from clients.
  13. unregister chan *WsClient
  14. handlers map[string]func(c *WsClient, message *models.AgentData) (interface{}, error)
  15. }
  16. func newHub() *Hub {
  17. return &Hub{
  18. broadcast: make(chan []byte),
  19. register: make(chan *WsClient),
  20. clientMap: make(map[string]*WsClient),
  21. handlers: make(map[string]func(c *WsClient, message *models.AgentData) (interface{}, error)),
  22. }
  23. }
  24. func (h *Hub) SetMessageHandler(key string, handler func(c *WsClient, message *models.AgentData) (interface{}, error)) {
  25. h.handlers[key] = handler
  26. }
  27. func (h *Hub) FindClient(key string) (*WsClient, bool) {
  28. c, ok := h.clientMap[key]
  29. return c, ok
  30. }
  31. func (h *Hub) run() {
  32. for {
  33. select {
  34. case client := <-h.register:
  35. h.clientMap[client.Token] = client
  36. case client := <-h.unregister:
  37. if _, ok := h.clientMap[client.Token]; ok {
  38. delete(h.clientMap, client.Token)
  39. close(client.send)
  40. }
  41. delete(h.clientMap, client.Token)
  42. case message := <-h.broadcast:
  43. for _, client := range h.clientMap {
  44. select {
  45. case client.send <- message:
  46. default:
  47. close(client.send)
  48. delete(h.clientMap, client.Token)
  49. }
  50. }
  51. }
  52. }
  53. }