多彩云软件开发项目一：网络消息发送系统简介

网络消息发送系统简介

1、产品详情

简介

可对接多个业务系统和平台，满足气象预报、应急广播、广告宣传、通知提醒等多项业务需求，提高消息发布效率，对合适的对象，在合适的时机用合适的方式发送合适的消息，达成业务目标。

核心功能及优势:

1、消息发布能力方面，已接入日活跃百万级别的智能机顶盒，经过线上长时间验证和优化，消息收发平均延迟低、稳定可靠；

2、消息接入方面，消息系统协议适配性好，支持国家应急广播接口规范、http、webservice等多种协议；

3、权限管理方面，实现了分组织分区域的多租户管理；

4、发布范围方面，通过区域码的适配映射实现了终端对国家区域码的支持和动态更新，以此为基础实现发布范围由县级细化到村级;

5、多媒体支持方面，系统支持文本、图片、视频等多种消息类型；

6、投递策略方面，支持区域广播、定向投递，同时消息支持审核和撤销。

7、统计分析方面，通过大数据技术实时统计终端开机、消息的触达数、阅读数和延迟时间等各项指标, 形成大屏报表；

模块简介

1、消息管理模块: 用于管理消息要发送的对象，主要包括系统管理、消息管理、消息配置模块

2、同步接收模块：主要包含接收第三方系统消息数据、内容校验、心跳检测、数据转换及通过与消息路由服务通信进行消息下发等功能

3、消息路由模块：包含消息通讯模块和消息存储两部分，设计完全与业务无关，仅作为通道使用。消息通讯包括两方面，一方面基于RPC与消息管理服务通信，另一方面，采用mqtt协议与通过emqx服务器与终端进行消息和数据内容的传递。消息路由系统 支持集群模式，负载均衡，可动态扩展。消息存储会将消息数据、设备信息以及终端上报事件数据存入kafka消息队列

4、终端业务模块：终端通过mqtt协议进行消息接收与行为事件数据上报、根据消息中携带的消息样式进行消息展示以及在消息中心对消息进行管理

5、报表模块：大数据平台通过消费kafka消息队列中的消息及终端上报的事件数据，根据需求，对消息相关的指标进行统计，并且以图表的方式进行展现

6、区域码更新模块：通过区域码的适配映射实现了终端对国家区域码的支持和动态更新

技术亮点及特性

1、基于大规模分布式物联网 MQTT 消息服务器EMQX，稳定承载大规模的 MQTT 客户端连接，高效可靠连接海量终端设备，实时处理分发消息与事件流数据，单服务器节点支持 30 万连接。

2、消息发布效率高、时延低，目前系统消息从后台发布到终端接收平均时延低于10秒。

3、采用微服务架构，服务调用使用Dubbo开发框架，各服务支持分布式部署和动态负载、扩容。

4、采用 MQTT 5.0协议，支持消息过期间隔的保留消息，具有更好的伸缩性、安全性和可靠性。

5、支持图片视频消息、跳转链接、定点推送、终端类型推送、演练播发、预约发布、循环发布等策略。

6、集成kafka、spark等大数据技术，基于ClickHouse （MPP架构的列式存储数据库）存储终端开机，消息触达等事件数据，提供实时统计分析查询及大屏报表展示。

2、截图