frp/cmd/frpc/sub/root.go

156 lines
4.0 KiB
Go
Raw Normal View History

2018-04-10 17:46:49 +08:00
// 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 sub
import (
"context"
2018-04-10 17:46:49 +08:00
"fmt"
2022-03-28 12:12:35 +08:00
"io/fs"
2018-04-10 17:46:49 +08:00
"os"
"os/signal"
2022-03-28 12:12:35 +08:00
"path/filepath"
"sync"
2018-04-10 17:46:49 +08:00
"syscall"
"time"
2022-08-29 01:02:53 +08:00
"github.com/spf13/cobra"
2018-04-10 17:46:49 +08:00
"github.com/fatedier/frp/client"
2020-09-23 13:49:14 +08:00
"github.com/fatedier/frp/pkg/config"
v1 "github.com/fatedier/frp/pkg/config/v1"
"github.com/fatedier/frp/pkg/config/v1/validation"
2020-09-23 13:49:14 +08:00
"github.com/fatedier/frp/pkg/util/log"
"github.com/fatedier/frp/pkg/util/version"
2018-04-10 17:46:49 +08:00
)
var (
cfgFile string
2022-03-28 12:12:35 +08:00
cfgDir string
2018-04-10 17:46:49 +08:00
showVersion bool
)
func init() {
2019-04-08 15:39:14 +08:00
rootCmd.PersistentFlags().StringVarP(&cfgFile, "config", "c", "./frpc.ini", "config file of frpc")
2022-03-28 12:12:35 +08:00
rootCmd.PersistentFlags().StringVarP(&cfgDir, "config_dir", "", "", "config directory, run one frpc service for each file in config directory")
2018-04-10 17:46:49 +08:00
rootCmd.PersistentFlags().BoolVarP(&showVersion, "version", "v", false, "version of frpc")
}
var rootCmd = &cobra.Command{
Use: "frpc",
Short: "frpc is the client of frp (https://github.com/fatedier/frp)",
RunE: func(cmd *cobra.Command, args []string) error {
if showVersion {
fmt.Println(version.Full())
return nil
}
2022-03-28 12:12:35 +08:00
// If cfgDir is not empty, run multiple frpc service for each config file in cfgDir.
// Note that it's only designed for testing. It's not guaranteed to be stable.
if cfgDir != "" {
_ = runMultipleClients(cfgDir)
2022-03-28 12:12:35 +08:00
return nil
}
2018-04-10 17:46:49 +08:00
// Do not show command usage here.
err := runClient(cfgFile)
if err != nil {
2023-09-13 18:59:51 +08:00
fmt.Println(err)
2018-04-10 17:46:49 +08:00
os.Exit(1)
}
return nil
},
}
func runMultipleClients(cfgDir string) error {
var wg sync.WaitGroup
err := filepath.WalkDir(cfgDir, func(path string, d fs.DirEntry, err error) error {
if err != nil || d.IsDir() {
return nil
}
wg.Add(1)
time.Sleep(time.Millisecond)
go func() {
defer wg.Done()
err := runClient(path)
if err != nil {
fmt.Printf("frpc service error for config file [%s]\n", path)
}
}()
return nil
})
wg.Wait()
return err
}
2018-04-10 17:46:49 +08:00
func Execute() {
if err := rootCmd.Execute(); err != nil {
os.Exit(1)
}
}
2023-06-30 17:35:37 +08:00
func handleTermSignal(svr *client.Service) {
2022-03-28 12:12:35 +08:00
ch := make(chan os.Signal, 1)
2018-04-10 17:46:49 +08:00
signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
<-ch
2021-10-19 15:02:45 +08:00
svr.GracefulClose(500 * time.Millisecond)
2018-04-10 17:46:49 +08:00
}
func runClient(cfgFilePath string) error {
cfg, pxyCfgs, visitorCfgs, isLegacyFormat, err := config.LoadClientConfig(cfgFilePath)
if err != nil {
return err
}
if isLegacyFormat {
fmt.Printf("WARNING: ini format is deprecated and the support will be removed in the future, " +
"please use yaml/json/toml format instead!\n")
}
warning, err := validation.ValidateAllClientConfig(cfg, pxyCfgs, visitorCfgs)
if warning != nil {
fmt.Printf("WARNING: %v\n", warning)
}
if err != nil {
return err
}
return startService(cfg, pxyCfgs, visitorCfgs, cfgFilePath)
}
2020-06-02 22:48:55 +08:00
func startService(
cfg *v1.ClientCommonConfig,
pxyCfgs []v1.ProxyConfigurer,
visitorCfgs []v1.VisitorConfigurer,
2020-06-02 22:48:55 +08:00
cfgFile string,
) error {
log.InitLog(cfg.Log.To, cfg.Log.Level, cfg.Log.MaxDays, cfg.Log.DisablePrintColor)
2022-03-28 12:12:35 +08:00
if cfgFile != "" {
log.Info("start frpc service for config file [%s]", cfgFile)
defer log.Info("frpc service for config file [%s] stopped", cfgFile)
}
svr, err := client.NewService(cfg, pxyCfgs, visitorCfgs, cfgFile)
if err != nil {
return err
2019-02-01 19:26:10 +08:00
}
2018-04-10 17:46:49 +08:00
shouldGracefulClose := cfg.Transport.Protocol == "kcp" || cfg.Transport.Protocol == "quic"
// Capture the exit signal if we use kcp or quic.
if shouldGracefulClose {
2023-06-30 17:35:37 +08:00
go handleTermSignal(svr)
2018-04-10 17:46:49 +08:00
}
2023-06-30 17:35:37 +08:00
_ = svr.Run(context.Background())
return nil
2018-04-10 17:46:49 +08:00
}