本篇文章給大家分享的是有關(guān)如何進(jìn)行Netlink源碼及實(shí)例的分析，小編覺(jué)得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話(huà)不多說(shuō)，跟著小編一起來(lái)看看吧。

創(chuàng)新互聯(lián)是一家專(zhuān)注于成都網(wǎng)站制作、做網(wǎng)站、外貿(mào)營(yíng)銷(xiāo)網(wǎng)站建設(shè)與策劃設(shè)計(jì),新興網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專(zhuān)注于網(wǎng)站建設(shè)十多年,網(wǎng)設(shè)計(jì)領(lǐng)域的專(zhuān)業(yè)建站公司;建站業(yè)務(wù)涵蓋:新興等地區(qū)。新興做網(wǎng)站價(jià)格咨詢(xún):18980820575

前言

這幾天在看 ipvs 相關(guān)代碼的時(shí)候又遇到了 netlink 的事情，所以這兩天花了點(diǎn)時(shí)間重新把 netlink 的事情梳理了一下。

什么是 netlink

linux  內(nèi)核一直存在的一個(gè)嚴(yán)重問(wèn)題就是內(nèi)核態(tài)和用戶(hù)態(tài)的交互的問(wèn)題，對(duì)于這個(gè)問(wèn)題內(nèi)核大佬們一直在研究各種方法，想讓內(nèi)核和用戶(hù)態(tài)交互能夠安全高效的進(jìn)行。如系統(tǒng)調(diào)用，proc，sysfs等內(nèi)存文件系統(tǒng)，但是這些方式一般都比較簡(jiǎn)單，只能在用戶(hù)空間輪詢(xún)?cè)L問(wèn)內(nèi)核的變化，內(nèi)核的變化無(wú)法主動(dòng)的推送出來(lái)。

而 netlink 的出現(xiàn)比較好的解決了這個(gè)問(wèn)題，而且 netlink 還有以下一些優(yōu)勢(shì)：

1. 鴻蒙官方戰(zhàn)略合作共建——HarmonyOS技術(shù)社區(qū)

2. 可以直接使用 socket 套接字的 API 進(jìn)行內(nèi)核和用戶(hù)態(tài)的通信，開(kāi)發(fā)使用上相對(duì)簡(jiǎn)單了很多。

3. 利用內(nèi)核協(xié)議棧有了緩沖隊(duì)列，是一種異步通信機(jī)制。

4. 可以是內(nèi)核和用戶(hù)態(tài)的雙向通信，內(nèi)核可以主動(dòng)向用戶(hù)態(tài)進(jìn)程發(fā)送消息。這個(gè)是以往通信方式不具備的。

5. 針對(duì)同一個(gè)協(xié)議類(lèi)型的所有用戶(hù)進(jìn)程，內(nèi)核可以廣播消息給所有的進(jìn)程，也可以指定進(jìn)程 pid 進(jìn)行消息發(fā)送。

目前 netlink 的這種機(jī)制被廣泛使用在各種場(chǎng)景中，在 Linux 內(nèi)核中使用 netlink 進(jìn)行應(yīng)用與內(nèi)核通信的應(yīng)用很多; 包括：路由  daemon(NETLINK_ROUTE)，用戶(hù)態(tài) socket  協(xié)議(NETLINK_USERSOCK)，防火墻(NETLINK_FIREWALL)，netfilter  子系統(tǒng)(NETLINK_NETFILTER)，內(nèi)核事件向用戶(hù)態(tài)通知(NETLINK_KOBJECT_UEVENT)等。具體支持的類(lèi)型可以查看這個(gè)文件  include/uapi/linux/netlink.h。

netlink 內(nèi)核代碼走讀

netlink 內(nèi)核相關(guān)文件介紹

netlink 的內(nèi)核代碼在內(nèi)核代碼的 net/netlink/ 目錄下，我目前看的是 5.7.10 的內(nèi)核版本，netlink  內(nèi)核相關(guān)的文件不多，還是比較清晰的：

