前端每打开一个客户端就会和后台建立一个websocket的长连接,每个连接中都会建立kafka的消息监听。当kafka监听到消息时,会通过每个websocket连接发送的相应的客户端,从而实现数据流的实时显示。
参考:http://blog.sina.com.cn/s/blog_12d84817c0102wvqx.html
开发依赖包:kafka-node-master 和socket.io