发布/订阅

摘要： 发布订阅系统因其去耦合和异步的特性被广泛用于大规模的信息传输系统中,然而随着云计算和大数据的飞速发展,发布订阅系统的应用环境已经从封闭的可信计算环境转变为开放的不可信计算环境,隐私保护问题开始凸显.因此,总结目前发布订阅系统在隐私保护方面取得的研究成果、存在的问题以及可能的研究趋势具有重要意义.本文首先介绍了发布订阅系统模型,发布订阅系统中的隐私性定义,威胁模型等.然后介绍了发布订阅系统中实现机密性保护和匿名性保护的研究现状与进展.接着根据发布订阅系统隐私保护技术方法存在的不足展望了未来的研究方向,最后给出了本文的总结.

摘要： 针对传统数据分发服务中,由慢订阅者与慢连接问题引起的高丢包率问题,提出多线程数据分发模型,降低丢包率。采用多线程技术,基于actor模型,引入多线程worker实现订阅者并行接收数据,改进订阅者无状态消息返回发布者可能引起的慢连接问题,建立了基于多线程worker的高可靠数据分发服务模型,有效降低了数据传输过程中的丢包率。不仅通过与ZeroMQ(zero message queue,零消息队列)进行对比试验,表明该模型在接收不同长度报文情况下,能有效降低丢包率。而且通过对模型进行压力测试,验证其降低丢包率的有效性。

摘要： 数据分发服务(data distribution service,DDS)是面向分布式系统的中间件技术规范,定义了以数据为中心的发布/订阅机制,实现了分布式应用程序之间数据的高效可靠传输。随着分布式实时系统复杂度和规模的不断增大,数据传输的需求量也不断增加,应用使用DDS通信前的配置工作使得应用程序承担了较大的通信开销。为了提高分布性系统的通信效率并减轻应用的通信开销,设计了一个基于DDS的分布式通信系统,通过部署DDS中间件和DDS管理器实现应用通信实体的动态创建和删除,采用服务管理模块对系统中的应用程序进行管理,最后在Linux环境下进行了系统实现,验证了分布式通信系统的各个功能实现。

摘要： 分析了中国当前游戏行业的发展形势,提出了将单机手游进行弱联网化改造,以便提升产品质量,找出新的利润增长点,分析了弱联网化改造所面临的问题。依托HTTP协议、MQTT协议、WebSocket协议等技术,设计并实现了一套应用于弱联网手游的服务器端架构,并利用模拟客户端和云主机搭建测试环境,验证了此架构的基本功能。

摘要： 多功能综合信息处理系统的软件密集程度与系统交互复杂程度显著增长,应用功能高实时、松耦合集成是复杂嵌入式系统快速集成研发、灵活升级重构需要解决的关键技术问题之一。基于此,提出了基于数据分发服务(data distribution service,DDS)、支持上层应用功能即插即用的高实时松耦合数据集成设计方法,基于标准的DDS数据分发服务,面向上层应用提供了分布式数据通信、可配置通信策略、通信状态监测等核心支撑服务,实现上层应用分布式松耦合集成,为复杂嵌入式系统上层软件快速研发、灵活升级重构提供基础环境。

摘要： 针对分布式系统应用规模大、范围广、运行环境复杂的特征,分析分布式交互平台在功能和性能上的需求,设计并实现了一个基于发布/订阅机制的实时交互平台Net-DDS.采取分层设计的思想,依次从分发服务层、QoS保障层和数据传输层3个方面完成实时交互平台的构建,提供基于发布/订阅机制的数据同步功能、灵活可配置的服务质量保障机制以及基于以太网的多协议数据传输机制,确保了数据传输的实时性、正确性与可靠性.实验结果表明,该交互平台具有较低的消息更新延迟,能满足分布式应用中数据分发对实时性的要求.

摘要： 传统防空作战的指挥中心通常也是信息中心,灵活性差,容易被摧毁,节点间信息传输效率低,并不适合未来大规模网络化作战.为实现通信网络去中心化,结合部队装备发展现状和未来战争实际需求,提出了基于Data?Distribution?Service(DDS)的防空武器信息交互系统.将以平台为中心的防空武器系统解耦成分布式功能节点,系统对被摧毁的节点缺失功能的后果进行评估,分配共享当前作战通信域中具有相同或类似功能的子系统的资源,通过Data Centric Publish Subscribe(DCPS)通信机制实现作战信息按需匹配分发和节点动态加入,通过服务质量管理减少传输带宽消耗,提高有效传输效率.经测试系统满足技术指标要求,信号处理时间控制在微秒级,为航空、航海、军事等实时性、可靠性要求高的实时性系统提供了借鉴.

