上一节文章主要是说了一下rabbitmq的安装以及搭建好环境的一些命令，以及常用的api调用，其实自从google被封掉之后，我之前收藏的很多技术连接都已经被禁止访问了，这个是多么可悲的一件事情啊，说多了都是泪。

     首先，我先写一段消费者的模块，建立连接，初始化amq以及销毁连接：

Comsumer::Comsumer(){}
void Comsumer::init(){conn = amqp_new_connection();int sockfd = amqp_open_socket(g_logSrv.m_conf.m_hostname.c_str(), g_logSrv.m_conf.m_port);amqp_set_sockfd(conn,sockfd);LogServer::die_on_amqp_error(amqp_login(conn, g_logSrv.m_conf.m_vhosts.c_str(), 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,  g_logSrv.m_conf.m_username.c_str(),  g_logSrv.m_conf.m_psw.c_str()),"Logging in");amqp_channel_open(conn, (amqp_channel_t)g_logSrv.m_conf.m_channel);LogServer::die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");for(list<ramqserverInfo>::iterator it = g_logSrv.m_conf.getAmqserverInfo.begin(); it != g_logSrv.m_conf.getAmqserverInfo.end(); it++){a