实时消费kafka写入{pinyin：rù}redis

大数据的实时统计有什么储存方案推荐？可以用spark streaming对kafka输入流进行实时统计处理后输出到ES或者mysql物联网实时数据应用，websocket和mqtt哪个比较适合？笔者完整设计过mqtt构架的云服务

大数据的实时统计有什么储存方案推荐？

可以用spark streaming对kafka输入流进行实时统计处理后输出到ES或者mysql

笔者完整设计过mqtt构架的云服务。可以提供一些经验。

mqtt更适合【hé】。

websocket其实是对浏览器《pinyin：qì》设计的协议。

浏览器链接mqtt server就是通过websocket。

两个都是保持tcpip链接。但【dàn】是mqtt支zhī 持的《pinyin：de》功能更多。比如QoS 0，1，2。Shared Subscription.

直播吧介意查{pinyin：chá}看下mqtt支持的各种功能。

澳门金沙全世shì 界最好的库就是国产的emqx。

其他澳门永利mqtt库(繁：庫)或者服务也可以考虑。不过相对都差很多。

亚博体育还有emqx比（pinyin：bǐ）别的库更适合kubernetes。

澳门新葡京emqx各种module也比较齐全，比bǐ 如AuthenticationModule，peformance monitor.