消息驱动

摘要： 企事业单位逐步向集团化、集中化迈进,势必面临一系列新的管理问题,但管理的根本是“人治”,因此提出以员工为中心,通过消息连接共建工作、薪酬、福利、学习、消费、生活等多场景服务的数字化助手。此方法探索的目的是希望能为企事业单位信息化建设起到一定的借鉴作用。

摘要： 随着多核处理器的发展和计算需求的不断增长,高性能计算系统规模不断增大.使用模拟器对高性能计算系统进行模拟,对系统设计及优化有着重要的作用,互连网络模拟则是其中不可或缺的一部分.设计实现了一种基于OM Net++的大规模InfiniBand互连网络模拟系统,该系统通过记录的并行程序M PI消息来驱动网络仿真过程,可以模拟互连网络在程序运行过程中的工作状态,并可与消息驱动的高性能计算机模拟系统集成.通过与真实集群中节点间通信时延做对比,验证了模拟精度,并测试了模拟性能.

摘要： 推演引擎是推演系统的核心部件,它为推演系统提供了组件集成、模拟、状态更新等基本功能.在消息系统里将导致系统状态变化的信息抽象为驱动消息,采用科学的消息调度与处理方法有效地解决了系统实时性需求以及组件式开发与集成的问题.采用分布式设计使得软件系统具备模块间低耦合、可伸缩、高性能等特点.文章提出一种消息驱动的分布式方案推演引擎设计.

摘要： 针对融媒体时代对气象服务产品加工个性化、准实时、智能化新诉求,以SOA架构组件式开发思想为指导,归纳气象服务产品加工业务共性,提出一套集成应用WebGIS、并行计算和大数据技术的气象服务产品自动化加工解决方案.利用组件开发和工作流引擎技术,搭建面向服务体系架构的产品加工模型装备框架,对产品加工组件进行模型编排,实现无须编程情况下的产品加工模型快速构建;利用基于分布式架构的加工服务器集群技术,搭建加工服务器集群环境,对产品加工模型服务进行发布和管理,实现产品加工任务的秒级高并发处理;利用基于消息和定时机制的加工任务调度技术,开发了产品加工任务调度器,通过设置消息主题和定时计划策略,实现加工任务参数智能解析和适配应用,统一协调触发各加工模型服务进行自动化作业.智能化气象服务产品自动加工系统自业务化运行以来,在加工效率、美观性和扩充性等方面表现出很好的应用价值.以温度、降水、风速、相对湿度全国实况格点服务产品加工为例进行实验,加工耗时由797 s缩减至14 s,效率提高50倍以上.

摘要： 前言:ERP系统、TC、MES、WMS、QMS等多个系统通过ESB平台进行了异步服务集成,系统之间可以通过消息发布-订阅模式进行消息驱动业务流程。该模式的业务集成可以较好地支撑消息自上游系统向下游系统进行消息传递,形成事件驱动为核心的业务流程。1.基于ESB平台的数据交互问题1.1数据以产定销。上游系统产生数据向下游推送,这种消息推送模式并不是根据下游对数据实际的需求的响应,下游无论是否需要数据都将收到数据,该问题在调研中多次被提到,譬如ERP向MES、WMS、TC等推送全量的物料变更数据,各系统必须先收取数据,经过分析后再决定是否丢弃或本地保存。

摘要： 高质量的气象图形产品是融媒体时代气象信息服务的重要载体.本文综合运用并行计算和大数据等技术,构建消息驱动的气象图形产品加工系统(WeatherStudio),分析了公共气象服务图形产品加工共性问题,探讨了基于消息驱动的产品加工系统的优势,设计了基于消息驱动和定时驱动相融合的气象图形产品加工系统的框架和功能,并以高速公路交通气象灾害风险预警业务为应用实例进行验证,显示出了其较好的应用前景.

摘要： 针对嵌入式系统特点,构建了一种基于嵌入式RTOS的图形显示系统(ERGS)架构,设计了一种基于服务器/客户端的异步回调模型和请求/应答处理机制,结合ERGS特点提出了一种改进的基于消息的发布/订阅模型和相应的路由规则.并在实时操作系统VxWorks实现了ERGS.实验结果表明,在相同的嵌入式平台上,ERGS相对于传统图形显示系统性能有较大提升,特别是启用GPU硬件加速时,ERGS图形系统性能大幅度提升.

