CNI portmap插件实现源码分析

DNAT创建的iptables规则如下：(重写目的IP和端口)

PREROUTING, OUTPUT: --dst-type local -j CNI-HOSTPORT_DNAT 　　　// PREROUTING和OUTPUT链中目的地址类型为local的跳转至CNI-HOSTPORT-DNAT进行处理

CNI-HOSTPORT-DNAT: -j CNI-DN-abcd123　　　　// 进入相应容器的chain进行处理

CNI-DN-abcd123: -p tcp --dport 8080 -j DNAT --to-destination 192.0.2.33:80

CNI-DN-abcd123: -p tcp --dport 8081 -j DNAT ....

// plugins/plugins/meta/portmap/main.go

1、func cmdAdd(args *skel.CmdArgs) error

1、首先调用netConf, err := parseConfig(args.StdinData, args.IfName)对配置进行解析

2、因为portmap只能作为chained plugin存在，因此当netConf.PrevResult为nil时，报错

3、当len(netConf.RuntimeConfig.PortMaps)为0时，说明没有配置portmap，直接返回PrevResult

4、当netConf.ConfIPv4不为nil时，调用forwardPorts(netConf, netConf.ContIPv4)

5、当netConf.ConfIPv6不为nil时，调用forwardPorts(netConf, netConf.ConfIPv6)

PortMapConf的结构如下所示：

type PortMapConf struct {
　　types.NetConf
　　SNAT　　*bool
　　ConditionsV4 *[]string
　　Conditions V6 *[]string
　　RuntimeConfig struct {
　　　　PortMaps　　[ ]PortMapEntry
　　}

　　RawPrevResult map[string]interface{}
　　PrevResult　　*current.Result
　　

　　// These are fields parsed out of the config or the environment;
　　// included here for convenience
　　ContainerID　　string
　　ContIPv4　　　 net.IP
　　ContIPv6　　　  net.IP
}

PortMapEntry的结构如下所示：

type PortMapEntry struct {
　　HostPort　　　　 int
　　ContainerPort　　int
　　Protocol　　　　  string
　　HostIP　　　　　 string
}

　　

// plugins/plugins/meta/portmap/main.go

2、func parseConfig(stdin []byte, ifName string) (*PortMapConf, error)

1、首先创建conf := PortMapConf{}，并调用json.Unmarshal(stdin, &conf)进行解析

2、如果conf.RawPrevResult不为nil，则先将其转换为conf.PrevResult

3、如果解析之后conf.SNAT为nil，则设置conf.SNAT赋值为true

4、遍历conf.RuntimeConfig.PortMaps，对每个pm进行检测，如果pm.ContainerPort <= 0或者pm.HostPort<=0，则报错

5、如果conf.PrevResult不为nil，则对conf.PrevResult.IPs进行遍历，将conf.ContIPv4和conf.ContIPv6分别设置为第一个遇到的container interface的地址

// plugins/plugins/meta/portmap/portmap.go

3、func forwardPorts(config *PortMapConf, containerIP net.IP) error

1、当containerIP为IPv4时，调用ipt, err = iptables.NewWithProtocol(iptables.ProtocolIPv4)和conditions = config.ConditionsV4获取iptable

2、调用toplevelDnatChain := genToplevelDnatChain()和toplevelDnatChain.setup(ipt, nil)创建top level chain，

3、调用dnatChain := genDnatChain(config.Name, config.ContainerID, conditions)创建dnat chain，并调用_ = dnatChain.teardown(ipt)进行清理，如果有冲突的话

4、调用dnatRules := dnatRules(config.RuntimeConfig.PortMaps, containerIP)和dnatChain.setup(ipt, dnatRules)在dnat chain中创建规则

5、如果config.SNAT为真，且不是地址不是IPv6，则首先调用toplevelSnatChain := genToplevelSnatChain(isV6)和toplevelSnatChain.setup(ipt, nil)创建top level snat chain

6、调用snatChain := genSnatChain(config.Name, config.ContainerID)和_ = snatChain.teardown(ipt)获取相应的snat chain，如果chain已存在，则进行清理

7、调用snatRules := snatRules(config.RuntimeConfig.PortMaps, containerIP)和snatChain.setup(ipt, snatRules)创建规则

8、如果isV6为false，则设置host interface的route_localnet bit，从而让127/8能cross a routing boundary，先调用hostIfName := getRoutableHostIF(containerIP)

如果hostIfName不为""，则调用enableLocalnetRouting(hostIfName)

// plugins/plugins/meta/portmap/portmap.go

4、func genToplevelDnatChain() chain

该函数仅仅返回一个chain{}结构，该chain为top-levle summary chain，其他所有的dnat chain都通过它进行调用，具体代码如下：

return chain{
　　table:　　"nat",
　　name:　　TopLevelDNATChainName,
　　entryRule:　　[ ]string{
　　　　"-m", "addrtype",
　　　　"--dst-type", "LOCAL",
　　},
　　entryChains: []string{"PREROUTING", "OUTPUT"},

}

　　

// plugins/plugins/meta/portmap/chain.go

5、func (c *chain) setup(ipt *iptables.IPTables, rules [][]string) error

1、调用exists, err := chainExists(ipt, c.table, c.name)判断chain是否存在，不在则调用ipt.NewChain(c.table, c.name)进行创建

2、倒序遍历rules，调用prependUnique(ipt, c.table, c.name, rules[i])将rule添加至chain中

