mirror of
https://gitee.com/acl-dev/acl.git
synced 2024-12-15 17:30:53 +08:00
74 lines
2.2 KiB
C++
74 lines
2.2 KiB
C++
#pragma once
|
||
#include "acl_cpp/acl_cpp_define.hpp"
|
||
#include <vector>
|
||
#include <map>
|
||
#include "acl_cpp/redis/redis_command.hpp"
|
||
|
||
namespace acl
|
||
{
|
||
|
||
class redis_client;
|
||
class redis_result;
|
||
class string;
|
||
|
||
class ACL_CPP_API redis_pubsub : public redis_command
|
||
{
|
||
public:
|
||
redis_pubsub(redis_client* conn = NULL);
|
||
~redis_pubsub();
|
||
|
||
/////////////////////////////////////////////////////////////////////
|
||
|
||
/**
|
||
*
|
||
* @return {int} 成功发送至订阅该频道的订阅者数量
|
||
* -1：表示出错
|
||
* 0：没有订阅者
|
||
* > 0：订阅该频道的订阅者数量
|
||
*/
|
||
int publish(const char* channel, const char* msg, size_t len);
|
||
|
||
int subscribe(const char* first_channel, ...);
|
||
int subscribe(const std::vector<const char*>& channels);
|
||
int subscribe(const std::vector<string>& channels);
|
||
|
||
int unsubscribe(const char* first_channel, ...);
|
||
int unsubscribe(const std::vector<const char*>& channels);
|
||
int unsubscribe(const std::vector<string>& channels);
|
||
|
||
int psubscribe(const char* first_pattern, ...);
|
||
int psubscribe(const std::vector<const char*>& patterns);
|
||
int psubscribe(const std::vector<string>& patterns);
|
||
|
||
int punsubscribe(const char* first_pattern, ...);
|
||
int punsubscribe(const std::vector<const char*>& patterns);
|
||
int punsubscribe(const std::vector<string>& patterns);
|
||
|
||
bool get_message(string& channel, string& msg);
|
||
|
||
int pubsub_channels(std::vector<string>& channels,
|
||
const char* first_pattern, ...);
|
||
int pubsub_channels(const std::vector<const char*>& patterns,
|
||
std::vector<string>& channels);
|
||
int pubsub_channels(const std::vector<string>& patterns,
|
||
std::vector<string>& channels);
|
||
|
||
int pubsub_numsub(std::map<string, int>& out,
|
||
const char* first_channel, ...);
|
||
int pubsub_numsub(const std::vector<const char*>& channels,
|
||
std::map<string, int>& out);
|
||
int pubsub_numsub(const std::vector<string>& channels,
|
||
std::map<string, int>& out);
|
||
|
||
int pubsub_numpat();
|
||
|
||
private:
|
||
int subop(const char* cmd, const std::vector<const char*>& channels);
|
||
int subop(const char* cmd, const std::vector<string>& channels);
|
||
int check_channel(const redis_result* obj, const char* cmd,
|
||
const string& channel);
|
||
int pubsub_numsub(const string& req, std::map<string, int>& out);
|
||
};
|
||
|
||
} // namespace acl
|