helightxu@  ~/open_code/linux-5.7.10  ls net/netlink config      Makefile     af_netlink.c af_netlink.h diag.c       genetlink.c helightxu@  ~/open_code/linux-5.7.10 

文件	描述
af_netlink.c 和 af_netlink.h：	是 netlink 的核心文件，這個(gè)也是下面詳細(xì)走讀的內(nèi)容。
diag.c	對(duì) netlink sock 進(jìn)行監(jiān)控，可以插入到內(nèi)核或者從內(nèi)核中卸載
genetlink.c	這個(gè)可以看作是 netlink 的升級(jí)版本，或者說(shuō)是一種高層封裝。

注：

genetlink.c 額外說(shuō)明：netlink 默認(rèn)支持了 30 多種的場(chǎng)景，但是對(duì)于其它場(chǎng)景并沒(méi)有具體定義，這個(gè)時(shí)候這種通用封裝就有了很大的好處，可以在不改動(dòng)內(nèi)核的前提下進(jìn)行應(yīng)用場(chǎng)景擴(kuò)展，這部分內(nèi)容可以看這個(gè) wiki：https://wiki.linuxfoundation.org/networking/generic_netlink_howto

還有一個(gè)頭文件是在 include  目錄，如下所示，這個(gè)頭文件是一些輔助函數(shù)、宏定義和相關(guān)數(shù)據(jù)結(jié)構(gòu)，大家學(xué)習(xí)的同學(xué)一定要看這個(gè)文件，它里面的注釋非常詳細(xì)。這些注釋對(duì)理解 netlink  的消息結(jié)構(gòu)非常有用，建議可以詳細(xì)看看。

helightxu@  ~/open_code/linux-5.7.10  ls include/net/netlink.h

af_netlink.c 代碼走讀

在 af_netlink.c 這個(gè)文件的最下面有一行代碼：

core_initcall(netlink_proto_init);

這段代碼的意思是什么呢?通過(guò)看這個(gè)代碼最終的實(shí)現(xiàn)可以看出，就是告訴編譯器把 netlink_proto_init 這個(gè)函數(shù)放入到最終編譯出來(lái)二進(jìn)制文件的  .init 段中，內(nèi)核在啟動(dòng)的時(shí)候會(huì)從這個(gè)端里面的函數(shù)挨個(gè)的執(zhí)行。這里也就是說(shuō) netlink  是內(nèi)核默認(rèn)就直接支持的，是原生內(nèi)核的一部分(這里其實(shí)想和內(nèi)核的動(dòng)態(tài)插拔模塊區(qū)別)。

在 netlink_proto_init 函數(shù)中最關(guān)鍵的一行代碼就是下面最后一行，把 netlink 的協(xié)議族注冊(cè)到網(wǎng)絡(luò)協(xié)議棧中去。

static const struct net_proto_family netlink_family_ops = {     .family = PF_NETLINK,     .create = netlink_create,     .owner  = THIS_MODULE,  /* for consistency 8) */ }; ... sock_register(&netlink_family_ops);

PF_NETLINK 是表示 netlink 的協(xié)議族，在后面我們?cè)诳蛻?hù)端創(chuàng)建 netlink socket  的時(shí)候就要用到這個(gè)東東。如下面的代碼，代碼來(lái)自我的測(cè)試代碼  https://github.com/helight/kernel_modules/tree/master/netlink_test  中的客戶(hù)端代碼，可以看出：PF_NETLINK 表示我們所用的就是 netlink 的協(xié)議，SOCK_RAW  表示我們使用的是原始協(xié)議包，NETLINK_USER 這個(gè)我們自己定義的一個(gè)協(xié)議字段。netlink 我們前面說(shuō)了有 30  多種應(yīng)用場(chǎng)景，這些都已經(jīng)在內(nèi)核代碼中固定了，所以在客戶(hù)端使用的時(shí)候會(huì)指定這個(gè)字段來(lái)表示和內(nèi)核中的那個(gè)應(yīng)用場(chǎng)景的函數(shù)模塊進(jìn)行交互。

