上一節文章主要是說了一下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