mirror of
https://github.com/fatedier/frp.git
synced 2024-11-24 02:59:19 +08:00
186 lines
4.2 KiB
Go
186 lines
4.2 KiB
Go
// Copyright 2018 fatedier, fatedier@gmail.com
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package health
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"io"
|
|
"net"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
v1 "github.com/fatedier/frp/pkg/config/v1"
|
|
"github.com/fatedier/frp/pkg/util/xlog"
|
|
)
|
|
|
|
var ErrHealthCheckType = errors.New("error health check type")
|
|
|
|
type Monitor struct {
|
|
checkType string
|
|
interval time.Duration
|
|
timeout time.Duration
|
|
maxFailedTimes int
|
|
|
|
// For tcp
|
|
addr string
|
|
|
|
// For http
|
|
url string
|
|
header http.Header
|
|
failedTimes uint64
|
|
statusOK bool
|
|
statusNormalFn func()
|
|
statusFailedFn func()
|
|
|
|
ctx context.Context
|
|
cancel context.CancelFunc
|
|
}
|
|
|
|
func NewMonitor(ctx context.Context, cfg v1.HealthCheckConfig, addr string,
|
|
statusNormalFn func(), statusFailedFn func(),
|
|
) *Monitor {
|
|
if cfg.IntervalSeconds <= 0 {
|
|
cfg.IntervalSeconds = 10
|
|
}
|
|
if cfg.TimeoutSeconds <= 0 {
|
|
cfg.TimeoutSeconds = 3
|
|
}
|
|
if cfg.MaxFailed <= 0 {
|
|
cfg.MaxFailed = 1
|
|
}
|
|
newctx, cancel := context.WithCancel(ctx)
|
|
|
|
var url string
|
|
if cfg.Type == "http" && cfg.Path != "" {
|
|
s := "http://" + addr
|
|
if !strings.HasPrefix(cfg.Path, "/") {
|
|
s += "/"
|
|
}
|
|
url = s + cfg.Path
|
|
}
|
|
header := make(http.Header)
|
|
for _, h := range cfg.HTTPHeaders {
|
|
header.Set(h.Name, h.Value)
|
|
}
|
|
|
|
return &Monitor{
|
|
checkType: cfg.Type,
|
|
interval: time.Duration(cfg.IntervalSeconds) * time.Second,
|
|
timeout: time.Duration(cfg.TimeoutSeconds) * time.Second,
|
|
maxFailedTimes: cfg.MaxFailed,
|
|
addr: addr,
|
|
url: url,
|
|
header: header,
|
|
statusOK: false,
|
|
statusNormalFn: statusNormalFn,
|
|
statusFailedFn: statusFailedFn,
|
|
ctx: newctx,
|
|
cancel: cancel,
|
|
}
|
|
}
|
|
|
|
func (monitor *Monitor) Start() {
|
|
go monitor.checkWorker()
|
|
}
|
|
|
|
func (monitor *Monitor) Stop() {
|
|
monitor.cancel()
|
|
}
|
|
|
|
func (monitor *Monitor) checkWorker() {
|
|
xl := xlog.FromContextSafe(monitor.ctx)
|
|
for {
|
|
doCtx, cancel := context.WithDeadline(monitor.ctx, time.Now().Add(monitor.timeout))
|
|
err := monitor.doCheck(doCtx)
|
|
|
|
// check if this monitor has been closed
|
|
select {
|
|
case <-monitor.ctx.Done():
|
|
cancel()
|
|
return
|
|
default:
|
|
cancel()
|
|
}
|
|
|
|
if err == nil {
|
|
xl.Tracef("do one health check success")
|
|
if !monitor.statusOK && monitor.statusNormalFn != nil {
|
|
xl.Infof("health check status change to success")
|
|
monitor.statusOK = true
|
|
monitor.statusNormalFn()
|
|
}
|
|
} else {
|
|
xl.Warnf("do one health check failed: %v", err)
|
|
monitor.failedTimes++
|
|
if monitor.statusOK && int(monitor.failedTimes) >= monitor.maxFailedTimes && monitor.statusFailedFn != nil {
|
|
xl.Warnf("health check status change to failed")
|
|
monitor.statusOK = false
|
|
monitor.statusFailedFn()
|
|
}
|
|
}
|
|
|
|
time.Sleep(monitor.interval)
|
|
}
|
|
}
|
|
|
|
func (monitor *Monitor) doCheck(ctx context.Context) error {
|
|
switch monitor.checkType {
|
|
case "tcp":
|
|
return monitor.doTCPCheck(ctx)
|
|
case "http":
|
|
return monitor.doHTTPCheck(ctx)
|
|
default:
|
|
return ErrHealthCheckType
|
|
}
|
|
}
|
|
|
|
func (monitor *Monitor) doTCPCheck(ctx context.Context) error {
|
|
// if tcp address is not specified, always return nil
|
|
if monitor.addr == "" {
|
|
return nil
|
|
}
|
|
|
|
var d net.Dialer
|
|
conn, err := d.DialContext(ctx, "tcp", monitor.addr)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
conn.Close()
|
|
return nil
|
|
}
|
|
|
|
func (monitor *Monitor) doHTTPCheck(ctx context.Context) error {
|
|
req, err := http.NewRequestWithContext(ctx, "GET", monitor.url, nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
req.Header = monitor.header
|
|
req.Host = monitor.header.Get("Host")
|
|
resp, err := http.DefaultClient.Do(req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer resp.Body.Close()
|
|
_, _ = io.Copy(io.Discard, resp.Body)
|
|
|
|
if resp.StatusCode/100 != 2 {
|
|
return fmt.Errorf("do http health check, StatusCode is [%d] not 2xx", resp.StatusCode)
|
|
}
|
|
return nil
|
|
}
|