基于消息驱动Bean的异步通信模型设计

异步通信是一种松耦合的分布式通信模式,允许应用程序以发送方和接受方相互独立的形式,通过交换消息进行通信.消息驱动Bean作为处理异步消息的EJB组件,因其支持异步非阻塞的消息传递机制,在基于EJB的应用系统中日渐得到应用.提出了一种基于消息驱动Bean的异步通信模型.该模型使用MDB实现消息的异步消费,解决了EJB远程方法调用开销大等问题,降低了应用程序和EJB组件之间的依赖性,从而有效地提高了异步通信的性能和可靠性.     

Windows系统环境下的消息传递机制分析

在Windows系统中进行的程序编写是事件驱动,通过消息进行传递。因此,只有深入了解消息传递机制才能够完成Windows系统中程序编写,笔者根据自己对消息传递以及相关资料来分析消息传递机制。让大家大致知道消息的传递方向,再解释消息传递机制。消息传递机制主要包括的内容是消息的定义、消息的发送、消息和接收、消息的处理以及消息的处理中与之相关的窗口函数。     

分布式实时操作系统消息机制的设计与实现

随着数字信号处理技术的迅猛发展,针对并行数字信号处理(DSP)应用自主开发了一个满足用户需要的高性能分布式实时操作系统--腾飞分布式实时操作系统(TF-RTOS).消息机制用于线程间的通信,是操作系统中的重要部分.在开发TF-RTOS过程中,从消息命令包、消息队列、消息传递过程和消息原语这4个方面设计并实现了一种直接消息传递的消息机制,该消息机制具有简化线程间通信、增强系统功能、提高系统性能的特点.     

微内核结构的测控系统软件

测控系统软件是测控系统重要组成部分,直接影响着测控系统的运行.提出了一种基于微内核结构的测控系统软件设计方法,该方法以消息数据处理为中心,通过统一的消息接口将测控任务插件化,利用受控的消息传递机制实现测控软件各个功能模块间的交互,并在微内核单元管理下进行HPFS-HRRN的测控任务调度;基于虚拟仪器技术,设计和实现了水...     

GIS命令消息在实时协同GIS系统中的应用研究

为了有效降低网络传输量以满足GIS实时协作的要求,针对地理空间数据量大的特点,通过对协作者的GIS操作进行抽象与封装,提出利用消息传递机制构建实时协同GIS系统的解决方案。首先分析了基于消息传递的实时协同GIS的实现机制,给出了系统体系结构;重点讨论了GIS操作的划分粒度与基于XML的GIS命令消息的编码规范;最后对GIS命令消息库进行了介绍。     

基于SOAP的消息传递安全性技术研究

Web服务安全性模型引入了一个由各个相互联系的规范组成的集合,这些规范描述了把安全性功能程序放到Web服务环境中的方法,从而使体系结构被设计成允许对规范进行混合匹配在分布式环境中.虽然SOAP的规范不涉及安全问题,但是允许安全问题作为扩展而被处理;WS-Security描述通过消息完整性、消息机密性和单独消息认证提供对SOAP消息传递的增强,这些机制可以用于提供多种安全性模型和加密技术.     

一种基于分布式结构的雷达系统仿真引擎机制研究*

随着系统规模的不断扩大,系统复杂度大大提高,采用单一的仿真程序已不能满足大规模复杂系统仿真的需求,采用分布式结构进行雷达系统仿真逐渐成为一种解决复杂系统仿真的主要方法。仿真引擎机制的研究是雷达仿真系统设计的关键,有利于深化和提升雷达仿真的效率。阐述了雷达仿真系统模型,采用分布式结构,提出了基于消息服务中心MSC和运行监控中心SC两层控制结构的仿真引擎机制,将用户接口服务与消息传递服务分离开来,增强了雷达仿真软件的灵活性和易操作性。在这种机制下,进一步提出了消息传递算法MPA并进行了系统性能测试和验证,仿真实验结果表明,MPA算法可以快速、可靠地实现雷达系统内部各执程体间的互连互通,准确地完成雷达仿真过程的控制与监视。     

基于分布式消息队列的企业级全文检索模型研究

针对传统集中式全文检索系统的查询性能不足的问题,提出基于分布式消息队列构建的企业级分布式全文检索模型。该模型充分利用分布式消息队列将查询集群中的各个节点去耦合,以异步方式对查询请求进行处理,提高整个集群的查询吞吐量。从该模型的总体结构、分布式全文检索算法过程设计、算法验证三个方面进行了阐述,验证了该模型的可行性,并且验证结果表明具有良好的查询性能。     

PVM并行程序向GAMMA迁移的方法

首先分析了PVM消息传递的通信机制以及影响其通信效率的原因，然后介绍了一种基于主动消息技术的通信系统GAMMA。在此基础上提出了将PVM程序迁移到GAMMA的方法。     

智能神经网络程序设计语言NIPL的分布实现

论文介绍了智能神经网络程序设计语言NIPL。设计并实现了消息传递系统及远程方法调用设施。结合代理对象机制实现了基于消息传递的分布式智能神经元模型,从而使开发大规模的分布式智能神经网络应用系统变为可能。     

基于消息传递的构件组装模型

利用构件组装分布式系统是软件开发的流行趋势,但由于构件之间规范不一致,相互联系和相互依赖,降低了构件的复用程度,限制了生成目标系统的灵活性.消息传递是应用程序和软件构件之间进行通信的一种方式,基于消息传递的构件组装模型采用了XML技术,通过连接子和消息总线进行消息传递,实现构件之间的交互,使构件在组装时对外呈现出一致的视图.     