摘要： 针对情报侦察系统数据分发的要求,提出将数据分发服务应用到情报侦察系统的设计思路,同时根据系统特点基于需求过滤机制对数据分发服务进行改进.实验结果表明,数据分发服务适合于情报侦察系统的集成,需求过滤机制能有效提高系统数据分发的效率.

摘要： OPC UA通过其地址空间形成通用应用接口,而TSN为标准以太网添加实时能力并实现千兆位数据速度。因此,通过发布/订阅(pub/sub)模型将这两种技术结合起来是有意义的,但在工业4.0的背景下,工业通信还有其他可能性。在本次采访中,ADI公司确定性以太网技术部的系统应用工程师Volker Goller提供了一些背景信息。

摘要： 采用ZeroMQ的多播传输方式上发布/订阅消息传递模式,并融合数据分发服务的域和主题的实体概念管控传输网络边际和消息交互匹配方式,以其SRC库源码二次开发并生成可复用组件.将组件嵌入各个子系统,使得分布式系统内形成消息通信软总线,以此避免采用第三方软件而需要复杂地安装部署.使得分布式系统架构灵活伸缩,并以ZeroMQ具有的高性能特点支持分布式系统高效应用.

摘要： 泛洪和主动探测是目前MPLS网络域内路由发布的主要方法，但它们一定程度上均存在冗余开销和路由收敛的问题。提出了一种用基于链路状态的发布订阅系统(LinkState based Publish/Subscribe System，LSPS)来实现MPLS网络域內路由发布，以有效地减少MPLS网络的路由开销并且消除路由收敛。LSPS首先定义了MPLS网络中基于链路状态的事件集合，用于支持每个边缘路由器订制和退订特定类型、地址和触发条件的网络事件，同时也命令所有路由器按订制內容探测和发布网络事件，从而消除冗余的路由探测和发布，实现按需路由。rn 其次LSPS以标签交换路径代替传统的OSPF连接，为路由报文提供了高速交换和服务质量(Quality of Service，QoS)保障，消除了报文传递的不确定性。路由发布以“异步发送，同步到达”的机制工作，基于各路径的传输延迟发送使路由报文能够在同一时间到达各个边缘路由器，实现同步更新。模拟结果显示，这一机制显著地减少了MPLS网络的路由开销并且有效地消除了路由收敛。

摘要： 设计了一个基于发布订阅模型的博客搜索系统.它能够利用采集器抓取博客更新,并实时地将满足匹配条件的内容按需推送给用户.实验表明该系统能够取得较好的效率,能够满足博客搜索的实时性要求.

摘要： 在普适计算环境中，软件模块之间的交互方式具有高度松耦合性、高动态性和高异构 性的特点，基于事件的发布订阅（P/S）模型以其时空和控制流完全解耦、支持多点通信及可重 配置等优点成为普适计算首选的交互方式，目前主流的移动环境下的 P/S 模型在满足普适计算环 境的需求方面尚有差距，本文从支持移动性和支持适应性两方面综述了当前 P/S 模型的研究成果，展望了普适计算环境下扩展发布订阅模型的研究趋势。

摘要： 当前，分布式实时应用领域蓬勃发展，包括军事化系统、长途通信、自动化工厂、交通控制、金融交易，医学成像等等，这些应用需要使数据能够实时可靠的传输。发布订阅通信模式非常适合分布式系统的应用。本文在基于OMG的DDS(Data Distributed Service)中间件的基础上，研究并设计了适用于分布式实时领域应用，支持数据库的实时发布订阅系统RMOS(Real-time MessageOriented System)。经过系统性能测试，证明RMOS系统满足大规模分布式网络的应用。

摘要： 无线传感器网络中信息传播是非常重要的问题,为它设计合适的通信机制是必要的,发布/订阅通信机制是其中之一。本文研究一种基于无线传感器网络在TinyOS上开发的中间件,命名为W-MPSS。它主要有三个主要特性:首先,W-MPSS是一个可扩展分布式中间件系统,它采用了组件技术,易于扩展系统功能。第二,提供了自适应多级QoS服务,有效地节约能耗。最后,提出基于XML匹配的内容/主题双模式,跟其他中间件相比有效提高了查询信息数量。

摘要： 发布订阅(Pub/Sub)中间件以发布/订阅的通信模式实现分布式系统中的各参与者之间的交互,它的松耦合、异步、组播等特点,使它能够很好地适应移动计算动态变化的网络环境.分析Pub/Sub中间件系统的框架模型和集中式、分布式两种结构,并将其扩展到移动计算环境.

