昆山外贸公司网站建设流程公司网站制作网络公司
《零入门kubernetes网络实战》视频专栏地址
https://www.ixigua.com/7193641905282875942
本篇文章视频地址(稍后上传)
上一篇文章,我们使用了golang在veth pair链接的网络命名空间里添加了网卡,
本篇文章,我尝试,在docker环境下的容器里,添加额外的网卡,使得容器实例变为多网卡环境。
1、测试环境介绍 |
一台centos虚拟机
# 查看操作系统版本
cat /etc/centos-release
# 内核版本
uname -a
uname -r
# 查看网卡信息
ip a s eth0
2、在测试服务上,创建测试容器 |
这里就以busybox镜像为例了。
主要过程如下:
编写启动容器启动脚本–>启动容器–>查看容器是否启动–>进入容器里查看容器当前网卡情况
编写创建测试容器的脚本
start-busybox.sh
docker stop my-busybox
docker rm my-busybox
docker run -itd --name my-busybox docker.io/busybox /bin/sh
主要过程如下:
3、获取容器实例my-busybox的进程号 |
docker inspect my-busybox | grep -w Pid
4、golang代码 |
编写代码,为ns1网络命名空间,添加veth2虚拟网卡,并设置IP
package mainimport ("flag""fmt""github.com/vishvananda/netlink""github.com/vishvananda/netns""golang.org/x/sys/unix""net""os""runtime"
)const (veth1Name = "veth1"veth2Name = "veth2"
)var pid intfunc main() {flag.IntVar(&pid, "pid", 0, "Use -pid xxx")flag.Parse()l, err := netlink.LinkByName(veth1Name)if err == nil {// 删除掉 已经存在的 veth pairnetlink.LinkDel(l)}vethpeer := &netlink.Veth{LinkAttrs: netlink.LinkAttrs{Name: veth1Name,Flags: net.FlagUp,MTU: 1500,},PeerName: veth2Name,}err = netlink.LinkAdd(vethpeer)if err != nil {panic(err)}// 获取到某个容器,如11101容器对应的网络命名空间// 11101是容器的PID,就是容器的进程号// /proc/11101/ns/net// 如何获取到某个容器的Pid呢?// 假设,容器名称是 my-sw// docker inspect my-sw | grep -w Pid// 将得到的值,复制过来nsPath := fmt.Sprintf("/proc/%d/ns", pid)ns, err := netns.GetFromPath(fmt.Sprintf("%s/%s", nsPath, "net"))if err != nil {panic(err)}// 因为是打开文件的,是一个句柄,因此必须closedefer ns.Close()veth2, err := netlink.LinkByName(veth2Name)if err != nil {panic(err)}// ip link set veth2 netns// /proc/11101/ns/net命名空间里// 就是将veth2网卡,移动到容器里的网络空间里err = netlink.LinkSetNsFd(veth2, int(ns))if err != nil {panic(err)}// 再切换到容器网络命名空间里前,先获取当前主网络命名空间;// 以便能切换回来hostNS, err := GetCurrentNS()if err != nil {panic(err)}// 设置当前网络命名空间// 假设,已经将veth2移动了容器里了// 此时在物理机上,直接ifconfig是查看不到veth2网卡的// 而你的二进制文件是在物理机上的,此二进制文件想操作veth2网卡的话// 只能先设置网络命名空间了err = netns.Set(ns)if err != nil {panic(err)}// 因为网络命名空间切换了,进入到容器网络命名空间里,必须再获取一次veth2r设备veth2, err = netlink.LinkByName(veth2Name)if err != nil {panic(err)}// 仅仅是设置IPaddr, _ := netlink.ParseAddr("10.244.1.2/24")err = netlink.AddrAdd(veth2, addr)if err != nil {panic(err)}// 可以将容器里的网卡名称,改为通用的名称,如eth0; 非必须步骤//netlink.LinkSetName(veth2, "eth0")// 将容器里的网卡eth0启动err = netlink.LinkSetUp(veth2)if err != nil {panic(err)}// 切换回到主网络命名空间里err = unix.Setns(int(hostNS.Fd()), unix.CLONE_NEWNET)if err != nil {panic(err)}addr, _ = netlink.ParseAddr("10.244.1.3/24")veth1, err := netlink.LinkByName(veth1Name)if err != nil {panic(err)}// 在主网络命名空间里设置veth1网卡的IPerr = netlink.AddrAdd(veth1, addr)if err != nil {panic(err)}// 将veth1网卡设置为up状态netlink.LinkSetUp(veth1)
}func GetCurrentNS() (*os.File, error) {runtime.LockOSThread()defer runtime.UnlockOSThread()return GetNS(getCurrentThreadNetNSPath())
}func getCurrentThreadNetNSPath() string {currentNetNSPath := fmt.Sprintf("/proc/%d/task/%d/ns/net", os.Getpid(), unix.Gettid())return currentNetNSPath
}func GetNS(nspath string) (*os.File, error) {fd, err := os.Open(nspath)if err != nil {return nil, err}return fd, nil
}
其实,代码还是上一篇文章的代码,完全没有变
5、Makefile 编译文档 |
build:CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -o createveth main.goscp:scp createveth root@10.211.55.122:/rootall:make build && make scp
执行运行
make all
6、登录到服务上,运行createveth |
./createveth -pid=1614ip a s veth1docker exec -it my-busybox sh
7、总结 |
其实,kubernetes中,给Pod里添加网卡或者添加额外网卡时,操作类似。
点击 下面 返回 专栏目录 |
<<零入门kubernetes网络实战>>技术专栏之文章目录