Victorique/vtqe/tools/tcping.go

package tools

import (
	"fmt"
	"os"
	"os/signal"
	"syscall"
	"time"

	"strconv"

	"victorique/vtqe/tools/ping"

	"github.com/spf13/cobra"
)

var (
	counter  int
	timeout  string
	interval string
	sigs     chan os.Signal

	httpMode bool
	httpHead bool
	httpPost bool
	httpUA   string

	permanent bool

	dnsServer []string
)

var tcpingcmd = &cobra.Command{
	Use:   "tcping",
	Short: "tcp ping",
	Long:  "进行Tcping",
	Example: `
  1. ping over tcp
	> tcping google.com
  2. ping over tcp with custom port
	> tcping google.com 443
  3. ping over http
  	> tcping -H google.com
  4. ping with URI schema
  	> tcping http://hui.lu
	`,
	Run: func(cmd *cobra.Command, args []string) {
		sigs = make(chan os.Signal, 1)
		signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
		if permanent && counter != 4 {
			fmt.Println("不能同时指定-t与-c，请检查您的输入")
			return
		}
		if permanent {
			counter = 0
		}
		if len(args) != 2 && len(args) != 1 {
			cmd.Usage()
			return
		}
		host := args[0]

		var (
			err    error
			port   int
			schema string
		)
		if len(args) == 2 {
			port, err = strconv.Atoi(args[1])
			if err != nil {
				fmt.Println("端口应当为Int类型")
				cmd.Usage()
				return
			}
			schema = ping.TCP.String()
		} else {
			var matched bool
			schema, host, port, matched = ping.CheckURI(host)
			if !matched {
				fmt.Println("不是一个合法的URI")
				cmd.Usage()
				return
			}
		}
		var timeoutDuration time.Duration
		if res, err := strconv.Atoi(timeout); err == nil {
			timeoutDuration = time.Duration(res) * time.Millisecond
		} else {
			timeoutDuration, err = time.ParseDuration(timeout)
			if err != nil {
				fmt.Println("parse timeout failed", err)
				cmd.Usage()
				return
			}
		}

		var intervalDuration time.Duration
		if res, err := strconv.Atoi(interval); err == nil {
			intervalDuration = time.Duration(res) * time.Millisecond
		} else {
			intervalDuration, err = time.ParseDuration(interval)
			if err != nil {
				fmt.Println("parse interval failed", err)
				cmd.Usage()
				return
			}
		}
		var protocol ping.Protocol
		if httpMode {
			protocol = ping.HTTP
		} else {
			protocol, err = ping.NewProtocol(schema)
			if err != nil {
				fmt.Println(err)
				cmd.Usage()
				return
			}
		}
		if len(dnsServer) != 0 {
			ping.UseCustomeDNS(dnsServer)
		}

		parseHost := ping.FormatIP(host)
		target := ping.Target{
			Timeout:  timeoutDuration,
			Interval: intervalDuration,
			Host:     parseHost,
			Port:     port,
			Counter:  counter,
			Protocol: protocol,
		}
		var pinger ping.Pinger
		switch protocol {
		case ping.TCP:
			pinger = ping.NewTCPing()
		case ping.HTTP, ping.HTTPS:
			var httpMethod string
			switch {
			case httpHead:
				httpMethod = "HEAD"
			case httpPost:
				httpMethod = "POST"
			default:
				httpMethod = "GET"
			}
			pinger = ping.NewHTTPing(httpMethod)
		default:
			fmt.Printf("schema: %s not support\n", schema)
			cmd.Usage()
			return
		}
		pinger.SetTarget(&target)
		pingerDone := pinger.Start()
		select {
		case <-pingerDone:
			break
		case <-sigs:
			break
		}

		fmt.Println(pinger.Result())
	},
}

func init() {
	tcpingcmd.Flags().IntVarP(&counter, "counter", "c", 4, "ping的次数")
	tcpingcmd.Flags().BoolVarP(&permanent, "permanent", "t", false, "一直ping下去")
	tcpingcmd.Flags().StringVarP(&timeout, "timeout", "T", "1s", `超时时间, 单位为 "ns", "us" (or "µs"), "ms", "s", "m", "h"`)
	tcpingcmd.Flags().StringVarP(&interval, "interval", "I", "1s", `ping间隔时间, 单位为 "ns", "us" (or "µs"), "ms", "s", "m", "h"`)

	tcpingcmd.Flags().BoolVarP(&httpMode, "http", "H", false, `Use "HTTP" mode. will ignore URI Schema, force to http`)
	tcpingcmd.Flags().BoolVar(&httpHead, "head", false, `使用http head模式`)
	tcpingcmd.Flags().BoolVar(&httpPost, "post", false, `使用http post模式`)
	tcpingcmd.Flags().StringVar(&httpUA, "user-agent", "victorique/tcping", `自定义UA`)

	tcpingcmd.Flags().StringArrayVarP(&dnsServer, "dns-server", "D", nil, `使用自定义DNS服务器`)

}

func init() {
	Maincmd.AddCommand(tcpingcmd)
}