front

README

front

这是一个简单的http/https/ws/wss均衡负载、故障转移路由/代理，通过定时刷新配置不中断地：

• 动态后端
• 路径继承
• 自定权重
• 故障转移
• 自定义头
• 多种轮询
• 请求路径过滤
• 请求头过滤
• 请求数据过滤

支持嵌入到其他项目中/独立运行

配置为json数组格式[]，下面为数组中的其中一个{}，下述字段倾斜的，表示不会根据配置动态加载

config:

• addr: string 监听端口 例：0.0.0.0:8081
• matchRule: string 匹配规则 prefix：当未匹配到时，返回最近的/匹配， all：当未匹配到时，返回404
• copyBlocks: int 转发的块数量，默认1000
• tls: {} 启用tls
  • pub: string 公钥pem路径
  • key: string 私钥pem路径
• routes: [] 路由
  • path: string 路径
  • pathAdd: bool 将客户端访问的路径附加在path上 例：/api/req => /ws => /ws/api/req
  • rollRule: string 可选
    • disableC_MinFirst(禁用数较少的优先)
    • dealingC_MinFirst(连接数较少的优先)
    • chosenC_MinFirst(被选择较少的优先)
    • lastResDur_MinFirst(上次响应时间较短的优先)
    • resDur_MinFirst(总响应时间较短的优先)
    • (使用rand.Shuffle随机，默认)
  • reqBody: 请求后端前，请求数据过滤器
    • action: string 可选access、deny。
    • reqSize：string 限定请求数据大小，默认为1M
    • matchExp: string access时如不匹配将结束请求。deny时如匹配将结束请求。
  • setting... 将会给backs默认值
  • backs: [] 后端
    • name: string 后端名称，将在日志中显示
    • to: string 后端地址，例s://www.baidu.com，会根据客户端自动添加http or ws在地址前
    • weight: int 权重，按routes中的全部back的权重比分配，当权重为0时，将停止新请求的进入
    • setting...

setting:

• splicing: int 当客户端支持cookie时，将会固定使用后端多少秒，默认不启用

• errToSec: float64 当后端响应超过(ws则指初次返回时间)指定秒，将会触发errBanSec

• errBanSec: int 当后端错误时（指连接失败，不指后端错误响应），将会禁用若干秒

• filiter:

  • reqUri: 请求后端前，请求路径过滤器
    • accessRule: 布尔表达式，为true时才通过
    • items: map[string]string
      • id: matchExp
  • reqHeader: 请求后端前，请求头处理器
    • accessRule: 布尔表达式，为true时才通过
    • items: map[string]{}
      • id:
        • key: string header头
        • matchExp: string
  • resHeader: 返回后端的响应前，请求头处理器
    • accessRule: 布尔表达式，为true时才通过
    • items: map[string]{}
      • id:
        • key: string header头
        • matchExp: string

• dealer:

  • reqHeader:[] 请求后端前，请求头处理器
    • action: string 可选replace、add、del、set。
    • key: string 具体处理哪个头
    • matchExp: string replace时结合value进行替换
    • value: string replace时结合matchExp进行替换。add时将附加值。set时将覆盖值。
  • resHeader:[] 返回后端的响应前，请求头处理器
    • action: string 可选add、del、set。
    • key: string 具体处理哪个头
    • matchExp: string replace时结合value进行替换
    • value: string replace时结合matchExp进行替换。add时将附加值。set时将覆盖值。

Documentation

Index

• Variables
• func DialContext(ctx context.Context, urlStr string, requestHeader http.Header) (net.Conn, *http.Response, error)
• func LoadPeriod(ctx context.Context, buf []byte, configF File, configS *[]Config, ...) error
• func Test(ctx context.Context, port int, logger Logger)
• func Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (net.Conn, error)
• type Back
  • func (t *Back) Disable()
  • func (t *Back) Id() string
  • func (t *Back) IsLive() bool
  • func (t *Back) PathAdd() bool
  • func (t *Back) Splicing() int
• type Config
  • func (t *Config) Run(ctx context.Context, logger Logger)
  • func (t *Config) SwapSign(ctx context.Context, logger Logger)
• type File
• type HandshakeError
  • func (t HandshakeError) Error() string