3、调用entryRule := append(c.entryRule, "-j", c.name)，并遍历c.entryChains，调用prependUnique(ipt, c.table, entryChain, entryRule)将rule加入其他chain中

// plugins/plugins/meta/portmap/chain.go

6、func genDnatChain(netName, containerID string, conditions *[]string) chain

1、首先调用name := formatChainName("DN-", netName, containerID)创建新的dnat chain名字

2、调用comment := fmt.Sprintf(...)创建comment

3、创建的chain如下所示：

ch := chain{
　　table:　　"nat",
　　name:　　name,
　　entryRule:　　[]string{
　　　　"-m", "comment",
　　　　"--comment", comment
　　},
　　entryChains:　　[]string{TopLevelDNATChainName},
}

4、如果conditions不为nil，且len(*conditions)不为0，则调用ch.entryRule = append(ch.entryRule, *conditions...)

时间： 2024-10-21 03:16:15

CNI portmap插件实现源码分析的相关文章

jQuery扩展与插件--附源码分析

扩展与插件 1. 编写JQuery插件 <script> $.extend(object) //为JQuery 添加一个静态方法. $.fn.extend(object) //为JQuery实例添加一个方法. jQuery.extend({ min: function(a, b) { return a < b ? a : b; }, max: function(a, b) { return a > b ? a : b; } }); console.log($.min(3,4));

Unity时钟定时器插件——Vision Timer源码分析之二

Unity时钟定时器插件--Vision Timer源码分析之二 By D.S.Qiu 尊重他人的劳动,支持原创,转载请注明出处:http.dsqiu.iteye.com 前面的已经介绍了vp_Timer(点击前往查看),vp_TimeUtility相对简单很多,vp_TimeUtility定义了个表示时间的结构Units: C#代码   /// <summary> /// represents a time measured in standard units /// </summar

插件开发之360 DroidPlugin源码分析（四）Activity预注册占坑

请尊重分享成果,转载请注明出处: http://blog.csdn.net/hejjunlin/article/details/52258434 在了解系统的activity,service,broadcastReceiver的启动过程后,今天将分析下360 DroidPlugin是如何预注册占坑的?本篇文章主要分析Activity预注册占坑,Activity占了坑后又是什么时候开始瞒天过海欺骗AMS的?先看下Agenda: AndroidMainfest.xml中概览 Activity中关键方

DroidPlugin源码分析插件进程管理以及预注册Activity，Service，ContentProvide的选择

在360对DroidPlugin的特点介绍中有云: 插件的四大组件完全不需要在Host程序中注册,支持Service.Activity.BroadcastReceiver.ContentProvider四大组件. 实现了进程管理,插件的空进程会被及时回收,占用内存低. 之所以支持Service,Activity,ContentProvider三大组件,是因为DroidPlugin在AndroidManifest文件中预先注册了8个运行插件的进程,每个进程预注册Service一个, Content

DroidPlugin源码分析插件运行环境初始化

从DroidPlugin的官方文档中我们知道. 2 在AndroidManifest.xml中使用插件的com.morgoo.droidplugin.PluginApplication: 或者在自定义的Application的onCreate()函数中,调用PluginHelper.getInstance().applicationOnCreate(getBaseContext()); 在Application的attachBaseContext()函数中,调用 PluginHelper.get

携程DynamicAPK插件化框架源码分析

携程DynamicAPK插件化框架源码分析 Author:莫川 插件核心思想 1.aapt的改造 分别对不同的插件项目分配不同的packageId,然后对各个插件的资源进行编译,生成R文件,然后与宿主项目的R文件进行id的合并. 要求:由于最终会将所有的资源文件id进行合并,因此,所有的资源名称均不能相同. 2.运行ClassLoader加载各Bundle 和MultiDex的思路是一样的,所有的插件都被加载到同一个ClassLoader当中,因此,不同插件中的Class必须保持包名和类名的唯一

插件开发之360 DroidPlugin源码分析（五）Service预注册占坑

请尊重分享成果,转载请注明出处: http://blog.csdn.net/hejjunlin/article/details/52264977 在了解系统的activity,service,broadcastReceiver的启动过程后,今天将分析下360 DroidPlugin是如何预注册占坑的?本篇文章主要分析Service预注册占坑,Service占了坑后又是什么时候开始瞒天过海欺骗AMS的?先看下Agenda: AndroidMainfest.xml中概览 Service中关键方法被h

Unity时钟定时器插件——Vision Timer源码分析之一

Unity时钟定时器插件--Vision Timer源码分析之一 By D.S.Qiu 尊重他人的劳动,支持原创,转载请注明出处:http.dsqiu.iteye.com 因为项目中,UI的所有模块都没有MonBehaviour类(纯粹的C#类),只有像NGUI的基本组件的类是继承MonoBehaviour.因为没有继承MonoBehaviour,这也不能使用Update,InVoke,StartCoroutine等方法,这样就会显得很蹩脚.后来一个同事添加vp_Timer和vp_TimeUti

Android Small插件化框架源码分析

Android Small插件化框架源码分析 目录 概述 Small如何使用 插件加载流程 待改进的地方 一.概述 Small是一个写得非常简洁的插件化框架,工程源码位置:https://github.com/wequick/Small 插件化的方案,说到底要解决的核心问题只有三个: 1.1 插件类的加载 这个问题的解决和其它插件化框架的解决方法差不多.Android的类是由DexClassLoader加载的,通过反射可以将插件包动态加载进去.Small的gradle插件生成的是.so包,在初始