Sockmap需要任何BPF程序吗？

在使用Sockmap时，需要编写BPF程序来实现所需的功能。以下是一个简单的示例，展示了如何使用Sockmap和BPF程序来实现一个简单的数据包过滤器。

首先，需要准备一个BPF程序，例如名为filter.bpf的文件：

#include <linux/bpf.h>
#include <linux/if_ether.h>
#include <linux/ip.h>
#include <linux/tcp.h>

struct bpf_map_def SEC("maps") sock_map = {
    .type = BPF_MAP_TYPE_SOCKMAP,
    .key_size = sizeof(int),
    .value_size = sizeof(int),
    .max_entries = 1024,
};

SEC("filter")
int filter(struct __sk_buff *skb) {
    struct ethhdr *eth = bpf_hdr_pointer(skb);
    struct iphdr *ip = (struct iphdr *)(eth + 1);
    struct tcphdr *tcp = (struct tcphdr *)(ip + 1);

    // 过滤条件：只接受源端口为80的TCP数据包
    if (ip->protocol == IPPROTO_TCP && tcp->source == htons(80)) {
        int ifindex = skb->ifindex;
        bpf_sock_map_update(skb, &sock_map, &ifindex, BPF_NOEXIST);
    }

    return XDP_PASS;
}

然后，需要编译并加载BPF程序，可以使用clang和bpftool来完成。假设将BPF程序编译为名为filter.o的文件：

$ clang -O2 -target bpf -c filter.bpf -o filter.o
$ bpftool map create /sys/fs/bpf/sock_map type sockmap key 4 value 4 entries 1024
$ bpftool map update pinned /sys/fs/bpf/sock_map key 0 0 0 value pinned /sys/fs/bpf/filter.o

最后，需要在用户空间中编写一个程序来使用Sockmap。以下是一个简单的示例程序，使用libbpf和libbpf_helpers库来加载BPF程序并进行数据包过滤：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <linux/if_ether.h>
#include <linux/ip.h>
#include <linux/tcp.h>
#include <bpf/bpf.h>
#include <bpf/libbpf.h>
#include <bpf/bpf_helpers.h>

int main() {
    struct bpf_object *obj;
    struct bpf_program *prog;
    int sock_map_fd;
    struct sockaddr_in addr = {
        .sin_family = AF_INET,
        .sin_port = htons(8080),
    };

    // 加载BPF程序
    if (bpf_prog_load("/sys/fs/bpf/filter.o", BPF_PROG_TYPE_SOCKET_FILTER, &obj, &prog) != 0) {
        fprintf(stderr, "Failed to load BPF program\n");
        return 1;
    }

    // 获取Sockmap文件描述符
    if (bpf_object__find_map_fd_by_name(obj, "sock_map", &sock_map_fd) != 0) {
        fprintf(stderr, "Failed to find sock_map\n");
        return 1;
    }

    // 创建Socket
    int sock = socket(AF_INET, SOCK_STREAM, 0);
    if (sock < 0) {
        perror("socket");
        return 1;
    }

    // 绑定Socket地址
    if (bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0) {
        perror("bind");
        return 1;
    }

    // 将Socket绑定到Sockmap
    if (setsockopt(sock, SOL_SOCKET, SO_ATTACH_BPF, &sock_map_fd, sizeof(sock_map_fd)) < 0) {
        perror("setsockopt");
        return 1;
    }

    // 监听Socket
    if (listen(sock, 128) < 0) {
        perror("listen");
        return 1;
    }

    while (1) {
        // 接受连接
        int client_sock = accept(sock, NULL, NULL);
        if (client_sock < 0) {
            perror("accept");
            return 1;
        }

        // 读取数据
        char buffer[1024];
        ssize_t len = read(client_sock, buffer, sizeof(buffer));
        if (len < 0) {
            perror("read");
            return 1;
        }

        // 打印数据
        printf("Received %ld bytes\n", len);
        printf("%.*