实（繁：實）时消费kafka写入redis

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

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

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

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

mq澳门银河tt更适（繁：適）合。

websocket其实[繁体：實]是对浏览器设计的协议。

浏览器链接{读：jiē}mqtt server就是通过websocket。

两个（繁体：個）都是保持tcpip链接。但是mqtt支持的de 功{读：gōng}能更多。比如QoS 0，1，2。Shared Subscription.

介意查看下澳门新葡京mqtt支持的各种功《练：gōng》能。

全世界最好的库就是国产的emqx。

其他mqtt库澳门威尼斯人或者服{fú}务也可以考虑。不过相对都差很多。

还极速赛车/北京赛车有emqx比【bǐ】别的库更适合kubernetes。

emqx各【练娱乐城：gè】种module也比较齐全，比如AuthenticationModule，peformance monitor.