Xray-core/app/router/balancing.go

87 lines
1.7 KiB
Go
Raw Normal View History

2020-11-25 11:01:53 +00:00
package router
import (
"context"
sync "sync"
2020-12-04 01:36:16 +00:00
"github.com/xtls/xray-core/common/dice"
"github.com/xtls/xray-core/features/extension"
2020-12-04 01:36:16 +00:00
"github.com/xtls/xray-core/features/outbound"
2020-11-25 11:01:53 +00:00
)
type BalancingStrategy interface {
PickOutbound([]string) string
}
2021-10-19 16:57:14 +00:00
type RandomStrategy struct{}
2020-11-25 11:01:53 +00:00
func (s *RandomStrategy) PickOutbound(tags []string) string {
n := len(tags)
if n == 0 {
panic("0 tags")
}
return tags[dice.Roll(n)]
}
type RoundRobinStrategy struct {
mu sync.Mutex
tags []string
index int
roundRobin *RoundRobinStrategy
}
func NewRoundRobin(tags []string) *RoundRobinStrategy {
return &RoundRobinStrategy{
tags: tags,
}
}
func (r *RoundRobinStrategy) NextTag() string {
r.mu.Lock()
defer r.mu.Unlock()
tags := r.tags[r.index]
r.index = (r.index + 1) % len(r.tags)
return tags
}
func (s *RoundRobinStrategy) PickOutbound(tags []string) string {
if len(tags) == 0 {
panic("0 tags")
}
if s.roundRobin == nil {
s.roundRobin = NewRoundRobin(tags)
}
tag := s.roundRobin.NextTag()
return tag
}
2020-11-25 11:01:53 +00:00
type Balancer struct {
selectors []string
strategy BalancingStrategy
ohm outbound.Manager
}
func (b *Balancer) PickOutbound() (string, error) {
hs, ok := b.ohm.(outbound.HandlerSelector)
if !ok {
return "", newError("outbound.Manager is not a HandlerSelector")
}
tags := hs.Select(b.selectors)
if len(tags) == 0 {
return "", newError("no available outbounds selected")
}
tag := b.strategy.PickOutbound(tags)
if tag == "" {
return "", newError("balancing strategy returns empty tag")
}
return tag, nil
}
2022-05-18 07:29:01 +00:00
func (b *Balancer) InjectContext(ctx context.Context) {
if contextReceiver, ok := b.strategy.(extension.ContextReceiver); ok {
contextReceiver.InjectContext(ctx)
}
}