为了满足业务异构语言、高峰限流、解耦的需求上，在第三方开源MQ基础上进行二次封装，实现分布式异步 消息平台对实时消息和延迟消息进行分发。系统由三大核心构成: 生产者服务、消费者服务、注册中心。 工作内容: 完成对的开发任务和参与部分架构设计 对生产环境存在的性能问题如CPU和内存异常诊断并优化JVM参数和代码 协助服务迁移部署到K8S集群 对上下游的数据背压问题进行协同处理增加类Nagle算法提高消费效率 系统出现的BUG定位和修复 进行数据埋点监控告警通知 工作成果 支持多实例且不限定消息中间件选型稳定同时支持Pulsar和Kafka 稳定支持亿级流量（2.4亿） 极简化接入明显提升业务开发效率 可横向伸缩扩容并支持不同业务进行动态资源隔离 消息中心管理平台 项目描述 对接入消息中心的项目进行可视化管理，如动态开启关闭消费、动态路由、实时限流、消息轨迹和消息回溯重 推等功能方便业务侧内部使用和问题排查。 工作内容: 负责前端界面的开发和设计 开发支持业务对消息平台管理的功能需求如上所述 封装基础SDK和Start提供给业务侧使用

负责并协同内部消息中心平台的开发、接入及输出文档。 根据业务开发者的需求进行功能定制化和方案设计。 日常维护和进行精细化功能完善迭代如监控告警等。