RedisPubSub.h

Go to the documentation of this file.

// -*- C++ -*-

#ifndef REDISPUBSUB_H
#define REDISPUBSUB_H

#include <iostream>
#include <vector>
#include <stdint.h>
#include <string>
#include <cstring>   // std::memcpy

#include "hiredis/hiredis.h"

#include <memory>
using std::string;
using std::vector;


struct RedisContextDeleter
{
  void operator()(redisContext* context) {
    redisFree(context);
  }
};


struct RedisReplyObjectDeleter
{
  void operator()(redisReply* reply) {
    freeReplyObject(reply);
  }
};


class RedisPublisher
{
  string m_host;  
  int32_t m_port; 
  std::shared_ptr<redisContext> m_context; 

public:
  RedisPublisher();

  RedisPublisher(const string& host, int32_t port = 6379);
  ~RedisPublisher();


  int32_t init();


  int32_t publish(const string& name, const char* src_buf, int32_t size);
};


class RedisSubscriber
{
protected:
  string m_host;  
  int32_t m_port; 
  std::shared_ptr<redisContext> m_context; 

public:
  RedisSubscriber();

  RedisSubscriber(const string& host, int32_t port = 6379);
  virtual ~RedisSubscriber();
    

  void setHost(const string& host, int32_t port);

};


class RedisSyncSubscriber : public RedisSubscriber
{

public:
  RedisSyncSubscriber();


  RedisSyncSubscriber(const string& host, int32_t port = 6379);

  virtual ~RedisSyncSubscriber();
  

  int32_t init();


  int32_t subscribe(const string& name);


  int32_t unsubscribe(const string& name);


  int32_t get(string& name, char* target_buf, int32_t& size,
      int32_t timeout = 2000);


  int32_t getChannels(string name, vector<string>& vec);

};

#endif // REDISPUBSUB_H