Как публиковать асинхронно с HiRedis

Question

Как публиковать асинхронно с HiRedis

Я использую HiRedis с программой на языке c / c ++ и написал несколько тестов, чтобы убедиться, что подписки работают (мое решение основано на этот комментарий).

Тем не менее, в настоящее время я могу публиковать только вручную, набрав что-то вроде publish foo "abcd" в redis-cli Терминал. Это работает согласно связанному комментарию, но я хотел бы опубликовать от моя программа на с ++. Как я могу это сделать?

Я попробовал эту команду:

redisAsyncCommand(c, SubCallback, (char*)"command", "publish foo \"abcd\"");

Но это приводит к этой ошибке во время выполнения:

Ошибка: только ERR (P) ПОДПИСАТЬСЯ / (P) ОТМЕНИТЬ / ВЫЙТИ разрешено в этом контексте

Как я могу публиковать данные из HiRedis?

0

c++hiredis redis

Решение

Другие решения

После того как контекст подключения подписан, его нельзя использовать для ПУБЛИКАЦИИ. Вы должны создать новое соединение.

0

Источник

Accepted Answer

от https://github.com/redis/hiredis в hiredis/examples/example-libevent.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>

#include <hiredis.h>
#include <async.h>
#include <adapters/libevent.h>

void getCallback(redisAsyncContext *c, void *r, void *privdata) {
redisReply *reply = r;
if (reply == NULL) return;
printf("argv[%s]: %s\n", (char*)privdata, reply->str);

/* Disconnect after receiving the reply to GET */
redisAsyncDisconnect(c);
}

void connectCallback(const redisAsyncContext *c, int status) {
if (status != REDIS_OK) {
printf("Error: %s\n", c->errstr);
return;
}
printf("Connected...\n");
}

void disconnectCallback(const redisAsyncContext *c, int status) {
if (status != REDIS_OK) {
printf("Error: %s\n", c->errstr);
return;
}
printf("Disconnected...\n");
}

int main (int argc, char **argv) {
signal(SIGPIPE, SIG_IGN);
struct event_base *base = event_base_new();

redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379);
if (c->err) {
/* Let *c leak for now... */
printf("Error: %s\n", c->errstr);
return 1;
}

redisLibeventAttach(c,base);
redisAsyncSetConnectCallback(c,connectCallback);
redisAsyncSetDisconnectCallback(c,disconnectCallback);
redisAsyncCommand(c, NULL, NULL, "SET key %b", argv[argc-1], strlen(argv[argc-1]));
redisAsyncCommand(c, getCallback, (char*)"end-1", "GET key");
event_base_dispatch(base);
return 0;
}

0