redis(サブスクリプションパブリケーション)に基づくpythonとjavaプロセス間の通信

主な構造は、pythonプロセスがメッセージを発行し、javaプロセスがメッセージを購読することです.
依存環境:
python:   pip install redis
java:  jedis
1.python側:
PubSub.py

import redis

class PubSub(object):
    def __init__(self, host, port, db):
        self.__conn = redis.Redis(host, port, db)

    def publish(self, channel, msg):
        self.__conn.publish(channel, msg)
        return True

    def subscribe(self, channel):
        pub = self.__conn.pubsub()
        pub.subscribe(channel)
        pub.parse_response()
        return pub

sub.py

from PubSub import PubSub

obj = PubSub('localhost', 6379, 1)
redis_sub = obj.subscribe('cord')

while True:
    msg = redis_sub.parse_response()
    msg = msg[2].decode()
    print(msg)

2.java側
RedisPub.java

import redis.clients.jedis.Jedis;
import java.util.Date;
public class RedisPub {
    private static Jedis jedis = new Jedis("localhost",6379);
    private static final String channel = "cord";
    public static void main(String[] args){ String message = new Date().toString(); jedis.publish(channel, message); } }

参照リンク:
http://www.cnblogs.com/melonjiang/p/5342383.html