hrpc

一个基于fmap和udp的可持久化rpc通讯，无需维护连接，天然异步，持久化消息，避免程序挂掉或者主动重启导致消息丢失。单线程就可以达到高性能，拉满带宽。单线程即可高达 30w op/s(CPU 10400F, 内存: x) 或 50w+ op/s (Mac Air)。非常适合c/c++游戏后端开发。

使用示例

#include <arpa/inet.h>
#include <errno.h>
#include <math.h>
#include <memory.h>
#include <netinet/in.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <time.h>
#include <unistd.h>

#include "hashmap.h"
#include "hrpc.h"

static long long time_curruent_ms() {
    long long now;
    struct timeval tv;
    gettimeofday(&tv, 0);
    now = tv.tv_sec;
    now = now * 1000000;
    now += tv.tv_usec;
    return now / 1000;
}

struct sockaddr_in get_addr(int nid) {
    struct sockaddr_in addr = {0};
    if (nid == 1) {
        addr.sin_family = AF_INET;
        addr.sin_addr.s_addr = inet_addr("127.0.0.1");
        addr.sin_port = htons(5670);
    }
    return addr;
}

static long long server_count = 0;
static long long server_count_size = 0;
static long long server_count_time = 0;

#define k_test_size 100

void on_client_data(int nid, void* data, unsigned int size) {
    // char* text = hrpc_send(1, k_test_size);
    // strcpy(text, "123321");
    // server_count_size += size;
    // server_count++;
}

void on_server_data(int nid, void* data, unsigned int size) {
    server_count_size += size;
    server_count++;
}

static int exited = 0;
void signal_handler_(int signum) {
    exited = 1;
    printf("app exit: signum=%d\n", signum);
}

int main(int argc, char const* argv[]) {
    signal(SIGINT, signal_handler_);
    signal(SIGQUIT, signal_handler_);
    signal(SIGTERM, signal_handler_);

    if (argc < 2) {
        printf("need argv[1]\n");
        return -1;
    }
    void (*on_data)(int nid, void* data, unsigned int size);
    int is_client = 1;
    if (strcmp(argv[1], "server") == 0) {
        int ret = hrpc_init("./fmap.bin.server", 1, 5670, get_addr);
        if (ret == 0) {
            printf("server init failed\n");
            return -1;
        }
        on_data = on_server_data;
        is_client = 0;
    }
    if (strcmp(argv[1], "client") == 0) {
        int ret = hrpc_init("./fmap.bin.client", 2, 0, get_addr);
        if (ret == 0) {
            printf("client init failed\n");
            return -1;
        }
        on_data = on_client_data;
    }
    while (!exited) {
        hrpc_once(on_data);
        long long curtime = time_curruent_ms();
        if (server_count_time == 0) {
            server_count_time = curtime;
            server_count = 0;
            server_count_size = 0;
        }
        if (is_client) {
            for (int i = 0; i < 100; i++) {
                char* text = hrpc_send(1, k_test_size);
                strcpy(text, "123321");
            }
        }
        if (curtime > server_count_time + 1000) {
            printf("%lld op/s, %lld kb/s\n", server_count * 1000 / (curtime - server_count_time), server_count_size * 1000 / (curtime - server_count_time) / 1024);
            server_count_time = curtime;
            server_count_size = 0;
            server_count = 0;
        }
    }
    return 0;
}

性能测试

上边的代码在 Mac Air下的测试，性能如下： （需要提前执行：sudo sysctl -w net.core.rmem_max=26214400 降低包阻塞）

0 op/s, 0 kb/s
0 op/s, 0 kb/s
0 op/s, 0 kb/s
0 op/s, 0 kb/s
560949 op/s, 54780 kb/s
529080 op/s, 51668 kb/s
533716 op/s, 52120 kb/s
534565 op/s, 52203 kb/s
523816 op/s, 51153 kb/s
409990 op/s, 40038 kb/s
app exit: signum=2