//int socket(int domain, int type, int protocol);     sock_fd = socket(PF_NETLINK, SOCK_RAW, NETLINK_USER);

sock_register 這個(gè)函數(shù)的作用主要就是注冊(cè) PF_NETLINK 這個(gè)協(xié)議類(lèi)型到內(nèi)核中，讓內(nèi)核認(rèn)識(shí)這個(gè)協(xié)議，在內(nèi)核網(wǎng)絡(luò)協(xié)議中建立 socket  的時(shí)候知道該使用那個(gè)協(xié)議為它提供操作支持。

注冊(cè)了之后內(nèi)核就支持了 netlink 協(xié)議了，接下來(lái)就是內(nèi)核中創(chuàng)建監(jiān)聽(tīng) socket，用戶(hù)態(tài)創(chuàng)建鏈接 socket 了。

netlink 用戶(hù)態(tài)和內(nèi)核交互過(guò)程

這里我簡(jiǎn)單畫(huà)一個(gè)圖來(lái)表示一下，socket 通信主要有 2 個(gè)操作對(duì)象：server 端和 client 端。netlink 的操作原理是這樣的：

對(duì)象	所處位置	-
server 端	內(nèi)核中	-
client 端	用戶(hù)態(tài)進(jìn)程	-

netlink 關(guān)鍵數(shù)據(jù)結(jié)構(gòu)和函數(shù)

sockaddr_nl 協(xié)議套接字

netlink 的地址表示由 sockaddr_nl 負(fù)責(zé)

struct sockaddr_nl {     __kernel_sa_family_t    nl_family;    /* AF_NETLINK    */     unsigned short          nl_pad;        /* zero        */     __u32                   nl_pid;        /* port ID 這個(gè)一般是進(jìn)程id */     __u32                   nl_groups;    /* multicast groups mask */ };

nl_family 制定了協(xié)議族，netlink 有自己獨(dú)立的值：AF_NETLINK，nl_pid 一般取為進(jìn)程 pid。nl_groups  用以多播，當(dāng)不需要多播時(shí)，該字段為 0。

nlmsghdr 消息體

netlink 消息是作為套接字緩沖區(qū) sk_buff 的數(shù)據(jù)部分傳遞的，其消息本身又分為頭部和數(shù)據(jù)。頭部為：

struct nlmsghdr {     __u32        nlmsg_len;    /* Length of message including header */     __u16        nlmsg_type;    /* Message content */     __u16        nlmsg_flags;    /* Additional flags */     __u32        nlmsg_seq;    /* Sequence number */     __u32        nlmsg_pid;    /* Sending process port ID */ };

nlmsg_len 為消息的長(zhǎng)度，包含該頭部在內(nèi)。nlmsg_pid 為發(fā)送進(jìn)程的端口 ID，這個(gè)用戶(hù)可以自定義，一般也是使用進(jìn)程 pid。

msghdr 用戶(hù)態(tài)系發(fā)送消息體

使用 sendmsg 和 recvmsg 函數(shù)進(jìn)行發(fā)送和接收消息，使用的消息體是這個(gè)樣子的。

struct iovec {                    /* Scatter/gather array items */     void  *iov_base;              /* Starting address */     size_t iov_len;               /* Number of bytes to transfer */ }; /* iov_base: iov_base 指向數(shù)據(jù)包緩沖區(qū)，即參數(shù) buff，iov_len 是 buff 的長(zhǎng)度。 msghdr 中允許一次傳遞多個(gè) buff，以數(shù)組的形式組織在 msg_iov 中，msg_iovlen 就記錄數(shù)組的長(zhǎng)度 （即有多少個(gè)buff） */ struct msghdr {     void    *    msg_name;    /* Socket name            */     int          msg_namelen;    /* Length of name        */     struct iovec *    msg_iov;    /* Data blocks            */     __kernel_size_t   msg_iovlen;    /* Number of blocks        */     void     *         msg_control;    /* Per protocol magic (eg BSD file descriptor passing) */     __kernel_size_t    msg_controllen;    /* Length of cmsg list */     unsigned int      msg_flags; }; /*    msg_name：數(shù)據(jù)的目的地址，網(wǎng)絡(luò)包指向 sockaddr_in, netlink 則指向 sockaddr_nl;    msg_namelen: msg_name 所代表的地址長(zhǎng)度    msg_iov: 指向的是緩沖區(qū)數(shù)組    msg_iovlen: 緩沖區(qū)數(shù)組長(zhǎng)度    msg_control: 輔助數(shù)據(jù)，控制信息(發(fā)送任何的控制信息)    msg_controllen: 輔助信息長(zhǎng)度    msg_flags: 消息標(biāo)識(shí) */