摘要： 发布/订阅是普适环境中进行信息共享、事件分发的重要手段之一.本文首先分析了发布/订阅系统中对事件分发的用户满意度产生重要影响的上下文,然后给出了利用时间上下文和事件偏好上下文为用户提供个性化事件分发服务的策略,其中,利用时间上下文,为用户提供了长效事件的扩展匹配;利用事件偏好上下文,提出了基于隐马尔科夫模型的用户评价推荐算法.性能分析和实验评估表明上述两种策略均能有效改善事件分发的用户体验.

摘要： 发布/订阅是普适环境中进行信息共享、事件分发的重要手段之一.本文首先分析了发布/订阅系统中对事件分发的用户满意度产生重要影响的上下文,然后给出了利用时间上下文和事件偏好上下文为用户提供个性化事件分发服务的策略,其中,利用时间上下文,为用户提供了长效事件的扩展匹配;利用事件偏好上下文,提出了基于隐马尔科夫模型的用户评价推荐算法.性能分析和实验评估表明上述两种策略均能有效改善事件分发的用户体验.

摘要： 发布/订阅是普适环境中进行信息共享、事件分发的重要手段之一.本文首先分析了发布/订阅系统中对事件分发的用户满意度产生重要影响的上下文,然后给出了利用时间上下文和事件偏好上下文为用户提供个性化事件分发服务的策略,其中,利用时间上下文,为用户提供了长效事件的扩展匹配;利用事件偏好上下文,提出了基于隐马尔科夫模型的用户评价推荐算法.性能分析和实验评估表明上述两种策略均能有效改善事件分发的用户体验.

摘要： 发布/订阅是普适环境中进行信息共享、事件分发的重要手段之一.本文首先分析了发布/订阅系统中对事件分发的用户满意度产生重要影响的上下文,然后给出了利用时间上下文和事件偏好上下文为用户提供个性化事件分发服务的策略,其中,利用时间上下文,为用户提供了长效事件的扩展匹配;利用事件偏好上下文,提出了基于隐马尔科夫模型的用户评价推荐算法.性能分析和实验评估表明上述两种策略均能有效改善事件分发的用户体验.

摘要： 本发明实施例提供了一种基于区块链技术的安全发布订阅系统及发布订阅方法，系统包括：密钥服务器，消息订阅客户端，消息发布服务器，包括多个区块链节点的区块链；方法包括：接收由消息发布服务器发送的密文和加密标签；接收由订阅客户端发送的属性值，陷门值，预解密密钥；验证密文是否与属性值匹配；如果匹配则验证加密标签是否与陷门值匹配；如果匹配则利用预解密密钥对密文进行预解密处理得到预解密密文；将预解密密文发送至消息订阅客户端，以使消息订阅客户端解密得到订阅消息。本发明实施例能够提高发布订阅系统中所保存数据的安全性。

摘要： 本发明提供一种信息发布订阅平台及方法和信息发布订阅系统。该信息发布订阅平台包括信息订阅单元和信息发布单元，信息订阅单元用于接受下级平台的信息订阅，还用于向上级平台订阅信息；信息发布单元用于向下级平台发布信息，还用于接收上级平台发布的信息；信息订阅单元与信息发布单元连接，且信息订阅单元与信息发布单元之间能进行信息传递。该信息发布订阅平台实现了信息在相互之间具有发布订阅关系的两级平台之间的直接传输，从而实现了信息发布订阅的多级嵌套模式，进而提高了信息的发布订阅效率，继而提高了信息的传输效率。该信息发布订阅平台无需额外编程即可实现信息发布订阅的多级嵌套，从而节约了该信息发布订阅平台的软件成本。

摘要： 本发明公开了一种用于发布订阅系统的实现历史事件订阅的缓存方法，包括如下步骤：路由表扩充步骤，在路由表中增设缓存路由信息；事件处理步骤，通过哈希函数计算缓存点参考值；事件发布步骤：根据缓存点参考值判断当前代理节点是否作为缓存点并进行缓存，同步更新缓存路由信息；缓存订阅步骤；以及缓存获取步骤。本发明具有以下有益效果：本发明提供的缓存方法实现了订阅者对历史事件的订阅；本发明充分利用了事件分发路径上所有代理及其邻居代理的存储空间，提高了存储资源利用率，增强了发布订阅系统的缓存能力；本发明对缓存冗余做了精简，在访存效率与存储占用率之间做了平衡。

摘要： 本发明提供一种可分类推送的信息发布订阅系统，涉及文件信息发布及管理技术领域，包括推送单元、接收单元、订阅单元及存储单元，所述推送单元用于接收上级平台发布的文件信息，并将所述文件信息发出，上级平台包括多个信息发布者；所述订阅单元用于订阅所述文件信息，并对信息发布者进行需求等级划分；所述存储单元用于保存对信息发布者的等级划分信息和上级平台发布的文件信息；所述接收单元用于根据等级划分信息选择性的接收推送单元发出的文件信息。本发明用于解决现有可分类推送的信息发布订阅系统不能根据用户对与文件信息的需求程度，来选择对文件信息的接收方式，或者推送方式等的技术问题。

