当前位置: 首页 > news >正文

零入门kubernetes网络实战-16->使用golang给docker环境下某个容器里添加一个额外的网卡

《零入门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网络实战>>技术专栏之文章目录

http://www.lryc.cn/news/14271.html

相关文章:

  • 音频信号处理笔记(二)
  • 钓鱼网站+bypassuac提权
  • 合并两个有序链表——递归解法
  • ADRC自抗扰控制总结
  • 3年工作之后是不是还在“点点点”,3年感悟和你分享....
  • 【自动化测试】web自动化测试验证码如何测?如何处理验证码问题?解决方案......
  • 面试浅谈之 C++ STL 篇
  • 【PTA Advanced】1144 The Missing Number(C++)
  • oracle的sqlnet.ora文件配置传输加密算法
  • RK3568存储性能测试
  • Homekit智能家居一智能灯泡
  • 轻量级 Java 权限认证框架——Sa-Token
  • 算法复习(四、五、六)
  • SORT与DeepSORT简介
  • TCP/IP网络编程——多播与广播
  • K8S DNS解析过程和延迟问题
  • 【JavaScript】js实现深拷贝的方法
  • RK3288 GPIO记录
  • MongoDB介绍及使用教程
  • 51单片机开发环境搭建 - VS Code 从编写到烧录
  • python datetime、字符串和时间戳之间的相互转换12小时制和24小时制时间相互转化
  • 百度百科词条怎么做?百度百科词条创建攻略分享
  • 基于Hive的河北新冠确诊人数分析系统的设计与实现
  • k8s二进制部署
  • Windows出现0xc00d36e5错误怎么办?
  • Idea搭建Spring5.3.x源码阅读环境
  • 2.20jdbc
  • 【代码随想录训练营】【Day19休息】【Day20】第六章|二叉树|654.最大二叉树|617.合并二叉树|700.二叉搜索树中的搜索|98.验证二叉搜索树
  • 华为云计算之容灾技术
  • React系列之Redux