Method StartServer

src/plugin/net/src/AFCWebSocketServer.cpp:36–146

}

bool AFCWebSocketServer::StartServer(AFHeadLength head_len, const int busid, const std::string& ip, const int port,
    const int thread_num, const unsigned int max_client, bool ip_v6 /* = false*/)
{
    using namespace brynet::net;
    using namespace brynet::net::http;

    this->bus_id_ = busid;

    tcp_service_ = TcpService::Create();
    tcp_service_->startWorkerThread(thread_num);

    auto shared_this = shared_from_this();
    auto OnEnterCallback = [shared_this, &head_len](const TcpConnectionPtr& session) {
        const std::string& session_ip = session->getIP();
        HttpService::setup(session, [shared_this, &head_len, &session_ip](const HttpSession::Ptr& httpSession) {
            //int64_t cur_session_id = shared_this->trusted_session_id_++;
            int64_t cur_session_id = shared_this->uid_generator_->GetUID(shared_this->bus_id_);
            AFNetEvent* net_connect_event = AFNetEvent::AllocEvent();
            net_connect_event->SetId(cur_session_id);
            net_connect_event->SetType(AFNetEventType::CONNECTED);
            net_connect_event->SetBusId(shared_this->bus_id_);
            net_connect_event->SetIP(session_ip);

            // Scope lock
            {
                AFScopeWLock guard(shared_this->rw_lock_);
                AFHttpSessionPtr session_ptr = ARK_NEW AFHttpSession(head_len, cur_session_id, httpSession);
                if (shared_this->AddNetSession(session_ptr))
                {
                    session_ptr->AddNetEvent(net_connect_event);
                }
            }

            httpSession->setWSCallback([shared_this](const HttpSession::Ptr& httpSession,
                                           WebSocketFormat::WebSocketFrameType opcode, const std::string& payload) {
                switch (opcode)
                {
                    case WebSocketFormat::WebSocketFrameType::ERROR_FRAME:
                    case WebSocketFormat::WebSocketFrameType::CONTINUATION_FRAME:
                    case WebSocketFormat::WebSocketFrameType::TEXT_FRAME:
                    case WebSocketFormat::WebSocketFrameType::BINARY_FRAME:
                    case WebSocketFormat::WebSocketFrameType::CLOSE_FRAME:
                    case WebSocketFormat::WebSocketFrameType::PING_FRAME:
                    {
                        auto frame = std::make_shared<std::string>();
                        WebSocketFormat::wsFrameBuild(payload.c_str(), payload.size(), *frame,
                            WebSocketFormat::WebSocketFrameType::PONG_FRAME, true, false);
                        return httpSession->send(frame);
                    }
                    case WebSocketFormat::WebSocketFrameType::PONG_FRAME:
                        break;
                    default:
                        break;
                }

                const auto ud = cast<int64_t>(httpSession->getUD());
                int64_t session_id = *ud;