flannel 实战与源码分析（七）

本文主要是介绍flannel 实战与源码分析（七），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

这是flannel最后一篇，我原本不准备介绍UDP，因为这种方案的网络损耗实在是太多，大约一半损耗，vxlan大约是30%损耗。但基本的UDP使用我还是想和大家分享一下的，主要是tun设备的使用。
像UDP的RegisterNetwork和VXLAN一样，我就不单独说了backend/udp/udp_network.go。

func (n *network) Run(ctx context.Context) {defer func() {n.tun.Close()n.conn.Close()n.ctl.Close()n.ctl2.Close()}()// one for each goroutine belowwg := sync.WaitGroup{}defer wg.Wait()wg.Add(1)go func() {runCProxy(n.tun, n.conn, n.ctl2, n.tunNet.IP, n.MTU())wg.Done()}()log.Info("Watching for new subnet leases")evts := make(chan []subnet.Event)wg.Add(1)go func() {subnet.WatchLeases(ctx, n.sm, n.SubnetLease, evts)wg.Done()}()for {select {case evtBatch := <-evts:n.processSubnetEvents(evtBatch)case <-ctx.Done():stopProxy(n.ctl)return}}
}

defer里面做资源回收，主要启动两个协程，一个是runCProxy另一个是WatchLeases，至于WatchLeases我在之前说过，这里的效果是一样主要添加route。主要讲解一下runCProxy

func runCProxy(tun *os.File, conn *net.UDPConn, ctl *os.File, tunIP ip.IP4, tunMTU int) {var log_errors intif log.V(1) {log_errors = 1}c, err := conn.File()if err != nil {log.Error("Converting UDPConn to File failed: ", err)return}defer c.Close()C.run_proxy(C.int(tun.Fd()),C.int(c.Fd()),C.int(ctl.Fd()),C.in_addr_t(tunIP.NetworkOrder()),C.size_t(tunMTU),C.int(log_errors),)
}

他是一个用golang调用c去实现的backend/udp/proxy.c。

    while( !exit_flag ) {int nfds = poll(fds, PFD_CNT, -1), activity;if( nfds < 0 ) {if( errno == EINTR )continue;log_error("Poll failed: %s\n", strerror(errno));exit(1);}if( fds[PFD_CTL].revents & POLLIN )process_cmd(ctl);if( fds[PFD_TUN].revents & POLLIN || fds[PFD_SOCK].revents & POLLIN )do {activity = 0;activity += tun_to_udp(tun, sock, buf, tun_mtu);activity += udp_to_tun(sock, tun, buf, tun_mtu);} while( activity );}

核心是这里的tun_to_udp和udp_to_tun分别是tun到udp和udp到tun。具体看代码，以udp_to_tun为例：

static int udp_to_tun(int sock, int tun, char *buf, size_t buflen) {struct iphdr *iph;ssize_t pktlen = sock_recv_packet(sock, buf, buflen);if( pktlen < 0 )return 0;iph = (struct iphdr *)buf;if( !decrement_ttl(iph) ) {goto _active;}tun_send_packet(tun, buf, pktlen);
_active:return 1;
}

这个里面先从sock获取sock_recv_packet，然后通过tun发送出去tun_send_packet，这样完成udp的拆包，封装包和这个流程是反过来了，在封装过程会用到目的地址（route）

static int tun_to_udp(int tun, int sock, char *buf, size_t buflen) {struct iphdr *iph;struct sockaddr_in *next_hop;ssize_t pktlen = tun_recv_packet(tun, buf, buflen);if( pktlen < 0 )return 0;iph = (struct iphdr *)buf;next_hop = find_route((in_addr_t) iph->daddr);if( !next_hop ) {send_net_unreachable(tun, buf);goto _active;}if( !decrement_ttl(iph) ) {/* TTL went to 0, discard.* TODO: send back ICMP Time Exceeded*/goto _active;}sock_send_packet(sock, buf, pktlen, next_hop);
_active:return 1;
}