摘要： In order to create a good teaching atmosphere and improve the teaching quality and efficiency, the process control system based on LAN is studied. Some key technologies of software are introduced, and the theory and technology of process control software based on LAN are studied in this paper. Through the use of MFC development technology, Windows message-driven technology, ADO and socket communication technology, the C/S system architecture mode is adopted, and the process control system based on local area network is realized.%为了营造良好的机房教学氛围，提高教学质量与效率，研究了基于局域网的进程控制系统。介绍了软件的一些关键技术，并对基于局域网的进程控制软件的理论和技术进行了深入研究。通过运用MFC开发技术，Windows消息驱动技术、ADO和套接字通信技术，采用C/S模式的系统体系结构，实现了满足机房需求的基于局域网的进程控制。

摘要： A new method was proposed for workflow design based on rule base and message driven mechanism to solve the problem of dynamic and complex business process in quality inspection agencies. The core of the model is three engines and three databases: the workflow engine, rule engine, message driven engine and the corresponding workflow database, rule database, message database. Routing rules of each node, rules for obtaining the next participant and message types were stored in the rule base. According to the message base, different application module was called. Verified by an example, the model has dynamic adaptability, and loose coupling characteristics. Therefore, the model can solve the problem of dynamic and complex business process.%为了解决质量检测机构中动态复杂多变的业务流程问题，用基于规则库与消息驱动机制来设计工作流。该模型的核心是三个引擎和三个库：工作流引擎、规则库引擎、消息驱动引擎以及对应的流程库、规则库、消息库。将流程中的各个节点路由规则、获取下一步参与者的规则以及消息类型都存储在规则库中，并结合消息库来调用不同的应用模块。通过一个实例来说明设计的过程，并验证该模型具有与业务松散耦合性、动态适应性等特点，能很好地解决动态复杂多变的业务流程问题。

摘要： 计算密集型应用中存在大量的并行性,如何优化并行处理任务,充分利用多核处理器的并行资源是当前多核编程领域亟待解决的重要问题.针对此问题,文中提出编译器辅助消息驱动的动态调度模型来优化任务调度;设计出新的编程模型DFBrook,以便更好地支持数据级和任务级的并行;采用编译器辅助的方式,由编译器产生将在运行时创建数据流图的代码;调度器对数据流图进行分析和解除任务依赖,并将任务分发到各处理核,处理核执行完任务后提供反馈信息给主控核进行调度决策.实验结果表明,调度模型具有较好的扩展性,并保持了较高的负载均衡效率和较低的通信开销.

摘要： 提出了基于消息驱动的通信机制,设计了检测器与管理器以及通讯器与通讯器间的通信模式和算法.分为3个层次实现通信协议,给出了常用消息的定义,并详细设计了通信流程.通过利用doorknob攻击进行测试与实验分析,协作实体可以很好地检测出分布式复杂攻击.

摘要： 为了优化组态软件中的编程,本文引入消息驱动机制并通过组态软件现有的开发环境或使用ActiveX控件作为接口的方法来实现,简化了脚本的编写,并使脚本的调试更方便.

摘要： 在空间信息共享平台中，元数据的一个重要运用是数据查询。传统的信息共享大都只调动中心结点检索元数据，检索效率不高。本文提出一种通过调动信息共享平台中所有结点参与元数据检索来提高检索效率的方法，即通过结点元教据目录服务同步机制来同步更新平台中所有结点的元数据，使得每个结点都有其他结点的元数据备份。该同步机制采用消息驱动与远程调用Web服务的方式实现。

摘要： 本文详细分析了B08FDP项目对探测数据的传输技术、数据监控与分发机制、组网雷达时间同步观测与基数据实时传输、数据格式等方面的需求。在此基础上,根据短时临近预报的原理及技术特点,建立了北京奥运短时临近预报数据快速收集处理系统并已投入业务运行。该系统实现了组网雷达时间同步观测和基数据实时传输、基于消息驱动的数据实时监控和分发等功能,很好地满足了北京2008年奥运FDP项目对数据预处理业务需求。

摘要： 本文针对装备维修训练的实际需要,提出了一个基于Agent的装备虚拟维修训练系统模型,讨论了各组成模块的功能.设计了一种基于消息驱动的Agent结构模型,研究了Agent交互消息表示格式,提出了一种基于XML文档的消息表示方法,给出了系统Agent的面向对象实现技术.文中所讨论的模型及实现思想已应用在某型导弹装备维修训练系统中.

