receiver.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. package outbound
  2. import (
  3. "math/rand"
  4. "sync"
  5. "time"
  6. v2net "github.com/v2ray/v2ray-core/common/net"
  7. "github.com/v2ray/v2ray-core/proxy/vmess"
  8. )
  9. type Receiver struct {
  10. sync.RWMutex
  11. Destination v2net.Destination
  12. Accounts []*vmess.User
  13. }
  14. func NewReceiver(dest v2net.Destination, users ...*vmess.User) *Receiver {
  15. return &Receiver{
  16. Destination: dest,
  17. Accounts: users,
  18. }
  19. }
  20. func (this *Receiver) HasUser(user *vmess.User) bool {
  21. this.RLock()
  22. defer this.RUnlock()
  23. for _, u := range this.Accounts {
  24. // TODO: handle AlterIds difference.
  25. if u.ID.Equals(user.ID) {
  26. return true
  27. }
  28. }
  29. return false
  30. }
  31. func (this *Receiver) AddUser(user *vmess.User) {
  32. if this.HasUser(user) {
  33. return
  34. }
  35. this.Lock()
  36. this.Accounts = append(this.Accounts, user)
  37. this.Unlock()
  38. }
  39. func (this *Receiver) PickUser() *vmess.User {
  40. userLen := len(this.Accounts)
  41. userIdx := 0
  42. if userLen > 1 {
  43. userIdx = rand.Intn(userLen)
  44. }
  45. return this.Accounts[userIdx]
  46. }
  47. type ExpiringReceiver struct {
  48. *Receiver
  49. until time.Time
  50. }
  51. func (this *ExpiringReceiver) Expired() bool {
  52. return this.until.Before(time.Now())
  53. }
  54. type ReceiverManager struct {
  55. receivers []*Receiver
  56. detours []*ExpiringReceiver
  57. detourAccess sync.RWMutex
  58. }
  59. func NewReceiverManager(receivers []*Receiver) *ReceiverManager {
  60. return &ReceiverManager{
  61. receivers: receivers,
  62. detours: make([]*ExpiringReceiver, 0, 16),
  63. }
  64. }
  65. func (this *ReceiverManager) AddDetour(rec *Receiver, availableMin byte) {
  66. if availableMin < 2 {
  67. return
  68. }
  69. this.detourAccess.RLock()
  70. destExists := false
  71. for _, r := range this.detours {
  72. if r.Destination == rec.Destination {
  73. destExists = true
  74. // Destination exists, add new user if necessary
  75. for _, u := range rec.Accounts {
  76. r.AddUser(u)
  77. }
  78. break
  79. }
  80. }
  81. this.detourAccess.RUnlock()
  82. if !destExists {
  83. expRec := &ExpiringReceiver{
  84. Receiver: rec,
  85. until: time.Now().Add(time.Duration(availableMin-1) * time.Minute),
  86. }
  87. this.detourAccess.Lock()
  88. this.detours = append(this.detours, expRec)
  89. this.detourAccess.Unlock()
  90. }
  91. }
  92. func (this *ReceiverManager) pickDetour() *Receiver {
  93. if len(this.detours) == 0 {
  94. return nil
  95. }
  96. this.detourAccess.RLock()
  97. idx := 0
  98. detourLen := len(this.detours)
  99. if detourLen > 1 {
  100. idx = rand.Intn(detourLen)
  101. }
  102. rec := this.detours[idx]
  103. this.detourAccess.RUnlock()
  104. if rec.Expired() {
  105. this.detourAccess.Lock()
  106. detourLen := len(this.detours)
  107. this.detours[idx] = this.detours[detourLen-1]
  108. this.detours = this.detours[:detourLen-1]
  109. this.detourAccess.Unlock()
  110. return nil
  111. }
  112. return rec.Receiver
  113. }
  114. func (this *ReceiverManager) pickStdReceiver() *Receiver {
  115. receiverLen := len(this.receivers)
  116. receiverIdx := 0
  117. if receiverLen > 1 {
  118. receiverIdx = rand.Intn(receiverLen)
  119. }
  120. return this.receivers[receiverIdx]
  121. }
  122. func (this *ReceiverManager) PickReceiver() (v2net.Destination, *vmess.User) {
  123. rec := this.pickDetour()
  124. if rec == nil {
  125. rec = this.pickStdReceiver()
  126. }
  127. user := rec.PickUser()
  128. return rec.Destination, user
  129. }