Reium -- 高性能网络库

目标

reactor + 多线程
高性能日志库（30%）
基于切片的字符串处理
定时任务
Tcp链接处理

Get start

客户端：

auto loop = reimu::EventLoop::GetInstance();

auto c = std::make_shared<reimu::TcpConn>(&loop, 10);

c->OnConnected([](reimu::TcpConnPtr conn ){
    std::cout<<"链接成功"<<std::endl;
    conn->Send("hello");
});

c->OnMsg([](reimu::TcpConnPtr conn, reimu::Slice s ){

    std::cout<<"收到消息"<<s.toString()<<std::endl;
});

c->Connect("0.0.0.0", 10010);


loop->Loop();

服务端：

    auto loop = reimu::EventLoop::GetInstance();

    auto s = new reimu::TcpServer(loop, "0.0.0.0", 10011);
    s->SetConnTimeout(5000);

    s->OnConnMsg([](reimu::TcpConnPtr conn, reimu::Slice s) {

        std::cout << "收到消息" << s.toString() << std::endl;
        conn->Send("hello");
    });

    s->OnConnDisconnected([](reimu::TcpConnPtr conn) {
        std::cout << "断开链接"<<std::endl;

    });
    s->OnAccept([](reimu::TcpConnPtr conn) {
        std::cout << "收到链接"<< "来自 "<<conn->GetDestAddr().ToString()<<std::endl;
    });

    s->StartServer();
    loop->Loop();

Q&A

Q1: 并发模式？ A1:

把可能比较费时间的用户逻辑放在单独的线程里处理，这样又能保证一个套接字（内核程度）只有一个线程在操作，不用加锁，性能也不错, 线程之间通过SafeQueue做同步

Q2: 事件处理？

只处理了 POLLIN 和 POLLOUT 具体的错误根据读写操作时的erron来判断

Q3：字符串处理？

用Slice 作为字符串的视图，记录起始地址，当用户真正需要的时候再自行拷贝

Q4: 错误处理？

erron 的 EAGAIN EMFILE EINTR ECONNABORTED 不视作错误直接重试或等下一次

Q5: 日志处理？

目前只是一个简单的基于SafeQueue做日志异步消费

Q6: 超时处理？

可对每个链接设置超时时间，调用超时的回调，完成回调后直接关闭，服务器会记录超时的链接，把超时的链接踢出去。

Q7: 压力测试

cd benchmark
./bench-echo.sh 2>&1 | tee out/echo.txt

IcyCC/reimu

Reium -- 高性能网络库

目标

Get start

Q&A