add message produce/subscribe protocol
Merge pull request #56 from ErikFang/realtime

add message produce/subscribe protocol