连接管理模块和服务器模块设计

1. 封装连接管理类

向用户提供一个用于实现网络通信的 Connection 对象，从其内部可创建出粒度更轻的 Channel 对象，用于与客户端进行网络通信。

成员信息：

• 连接关联的信道管理句柄（实现信道的增删查）
• 连接关联的实际用于通信的 muduo::net::Connection 连接
• protobuf 协议处理的句柄（ProtobufCodec 对象）
• 消费者管理句柄
• 虚拟机句柄
• 异步工作线程池句柄

连接操作：

• 提供创建 Channel 信道的操作
• 提供删除 Channel 信道的操作

连接管理：

• 连接的增删查

为什么需要这些成员和操作？

1. 信道管理句柄：因为 AMQP 协议允许在一个连接上创建多个信道，每个信道可以独立进行操作（如声明队列、发布消息等）。所以连接管理模块需要能够管理这些信道，包括创建、删除和查找。
2. muduo::net::Connection：这是实际进行网络通信的对象，连接管理模块需要持有它以便进行数据的发送和接收，同时也需要监听连接的事件（如断开、消息到达等）。
3. ProtobufCodec：因为我们的通信协议是使用 protobuf 序列化的，所以需要这个编解码器来解析和封装消息。
4. 消费者管理句柄：消费者是消息队列的重要概念，连接管理模块需要消费者管理句柄来管理消费者（因为消费者是建立在连接上的，虽然具体操作在信道，但消费者资源属于连接）。在 Channel 类中，我们看到了消费者管理器的使用，所以连接管理模块需要持有消费者管理器，并传递给每个信道。
5. 虚拟机句柄：虚拟机是 RabbitMQ 中资源隔离的单位，连接必须属于一个虚拟机。连接管理模块需要虚拟机句柄来访问虚拟机中的交换机、队列等资源。
6. 异步工作线程池句柄：为了不阻塞网络线程，一些耗时的操作（如消息的消费）需要放到线程池中执行。因此，连接管理模块需要持有线程池的句柄，并传递给信道使用。

操作方面： 创建和删除信道是 AMQP 协议的基本操作，因为客户端可以通过打开和关闭信道来在同一个连接上实现多路复用。

连接管理（增删查）则是对连接本身的管理，当客户端建立连接时，服务器需要创建一个连接对象，并管理起来，以便在连接断开时清理资源。

class Connection {
public:
    using ptr = std::shared_ptr<Connection>;
    Connection(const VirtualHost::ptr &host, const ConsumerManager::ptr &cmp, const ProtobufCodecPtr &codec, const muduo::net::TcpConnectionPtr &conn, const threadpool::ptr &pool)
        : _conn(conn), _codec(codec), _cmp(cmp), _host(host), _pool(pool), _channels(std::make_shared<ChannelManager>()) {}

    void openChannel(const openChannelRequestPtr& req) {
        // 1. 判断信道 ID 是否重复，创建信道
        bool ret = _channels->openChannel(req->(), _host, _cmp, _codec, _conn, _pool);
         (ret == ) {
            ();
            (, req->(), req->());
            ;
        }
        (, req->().());
        
        (, req->(), req->());
    }

    {
        _channels->(req->());
        (, req->(), req->());
    }

    {
         _channels->(cid);
    }

:
    {
        basicCommonResponse resp;
        resp.(rid);
        resp.(cid);
        resp.(ok);
        _codec->(_conn, resp);
    }

:
    muduo::net::TcpConnectionPtr _conn;
    ProtobufCodecPtr _codec;
    ConsumerManager::ptr _cmp;
    VirtualHost::ptr _host;
    threadpool::ptr _pool;
    ChannelManager::ptr _channels;
};