TcpServer模块的公开接口:

        对于TcpServer对象设置回调函数，其实最终会被设置到Connection对象上，而每个客户端对于一个Connection对象。 

        启动非活跃连接销毁，Tcpserver对象默认是关闭非活跃连接销毁的，添加定时任务下面会讲。

         TcpServer对象创建后，就需要调用Start()函数进行线程池的创建，以及主线程EventLooop对象的运行，这个就是死循环。

添加定时任务：

         这个添加定时任务是添加到主线程中的EventLoop对象的定时器对象当中去的。

         而子线程是不会添加这种定时器任务，他只会运行非活跃连接的销毁工作。

连接的删除:

当连接断开时，需要将断开的连接从容器中删除。

        这是设置给新连接的关闭回调函数，注意这个需要最后删除，否则Connection对象中保存的资源就不存在了，如果再去访问这些资源会出错，会什么还要去访问这些资源，因为如果你先删除Connection对象，就会找不到那些还没删除的资源，造成资源泄漏。

创建新连接并且为新连接设置回调函数：

        新连接的回调函数是外部进行设置的。

 上面就是有新连接到来调用的回调函数。

        为新连接分配EventLoop对象和_next_id，将回调函数设置给Connection对象，在connection对象连接的不同状态中，进行调用。这不是设置给Channel对象的，channel对象设置的回调函数，是Connection对象的私有成员函数。

        该回调函数最终会被设置给Acceptor对象。

        当有新连接到来时，就会用新连接的文件描述符，初始化Connection,并将初始化好的connection对象放到存储容器中。 

TcpServer模块中的成员变量：

_next_id：

        他是自动增长的，可以标记连接的唯一性。

_port:

        这是服务器端口号。

_timeout和_enable_inactive_release:

        启动非活跃连接时设置的超时销毁时间 和 销毁标志。

EventLoop：

        这个是主线程对应的事件管理对象。有可能客户端多个客户端对应一个套接字对象，主线程上的套接字对应一个EventLoop对象。这也体现Reactor模型。

Acceptor:

        这个就是TcpServer模块如何让EventLoop对象去监听，主线程上的套接字有没有新的套接字到来。

LoopThreadPool：

        TcpServer模块对应的线程池，该线程池中的每一个线程都绑定这一个EventLoop对象。

std::unordered_map:

        这是用_next_id将Connection对象标识起来，存放到容器中，方便查找。

TcpServer模块整体代码：

class TcpServer {     private:         uint64_t _next_id;      //这是一个自动增长的连接ID，         int _port;         int _timeout;           //这是非活跃连接的统计时间---多长时间无通信就是非活跃连接         bool _enable_inactive_release;//是否启动了非活跃连接超时销毁的判断标志         EventLoop _baseloop;    //这是主线程的EventLoop对象，负责监听事件的处理         Acceptor _acceptor;    //这是监听套接字的管理对象         LoopThreadPool _pool;   //这是从属EventLoop线程池         std::unordered_map _conns;//保存管理所有连接对应的shared_ptr对象          using ConnectedCallback = std::function;         using MessageCallback = std::function;         using ClosedCallback = std::function;         using AnyEventCallback = std::function;         using Functor = std::function;         ConnectedCallback _connected_callback;         MessageCallback _message_callback;         ClosedCallback _closed_callback;         AnyEventCallback _event_callback;     private:         void RunAfterInLoop(const Functor &task, int delay) {             _next_id++;             _baseloop.TimerAdd(_next_id, delay, task);         }         //为新连接构造一个Connection进行管理         void NewConnection(int fd) {             _next_id++;             PtrConnection conn(new Connection(_pool.NextLoop(), _next_id, fd));             conn->SetMessageCallback(_message_callback);             conn->SetClosedCallback(_closed_callback);             conn->SetConnectedCallback(_connected_callback);             conn->SetAnyEventCallback(_event_callback);             conn->SetSrvClosedCallback(std::bind(&TcpServer::RemoveConnection, this, std::placeholders::_1));             if (_enable_inactive_release) conn->EnableInactiveRelease(_timeout);//启动非活跃超时销毁             conn->Established();//就绪初始化             _conns.insert(std::make_pair(_next_id, conn));         }         void RemoveConnectionInLoop(const PtrConnection &conn) {             int id = conn->Id();             auto it = _conns.find(id);             if (it != _conns.end()) {                 _conns.erase(it);             }         }         //从管理Connection的_conns中移除连接信息         void RemoveConnection(const PtrConnection &conn) {             _baseloop.RunInLoop(std::bind(&TcpServer::RemoveConnectionInLoop, this, conn));         }     public:         TcpServer(int port):             _port(port),              _next_id(0),              _enable_inactive_release(false),              _acceptor(&_baseloop, port),             _pool(&_baseloop) {             _acceptor.SetAcceptCallback(std::bind(&TcpServer::NewConnection, this, std::placeholders::_1));             _acceptor.Listen();//将监听套接字挂到baseloop上         }         void SetThreadCount(int count) { return _pool.SetThreadCount(count); }         void SetConnectedCallback(const ConnectedCallback&cb) { _connected_callback = cb; }         void SetMessageCallback(const MessageCallback&cb) { _message_callback = cb; }         void SetClosedCallback(const ClosedCallback&cb) { _closed_callback = cb; }         void SetAnyEventCallback(const AnyEventCallback&cb) { _event_callback = cb; }         void EnableInactiveRelease(int timeout) { _timeout = timeout; _enable_inactive_release = true; }         //用于添加一个定时任务         void RunAfter(const Functor &task, int delay) {             _baseloop.RunInLoop(std::bind(&TcpServer::RunAfterInLoop, this, task, delay));         }         void Start() { _pool.Create();  _baseloop.Start(); } };