#ifndef RABBITMQ_CLIENT_H_
|
#define RABBITMQ_CLIENT_H_
|
|
|
#include <string>
|
#include <vector>
|
#include "amqp_tcp_socket.h"
|
|
using std::string;
|
using std::vector;
|
|
class CRabbitmqClient {
|
public:
|
CRabbitmqClient();
|
~CRabbitmqClient();
|
|
|
int Connect(const string& strHostname, int iPort, const string& strUser, const string& strPasswd);
|
int Disconnect();
|
|
/**
|
* @brief ExchangeDeclare 声明exchange
|
* @param [in] strExchange
|
* @param [in] strType
|
* @return 等于0值代表成功创建exchange，小于0代表错误
|
*/
|
int ExchangeDeclare(const string& strExchange, const string& strType);
|
|
/**
|
* @brief QueueDeclare 声明消息队列
|
* @param [in] strQueueName 消息队列实例
|
* @param
|
* @return 等于0值代表成功创建queue，小于0代表错误
|
*/
|
int QueueDeclare(const string& strQueueName);
|
|
/**
|
* @brief QueueBind 将队列，交换机和绑定规则绑定起来形成一个路由表
|
* @param [in] strQueueName 消息队列
|
* @param [in] strExchange 交换机名称
|
* @param [in] strBindKey 路由名称 “msg.#” “msg.weather.**”
|
* @return 等于0值代表成功绑定，小于0代表错误
|
*/
|
int QueueBind(const string& strQueueName, const string& strExchange, const string& strBindKey);
|
|
/**
|
* @brief QueueUnbind 将队列，交换机和绑定规则绑定解除
|
* @param [in] strQueueName 消息队列
|
* @param [in] strExchange 交换机名称
|
* @param [in] strBindKey 路由名称 “msg.#” “msg.weather.**”
|
* @return 等于0值代表成功绑定，小于0代表错误
|
*/
|
int QueueUnbind(const string& strQueueName, const string& strExchange, const string& strBindKey);
|
|
/**
|
* @brief QueueDelete 删除消息队列。
|
* @param [in] strQueueName 消息队列名称
|
* @param [in] iIfUnused 消息队列是否在用，1 则论是否在用都删除
|
* @return 等于0值代表成功删除queue，小于0代表错误
|
*/
|
int QueueDelete(const string& strQueueName, int iIfUnused);
|
|
/**
|
* @brief Publish 发布消息
|
* @param [in] strMessage 消息实体
|
* @param [in] strExchange 交换器
|
* @param [in] strRoutekey 路由规则
|
* 1.Direct Exchange – 处理路由键。需要将一个队列绑定到交换机上，要求该消息与一个特定的路由键完全匹配。
|
* 2.Fanout Exchange – 不处理路由键。将队列绑定到交换机上。一个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。
|
* 3.Topic Exchange – 将路由键和某模式进行匹配。此时队列需要绑定要一个模式上。符号“#”匹配一个或多个词，符号“*”匹配不多不少一个词。
|
* 因此“audit.#”能够匹配到“audit.irs.corporate”，但是“audit.*” 只会匹配到“audit.irs”
|
* @return 等于0值代表成功发送消息实体，小于0代表发送错误
|
*/
|
int Publish(const string& strMessage, const string& strExchange, const string& strRoutekey);
|
|
/**
|
* @brief consumer 消费消息
|
* @param [in] strQueueName 队列名称
|
* @param [out] message_array 获取的消息实体
|
* @param [int] GetNum 需要取得的消息个数
|
* @param [int] timeout 取得的消息是延迟，若为NULL，表示持续取，无延迟，阻塞状态
|
* @return 等于0值代表成功，小于0代表错误，错误信息从ErrorReturn返回
|
*/
|
int Consumer(const string& strQueueName, vector<string>& message_array, int GetNum = 1, struct timeval* timeout = NULL);
|
|
|
private:
|
CRabbitmqClient(const CRabbitmqClient& rh);
|
void operator=(const CRabbitmqClient& rh);
|
|
int ErrorMsg(amqp_rpc_reply_t x, char const* context);
|
|
|
string m_strHostname; // amqp主机
|
int m_iPort; // amqp端口
|
string m_strUser;
|
string m_strPasswd;
|
int m_iChannel;
|
|
amqp_socket_t* m_pSock;
|
amqp_connection_state_t m_pConn;
|
};
|
|
#endif
|
