高性能分布式网络服务器--TCPServer模块-创新互联

TCPServer模块

TCPServer模块是采用Template Pattern设计模式封装了一个常规TCP服务器。支持同时绑定多个地址进行监听，只需要在绑定时传入地址数组即可。还可以分别指定接收客户端和处理客户端的协程调度器

在科尔沁等地区，都构建了全面的区域性战略布局，加强发展的系统性、市场前瞻性、产品创新能力，以专注、极致的服务理念，为客户提供成都做网站、成都网站制作 网站设计制作专业公司,公司网站建设,企业网站建设,品牌网站设计,全网整合营销推广,外贸网站建设,科尔沁网站建设费用合理。github

https://github.com/huxiaohei/tiger.git

实现

初始化TCPServer时需要制定两个IO调度器，分别用于接受客户端和处理客户端请求。在接受到客户端连接请求时，生成对应的客户端Socket实例(前面在接受Socket模块的时候已经介绍过，Socket所对应的sock会在IO调度器中注册读写事件)，并将Socket实例交由handle_client处理

因此，使用TCPServer时，必须从TCPServer派生一个新类，并重新实现子类的handle_client

使用可以参考EchoServer

class EchoServer : public tiger::TCPServer {public:
    void handle_client(tiger::Socket::ptr client) override {TIGER_LOG_D(tiger::TEST_LOG)<< "[handle client:"<< client<< "]";
        auto buf = std::make_shared();
        while (true) {buf->clear();
            std::vectoriovs;
            buf->get_enable_write_buffers(iovs, 1024);
            int rt = client->recv(&iovs[0], iovs.size());
            if (rt == 0) {TIGER_LOG_I(tiger::TEST_LOG)<< "[has closed client:"<< client<< "]";
                break;
            } else if (rt< 0) {TIGER_LOG_E(tiger::TEST_LOG)<< "[client error"
                                  << " erron:"<< strerror(errno)<< "]";
                break;
            }
            buf->set_position(buf->get_position() + rt);
            buf->set_position(0);
            const std::string &msg = buf->to_string();
            TIGER_LOG_D(tiger::TEST_LOG)<< "[Echo receive: "<< msg<< "]";
            client->send(msg.c_str(), msg.size());
            if (msg.find("stop") == 0) {TIGER_LOG_I(tiger::TEST_LOG)<< "[ECHO STOP]";
                stop();
                tiger::IOManager::GetThreadIOM()->stop();
            }
        }
    }
};


void run() {auto addr = tiger::Address::LookupAny("0.0.0.0:8080");
    auto ech_server = std::make_shared();
    ech_server->bind(addr);
    ech_server->start();
}

int main() {tiger::SingletonLoggerMgr::Instance()->add_loggers("tiger", "../conf/tiger.yml");
    tiger::Thread::SetName("TCPServer");
    TIGER_LOG_D(tiger::TEST_LOG)<< "[tcp_server test start]";
    auto iom = std::make_shared("TCPServer", true, 1);
    iom->schedule(run);
    iom->start();
    TIGER_LOG_D(tiger::TEST_LOG)<< "[tcp_server test end]";
    return 0;
}

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧

分享题目：高性能分布式网络服务器--TCPServer模块-创新互联
文章地址：http://bjjierui.cn/article/jcdde.html