摘要： 在基地JMS(Java Message Service)的通信中,JMS中间件通过缓存通信内容,分离通信参与者,从底层设施上支持异步的通信模式.目前J2EE体系已将JMS作为一项标准服务纳入,同时提出消息驱动的EJB作为JMS消息的消费者,为基于J2EE的应用提供了异步通信的能力.如何提供对JMS和消息驱动EJB的支持已成为J2EE应用服务器开发者需要关注的内容.本文介绍了在J2EE应用服务器PKUAS中JMS消息服务和消息驱动容器的设计和实现.

摘要： 协同设计中的实时通信性能是衡量该协同设计系统性能的重要指标,实时通信系统所提供的网络环境能否及时的将各设计终端的设计操作反映在服务器和其他的设计端直接决定了该协同系统协同性能的高低.在对现有的实时通信系统深入研究得基础上,给出了一个基于HOOPS的三维协同设计系统中的实时通信系统的实现框架、机制和具体的方法.

摘要： 协同设计中的实时通信性能是衡量该协同设计系统性能的重要指标,实时通信系统所提供的网络环境能否及时的将各设计终端的设计操作反映在服务器和其他的设计端直接决定了该协同系统协同性能的高低.在对现有的实时通信系统深入研究得基础上,给出了一个基于HOOPS的三维协同设计系统中的实时通信系统的实现框架、机制和具体的方法.

摘要： 协同设计中的实时通信性能是衡量该协同设计系统性能的重要指标,实时通信系统所提供的网络环境能否及时的将各设计终端的设计操作反映在服务器和其他的设计端直接决定了该协同系统协同性能的高低.在对现有的实时通信系统深入研究得基础上,给出了一个基于HOOPS的三维协同设计系统中的实时通信系统的实现框架、机制和具体的方法.

摘要： 协同设计中的实时通信性能是衡量该协同设计系统性能的重要指标,实时通信系统所提供的网络环境能否及时的将各设计终端的设计操作反映在服务器和其他的设计端直接决定了该协同系统协同性能的高低.在对现有的实时通信系统深入研究得基础上,给出了一个基于HOOPS的三维协同设计系统中的实时通信系统的实现框架、机制和具体的方法.

摘要： 本发明提供了一种驱动层消息处理方法、交互模块及驱动装置，应用于驱动层的与上层应用交互的交互模块中，预先在所述交互模块中创建目标窗口类，还包括：通过所述目标窗口类接收底层动态库发来的至少一个目标消息；通过所述目标窗口类生成每个所述目标消息对应的目标事件；通过所述目标窗口类调用所述交互模块的自身类，将每个所述目标事件发送给所述上层应用。本发明能够提高驱动层的执行效率。

摘要： 为了缩短用于将多媒体消息从任意的发送方传输到任意的接收方的时间，并且为了由此在总体上降低业务“Multimedia MessageService(MMS)”的成本，建议：一个多媒体消息业务中心(MMNDZ)例如已接收到由发送电信设备(STKG)指定给接收电信设备(ETKG)的多媒体消息(MMN)，为了在SMS会话(IS)期间向该接收电信设备(ETKG)传输一个通知消息(MN)，该多媒体消息业务中心利用该通知消息将多媒体消息(MMN)的到达通知该接收电信设备(ETKG)，由该多媒体消息业务中心(MMNDZ)所建立的到接收电信设备(ETKG)的有效信道连接(NKV)至少一直保持建立，直到该接收电信设备(ETKG)已分析了所接收的通知消息(MN)并且已实施了用于提取在该多媒体消息业务中心(MMNDZ)处的指定给该接收电信设备(ETKG)的多媒体消息(MMN)的消息内容的MMS会话(AS)。

摘要： 本发明提供了一种驱动层消息处理方法、交互模块及驱动装置，应用于驱动层的与上层应用交互的交互模块中，预先在所述交互模块中创建目标窗口类，还包括：通过所述目标窗口类接收底层动态库发来的至少一个目标消息；通过所述目标窗口类生成每个所述目标消息对应的目标事件；通过所述目标窗口类调用所述交互模块的自身类，将每个所述目标事件发送给所述上层应用。本发明能够提高驱动层的执行效率。