邏輯結(jié)構(gòu)如下：

socket 也是一種特殊的文件，通過(guò) VFS 的接口同樣可以對(duì)其進(jìn)行使用管理。socket  本身就需要實(shí)現(xiàn)文件系統(tǒng)的相應(yīng)接口，有自己的操作方法集。

netlink 常用宏

#define NLMSG_ALIGNTO   4U/* 宏 NLMSG_ALIGN(len) 用于得到不小于len且字節(jié)對(duì)齊的最小數(shù)值 */ #define NLMSG_ALIGN(len) ( ((len)+NLMSG_ALIGNTO-1) & ~(NLMSG_ALIGNTO-1) ) /* Netlink&nbsp;頭部長(zhǎng)度 */ #define NLMSG_HDRLEN     ((int) NLMSG_ALIGN(sizeof(struct nlmsghdr))) /* 計(jì)算消息數(shù)據(jù) len 的真實(shí)消息長(zhǎng)度（消息體 +　消息頭）*/ #define NLMSG_LENGTH(len) ((len) + NLMSG_HDRLEN) /* 宏 NLMSG_SPACE(len) 返回不小于 NLMSG_LENGTH(len) 且字節(jié)對(duì)齊的最小數(shù)值 */ #define NLMSG_SPACE(len) NLMSG_ALIGN(NLMSG_LENGTH(len)) /* 宏 NLMSG_DATA(nlh) 用于取得消息的數(shù)據(jù)部分的首地址，設(shè)置和讀取消息數(shù)據(jù)部分時(shí)需要使用該宏 */ #define NLMSG_DATA(nlh)  ((void*)(((char*)nlh) + NLMSG_LENGTH(0))) /* 宏 NLMSG_NEXT(nlh,len) 用于得到下一個(gè)消息的首地址, 同時(shí) len 變?yōu)槭Ｓ嘞⒌拈L(zhǎng)度 */ #define NLMSG_NEXT(nlh,len)  ((len) -= NLMSG_ALIGN((nlh)->nlmsg_len), \                  (struct nlmsghdr*)(((char*)(nlh)) + NLMSG_ALIGN((nlh)->nlmsg_len))) /* 判斷消息是否 >len */ #define NLMSG_OK(nlh,len) ((len) >= (int)sizeof(struct nlmsghdr) && \               (nlh)->nlmsg_len >= sizeof(struct nlmsghdr) && \               (nlh)->nlmsg_len <= (len)) /* NLMSG_PAYLOAD(nlh,len) 用于返回 payload 的長(zhǎng)度*/ #define NLMSG_PAYLOAD(nlh,len) ((nlh)->nlmsg_len - NLMSG_SPACE((len)))

netlink 內(nèi)核常用函數(shù)

netlink_kernel_create

這個(gè)內(nèi)核函數(shù)用于創(chuàng)建內(nèi)核 socket，以提供和用戶(hù)態(tài)通信

static inline struct sock * netlink_kernel_create(struct net *net, int unit, struct netlink_kernel_cfg *cfg) /*     net: 指向所在的網(wǎng)絡(luò)命名空間, 默認(rèn)傳入的是 &init_net (不需要定義);  定義在 net_namespace.c(extern struct net init_net);     unit: netlink 協(xié)議類(lèi)型     cfg:  cfg 存放的是 netlink 內(nèi)核配置參數(shù)（如下） */  /* optional Netlink kernel configuration parameters */ struct netlink_kernel_cfg {     unsigned int    groups;     unsigned int    flags;     void        (*input)(struct sk_buff *skb); /* input 回調(diào)函數(shù) */     struct mutex    *cb_mutex;     void        (*bind)(int group);     bool        (*compare)(struct net *net, struct sock *sk); };