• type Logger
• type Route
  • func (t *Route) FiliterBackByRequest(r *http.Request) []*Back
  • func (t *Route) Id() string
  • func (t *Route) SwapSign(add func(string, *Back), del func(string, *Back), logger Logger)
• type Setting

Variables

var (
	ErrRedirect        = errors.New("ErrRedirect")
	ErrNoHttp          = errors.New("ErrNoHttp")
	ErrNoWs            = errors.New("ErrNoWs")
	ErrCopy            = errors.New("ErrCopy")
	ErrReqCreFail      = errors.New("ErrReqCreFail")
	ErrReqDoFail       = errors.New("ErrReqDoFail")
	ErrResDoFail       = errors.New("ErrResDoFail")
	ErrResTO           = errors.New("ErrResTO")
	ErrUriTooLong      = errors.New("ErrUriTooLong")
	ErrPatherCheckFail = errors.New("ErrPatherCheckFail")
	ErrHeaderCheckFail = errors.New("ErrHeaderCheckFail")
	ErrBodyCheckFail   = errors.New("ErrBodyCheckFail")
	ErrAllBacksFail    = errors.New("ErrAllBacksFail")
	ErrBackFail        = errors.New("ErrBackFail")
	ErrNoRoute         = errors.New("ErrNoRoute")
	ErrDealReqHeader   = errors.New("ErrDealReqHeader")
	ErrDealResHeader   = errors.New("ErrDealResHeader")
)

Functions

func DialContext

func DialContext(ctx context.Context, urlStr string, requestHeader http.Header) (net.Conn, *http.Response, error)

func LoadPeriod

func LoadPeriod(ctx context.Context, buf []byte, configF File, configS *[]Config, logger Logger) error

加载

func Test

func Test(ctx context.Context, port int, logger Logger)

测试

func Upgrade

func Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (net.Conn, error)

Types

type Back

type Back struct {
	Name   string `json:"name"`
	To     string `json:"to"`
	Weight int    `json:"weight"`

	Setting
	// contains filtered or unexported fields
}

func (*Back) Disable

func (t *Back) Disable()

func (*Back) Id

func (t *Back) Id() string

func (*Back) IsLive

func (t *Back) IsLive() bool

func (*Back) PathAdd

func (t *Back) PathAdd() bool

func (*Back) Splicing

func (t *Back) Splicing() int

type Config

type Config struct {
	Addr string `json:"addr"`
	TLS  struct {
		Pub string `json:"pub"`
		Key string `json:"key"`
	} `json:"tls"`
	MatchRule  string               `json:"matchRule"`
	CopyBlocks int                  `json:"copyBlocks"`
	BlocksI    pslice.BlocksI[byte] `json:"-"`

	Routes []Route `json:"routes"`
	// contains filtered or unexported fields
}

func (*Config) Run

func (t *Config) Run(ctx context.Context, logger Logger)

func (*Config) SwapSign

func (t *Config) SwapSign(ctx context.Context, logger Logger)

type File

type File interface {
	Read(data []byte) (int, error)
}

type HandshakeError

type HandshakeError struct {
	// contains filtered or unexported fields
}

func (HandshakeError) Error

func (t HandshakeError) Error() string

type Logger

type Logger interface {
	Error(msg string, args ...any)
	Debug(msg string, args ...any)
	Info(msg string, args ...any)
	Warn(msg string, args ...any)
}

type Route

type Route struct {
	Path string `json:"path"`

	PathAdd  bool         `json:"pathAdd"`
	RollRule string       `json:"rollRule"`
	ReqBody  filiter.Body `json:"reqBody"`
	Setting

	Backs []Back `json:"backs"`
	// contains filtered or unexported fields
}

func (*Route) FiliterBackByRequest

func (t *Route) FiliterBackByRequest(r *http.Request) []*Back

func (*Route) Id

func (t *Route) Id() string

func (*Route) SwapSign

func (t *Route) SwapSign(add func(string, *Back), del func(string, *Back), logger Logger)

type Setting

type Setting struct {
	ErrToSec  float64         `json:"errToSec"`
	Splicing  int             `json:"splicing"`
	ErrBanSec int             `json:"errBanSec"`
	Filiter   filiter.Filiter `json:"filiter"`
	Dealer    dealer.Dealer   `json:"dealer"`
}