摘要： 为了缩短用于将多媒体消息从任意的发送方传输到任意的接收方的时间，并且为了由此在总体上降低业务“Multimedia Message Service(MMS)”的成本，建议：一个多媒体消息业务中心(MMNDZ)例如已接收到由发送电信设备(STKG)指定给接收电信设备(ETKG)的多媒体消息(MMN)，为了在SMS会话(IS)期间向该接收电信设备(ETKG)传输一个通知消息(MN)，该多媒体消息业务中心利用该通知消息将多媒体消息(MMN)的到达通知该接收电信设备(ETKG)，由该多媒体消息业务中心(MMNDZ)所建立的到接收电信设备(ETKG)的有效信道连接(NKV)至少一直保持建立，直到该接收电信设备(ETKG)已分析了所接收的通知消息(MN)并且已实施了用于提取在该多媒体消息业务中心(MMNDZ)处的指定给该接收电信设备(ETKG)的多媒体消息(MMN)的消息内容的MMS会话(AS)。

摘要： 本发明公开了一种应急消息在事件驱动网格中流转追踪方法，涉及应急消息追踪技术领域。本发明包括应急消息数据标注管理与服务以及应急消息网格内流转过程追踪。本发明事件驱动网格单元通过部署客户端代理程序，捕获到应急消息在数据举动网格的流转事件后，对应急消息流向进行实时监控，动态收集数据中心内外各类处理终端上应急消息流转路径、异常事件以及调用的应急消息数据处理服务等信息，并实时传输到控制平台服务端，进行追踪、溯源、回放、可视化显示处理和分析，为应急管理部门实时掌握消息流转态势提供支撑；提供应急消息动向展示功能支持对消息流转路径，异常事件进行追溯、回放，可视化显示处理和分析。

摘要： 本发明提供一种消息驱动系统中无效超时消息的检测方法，包括以下步骤：S1、在超时消息中插入超时消息控制块，其中所述超时消息控制块包括标志字段、引用字段及有效字段；S2、接收任务从消息队列取出所述超时消息，并判断所述超时消息中，是否有效字段大于0且所述有效字段等于引用字段减1；S3、若是，所述接收任务确定所述超时消息为有效消息，否则为无效消息并将其丢弃。

摘要： 本发明提供一种消息驱动系统中无效超时消息的检测方法，包括以下步骤：S1、在超时消息中插入超时消息控制块，其中所述超时消息控制块包括标志字段、引用字段及有效字段；S2、接收任务从消息队列取出所述超时消息，并判断所述超时消息中，是否有效字段大于0且所述有效字段等于引用字段减1；S3、若是，所述接收任务确定所述超时消息为有效消息，否则为无效消息并将其丢弃。

摘要： 本发明公开了一种基于Netty消息驱动的终端信息发布系统，客户终端用于收发消息，提供基于四个报文的QoS机制；消息服务器为基于Netty框架的使用UDP通信协议的服务器；提供基于四个报文的QoS机制；数据库服务器用于存储消息服务器向客户终端投递失败的离线消息。当客户终端断网或虚网时，客户终端启动一个断网重连守护进程，设置最大重连时间周期阙值和重连线程的等待接收消息服务器反馈数据的超时时间，周期性地尝试重连消息服务器，记录重连次数，增大重连时间周期，直至连接成功为止。本发明优化了客户终端断网和虚网重连算法，解决终端应用崩溃的问题，同时设计基于四个报文的QoS消息可靠投递算法，能节约网络资源和计算资源。

摘要： 本申请提供一种基于消息驱动的微服务动态编排方法及相关设备。其中，所述方法应用于微服务动态编排系统，所述系统包括多个微服务，所述方法包括：从业务报文中获取所述微服务的影响因子；根据所述微服务预设的消息主题以及所述影响因子生成所述微服务的流程编排数据，并将所述流程编排数据存储至缓存中心中；令全部所述微服务中的每个所述微服务从所述缓存中心中读取所述流程编排数据并根据所述流程编排数据确定与其连接的下一个所述微服务。本申请提供的方法实现了微服务的动态编排，在调整微服务调用链路时无需更改或重启微服务，保证了系统的工作效率，降低了系统的维护难度，解决了微服务调用链路难以调整的问题。

摘要： 本发明公开了一种基于消息驱动的异步日志处理方法，包括获取多条用户线程的日志信息；对多线程并发的用户线程加第一互斥锁；根据每条用户线程的日志信息，从静态缓冲区选取与日志信息大小匹配的内存块，并对选取的内存块加调用锁，得到已分配内存块；释放调用锁，并将对应的日志信息写入解锁后的已分配内存块；通过调用事件通知调用线程，使得调用线程从静态缓冲区读取多条日志信息，并发送到多条处理线程；每条处理线程通过自定义回调函数控制日志信息的输出格式。本发明采用双缓存机制，能够实现多线程同时读写，有效避免读写线程互相阻塞，提升异步日志处理的效率，保证自动驾驶系统的实时性与可靠性。