單播函數(shù) netlink_unicast() 和多播函數(shù) netlink_broadcast()

/* 來(lái)發(fā)送單播消息 */ extern int netlink_unicast(struct sock *ssk, struct sk_buff *skb, __u32 portid, int nonblock); /* ssk: netlink socket    skb: skb buff 指針    portid：通信的端口號(hào)    nonblock：表示該函數(shù)是否為非阻塞，如果為1，該函數(shù)將在沒(méi)有接收緩存可利用時(shí)立即返回，而如果為 0，該函數(shù)在沒(méi)有接收緩存可利用 定時(shí)睡眠 */  /* 用來(lái)發(fā)送多播消息 */ extern int netlink_broadcast(struct sock *ssk, struct sk_buff *skb, __u32 portid,                  __u32 group, gfp_t allocation); /* ssk: 同上（對(duì)應(yīng) netlink_kernel_create 返回值）、    skb: 內(nèi)核 skb buff    portid：端口id    group: 是所有目標(biāo)多播組對(duì)應(yīng)掩碼的"OR"操作的。    allocation: 指定內(nèi)核內(nèi)存分配方式，通常 GFP_ATOMIC 用于中斷上下文，而 GFP_KERNEL 用于其他場(chǎng)合。                 這個(gè)參數(shù)的存在是因?yàn)樵?nbsp;API 可能需要分配一個(gè)或多個(gè)緩沖區(qū)來(lái)對(duì)多播消息進(jìn)行 clone。 */

測(cè)試?yán)哟a

netlink 內(nèi)核建立 socket 過(guò)程

內(nèi)核的代碼非常簡(jiǎn)單，這里給出了核心代碼，就這么多，接收函數(shù)中直接打印了接收到的消息。

#include <linux/module.h>#include <linux/kernel.h>#include <linux/init.h>#include <net/sock.h>#include <asm/types.h>#include <linux/netlink.h>#include <linux/skbuff.h> #define NETLINK_XUX           31       /* testing */   static struct sock *xux_sock = NULL;  // 接收消息的回調(diào)函數(shù)，接收參數(shù)是 sk_buff static void recv_netlink(struct sk_buff *skb) {     struct nlmsghdr *nlh;     nlh = nlmsg_hdr(skb); // 取得消息體     printk("receive data from user process: %s", (char *)NLMSG_DATA(nlh)); // 打印接收的數(shù)據(jù)內(nèi)容      ... }  int __init init_link(void) {     struct netlink_kernel_cfg cfg = {         .input = recv_netlink,     };     xux_sock = netlink_kernel_create(&init_net, NETLINK_XUX, &cfg); // 創(chuàng)建內(nèi)核 socket     if (!xux_sock){         printk("cannot initialize netlink socket");         return -1;     }          printk("Init OK!\n");     return 0; }

netlink 用戶(hù)態(tài)建立鏈接和收發(fā)信息

