sudp.go 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113
  1. // Copyright 2018 fatedier, fatedier@gmail.com
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. package sub
  15. import (
  16. "fmt"
  17. "os"
  18. "github.com/spf13/cobra"
  19. "github.com/fatedier/frp/pkg/config/types"
  20. v1 "github.com/fatedier/frp/pkg/config/v1"
  21. "github.com/fatedier/frp/pkg/config/v1/validation"
  22. "github.com/fatedier/frp/pkg/consts"
  23. )
  24. func init() {
  25. RegisterCommonFlags(sudpCmd)
  26. sudpCmd.PersistentFlags().StringVarP(&proxyName, "proxy_name", "n", "", "proxy name")
  27. sudpCmd.PersistentFlags().StringVarP(&role, "role", "", "server", "role")
  28. sudpCmd.PersistentFlags().StringVarP(&sk, "sk", "", "", "secret key")
  29. sudpCmd.PersistentFlags().StringVarP(&serverName, "server_name", "", "", "server name")
  30. sudpCmd.PersistentFlags().StringVarP(&localIP, "local_ip", "i", "127.0.0.1", "local ip")
  31. sudpCmd.PersistentFlags().IntVarP(&localPort, "local_port", "l", 0, "local port")
  32. sudpCmd.PersistentFlags().StringVarP(&bindAddr, "bind_addr", "", "", "bind addr")
  33. sudpCmd.PersistentFlags().IntVarP(&bindPort, "bind_port", "", 0, "bind port")
  34. sudpCmd.PersistentFlags().BoolVarP(&useEncryption, "ue", "", false, "use encryption")
  35. sudpCmd.PersistentFlags().BoolVarP(&useCompression, "uc", "", false, "use compression")
  36. sudpCmd.PersistentFlags().StringVarP(&bandwidthLimit, "bandwidth_limit", "", "", "bandwidth limit")
  37. sudpCmd.PersistentFlags().StringVarP(&bandwidthLimitMode, "bandwidth_limit_mode", "", types.BandwidthLimitModeClient, "bandwidth limit mode")
  38. rootCmd.AddCommand(sudpCmd)
  39. }
  40. var sudpCmd = &cobra.Command{
  41. Use: "sudp",
  42. Short: "Run frpc with a single sudp proxy",
  43. RunE: func(cmd *cobra.Command, args []string) error {
  44. clientCfg, err := parseClientCommonCfgFromCmd()
  45. if err != nil {
  46. fmt.Println(err)
  47. os.Exit(1)
  48. }
  49. pxyCfgs := make([]v1.ProxyConfigurer, 0)
  50. visitorCfgs := make([]v1.VisitorConfigurer, 0)
  51. var prefix string
  52. if user != "" {
  53. prefix = user + "."
  54. }
  55. switch role {
  56. case "server":
  57. cfg := &v1.SUDPProxyConfig{}
  58. cfg.Name = prefix + proxyName
  59. cfg.Type = consts.SUDPProxy
  60. cfg.Transport.UseEncryption = useEncryption
  61. cfg.Transport.UseCompression = useCompression
  62. cfg.Secretkey = sk
  63. cfg.LocalIP = localIP
  64. cfg.LocalPort = localPort
  65. cfg.Transport.BandwidthLimit, err = types.NewBandwidthQuantity(bandwidthLimit)
  66. if err != nil {
  67. fmt.Println(err)
  68. os.Exit(1)
  69. }
  70. cfg.Transport.BandwidthLimitMode = bandwidthLimitMode
  71. if err := validation.ValidateProxyConfigurerForClient(cfg); err != nil {
  72. fmt.Println(err)
  73. os.Exit(1)
  74. }
  75. pxyCfgs = append(pxyCfgs, cfg)
  76. case "visitor":
  77. cfg := &v1.SUDPVisitorConfig{}
  78. cfg.Name = prefix + proxyName
  79. cfg.Type = consts.SUDPProxy
  80. cfg.Transport.UseEncryption = useEncryption
  81. cfg.Transport.UseCompression = useCompression
  82. cfg.SecretKey = sk
  83. cfg.ServerName = serverName
  84. cfg.BindAddr = bindAddr
  85. cfg.BindPort = bindPort
  86. if err := validation.ValidateVisitorConfigurer(cfg); err != nil {
  87. fmt.Println(err)
  88. os.Exit(1)
  89. }
  90. visitorCfgs = append(visitorCfgs, cfg)
  91. default:
  92. fmt.Println("invalid role")
  93. os.Exit(1)
  94. }
  95. err = startService(clientCfg, pxyCfgs, visitorCfgs, "")
  96. if err != nil {
  97. os.Exit(1)
  98. }
  99. return nil
  100. },
  101. }