kcpserver.go

package main

import (
	"fmt"

	"github.com/xtaci/kcp-go"
)

const port = ":9999"

func ListenTest() (*kcp.Listener, error) {
	return kcp.ListenWithOptions(port, nil, 0, 0)
}

func server() {
	l, err := ListenTest()
	if err != nil {
		panic(err)
	}
	for {
		s, err := l.Accept()
		if err != nil {
			panic(err)
		}

		go handle_client(s)
	}
}
func handle_client(conn *kcp.UDPSession) {
	conn.SetWindowSize(1024, 1024)
	conn.SetNoDelay(1, 20, 2, 1)
	fmt.Println("new client", conn.RemoteAddr())
	buf := make([]byte, 65536)
	count := 0
	for {
		n, err := conn.Read(buf)
		if err != nil {
			panic(err)
		}
		count++
		fmt.Println("received:", buf[:n])
		conn.Write(buf[:n])
	}
}

func main() {
	server()
}