... // 上面的就省了 #define NETLINK_USER 31  //self defined #define MAX_PAYLOAD 1024 /* maximum payload size*/ struct sockaddr_nl src_addr, dest_addr; struct nlmsghdr *nlh = NULL; struct msghdr msg; struct iovec iov; int sock_fd;  int main(int args, char *argv[]) {     sock_fd = socket(PF_NETLINK, SOCK_RAW, NETLINK_USER); // 建立 socket      if(sock_fd < 0)         return -1;      memset(&src_addr, 0, sizeof(src_addr));     src_addr.nl_family = AF_NETLINK;     src_addr.nl_pid = getpid(); /* 當(dāng)前進(jìn)程的 pid */      if(bind(sock_fd, (struct sockaddr*)&src_addr, sizeof(src_addr))){ // 和指定協(xié)議進(jìn)行 socket 綁定         perror("bind() error\n");         close(skfd);         return -1;     }      memset(&dest_addr, 0, sizeof(dest_addr));     dest_addr.nl_family = AF_NETLINK;     dest_addr.nl_pid = 0;       /* For Linux Kernel */     dest_addr.nl_groups = 0;    /* unicast */      nlh = (struct nlmsghdr *)malloc(NLMSG_SPACE(MAX_PAYLOAD));     memset(nlh, 0, NLMSG_SPACE(MAX_PAYLOAD));     nlh->nlmsg_len = NLMSG_SPACE(MAX_PAYLOAD);     nlh->nlmsg_pid = getpid();  //self pid     nlh->nlmsg_flags = 0;     // 拷貝信息到發(fā)送緩沖中     strcpy(NLMSG_DATA(nlh), "Hello this is a msg from userspace");     // 構(gòu)造發(fā)送消息體     iov.iov_base = (void *)nlh;         //iov -> nlh     iov.iov_len = nlh->nlmsg_len;     msg.msg_name = (void *)&dest_addr;     msg.msg_namelen = sizeof(dest_addr);     msg.msg_iov = &iov;  // iov 中存放 netlink 消息頭和消息數(shù)據(jù)     msg.msg_iovlen = 1;      printf("Sending message to kernel\n");      int ret = sendmsg(sock_fd, &msg, 0);  // 發(fā)送消息到內(nèi)核     printf("send ret: %d\n", ret);      printf("Waiting for message from kernel\n");      /* 從內(nèi)核接收消息 */     recvmsg(sock_fd, &msg, 0);     printf("Received message payload: %s\n", NLMSG_DATA(nlh));  // 打印接收到的消息      close(sock_fd);     return 0; }

netlink 目前感覺(jué)還是一個(gè)比較好用的內(nèi)核和用戶(hù)空間的交互方式，但是也是有他的使用場(chǎng)景，適合用戶(hù)空間和內(nèi)核空間主動(dòng)交互的場(chǎng)景。

但是在單機(jī)場(chǎng)景下，大多數(shù)的主動(dòng)權(quán)在用戶(hù)進(jìn)程，用戶(hù)進(jìn)程寫(xiě)數(shù)據(jù)到內(nèi)核，用戶(hù)進(jìn)程主動(dòng)讀取內(nèi)核數(shù)據(jù)。這兩種場(chǎng)景覆蓋了內(nèi)核的絕大多數(shù)場(chǎng)景。

在內(nèi)核要主動(dòng)的場(chǎng)景下，netlink 就比較適合。我能想到的就是內(nèi)核數(shù)據(jù)審計(jì)，安全觸發(fā)等，這類(lèi)場(chǎng)景下內(nèi)核可以實(shí)時(shí)的告知用戶(hù)進(jìn)程內(nèi)核發(fā)生的情況。

我是在看 ipvs 的代碼時(shí)候看到了里面有 netlink 的使用，發(fā)現(xiàn)早期 iptables 就是使用 netlink 來(lái)下發(fā)配置指令的，內(nèi)核中  netfilter 和 iptables 中還有這部分的代碼，今天也順便下載大致走讀了一遍，大家可以搜索 NETLINK 這個(gè)關(guān)鍵字來(lái)看。但是 iptables  后來(lái)的代碼中沒(méi)有使用這樣的方式，而是采用了一個(gè)叫做 iptc 的庫(kù)，其核心思路還是使用 setsockops 的方式，最終還是  copy_from_user。不過(guò)這種方式對(duì)于 iptables 這種配置下發(fā)的場(chǎng)景來(lái)說(shuō)還是非常實(shí)用的。

以上就是如何進(jìn)行Netlink源碼及實(shí)例的分析，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見(jiàn)到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網(wǎng)站欄目：如何進(jìn)行Netlink源碼及實(shí)例的分析
文章出自：http://chinadenli.net/article38/jggspp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供商城網(wǎng)站、虛擬主機(jī)、小程序開(kāi)發(fā)、定制開(kāi)發(fā)、網(wǎng)站維護(hù)、微信小程序

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)