基于发布订阅模式的中间件设计与实现

被引量 : 0次 | 上传用户:GYQ865739853
下载到本地 , 更方便阅读
声明 : 本文档内容版权归属内容提供方 , 如果您对本文有版权争议 , 可与客服联系进行内容授权或下架
论文部分内容阅读
随着互联网技术的飞速发展,云计算成为主流,后台演变为越来越复杂的分布式系统,并且应用范围和规模不断的扩大。为了让这些数量庞大的机器通信和协作来完成现代社会的计算任务,迫切需要一种异步的,多点通信的基础架构,满足互联网大型应用系统松散通信的需求,从而为构建大规模分布式应用系统打下良好的基础。发布/订阅的通信方式很好的解决了这种问题,它使得消息的生产者和消费者在时间,空间上充分地解耦,具有异步,松散耦合和多对多通信的特点。本文在此背景下,对发布/订阅系统做了深入研究,设计了一个发布/订阅模式的中间件,并且对核心模块事件过滤器,设计了高效的匹配算法,采用多级索引,位运算,对订阅做聚类,减少了多余的匹配,有效地提高了系统的吞吐量。整个系统由三部分组成,发布者,订阅者,发布订阅中间件。发布者即信息的生产者,把产生的数据源源不断地输入到系统当中。信息的订阅者则向中间件定义一个订阅条件,表示对系统中的哪些信息感兴趣。这样的话,信息消费者便能够通过中间件,及时,可靠地得到发布过的感兴趣消息。中间件是整个系统的核心部分,有发布代理服务器,订阅代理服务器,事件代理服务器。事件代理服务器负责整个事件的过滤和路由,将事件表示成一系列谓词组成的集合,通过匹配合适的谓词,选择性的分发来自发布者的数据,通知感兴趣的订阅者,达到了基于内容的匹配目标,区别于传统的基于主题的匹配方式,给系统带来了很大的灵活性。发布代理服务器负责接受生产者的事件消息,过滤掉垃圾内容,发送给发布订阅的中间件,做匹配和路由。订阅代理服务器,则接受订阅者的订阅信息,发送给事件代理器,发布订阅模式的中间件则对订阅条件做处理,便于更快的做事件匹配。事件过滤器是中间件的最核心模块,效率高低关乎着整个系统的响应速度。本文通过事先做预处理,把对兴趣具有一定共性的订阅放到一组,并且提取其中的谓词做多级索引,按照属性类别如类型,名字,操作符分为三级,对等号操作符构造哈希表,对于大于,小于符号按照约束关系做排序,所以对于小于号索引的某个谓词符合要求,则该值后面的谓词也符合要求,可以大幅度的减少匹配次数。并且构造订阅树,寻找最小谓词,剔除不满足条件的匹配,进一步提高了系统的效率。总之,本文在分析和研究了以往发布订阅系统的基础上,取长补短,设计了一个发布订阅模式的中间件框架,并且实现了一个发布订阅系统的原型PSSDJ。在该原型的基础上对使用不同算法的过滤器做了对比和分析,取得了一定的成果。
其他文献
目的:对妊娠合并高血压患者中的人性化护理干预进行探讨,并分析其效果。方法:选取2011年5月至2014年6月间在我院进行诊断和分娩的妊娠合并高血压患者共50例为研究对象,并且采
危险天气是造成飞行事故的重要原因,具有空间尺度小、持续时间短等特性的低空风切变是其中危害极大的一种。由于低空风切变持续时间短,在遭遇风切变时,飞行员进行决策的反应
我国中低温余热资源总量十分丰富,尤其是在工业领域,如果能加以充分利用,将为社会节约大量资源。有机朗肯循环(Organic Rankine Cycle,简称ORC)发电系统具有结构简单、效率高
<正>据江苏省市场监管局网站消息,2019年2季度,江苏省市场监管局委托江苏省纺织产品质量监督检验研究院、南京市产品质量监督检验院、苏州市产品质量监督检验院和大加利(太仓
长城不仅是中华民族标志性的物质文化遗产,也是在特定军事管理制度下具有高度整体性及层级性的军事防御体系。以往关于“明长城蓟镇”的研究和保护多关注于某一地段或某种防
"对写话有兴趣,留心周围事物,写自己想说的话,写想象中的事物。"这是课程标准对第一学段学生的写话要求。本文通过让孩子养成倾听的习惯,学会倾听的方法,感受倾听的乐趣;教会
我国工业能源消耗占全国总能源消耗的70%以上,其中至少50%的工业耗能以各种形式的余热被直接废弃,有机朗肯循环(Organic Rankine Cycle)系统是一种可利用低温热源发电的新技
目的探究口腔3D打印模型与传统石膏模型的精确性。方法选择常规正畸治疗后的石膏模型40副,随机分为两组,每组20个,两组模型一般资料比较差异无统计学意义(P>0.05),具有可比性
食品是人类生存和发展的基本需求,也是重要的物质基础。近年来我国食品安全问题却层出不穷,从瘦肉精到陈化粮,从毒奶粉到地沟油,食品安全问题频频发生,屡禁不止。如今,国内民
随着我国福利制度的改革和热能计量的规范化 ,对热能的准确计量成为一个比较关键的环节。文中介绍了热能表的组成和工作原理 ,给出了一种基于PIC16C64单片机的热能表设计方案