package main import ( "crypto/sha1" "fmt" "io" "log" "math/rand" "net" "net/http" _ "net/http/pprof" "os" "sync" "time" "golang.org/x/crypto/pbkdf2" "github.com/urfave/cli" kcp "github.com/xtaci/kcp-go" "github.com/xtaci/kcptun/generic" "github.com/xtaci/smux" ) // SALT is use for pbkdf2 key expansion const SALT = "kcp-go" // VERSION is injected by buildflags var VERSION = "SELFBUILD" // A pool for stream copying var xmitBuf sync.Pool // handle multiplex-ed connection func handleMux(conn io.ReadWriteCloser, config *Config) { // stream multiplex smuxConfig := smux.DefaultConfig() smuxConfig.MaxReceiveBuffer = config.SmuxBuf smuxConfig.KeepAliveInterval = time.Duration(config.KeepAlive) * time.Second mux, err := smux.Server(conn, smuxConfig) if err != nil { log.Println(err) return } defer mux.Close() for { stream, err := mux.AcceptStream() if err != nil { log.Println(err) return } go func(p1 *smux.Stream) { p2, err := net.Dial("tcp", config.Target) if err != nil { log.Println(err) p1.Close() return } handleClient(p1, p2, config.Quiet) }(stream) } } func handleClient(p1 *smux.Stream, p2 net.Conn, quiet bool) { logln := func(v ...interface{}) { if !quiet { log.Println(v...) } } defer p1.Close() defer p2.Close() logln("stream opened", "in:", fmt.Sprint(p1.RemoteAddr(), "(", p1.ID(), ")"), "out:", p2.RemoteAddr()) defer logln("stream closed", "in:", fmt.Sprint(p1.RemoteAddr(), "(", p1.ID(), ")"), "out:", p2.RemoteAddr()) // start tunnel & wait for tunnel termination streamCopy := func(dst io.Writer, src io.ReadCloser) chan struct{} { die := make(chan struct{}) go func() { buf := xmitBuf.Get().([]byte) generic.CopyBuffer(dst, src, buf) xmitBuf.Put(buf) close(die) }() return die } select { case <-streamCopy(p1, p2): case <-streamCopy(p2, p1): } } func checkError(err error) { if err != nil { log.Printf("%+v\n", err) os.Exit(-1) } } func main() { rand.Seed(int64(time.Now().Nanosecond())) if VERSION == "SELFBUILD" { // add more log flags for debugging log.SetFlags(log.LstdFlags | log.Lshortfile) } xmitBuf.New = func() interface{} { return make([]byte, 32768) } myApp := cli.NewApp() myApp.Name = "kcptun" myApp.Usage = "server(with SMUX)" myApp.Version = VERSION myApp.Flags = []cli.Flag{ cli.StringFlag{ Name: "listen,l", Value: ":29900", Usage: "kcp server listen address", }, cli.StringFlag{ Name: "target, t", Value: "127.0.0.1:12948", Usage: "target server address", }, cli.StringFlag{ Name: "key", Value: "it's a secrect", Usage: "pre-shared secret between client and server", EnvVar: "KCPTUN_KEY", }, cli.StringFlag{ Name: "crypt", Value: "aes", Usage: "aes, aes-128, aes-192, salsa20, blowfish, twofish, cast5, 3des, tea, xtea, xor, sm4, none", }, cli.StringFlag{ Name: "mode", Value: "fast", Usage: "profiles: fast3, fast2, fast, normal, manual", }, cli.IntFlag{ Name: "mtu", Value: 1350, Usage: "set maximum transmission unit for UDP packets", }, cli.IntFlag{ Name: "sndwnd", Value: 1024, Usage: "set send window size(num of packets)", }, cli.IntFlag{ Name: "rcvwnd", Value: 1024, Usage: "set receive window size(num of packets)", }, cli.IntFlag{ Name: "datashard,ds", Value: 10, Usage: "set reed-solomon erasure coding - datashard", }, cli.IntFlag{ Name: "parityshard,ps", Value: 3, Usage: "set reed-solomon erasure coding - parityshard", }, cli.IntFlag{ Name: "dscp", Value: 0, Usage: "set DSCP(6bit)", }, cli.BoolFlag{ Name: "nocomp", Usage: "disable compression", }, cli.BoolFlag{ Name: "acknodelay", Usage: "flush ack immediately when a packet is received", Hidden: true, }, cli.IntFlag{ Name: "nodelay", Value: 0, Hidden: true, }, cli.IntFlag{ Name: "interval", Value: 50, Hidden: true, }, cli.IntFlag{ Name: "resend", Value: 0, Hidden: true, }, cli.IntFlag{ Name: "nc", Value: 0, Hidden: true, }, cli.IntFlag{ Name: "sockbuf", Value: 4194304, // socket buffer size in bytes Usage: "per-socket buffer in bytes", }, cli.IntFlag{ Name: "smuxbuf", Value: 4194304, Usage: "the overall de-mux buffer in bytes", }, cli.IntFlag{ Name: "keepalive", Value: 10, // nat keepalive interval in seconds Usage: "seconds between heartbeats", }, cli.StringFlag{ Name: "snmplog", Value: "", Usage: "collect snmp to file, aware of timeformat in golang, like: ./snmp-20060102.log", }, cli.IntFlag{ Name: "snmpperiod", Value: 60, Usage: "snmp collect period, in seconds", }, cli.BoolFlag{ Name: "pprof", Usage: "start profiling server on :6060", }, cli.StringFlag{ Name: "log", Value: "", Usage: "specify a log file to output, default goes to stderr", }, cli.BoolFlag{ Name: "quiet", Usage: "to suppress the 'stream open/close' messages", }, cli.BoolFlag{ Name: "tcp", Usage: "to emulate a TCP connection(linux)", }, cli.StringFlag{ Name: "c", Value: "", // when the value is not empty, the config path must exists Usage: "config from json file, which will override the command from shell", }, } myApp.Action = func(c *cli.Context) error { config := Config{} config.Listen = c.String("listen") config.Target = c.String("target") config.Key = c.String("key") config.Crypt = c.String("crypt") config.Mode = c.String("mode") config.MTU = c.Int("mtu") config.SndWnd = c.Int("sndwnd") config.RcvWnd = c.Int("rcvwnd") config.DataShard = c.Int("datashard") config.ParityShard = c.Int("parityshard") config.DSCP = c.Int("dscp") config.NoComp = c.Bool("nocomp") config.AckNodelay = c.Bool("acknodelay") config.NoDelay = c.Int("nodelay") config.Interval = c.Int("interval") config.Resend = c.Int("resend") config.NoCongestion = c.Int("nc") config.SockBuf = c.Int("sockbuf") config.SmuxBuf = c.Int("smuxbuf") config.KeepAlive = c.Int("keepalive") config.Log = c.String("log") config.SnmpLog = c.String("snmplog") config.SnmpPeriod = c.Int("snmpperiod") config.Pprof = c.Bool("pprof") config.Quiet = c.Bool("quiet") config.TCP = c.Bool("tcp") if c.String("c") != "" { //Now only support json config file err := parseJSONConfig(&config, c.String("c")) checkError(err) } // log redirect if config.Log != "" { f, err := os.OpenFile(config.Log, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666) checkError(err) defer f.Close() log.SetOutput(f) } switch config.Mode { case "normal": config.NoDelay, config.Interval, config.Resend, config.NoCongestion = 0, 40, 2, 1 case "fast": config.NoDelay, config.Interval, config.Resend, config.NoCongestion = 0, 30, 2, 1 case "fast2": config.NoDelay, config.Interval, config.Resend, config.NoCongestion = 1, 20, 2, 1 case "fast3": config.NoDelay, config.Interval, config.Resend, config.NoCongestion = 1, 10, 2, 1 } log.Println("version:", VERSION) log.Println("initiating key derivation") pass := pbkdf2.Key([]byte(config.Key), []byte(SALT), 4096, 32, sha1.New) var block kcp.BlockCrypt switch config.Crypt { case "sm4": block, _ = kcp.NewSM4BlockCrypt(pass[:16]) case "tea": block, _ = kcp.NewTEABlockCrypt(pass[:16]) case "xor": block, _ = kcp.NewSimpleXORBlockCrypt(pass) case "none": block, _ = kcp.NewNoneBlockCrypt(pass) case "aes-128": block, _ = kcp.NewAESBlockCrypt(pass[:16]) case "aes-192": block, _ = kcp.NewAESBlockCrypt(pass[:24]) case "blowfish": block, _ = kcp.NewBlowfishBlockCrypt(pass) case "twofish": block, _ = kcp.NewTwofishBlockCrypt(pass) case "cast5": block, _ = kcp.NewCast5BlockCrypt(pass[:16]) case "3des": block, _ = kcp.NewTripleDESBlockCrypt(pass[:24]) case "xtea": block, _ = kcp.NewXTEABlockCrypt(pass[:16]) case "salsa20": block, _ = kcp.NewSalsa20BlockCrypt(pass) default: config.Crypt = "aes" block, _ = kcp.NewAESBlockCrypt(pass) } lis, err := listen(&config, block) checkError(err) log.Println("listening on:", lis.Addr()) log.Println("target:", config.Target) log.Println("encryption:", config.Crypt) log.Println("nodelay parameters:", config.NoDelay, config.Interval, config.Resend, config.NoCongestion) log.Println("sndwnd:", config.SndWnd, "rcvwnd:", config.RcvWnd) log.Println("compression:", !config.NoComp) log.Println("mtu:", config.MTU) log.Println("datashard:", config.DataShard, "parityshard:", config.ParityShard) log.Println("acknodelay:", config.AckNodelay) log.Println("dscp:", config.DSCP) log.Println("sockbuf:", config.SockBuf) log.Println("smuxbuf:", config.SmuxBuf) log.Println("keepalive:", config.KeepAlive) log.Println("snmplog:", config.SnmpLog) log.Println("snmpperiod:", config.SnmpPeriod) log.Println("pprof:", config.Pprof) log.Println("quiet:", config.Quiet) log.Println("tcp:", config.TCP) if err := lis.SetDSCP(config.DSCP); err != nil { log.Println("SetDSCP:", err) } if err := lis.SetReadBuffer(config.SockBuf); err != nil { log.Println("SetReadBuffer:", err) } if err := lis.SetWriteBuffer(config.SockBuf); err != nil { log.Println("SetWriteBuffer:", err) } go generic.SnmpLogger(config.SnmpLog, config.SnmpPeriod) if config.Pprof { go http.ListenAndServe(":6060", nil) } for { if conn, err := lis.AcceptKCP(); err == nil { log.Println("remote address:", conn.RemoteAddr()) conn.SetStreamMode(true) conn.SetWriteDelay(false) conn.SetNoDelay(config.NoDelay, config.Interval, config.Resend, config.NoCongestion) conn.SetMtu(config.MTU) conn.SetWindowSize(config.SndWnd, config.RcvWnd) conn.SetACKNoDelay(config.AckNodelay) if config.NoComp { go handleMux(conn, &config) } else { go handleMux(generic.NewCompStream(conn), &config) } } else { log.Printf("%+v", err) } } } myApp.Run(os.Args) }