channel.hpp 文件参考

信道与信道管理模块的头文件，包含了信道的声明和其管理类的定义。 更多...

#include "muduo/net/TcpConnection.h"
#include "muduo/protobuf/codec.h"
#include "muduo/protobuf/dispatcher.h"
#include "muduo/base/Atomic.h"
#include "muduo/base/Types.h"
#include "../common/logger.hpp"
#include "../common/helper.hpp"
#include "../common/msg.pb.h"
#include "../common/protocol.pb.h"
#include "../common/threadpool.hpp"
#include <google/protobuf/map.h>
#include "consumer.hpp"
#include "host.hpp"
#include "route.hpp"

channel.hpp 的引用(Include)关系图:

此图展示该文件直接或间接的被哪些文件引用了:

浏览源代码.

类
class	XuMQ::Channel
	客户端信道类 更多...
class	XuMQ::ChannelManager
	信道管理类 更多...

命名空间
namespace	XuMQ

类型定义
using	XuMQ::openChannelRequestPtr = std::shared_ptr< openChannelRequest >
	打开信道请求
using	XuMQ::closeChannelRequestPtr = std::shared_ptr< closeChannelRequest >
	关闭信道请求
using	XuMQ::declareExchangeRequestPtr = std::shared_ptr< declareExchangeRequest >
	声明交换机请求
using	XuMQ::deleteExchangeRequestPtr = std::shared_ptr< deleteExchangeRequest >
	删除交换机请求
using	XuMQ::declareQueueRequestPtr = std::shared_ptr< declareQueueRequest >
	声明队列请求
using	XuMQ::deleteQueueRequestPtr = std::shared_ptr< deleteQueueRequest >
	删除队列请求
using	XuMQ::queueBindRequestPtr = std::shared_ptr< queueBindRequest >
	绑定请求
using	XuMQ::queueUnBindRequestPtr = std::shared_ptr< queueUnBindRequest >
	解除绑定请求
using	XuMQ::basicPublishRequestPtr = std::shared_ptr< basicPublishRequest >
	消息发布请求
using	XuMQ::basicAckRequestPtr = std::shared_ptr< basicAckRequest >
	消息应答请求
using	XuMQ::basicCancelRequestPtr = std::shared_ptr< basicCancelRequest >
	取消订阅请求
using	XuMQ::basicConsumeRequestPtr = std::shared_ptr< basicConsumeRequest >
	取消订阅请求

详细描述

信道与信道管理模块的头文件，包含了信道的声明和其管理类的定义。

该文件定义了消息队列系统中信道 (Channel) 及信道管理 (ChannelManager) 的类，主要用于处理信道相关的操作 例如声明队列、发布消息、消费者回调等。依赖于 Protobuf 和 Muduo 库，并使用了自定义的日志模块和线程池。

• 消息队列系统模块
• 基于 TCP 和 Protobuf 的消息通信
• 支持多线程处理和消费者管理