linux開發：從官網下載amqp-cpp（https://github.com/CopernicaMarketingSoftware/AMQP-CPP）這個庫，這個庫是linux 下的。里面包含了linux下的tcp通信（不兼容widows），適合linux開發。
windows開發：由于官網沒有提供可以直接在windows下使用的amqp-cpp，所以需要將官網的linux下的庫經過修改，剝離了tcp通信部分，只留下了AMQP協議框架部分（https://git.oschina.net/Ailsc/amqp-cpp.git）。所以開發的話需要自己加入tcp（iocp：https://git.oschina.net/Ailsc/jeflib.git）通信部分配合AMQP-cpp協議框架，來共同開發AMQP。amqp-cpp.git內部有完整的Demo。
AMQP開發之前需要了解AMQP協議，可以參考前面幾章對vhost，exchange，que的參數做一個基本了解。然后配合AMQP-cpp進行軟件開發。
開發流程： 1.實現自己的AMQP::ConnectionHandler，ConnectionHandler類似于一個中間組件，將AMQP請求指令轉化為數據流，然后通過Tcp將數據流發送出去。
class CTcpConnectionHandle : public AMQP::ConnectionHandler{public: CTcpConnectionHandle(CTcpLink *plink); virtual ~CTcpConnectionHandle();public: ///> 當AMQP發送數據的時候觸發onData virtual void onData(AMQP::Connection *connection, const char *buffer, size_t size); ///> 當AMQP協議準備好（已經登錄成功）觸發 virtual void onConnected(AMQP::Connection *connection); ///> 這個需要在tcp 斷開的時候手動調用一下 virtual void onClosed(AMQP::Connection *connection); ///> 當發生錯誤的時候，該連接不可再用需要重新建立連接 virtual void onError(AMQP::Connection *connection, const char *message);PRivate: CTcpLink *m_plink;//和當前連接關聯};2.實現TcpLink進行數據流的收發操作，以及數據解析。
class CTcpLink :public jeflib::iocp::ILinkContext{ friend class CTcpConnectionHandle;public: CTcpLink(); ~CTcpLink();public: ///> set usr psw vhost void setAMQP(std::string strusr, std::string strpsw, std::string strvhost); ///> block bool IsReady(); virtual void on_close();//on connection close,主動斷開不會收到通知 ///> for tcp svr call back virtual void on_accepted(jeflib::iocp::NETHANDLE nethandle, const char *szip, const unsigned short sport){}; ///> tcp recv data virtual void on_recv(const char *pdata, int ndatasize); ///> client connect ok virtual void on_connect_ok(jeflib::iocp::NETHANDLE nethandle); ///> client connect error virtual void on_connect_err(jeflib::iocp::NETHANDLE nethandle, bool bactive/*是否為主本端動關閉*/); ///> for iocp send data call back to resend virtual void on_send_ok(const char *pdata, int ndatasize){} virtual void on_send_err(const char *pdata, int ndatasize){} virtual CTcpLink* new_context(){ return new CTcpLink; } bool send(const char *data, int size); void parse(); Operator AMQP::Connection&(){ return *m_pConnect;}protected: std::promise<bool> m_bready;//是否準備好 bool m_blink; mutable std::mutex m_lock; std::vector<char> m_recv_buff;//數據接收緩沖區 AMQP::Connection *m_pConnect;//AMQP connect CTcpConnectionHandle *m_phandler; bool m_bpares;private://AMQP 登錄信息 std::string m_strusr; std::string m_strpsw; std::string m_strvhost;};3.AMQP::Connection 這個是將網絡來的數據解析為AMQP協議，并且將數據行為反應到對應的回調函數之中。
void CTcpLink::parse(){ if (m_pConnect == NULL) return; uint64_t use = 0; ///> 不阻塞線程，parse一次只能一個線程調用，不能多個線程 std::unique_lock<std::mutex> guard(m_lock, std::try_to_lock); if (!guard.owns_lock()) return; if (m_bpares) return; m_bpares = true; size_t size = m_recv_buff.size(); while (size - use >= m_pConnect->expected()) { std::vector<char> buff(m_recv_buff.begin() + use, m_recv_buff.begin() + use + m_pConnect->expected()); ///> 解析期間打開鎖，允許接收數據 guard.unlock(); use += m_pConnect->parse(buff.data(), buff.size()); guard.lock(); } m_recv_buff.erase(m_recv_buff.begin(), m_recv_buff.begin() + use); m_bpares = false;}4.連接Rabbit服務器，然后進行AMQP的通信。通信流程
Y-操作成功 連接服務器-》（Y）創建通道=》（Y）啟用ACK=》（Y）聲明exchange=》（Y）聲明隊列=》（Y）bind 隊列=》（Y）開始消費隊列,publish隊列
異常處理: tcp連接異常:可以采取重連或者關閉連接。 rabbit登錄異常:斷開Tcp連接。 通道異常:關閉當前通道，然后重啟一個通道，復制該異常通道的業務。
if(channel ready){ if(declare que) { channel->bind current que； channel->declare next que； } else//聲明隊列失敗 { 從需要聲明的隊列中移除當前錯誤的隊列，因此即使再次嘗試聲明該隊列還是會異常，所以拋棄該隊列。 channel->erase(que); 獲取當前所有需要聲明的隊列 aryque = channel->getqueary(); 重啟通道，并且將需要聲明的隊列讓新通道去做 new channel(aryque ); }}具體AMQP實現請參照上述Demo。
注意事項： 1.隊列的Auto delete 屬性，只有已經發生過consumer操作的時候才會生效。 2.只有觸發AMQP::ConnectionHandler::onConnected才能表明AMQP協議準備完成，包括連接和登錄準備完畢，才能進行AMQP操作。 3.AMQP的通道不是線程安全的，在進行通道操作的時候需要加鎖?；蛘咭粋€線程操作一個通道。 4.AMQP同一個通道的指令處理順序需要保證序列性，因為一個請求或者指令可能存在幾個通信包。例如：publis存在三次send才完成一次publish指令。否則可能導致指令交匯，導致異常。
新聞熱點
疑難解答
