mirror of
https://github.com/kubenetworks/kubevpn.git
synced 2025-12-24 11:51:13 +08:00
48 lines
908 B
Go
48 lines
908 B
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"net"
|
|
|
|
"github.com/containernetworking/cni/pkg/types"
|
|
plog "github.com/wencaiwulue/kubevpn/v2/pkg/log"
|
|
"github.com/wencaiwulue/kubevpn/v2/pkg/tun"
|
|
)
|
|
|
|
func main() {
|
|
ip := net.ParseIP("fe80::cff4:d42c:7e73:e84a")
|
|
listener, err := tun.Listener(tun.Config{
|
|
Addr: ip.String() + "/64",
|
|
MTU: 1350,
|
|
Routes: []types.Route{
|
|
{
|
|
Dst: net.IPNet{
|
|
IP: ip,
|
|
Mask: net.CIDRMask(64, 128),
|
|
},
|
|
}, {
|
|
Dst: net.IPNet{
|
|
IP: net.ParseIP("192.168.0.0"),
|
|
Mask: net.CIDRMask(64, 128),
|
|
},
|
|
},
|
|
},
|
|
})
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
var tunConn net.Conn
|
|
tunConn, err = listener.Accept()
|
|
if err != nil {
|
|
plog.G(context.Background()).Fatal(err)
|
|
}
|
|
defer tunConn.Close()
|
|
tcpConn, err := net.Dial("tcp", ":1080")
|
|
if err != nil {
|
|
plog.G(context.Background()).Fatal(err)
|
|
}
|
|
go io.Copy(tunConn, tcpConn)
|
|
io.Copy(tcpConn, tunConn)
|
|
}
|