摘要： 本发明实施例提供了一种基于区块链技术的安全发布订阅系统及发布订阅方法，系统包括：密钥服务器，消息订阅客户端，消息发布服务器，包括多个区块链节点的区块链；方法包括：接收由消息发布服务器发送的密文和加密标签；接收由订阅客户端发送的属性值，陷门值，预解密密钥；验证密文是否与属性值匹配；如果匹配则验证加密标签是否与陷门值匹配；如果匹配则利用预解密密钥对密文进行预解密处理得到预解密密文；将预解密密文发送至消息订阅客户端，以使消息订阅客户端解密得到订阅消息。本发明实施例能够提高发布订阅系统中所保存数据的安全性。

摘要： 本发明提供一种信息发布订阅平台及方法和信息发布订阅系统。该信息发布订阅平台包括信息订阅单元和信息发布单元，信息订阅单元用于接受下级平台的信息订阅，还用于向上级平台订阅信息；信息发布单元用于向下级平台发布信息，还用于接收上级平台发布的信息；信息订阅单元与信息发布单元连接，且信息订阅单元与信息发布单元之间能进行信息传递。该信息发布订阅平台实现了信息在相互之间具有发布订阅关系的两级平台之间的直接传输，从而实现了信息发布订阅的多级嵌套模式，进而提高了信息的发布订阅效率，继而提高了信息的传输效率。该信息发布订阅平台无需额外编程即可实现信息发布订阅的多级嵌套，从而节约了该信息发布订阅平台的软件成本。

摘要： 本发明公开了一种用于发布订阅系统的实现历史事件订阅的缓存方法，包括如下步骤：路由表扩充步骤，在路由表中增设缓存路由信息；事件处理步骤，通过哈希函数计算缓存点参考值；事件发布步骤：根据缓存点参考值判断当前代理节点是否作为缓存点并进行缓存，同步更新缓存路由信息；缓存订阅步骤；以及缓存获取步骤。本发明具有以下有益效果：本发明提供的缓存方法实现了订阅者对历史事件的订阅；本发明充分利用了事件分发路径上所有代理及其邻居代理的存储空间，提高了存储资源利用率，增强了发布订阅系统的缓存能力；本发明对缓存冗余做了精简，在访存效率与存储占用率之间做了平衡。

摘要： 本发明公开了一种适用于智能量测设备的轻量级发布订阅方法及系统、设备、存储介质，该方法通过构建消息管理器，将智能量测设备中的多个App虚拟化映射在Docker容器内，并实现多个APP之间的相互通信，消息管理器在获取消息发布App所发布的消息后根据每个消息订阅App所订阅的消息内容将对发布消息进行对应发送，多个智能量测设备的App通过消息管理器进行消息传递，不仅为智能量测设备上的App提供了独立部署的隔离环境，而且支持多个App之间的互联互通，智能量测设备可以下载多元功能的App，保证智能量测设备对及时控制类消息可以进行及时、有效、稳定和安全的处理。

摘要： 本发明公开了一种基于发布订阅式物联网大数据实时处理方法、装置及系统，所述方法包括启动独立线程从数据库信息中获取业务应用数据，并同步到缓存中，形成缓存业务信息；响应于业务应用被操作的信号，获得变更信息，并基于发布订阅方式对所述缓存业务信息进行数据更新；对设备采集的数据进行预处理，获得结构化数据；对所述缓存业务信息和结构化数据进行数据关联，形成新的结构体；基于所述新的结构体，进行实时业务处理。本发明基于发布订阅的方式实现了数据库的更新与缓存信息的同步，既提高了流式计算与数据库数据交互的性能，又保证了数据准确性。

摘要： 本申请提供了一种基于DDS的发布订阅动态绑定通信系统，属于分布式通信技术领域，具体系统应用于分布式系统，DDS中间件部署在分布式系统的各个节点上，对外提供创建/删除主题、建立/删除绑定关系、发布数据和订阅数据等服务，实现业务数据的通信功能；分布式系统中各节点的应用程序采用微服务的形式进行管理，用户应用程序需要在中心节点的DDS管理器处进行注册后加入到分布式系统中；DDS管理器部署在中心节点，在收到用户应用程序加入和退出请求后，解析应用程序的配置文件，获取其通信时需要的通信实体，并通过远程调用DDS中间件接口创建或删除相应的通信实体。