Hiredis Pub/Sub

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Pub/Sub

변수 선언

redisReply *reply;
char channel[] = "ch01";

Publish

void publish() {
	printf("---------------------------------------------------\n");
	printf("PUBLISH channel message -> Integer reply: the number of clients that received the message.\n");
	// #1 PUBLISH channel message
	reply = redisCommand(c, "PUBLISH %s %s", channel, "Hello Hiredis");
	if (reply == NULL) {
 		printf("redisCommand reply is NULL: %s\n", c->errstr);
		return;
	}
	if (reply->type == REDIS_REPLY_ERROR) {
		printf("Command Error: %s\n", reply->str);
 		freeReplyObject(reply);
		return;
 	} 
	printf("1. PUBLISH %s %s -> %d\n", channel, "Hello Hiredis", reply->integer);
 	freeReplyObject(reply);
}

redisGetReply()를 사용한다.

void subscribe() {
	printf("---------------------------------------------------\n");
	printf("SUBSCRIBE channel [channel ...] -> Array reply.\n");
	printf("\t메시지를 가져오는데 redisGetReply()를 사용한다. \n");
	printf("\t메시지가 'exit'면 종료하게 했다.\n");
	int i;
	// #1 SUBSCRIBE channel 
	reply = redisCommand(c, "SUBSCRIBE %s", channel);
	if (reply == NULL) {
 		printf("redisCommand reply is NULL: %s\n", c->errstr);
		return;
	}
	if (reply->type == REDIS_REPLY_ERROR) {
		printf("Command Error: %s\n", reply->str);
 		freeReplyObject(reply);
		return;
 	} 
 	freeReplyObject(reply);
	while(redisGetReply(c,(void**) &reply) == REDIS_OK) {
		for(i=0;i<reply->elements;i++) {
			printf("%d) %s\n", i, reply->element[i]->str);
			if (i==2 && !strcmp(reply->element[i]->str,"exit")) {
				return;
			}
		}
		freeReplyObject(reply);
	}
}

<< Hashes	Pub/Sub	Common Keys >>

Email 답글이 올라오면 이메일로 알려드리겠습니다.

Hiredis Pub/Sub

Pub/Sub

Publish

Subscribe