基于Kafka的跨节点消息队列容灾实践应用

基于高并发、稳定性、生态良好考虑,中移互联网有限公司部门项目引入成熟工具实现Kafka消息的异地节点同步,并采用一种基于滑动时间窗口的同步延迟检测算法实现Kafka消息同步进度的检测,从而很好地实现跨节点同步过程中,消息队列同步延迟的检测。

一种用于Java消息中间件的自适应框架

一般而言,在消息中间件与系统之间表现出较为明显的矛盾,如果通过人工配置的形式进行矛盾处理,则会造成一定的配置风险,难以充分适应系统的动态化发展。为此,笔者将提出一种以模糊控制理论为依据的自适应框架模型,希望可以在提升消息中间件性能和维持消息中间件运行稳定性之间建立良好的平衡机制,以推动系统的发展。