XuMQ::ConnectionManager类 参考

连接管理类 更多...

#include <connection.hpp>

Public 类型
using	ptr = std::shared_ptr< ConnectionManager >
	连接管理句柄

Public 成员函数
	ConnectionManager ()
	构造函数
void	newConnection (const VirtualHost::ptr &host, const ConsumerManager::ptr &cmp, const ProtobufCodecPtr &codec, const muduo::net::TcpConnectionPtr &conn, const threadpool::ptr &pool)
	新建一个连接
void	deleteConnection (const muduo::net::TcpConnectionPtr &conn)
	删除一个连接
Connection::ptr	getConnection (const muduo::net::TcpConnectionPtr &conn)
	获取一个连接

Private 属性
std::mutex	_mutex
	互斥锁
std::unordered_map< muduo::net::TcpConnectionPtr, Connection::ptr >	_conns
	一个从muduo连接管理句柄到连接管理句柄的映射表

详细描述

连接管理类

成员类型定义说明

ptr

using XuMQ::ConnectionManager::ptr = std::shared_ptr<ConnectionManager>

连接管理句柄

构造及析构函数说明

ConnectionManager()

XuMQ::ConnectionManager::ConnectionManager ( )

inline

构造函数

成员函数说明

deleteConnection()

void XuMQ::ConnectionManager::deleteConnection ( const muduo::net::TcpConnectionPtr &  conn )

inline

删除一个连接

参数

conn	muduo连接管理句柄

getConnection()

Connection::ptr XuMQ::ConnectionManager::getConnection ( const muduo::net::TcpConnectionPtr &  conn )

inline

获取一个连接

参数

conn	muduo连接管理句柄

返回

连接句柄

newConnection()

void XuMQ::ConnectionManager::newConnection ( const VirtualHost::ptr &  host, const ConsumerManager::ptr &  cmp, const ProtobufCodecPtr &  codec, const muduo::net::TcpConnectionPtr &  conn, const threadpool::ptr &  pool  )

inline

新建一个连接

参数

host	虚拟机
cmp	消费者管理句柄
codec	协议处理句柄
conn	muduo连接管理句柄
pool	线程池管理句柄

类成员变量说明

_conns

std::unordered_map<muduo::net::TcpConnectionPtr, Connection::ptr> XuMQ::ConnectionManager::_conns

private

一个从muduo连接管理句柄到连接管理句柄的映射表

_mutex

std::mutex XuMQ::ConnectionManager::_mutex

private

互斥锁