[java] Redis pub/sub을 이용한 IPC

 

Java와 C언어의 프로세스간 통신을 Redis Pub / Sub 기능을 활용하여 통신 해 보도록 한다

(잘 되겠지만 그냥 해봄)

 

Java는 jedis-2.7.2.jar 를 사용하고, Window 환경에서 테스트하였고

C 프로그램은 hiredis 를 사용하고, Centos 환경에서 테스트한다.

(Windows 환경에서 컴파일 및 실행 가능하다고 한다 https://yoonbh2714.blogspot.kr/2015/10/hiredis-for-windows.html)

 

 

내 PC(Java Process) <--------------->원격지 서버 1( Redis )<--------------->원격지 서버2(C Process)

 

 

Java 프로그램

 

jedis = new Jedis("192.168.10.10", 6379); JedisPubSub pubsub= new JedisPubSub() { public void onMessage(String channel, String message) { System.out.println("channel : " + channel); System.out.println("message : " + message); } public void onSubscribe(String channel, int subscribedChannels) { System.out.println("channel : " + channel); System.out.println("subscribedChannels : " + subscribedChannels); } public void onUnsubscribe(String channel, int subscribedChannels) { System.out.println("channel : " + channel); System.out.println("subscribedChannels : " + subscribedChannels); } public void onPSubscribe(String pattern, int subscribedChannels) { System.out.println("pattern : " + pattern); System.out.println("subscribedChannels : " + subscribedChannels); } public void onPUnsubscribe(String pattern, int subscribedChannels) { System.out.println("pattern : " + pattern); System.out.println("subscribedChannels : " + subscribedChannels); } public void onPMessage(String pattern, String channel, String message) { System.out.println("pattern : " + pattern); System.out.println("channel : " + channel); System.out.println("message : " + message); } }; jedis.psubscribe(pubsub, "channel");

 

참고로 subscribe 관련 함수는 blocking method임으로 스레드로 처리하던지

 

publish 할 때는 아래 함수를 사용한다

jedis.publish("channel", "message");

 

 

C 프로그램

 

 

#include "stdio.h" #include "stdlib.h" #include "string.h" #include "signal.h" #include "hiredis-0.13.3/hiredis.h" #include "hiredis-0.13.3/async.h" #include "hiredis-0.13.3/adapters/libevent.h" void onMessage(redisAsyncContext *c, void *reply, void *privdata) { redisReply *r = reply; if (reply == NULL) return; if (r->type == REDIS_REPLY_ARRAY) { int j = 0; for (j = 0; j < r->elements; j++) { printf("%u) %s\n", j, r->element[j]->str); } } } int main(int argc, char *argv[]) { signal(SIGPIPE, SIG_IGN); struct event_base *base = event_base_new(); redisAsyncContext *c = redisAsyncConnect("192.168.10.10", 6379); if (c->err) { //printf("error : %s\n", c->errstr); return 1; } redisLibeventAttach(c, base); redisAsyncCommand(c, onMessage, NULL, "PSUBSCRIBE 1.2.3.4.*"); event_base_dispatch(base); return 0; }

 

 

위 소스와 같이 퍼블리쉬 또한  redisAsyncCommand 함수를 통해 가능하다

redisAsyncCommand(c, onMessage, NULL, "publish 1.2.3.4.* test");

 

컴파일을 아래와 같이...

 

gcc main.c -c -levent -lhiredis gcc main.o /root/redis-3.0.2/deps/hiredis/libhiredis.a -o main -levent

 

테스트는 각 프로그램에서 publish 하면 등록한 채널에 따라 메시지를 출력 할 수 있는지를 확인

 

간단하게 끗..