实时消[pinyin：xiāo]费kafka写入redis

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

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

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

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

mqtt更适合(繁体：閤)。

websock澳门银河et其实是[pinyin：shì]对浏览器设计的协议。

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

两个都{dōu}是保持tcpip链接。但[读：dàn]是mqtt支[拼音：zhī]持的功能更多。比如QoS 0，1，2。Shared Subscription.

介{pinyi开云体育n：jiè}意查看下mqtt支持的各种功能。

全世界澳门威尼斯人最好（拼音：hǎo）的库就是国产的emqx。

其他mqtt库或者服务也可以考虑。不过相对都差很多(读：duō)。

还（繁体：還）澳门伦敦人有emqx比别的库更适合kubernetes。

emqx澳门博彩各种module也比较齐全，比如《rú》AuthenticationModule，peformance monitor.