Active optimistic and distributed message logging for message‐passing applications

Message logging is an attractive solution to provide fault tolerance for message‐passing applications because it is more scalable than coordinated checkpointing. Sender‐based message logging is a well‐known optimization that allows the saving of message payload in the sender memory. Thus, only message reception events have to be logged reliably by using an event logger. This paper proposes solutions to further improve message logging protocol scalability. In existing works on message logging, the event logger has always been considered as a centralized process. We propose a distributed event logger that takes advantage of multi‐core processors that are to be executed in parallel with application processes, leveraging the volatile memory of the nodes to save events reliably. We also propose the combination of our distributed event logger and O2P, an active optimistic message logging protocol using a gossip‐based protocol to disseminate information on new stable events. Our distributed event logger and O2P are implemented in the Open MPI library. Our results show the following: (i) distributed event logging improves message logging protocol scalability and (ii) using O2P with a distributed event logger provides an efficient and scalable fault‐tolerant solution for message‐passing applications. Copyright © 2011 John Wiley & Sons, Ltd.     

基于一般逻辑拓扑结构的广播通信研究和实现

在分布存储并行计算消息传递系统中,许多广播通信中的消息传递路径是对程序员透明的,程序员不能改变消息传递路径,但应用程序运行时的情况很复杂。程序员根据计算环境及应用程序特征选择消息传递路径,有助于提高广播通信的效能。在通信过程中,消息标志是用来区分消息的,以便接受进程能正确接受消息。然后,消息标志易导致应用程序出错,而且消息标志增加编制程序的复杂性。文中首先给出了逻辑拓扑结构的形式定义及基本性质,提     

主动消息与MPI

本文详细分析了消息传递的开销问题,并对可降低开销的一种机制：主动消息进行了深入探计,在此基础上给出了将主动消息引入ＭＰ少基于主动消息实现ＭＰＩ的原型。     

嵌入式实时内核的串口通信模块设计

针对51系列单片机与智能模块的串口通信,研究嵌入式实时内核的串口通信方案。讨论了实时操作系统下消息队列功能正确配置方法,利用系统中断和内核提供的消息队列功能,实现了串口通信和数据存储,对通信协议、消息队列功能配置、驱动程序任务分解、数据存储方式作了重点论述,为设计使用智能模块与单片机串口通信的控制系统应用领域提供了良好的升级解决方案。     

Customized Message Passing

Replacing traditional operating systems communication implementations with customized implementations increases the performance of parallel and distributed applications. This paper describes the design and implementation of customizable message passing systems. The customized message passing systems are generated using application-specific information such as the profile of an application's communication pattern. FFT, Simplex, and Cholesky are used as example parallel applications. The message passing system has also been customized for different types of distributed system services including a distributed scheduling facility. The customized message passing system likewise improves the performance of these facilities and enhances their scalability. As a practical concern, as there are a large number of possible optimizations, object-oriented frameworks are employed to organize the implementations and to facilitate the choice of optimizations.     

Nonblocking collectives for scalable Java communications

This paper presents a Java implementation of the recently published MPI 3.0 nonblocking message passing collectives in order to analyze and assess the feasibility of taking advantage of these operations in shared memory systems using Java. Nonblocking collectives aim to exploit the overlapping between computation and communication for collective operations to increase scalability of message passing codes, as it has been carried out for nonblocking point‐to‐point primitives. This scalability has become crucial not only for clusters but also for shared memory systems because of the current trend of increasing the number of cores per chip, which is leading to the generalization of multi‐core and many‐core processors. Message passing libraries based on remote direct memory access, thread‐based progression, or implementing pure multi‐threading shared memory support could potentially benefit from the lack of imposed synchronization by nonblocking collectives. But, although the distributed memory scenario has been well studied, the shared memory one has not been tackled yet. Hence, nonblocking collectives support has been included in FastMPJ, a Message Passing in Java (MPJ) implementation, and evaluated on a representative shared memory system, obtaining significant improvements because of overlapping and lack of implicit synchronization, and with barely any overhead imposed over common blocking operations. Copyright © 2014 John Wiley & Sons, Ltd.     

消息传递方法及其在信息融合中的应用

作为针对复杂问题的确定性推断方法,近年来消息传递方法及其在信息融合领域中的应用备受关注.消息传递为大规模问题提供了基于贝叶斯的、统一的、可扩展的、效率高的推断框架,消息传递方法在概率图模型的节点之间传递消息.首先,对概率图模型进行简要介绍,总结消息传递基础理论方法和近似拓展方法的基本原理、特点以及研究进展;然后,针对信息融合领域中的3类重难点问题:状态估计与平滑、目标跟踪和多源异构数据融合,分别综述消息传递在信息融合中的最新研究进展,并总结不同消息传递方法的适用场景;最后,讨论消息传递方法在信息融合领域未来可能的研究方向.     

OpenMP extensions for master–slave message passing computing

This paper presents a directive-based programming environment for master–slave message passing applications that enables the efficient execution of the same code on both shared and distributed memory multiprocessors. The environment exports an extension of the OpenMP workqueuing model, supports multiple levels of task parallelism and more than one master and provides transparent load balancing with a combination of static and dynamic scheduling of tasks. In addition, it operates exclusively through the available hardware on shared-memory machines and exploits MPI for explicit communication on clusters. Experimental results on a Linux-cluster demonstrate the successful combination of ease of programming with the performance of message passing.