[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN106302102A - Instant message delivery system - Google Patents

Instant message delivery system Download PDF

Info

Publication number
CN106302102A
CN106302102A CN201510362340.3A CN201510362340A CN106302102A CN 106302102 A CN106302102 A CN 106302102A CN 201510362340 A CN201510362340 A CN 201510362340A CN 106302102 A CN106302102 A CN 106302102A
Authority
CN
China
Prior art keywords
message
instant message
client
user
module
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN201510362340.3A
Other languages
Chinese (zh)
Inventor
夏凡
李欣怡
杨超
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Southwestern Institute of Physics
Original Assignee
Southwestern Institute of Physics
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Southwestern Institute of Physics filed Critical Southwestern Institute of Physics
Priority to CN201510362340.3A priority Critical patent/CN106302102A/en
Publication of CN106302102A publication Critical patent/CN106302102A/en
Pending legal-status Critical Current

Links

Landscapes

  • Information Transfer Between Computers (AREA)

Abstract

本发明涉及受控热核聚变以及即时消息发布领域,具体公开一种能够应用至核聚变试验的即时消息发布系统,包括消息收集和处理系统、云计算平台、存储系统、即时信息发布后台系统和至少一个客户端。本发明解决了现有的用于展示聚变试验结果的系统只能在固定展示场合进行展示、扩展性差、无法满足大规模的代码迭代计算需求、展示内容受限等问题,进而提供一种即时消息发布系统,该即时消息发布系统应用于在聚变实验期间,能够使所有对实验感兴趣的人员无论在何地均可以在第一时间内得到其想要的所有的信息。

The present invention relates to the fields of controlled thermonuclear fusion and instant message release, and specifically discloses an instant message release system that can be applied to nuclear fusion experiments, including a message collection and processing system, a cloud computing platform, a storage system, an instant message release background system and At least one client. The present invention solves the problems that the existing systems for displaying fusion test results can only be displayed in fixed display occasions, has poor scalability, cannot meet large-scale code iterative calculation requirements, and has limited display content, and further provides an instant message Publishing system, the instant message publishing system is applied during the fusion experiment, so that all those who are interested in the experiment can get all the information they want in the first time no matter where they are.

Description

即时消息发布系统instant messaging system

技术领域technical field

本发明涉及受控热核聚变以及即时消息发布领域,尤其涉及一种能够应用至核聚变试验的即时消息发布系统。The invention relates to the fields of controlled thermonuclear fusion and instant message release, in particular to an instant message release system that can be applied to nuclear fusion experiments.

背景技术Background technique

受控核聚变研究的一个主要的目的是为了实现能够商用的聚变电站,为了达到这个目标,必须扫除与等离子体聚变反应相关的物理和工程上的障碍,这些物理上的理论和工程上的方案必须要在聚变装置上的等离子体实验中加以更新和验证,因此受控核聚变的研究从某种意义上讲是一种实验驱动的学科。One of the main goals of controlled nuclear fusion research is to achieve commercial fusion power plants. In order to achieve this goal, physical and engineering obstacles related to plasma fusion reactions must be removed. These physical theories and engineering solutions It must be updated and verified in plasma experiments on fusion devices, so the study of controlled nuclear fusion is in a sense an experiment-driven discipline.

无论是在传统的常规导体聚变装置中,还是在可以实现时间内约束的超导聚变装置中,实现成功的等离子体放电实验,需要将所有的子系统同时协调的参与进来,需要工程操作人员和物理研究人员协力配合。因为系统众多,例如典型的存在电机系统、电源系统、诊断系统、真空系统、中性束系统、电子回旋系统、等离子体控制系统、数据采集系统、网络系统、真空系统、送气系统等等,每个系统之中均包含了大量的子系统和设备,这些数量庞大的系统、子系统和设备的存在导致了一个事实:对于一个无论工程人员还是物理研究人员,只可能对一个或者多个系统或者领域非常熟悉,这就导致了在等离子体放电实验期间,特别是在两次实验之间短暂的时间间隔内,有了解其他系统的状况、信息和数据的需求,然后结合自身的系统或者领域,做出下一个实验的工程决定或者物理研究提案。Whether it is in a traditional conventional conductor fusion device or in a superconducting fusion device that can achieve time constraints, to achieve a successful plasma discharge experiment, it is necessary to coordinate and participate in all subsystems at the same time, requiring engineering operators and Physics researchers work together. Because there are many systems, such as the typical motor system, power supply system, diagnostic system, vacuum system, neutral beam system, electron cyclone system, plasma control system, data acquisition system, network system, vacuum system, gas supply system, etc., each Each system contains a large number of subsystems and equipment. The existence of these huge number of systems, subsystems and equipment leads to the fact that for an engineer or a physics researcher, it is only possible to analyze one or more systems or The field is very familiar, which leads to the need to understand the status, information and data of other systems during the plasma discharge experiment, especially in the short time interval between two experiments, and then combine with its own system or field, Make engineering decisions for your next experiment or physics research proposal.

为了达到这个目的,目前通用的解决方案是在控制大厅放置多个投影屏幕或者大屏幕的电视机,上面将各个系统的曲线进行显示,然后参与实验的人员需要从一个屏幕走到另外一个屏幕,了解到整个装置的放电实验状况。In order to achieve this goal, the current common solution is to place multiple projection screens or large-screen TVs in the control hall, on which the curves of each system are displayed, and then the personnel participating in the experiment need to walk from one screen to another. Understand the discharge test status of the entire device.

这种技术方案存在几个固有的缺点:This technical solution has several inherent disadvantages:

1、参与实验的人员无法离开中控大厅,来获得当前的全局状态和数据;1. The personnel participating in the experiment cannot leave the central control hall to obtain the current global status and data;

2、展示内容,受大屏幕的数量的限制,随着实验内容越来越丰富,必须持续投资大屏幕和对应的软件开发,扩展性非常差;2. The display content is limited by the number of large screens. As the experimental content becomes more and more abundant, it is necessary to continue to invest in large screens and corresponding software development, and the scalability is very poor;

3、参与实验的人员根据所负责的系统和研究的内容不同,感兴趣的内容并不相同,这种技术方案无法提供个性化的定制内容。3. The personnel involved in the experiment have different interests depending on the system they are responsible for and the content of the research. This technical solution cannot provide personalized customized content.

4、很多内容,特别是物理研究相关的,必须通过大规模的代码迭代计算才能够得到,这种技术方案单纯用于展示,并不能满足这种要求。4. A lot of content, especially related to physics research, must be obtained through large-scale code iterative calculations. This technical solution is purely for display and cannot meet this requirement.

5、很多内容,特别是需要几个系统的数据进行综合分析才能得出的结论,这类内容无法在显示曲线的大屏方案上实现;5. A lot of content, especially the conclusions that require comprehensive analysis of the data of several systems, cannot be realized on the large-screen solution that displays curves;

6、一些内容,例如突发事件、某个系统的重要参数,这些无法用曲线表示的内容无法展现;6. Some content, such as emergencies and important parameters of a certain system, cannot be represented by curves;

7、无法随时得到某些不熟悉系统的背景知识;7. Unable to obtain some background knowledge of unfamiliar systems at any time;

发明内容Contents of the invention

本发明解决的技术问题是现有的用于展示聚变试验结果的系统只能在固定展示场合进行展示、扩展性差、无法满足大规模的代码迭代计算需求、展示内容受限等问题,进而提供一种能够解决前述问题的即时消息发布系统,该即时消息发布系统应用于在聚变实验期间,能够使所有对实验感兴趣的人员无论在何地均可以在第一时间内得到其想要的所有的信息。The technical problem solved by the present invention is that the existing systems for displaying fusion test results can only be displayed in fixed display occasions, have poor scalability, cannot meet the needs of large-scale code iterative calculations, and display content is limited. An instant message publishing system that can solve the aforementioned problems, the instant message publishing system is applied during the fusion experiment, so that all those who are interested in the experiment can get all the information they want in the first time no matter where they are information.

为了解决上述技术问题,本发明采用的技术方案如下:In order to solve the problems of the technologies described above, the technical scheme adopted in the present invention is as follows:

即时消息发布系统,包括消息收集和处理系统、云计算平台、存储系统、即时信息发布后台系统和至少一个客户端。The instant message release system includes a message collection and processing system, a cloud computing platform, a storage system, an instant message release background system and at least one client.

所述消息收集和处理系统,通过设置相应的通讯手段和协议接收来自所有受监控设备的消息,其一直处于监听状态,并在接收到预先设定的消息且满足对应的条件时向所述云计算平台发送消息处理的计算请求;The message collection and processing system receives messages from all monitored devices by setting corresponding communication means and protocols, and it is always in a monitoring state, and sends a message to the cloud when a preset message is received and the corresponding conditions are met. The computing platform sends computing requests for message processing;

所述云计算平台上预置有计算策略,在接收到上述计算请求后,所述云计算平台根据预置的计算策略启动相应的计算线程进行计算、在计算完成后将计算结果生成预设的各种展现形式存入所述存储系统,并向所述即时信息发布后台系统发送消息;The computing strategy is preset on the cloud computing platform, and after receiving the above computing request, the cloud computing platform starts the corresponding computing thread to perform calculation according to the preset computing strategy, and generates a preset computing result after the computing is completed. Various display forms are stored in the storage system, and messages are sent to the instant message release background system;

所述即时信息发布后台系统解析所述云计算平台发送的消息,并根据解析结果获取本条消息对应的上述各种展现形式的计算结果并以消息方式向至少一个所述客户端推送;The instant message publishing background system analyzes the message sent by the cloud computing platform, and obtains the calculation results of the above-mentioned various presentation forms corresponding to this message according to the analysis result, and pushes it to at least one of the clients in the form of a message;

所述客户端包括消息对话框接口模块,所述消息对话框接口模块接收并向用户展示所述即时信息发布后台系统推送过来的消息。The client includes a message dialog interface module, and the message dialog interface module receives and displays to the user the messages pushed by the instant message publishing background system.

所述云计算平台将计算结果的各种展现形式中的非结构化数据存储至所述存储子系统中,并将结构化数据以及非结构化数据的存储地址存储至所述结构化数据库系统,所述云计算平台向所述即时信息发布后台系统发送的消息中包括结构化数据以及非结构化数据的存储地址,所述即时信息发布后台系统解析收到的消息得到非结构化数据的存储地址以及结构化数据,并从该存储地址读取非结构化数据和结构化数据一起发送至所述客户端。The cloud computing platform stores unstructured data in various presentation forms of calculation results in the storage subsystem, and stores the structured data and the storage address of the unstructured data in the structured database system, The message sent by the cloud computing platform to the instant message release background system includes storage addresses of structured data and unstructured data, and the instant message release background system parses the received message to obtain the storage address of the unstructured data and structured data, and read unstructured data and structured data from the storage address and send them to the client.

所述即时消息发布系统还包括网站系统,所述网站系统上设置有若干应用模块;The instant message publishing system also includes a website system, and the website system is provided with several application modules;

所述客户端还包括定制模块,所述定制模块中设置与所述网站系统的应用模块对应的配置接口模块;The client also includes a customization module, and a configuration interface module corresponding to the application module of the website system is set in the customization module;

所述配置接口模块经用户触发调用所述网站系统的相应应用模块完成功能。The configuration interface module is triggered by the user to call the corresponding application module of the website system to complete the function.

所述应用模块包括消息配置模块,与之对应,所述配置接口模块包括消息配置接口模块,所述消息配置接口模块受用户触发调用所述消息配置模块,同时将当前用户信息发送至所述消息配置模块,所述消息配置模块将接收到的用户信息嵌入消息配置窗口文件返回至当前用户所在客户端,接收用户配置信息,并将接收的配置信息存入所述结构化数据库;The application module includes a message configuration module, and correspondingly, the configuration interface module includes a message configuration interface module, and the message configuration interface module is triggered by a user to call the message configuration module, and at the same time sends current user information to the message Configuration module, the message configuration module embeds the received user information into the message configuration window file and returns to the client where the current user is located, receives user configuration information, and stores the received configuration information into the structured database;

所述即时信息发布后台系统在接收到来自所述云计算平台的消息后,从所述结构化数据库中调取对相应的配置信息获取定制该消息的用户的信息,并将解析后获取的各种展现形式的计算结果以消息方式向定制该消息的用户所在的所述客户端推送。After receiving the message from the cloud computing platform, the instant message release background system retrieves the corresponding configuration information from the structured database to obtain the information of the user who customizes the message, and parses the obtained The calculation results of the presentation forms are pushed to the client where the user who customizes the message is located in the form of a message.

所述应用模块还包括自助计算服务模块,所述自助计算服务模块内预设有对应若干自助运算程序;The application module also includes a self-service calculation service module, and a number of corresponding self-service calculation programs are preset in the self-service calculation service module;

与之对应,所述配置接口模块包括自助计算服务接口模块,所述自助计算服务接口模块受用户触发调用所述自助计算服务模块,同时将当前用户信息发送至所述自助计算服务模块;Correspondingly, the configuration interface module includes a self-service computing service interface module, the self-service computing service interface module is triggered by a user to invoke the self-service computing service module, and at the same time, sends current user information to the self-service computing service module;

所述自助计算服务模块接收用户输入的计算参数,并向所述云计算平台发送包含用户信息的计算请求,所述云计算平台完成计算后将计算结果以及用户信息以消息方式发送至所述即时信息发布后台系统,所述即时信息发布后台系统解析消息中包含的当前用户的用户信息并将接收到的消息返回当前用户所在的所述客户端。The self-service calculation service module receives the calculation parameters input by the user, and sends a calculation request containing user information to the cloud computing platform, and the cloud computing platform sends the calculation result and user information to the instant An information release background system, the instant information release background system parses the user information of the current user included in the message and returns the received message to the client where the current user is located.

所述即时信息发布后台系统设置有队列机制,所述云计算平台发送过来的消息根据优先级和到达的先后顺序进行排队,按排队顺序取出消息进行解析。The background system for publishing instant information is provided with a queue mechanism, and the messages sent by the cloud computing platform are queued according to the priority and the order of arrival, and the messages are taken out according to the queued order for analysis.

在所述网站系统上设置有历史消息查询模块,所述即时信息发布后台系统将解析之后的消息保存到所述结构化数据库中,所述历史消息查询模块接收用户的查询指令从所述结构化数据库中找到符合条件的历史消息,对于带有链接地址的消息,按照地址从所述存储系统中获取相应的文件,并显示在当前查询用户所在的所述客户端的网页中。。A historical message query module is provided on the website system, and the instant message release background system saves the parsed message in the structured database, and the historical message query module receives user query instructions from the structured database. Find the qualified historical message in the database, and for the message with the link address, obtain the corresponding file from the storage system according to the address, and display it on the webpage of the client where the querying user is currently located. .

在所述即时消息发布后台系统上设置有第三方程序接口模块,所述即时消息发布后台系统接收用户的第三方程序通过该第三方程序接口模块发布的内容,并根据其预设的消息发送规则,将消息发送到对应的所述客户端。A third-party program interface module is set on the instant message publishing background system, and the instant message publishing background system receives the content issued by the user's third-party program through the third-party program interface module, and sends messages according to its preset message sending rules , to send the message to the corresponding client.

所述结构化数据包括文字、链接信息,所述非结构化数据包括图片、动画,所述链接信息包括所述网站上背景知识的链接信息,所述云计算平台在接收到计算请求后,找到与当前消息相关的背景知识的链接和其它信息一起发送至所述即时信息发布后台系统。The structured data includes text and link information, the unstructured data includes pictures and animations, and the link information includes link information of background knowledge on the website. After receiving the computing request, the cloud computing platform finds The link of background knowledge related to the current message and other information are sent to the background system for publishing instant information.

所述云计算平台向所述即时消息发布后台系统发送的消息采用JSON格式,所述客户端包括Windows客户端、iOS客户端和Andriod客户端,所述即时信息发布后台系统根据当前登录用户的客户端种类选择推送至客户端进行显示的即时消息的内容,所述云计算平台采用基于Matlab的并行计算和分布式计算策略。The message sent by the cloud computing platform to the instant message release background system adopts the JSON format, and the client includes a Windows client, an iOS client and an Andriod client, and the instant message release background system is based on the current login user's client The terminal type selects the content of the instant message pushed to the client for display, and the cloud computing platform adopts Matlab-based parallel computing and distributed computing strategies.

本发明的有益效果如下:The beneficial effects of the present invention are as follows:

本发明的即时消息发布系统应用至受控热核聚变试验中,利用云计算、分布式控制、并行计算和以及网络通讯技术,能够在托卡马克核聚变装置运行期间,根据实验的进展情况,即时向参与实验的工程师和物理学家发送其感兴趣的与整个装置的当前实验或者最近一段时间实验的工程运行分析和物理分析相关的信息,信息的格式可以根据需要预设,例如可以是带格式的文字、链接、图片以及动画,并且不受地理范围的限制,从而为在全球范围内的实现聚变装置的远程监控提供了一种解决方案。The instant message release system of the present invention is applied to the controlled thermonuclear fusion test, using cloud computing, distributed control, parallel computing and network communication technology, during the operation of the tokamak nuclear fusion device, according to the progress of the experiment, Immediately send the information related to the current experiment of the whole device or the engineering operation analysis and physical analysis of the experiment to the engineers and physicists participating in the experiment. The format of the information can be preset according to the needs, for example, it can be Format text, links, pictures and animations, and not limited by geographical scope, thus providing a solution for the remote monitoring of fusion devices on a global scale.

附图说明Description of drawings

图1为本发明的即时消息发布系统的结构框图。Fig. 1 is a structural block diagram of the instant message publishing system of the present invention.

具体实施方式detailed description

下面结合附图和具体实施例对本发明的技术方案和有益效果进一步进行说明。The technical solutions and beneficial effects of the present invention will be further described below in conjunction with the accompanying drawings and specific embodiments.

参见附图1,本发明的即时消息发布系统,包括消息收集和处理系统、云计算平台、存储系统、即时信息发布后台系统和至少一个客户端,其中:Referring to accompanying drawing 1, instant message release system of the present invention comprises message collection and processing system, cloud computing platform, storage system, instant message release background system and at least one client, wherein:

消息收集和处理系统,通过设置相应的通讯手段和协议接收来自所有受监控设备的消息,其一直处于监听状态,并在接收到预先设定的消息且满足对应的条件时向云计算平台发送消息处理的计算请求;The message collection and processing system receives messages from all monitored devices by setting corresponding communication means and protocols. It is always in a monitoring state, and sends messages to the cloud computing platform when it receives preset messages and meets the corresponding conditions. Compute requests processed;

云计算平台上预置有计算策略,在接收到上述计算请求后,云计算平台根据预置的计算策略启动相应的计算线程进行计算、在计算完成后将计算结果生成预设的各种展现形式存入存储系统,并向即时信息发布后台系统发送消息;The computing strategy is preset on the cloud computing platform. After receiving the above computing request, the cloud computing platform starts the corresponding computing thread to perform calculation according to the preset computing strategy, and generates various preset presentation forms of the computing results after the computing is completed. Stored in the storage system, and send a message to the background system of instant message publishing;

即时信息发布后台系统解析云计算平台发送的消息,并根据解析结果获取本条消息对应的上述各种展现形式的计算结果并以消息方式向至少一个客户端推送;The instant message release background system analyzes the message sent by the cloud computing platform, and obtains the calculation results of the above-mentioned various presentation forms corresponding to this message according to the analysis result, and pushes it to at least one client in the form of a message;

客户端包括消息对话框接口模块,消息对话框接口模块接收并向用户展示即时信息发布后台系统推送过来的消息。The client includes a message dialog interface module, which receives and displays to the user the messages pushed by the background system of instant information release.

当本发明的系统应用至聚变试验时,系统后台所面向的对象是所有参与聚变工程和物理实验的运行和分析、并能够被实时监控或能够主动提供信息的设备和子系统,系统前台所面向的对象是所有关心聚变工程和物理实验运行和分析的工程师和科学家。。本发明的即时消息发布系统可以是面向全球从事聚变工程和物理研究人员,在全球任何一个位置,在聚变实验期间,均可以通过互联网接入到本系统中,获取所有的实验即时信息。When the system of the present invention is applied to fusion experiments, the objects of the system background are all equipment and subsystems that participate in the operation and analysis of fusion engineering and physical experiments, and can be monitored in real time or can actively provide information. The audience is all engineers and scientists concerned with the operation and analysis of fusion engineering and physics experiments. . The instant message publishing system of the present invention can be oriented to fusion engineering and physics researchers around the world. In any location in the world, during fusion experiments, they can access the system through the Internet to obtain all experimental instant information.

本发明的存储系统包括存储子系统和结构化数据库系统,以便将结构化数据和非结构化数据按照分别存储,方便后续过程根据不同根据数据种类部分分别进行处理和传送,提高消息传送效率:The storage system of the present invention includes a storage subsystem and a structured database system, so that structured data and unstructured data are stored separately, and subsequent processes are conveniently processed and transmitted according to different types of data, and the efficiency of message transmission is improved:

云计算平台将计算结果的各种展现形式中的非结构化数据存储至存储子系统中,并将结构化数据以及非结构化数据的存储地址存储至结构化数据库系统,云计算平台向即时信息发布后台系统发送的消息中包括结构化数据以及非结构化数据的存储地址,即时信息发布后台系统解析收到的消息得到非结构化数据的存储地址以及结构化数据,并从该存储地址读取非结构化数据和结构化数据一起发送至客户端。The cloud computing platform stores the unstructured data in various presentation forms of the calculation results in the storage subsystem, and stores the structured data and the storage address of the unstructured data in the structured database system. The cloud computing platform provides real-time information The messages sent by the release background system include the storage addresses of structured data and unstructured data. The instant message release background system analyzes the received messages to obtain the storage addresses of unstructured data and structured data, and reads them from the storage addresses. Unstructured data is sent to the client together with structured data.

为了适应不同用户的个性化需求,本发明的即时消息发布系统还设置有网站系统,并在网站系统上设置有若干应用模块;In order to adapt to the personalized needs of different users, the instant message publishing system of the present invention is also provided with a website system, and several application modules are provided on the website system;

客户端还包括定制模块,定制模块中设置与网站系统的应用模块对应的配置接口模块;The client also includes a custom module, in which a configuration interface module corresponding to the application module of the website system is set;

配置接口模块经用户触发调用网站系统的相应应用模块完成功能。The configuration interface module is triggered by the user to call the corresponding application module of the website system to complete the function.

应用模块可以根据用户的需求设置,本发明中,为了满足用户的消息定制需求,设置了消息配置模块,为了满足用户的自定义计算需要,设置了自助计算服务模块,具体如下:The application module can be set according to the user's needs. In the present invention, in order to meet the user's message customization needs, a message configuration module is set. In order to meet the user's custom calculation needs, a self-service calculation service module is set, as follows:

应用模块包括消息配置模块,与之对应,配置接口模块包括消息配置接口模块,消息配置接口模块受用户触发调用消息配置模块,同时将当前用户信息发送至消息配置模块,消息配置模块将接收到的用户信息嵌入消息配置窗口文件返回至当前用户所在客户端,接收用户配置信息,并将接收的配置信息存入结构化数据库;The application module includes a message configuration module. Correspondingly, the configuration interface module includes a message configuration interface module. The message configuration interface module is triggered by the user to call the message configuration module, and at the same time sends the current user information to the message configuration module. The message configuration module will receive the User information embedded in the message configuration window file returns to the client where the current user is located, receives user configuration information, and stores the received configuration information into the structured database;

即时信息发布后台系统在接收到来自云计算平台的消息后,从结构化数据库中调取对相应的配置信息获取定制该消息的用户的信息,并将解析后获取的各种展现形式的计算结果以消息方式向定制该消息的用户所在的客户端推送。After receiving the message from the cloud computing platform, the real-time information publishing background system retrieves the corresponding configuration information from the structured database to obtain the information of the user who customized the message, and analyzes the obtained calculation results of various presentation forms Push the message to the client where the user who customizes the message resides.

应用模块还包括自助计算服务模块,自助计算服务模块内预设有对应若干自助运算程序;The application module also includes a self-service calculation service module, and a number of corresponding self-service calculation programs are preset in the self-service calculation service module;

与之对应,配置接口模块包括自助计算服务接口模块,自助计算服务接口模块受用户触发调用自助计算服务模块,同时将当前用户信息发送至自助计算服务模块;Correspondingly, the configuration interface module includes a self-service computing service interface module. The self-service computing service interface module is triggered by the user to call the self-service computing service module, and at the same time sends the current user information to the self-service computing service module;

自助计算服务模块接收用户输入的计算参数,并向云计算平台发送包含用户信息的计算请求,云计算平台完成计算后将计算结果以及用户信息以消息方式发送至即时信息发布后台系统,即时信息发布后台系统解析消息中包含的当前用户的用户信息并将接收到的消息返回当前用户所在的客户端。The self-service calculation service module receives the calculation parameters input by the user, and sends a calculation request including user information to the cloud computing platform. After the calculation is completed, the cloud computing platform sends the calculation result and user information to the instant information release background system in the form of a message, and the instant information release The background system parses the user information of the current user contained in the message and returns the received message to the client where the current user is located.

因为云计算平台是一个高性能计算集群,其进行的是大量的并发运算,会导致很多信息在同一个时刻到达即时信息发布后台系统,为了快速高效的处理这些信息,本发明在即时信息发布后台系统设置有队列机制,云计算平台发送过来的消息根据优先级和到达的先后顺序进行排队,按排队顺序取出消息进行解析。Because the cloud computing platform is a high-performance computing cluster, it performs a large number of concurrent operations, which will cause a lot of information to arrive at the instant information release background system at the same time. The system is equipped with a queue mechanism. The messages sent by the cloud computing platform are queued according to the priority and the order of arrival, and the messages are taken out according to the queued order for analysis.

为了方便用户查看历史消息,本发明在网站系统上设置有历史消息查询模块,即时信息发布后台系统将解析之后的消息保存到结构化数据库中,历史消息查询模块接收用户的查询指令从结构化数据库中找到符合条件的历史消息,对于带有链接地址的消息,按照地址从存储系统中获取相应的文件,并显示在当前查询用户所在的客户端的网页中。。In order to facilitate users to view historical messages, the present invention is provided with a historical message query module on the website system, and the instant information release background system saves the parsed messages in the structured database, and the historical message query module receives the user's query instructions from the structured database Find the qualified historical messages in , and for the messages with the link address, obtain the corresponding file from the storage system according to the address, and display it on the web page of the client where the querying user is currently located. .

在聚变试验中,有需要有一些临时参加进行来的设备需要在系统中发送消息,本发明在即时消息发布后台系统上设置有第三方程序接口模块作为这些设备的接入口,即时消息发布后台系统接收用户的第三方程序通过该第三方程序接口模块发布的内容,并根据其预设的消息发送规则,将消息发送到对应的客户端。In the fusion experiment, there are some temporary participating devices that need to send messages in the system. The present invention is equipped with a third-party program interface module on the instant message release background system as the access port of these devices. The instant message release background system Receive the content released by the user's third-party program through the third-party program interface module, and send the message to the corresponding client according to its preset message sending rules.

本发明中的数据表现形式可以根据实际的试验数据表现需求确定,其中结构化数据可以包括文字、链接信息,非结构化数据可以包括图片、动画,链接信息包括网站上背景知识的链接信息,云计算平台在接收到计算请求后,找到与当前消息相关的背景知识的链接和其它信息一起发送至即时信息发布后台系统。The data representation form in the present invention can be determined according to the actual test data performance requirements, wherein structured data can include text and link information, unstructured data can include pictures and animations, and link information includes link information of background knowledge on the website, cloud After the calculation platform receives the calculation request, it finds the link of the background knowledge related to the current message and sends it to the background system of the instant information distribution together with other information.

本发明中的云计算平台向即时消息发布后台系统发送的消息可以采用JSON格式。The message sent by the cloud computing platform in the present invention to the instant message release background system can adopt JSON format.

本发明中的客户端可以是Windows客户端、iOS客户端和Andriod客户端的任何一种,考虑到移动平台的内存、存储空间和计算能力,在Andriod和iOS版本的客户端中只显示文字和链接两种消息,但是通过点击链接可以看到图片和动画即时信息发布后台系统根据当前登录用户的客户端种类选择推送至客户端进行显示的即时消息的内容。Client among the present invention can be any of Windows client, iOS client and Andriod client, considering the internal memory of mobile platform, storage space and computing power, only display text and link in the client of Andriod and iOS version Two types of messages, but by clicking on the link, you can see pictures and animations. The instant message publishing background system selects the content of the instant message that is pushed to the client for display according to the client type of the currently logged-in user.

本发明的云计算平台可以采用基于Matlab的并行计算和分布式计算策略。The cloud computing platform of the present invention can adopt Matlab-based parallel computing and distributed computing strategies.

下面结合本发明在我国第一个实现偏滤器放电实验的常规托卡马克实验装置HL-2A上的应用实例进一步进行说明,HL-2A上的本发明的即时消息发布系统运行时间周期设置为8~15分钟:Below in conjunction with the application example of the present invention on the first conventional tokamak experimental device HL-2A that realizes the divertor discharge experiment in my country to further illustrate, the instant message distribution system running time cycle of the present invention on the HL-2A is set to 8 ~15 minutes:

本发明的即时消息发布系统应用到聚变实验中时,需要首先对各子系统的消息接口进行规范,在聚变实验期间,各个子系统将各自产生的消息和事件按照预先设定的标准接口规范进行转化,并发送到指定的位置进行发布共享,典型的发布和共享的方式是:UDP消息、EPICS消息以及各种监控事件消息;When the instant message publishing system of the present invention is applied to fusion experiments, it is necessary to first standardize the message interfaces of each subsystem. During the fusion experiment, each subsystem will generate messages and events according to the preset standard interface specifications. Convert and send to the designated location for publishing and sharing. The typical publishing and sharing methods are: UDP messages, EPICS messages and various monitoring event messages;

消息收集和处理系统一直处于监听的状态,通过一系列的通讯手段和协议(包括UDP,EPCIS等等)接收聚变实验各子系统发送的消息,参与聚变实验的所有子系统、子系统和设备的消息和事件都可以通过网络消息的方式自由的传送到此系统,每一类消息均对应一个线程,一旦接收到预先设定的消息并且满足对应的条件,则立即向作为云计算平台的高性能云计算集群发送消息处理的计算请求;The message collection and processing system is always in the state of monitoring, and receives the messages sent by the subsystems of the fusion experiment through a series of communication means and protocols (including UDP, EPCIS, etc.). Messages and events can be freely transmitted to this system through network messages. Each type of message corresponds to a thread. Once a preset message is received and the corresponding conditions are met, it will immediately send to the high-performance The cloud computing cluster sends computing requests for message processing;

高性能云计算集群拥有多个大容量内存和多CPU的计算资源,采用了基于Matlab的并行计算和分布式计算策略。可以同时处理多个计算请求。计算请求根据计算量的大小,计算代码执行的分为两种策略,一种是计算量较小的,直接使用一个线程一个CPU进行计算,一种计算量较大的,需要进行多核并行计算的优化。在计算完毕后,高性能计算集群根据预先设置的策略,将包括各种工程和物理判断结论在内的计算结果生成各种展现形式,包括指定格式的文字消息、链接信息、指定像素大小的图片信息以及将一系列的图片生成动画等;The high-performance cloud computing cluster has multiple large-capacity memory and multi-CPU computing resources, and adopts Matlab-based parallel computing and distributed computing strategies. Multiple computing requests can be processed concurrently. Calculation requests are divided into two strategies for computing code execution according to the amount of calculation. One is to use a small amount of calculation, directly using one thread and one CPU for calculation, and the other is to use a large amount of calculation, which requires multi-core parallel computing. optimization. After the calculation is completed, the high-performance computing cluster will generate various presentation forms of the calculation results including various engineering and physical judgment conclusions according to the preset strategy, including text messages in specified formats, link information, and pictures with specified pixel sizes Information and animation of a series of pictures, etc.;

高性能云计算集群将生成的图片和动画保存到存储系统的指定位置上,并将文字、链接、图片和动画的信息按照指定的JSON格式发送到即时信息发布后台系统;The high-performance cloud computing cluster saves the generated pictures and animations to the specified location of the storage system, and sends the information of text, links, pictures and animations to the real-time information release background system according to the specified JSON format;

具体的,可以在存储系统上建有一个http服务器,上述图片、动画等非结构化数据的存储地址既是一个网站的地址,当消息被生成的时候,消息附带的文件存储地址就已经生成了,例如http//4.4.4.4/3.jpg,这个地址随着文本消息打包成一个json格式的消息;Specifically, an http server can be built on the storage system. The storage address of the above-mentioned unstructured data such as pictures and animations is the address of a website. When the message is generated, the storage address of the file attached to the message has already been generated. For example http//4.4.4.4/3.jpg, this address is packaged into a message in json format along with the text message;

文字可以作为字符串的形式存储,例如mysql数据库,文字可以以varchar的类型(字符串)作为一个字段进行存储;Text can be stored as a string, such as mysql database, text can be stored as a field of varchar type (string);

因为高性能计算集群进行的是大量的并发运算,会导致很多JSON信息在同一个时刻到达,即时信息发布后台系统将收到的JSON格式消息排成队列,并根据先后顺序和优先级从队列中取出消息进行解析,首先通过查询数据库,找到订阅此条消息的所有用户,然后解析出信息所包含的文字、链接地址、图片和动画的等内容;Because the high-performance computing cluster performs a large number of concurrent operations, many JSON messages will arrive at the same time. The background system of the instant message publishing queues the received messages in JSON format and selects them from the queue according to the sequence and priority. Take out the message for analysis, first find all the users who subscribed to this message by querying the database, and then parse out the text, link address, picture and animation contained in the message;

即时信息发布后台系统将解析之后的消息按照特定的格式保存到数据库中,以供后期的查询;The background system of instant message publishing saves the parsed message in the database according to a specific format for later query;

即时信息发布后台系统将本条消息对应的文字、链接地址、图片和动画依次发送给所有订阅了此条消息的客户端。其中文字和链接地址直接按照指定的格式发送出去,而图片和动画则首先是从存储系统的指定位置读出,然后按照与客户端约定的格式,以流的形式发送到客户端;The instant message release background system sends the text, link address, picture and animation corresponding to this message to all clients who have subscribed to this message in sequence. Among them, the text and link address are sent directly according to the specified format, while the pictures and animations are first read from the specified location of the storage system, and then sent to the client in the form of a stream according to the format agreed with the client;

对应最常见的操作系统,客户端存在三种版本:Windows、Andriod和iOS。客户端是整个系统与参与聚变实验人员之间的唯一接口。接口分为两种,一种是消息对话框接口,可以在其中直接显示系统后台推送过来用户订阅的各种消息。消息分为四种,均直接在对话框中显示:Corresponding to the most common operating systems, there are three versions of the client: Windows, Andriod and iOS. The client is the only interface between the entire system and those involved in fusion experiments. The interface is divided into two types, one is the message dialog interface, which can directly display various messages pushed by the system background and subscribed by the user. There are four types of messages, all displayed directly in the dialog box:

1)带格式的文本消息,后台根据消息的种类不同(例如普通、错误、警报、特色、参数、结论等等),生成不同颜色和字体的消息,使得参与聚变实验的人员可以直观地进行区分;1) For formatted text messages, the background generates messages with different colors and fonts according to different types of messages (such as normal, error, alarm, feature, parameter, conclusion, etc.), so that the personnel participating in the fusion experiment can distinguish intuitively ;

2)链接,给出文本、图片或者动画的补充和背景知识的链接,直接在对话框中点击,即可以在浏览器中显示对应的页面2) Links, which provide supplementary and background knowledge links for texts, pictures or animations, click directly in the dialog box, and the corresponding pages can be displayed in the browser

3)静态图片,最典型的格式是PNG和JPG,图片比文字可以更直观的显示某个或者多个参数在实验中演化过程以及对比;3) Static pictures, the most typical formats are PNG and JPG. Pictures can more intuitively display the evolution process and comparison of one or more parameters in the experiment than text;

4)动画,最典型的格式是GIF,动画可以直观的显示二维图像在实验过程中的演化过程,例如等离子的图像和剖面等等;4) Animation, the most typical format is GIF, which can intuitively display the evolution process of two-dimensional images during the experiment, such as plasma images and profiles, etc.;

在Windows版本中,所有的内容均会显示出来,但是在Andriod和iOS版本中,考虑到移动平台的内存、存储空间和计算能力,只显示文字和链接两种消息,但是通过点击链接可以看到图片和动画;In the Windows version, all content will be displayed, but in the Andriod and iOS versions, considering the memory, storage space and computing power of the mobile platform, only text and link messages are displayed, but you can see them by clicking on the link pictures and animations;

第二种接口是带有用户信息的配置应用,集成在客户端中。当用户点击相关应用图标的时候,会弹出对应的网页,网页中带有用户的信息,为单个用户提供个性化的服务,主要的服务有:The second interface is a configuration application with user information, which is integrated in the client. When the user clicks on the relevant application icon, the corresponding webpage will pop up, with the user's information in the webpage, providing personalized services for a single user. The main services are:

1)客户端接收消息种类的自定义配置。用户可以选中其感兴趣的消息,从而用其账号登陆的客户端只会接收用户选中的消息;1) Custom configuration of the type of message received by the client. Users can select the messages they are interested in, so that the client logged in with their account will only receive the messages selected by the user;

2)自定义计算。云计算平台提供了一系列的后台计算服务程序及其接口,只需要在网页中提交计算的输入参数,云计算平台就会自动进入计算,计算的过程和结果以各种消息的形式发送到客户端,特别是计算的结果在客户端对话框中以图片和链接的方式供直观查看和下载;Windows客户端接收并显示所有的即时消息,iOS客户端和Andriod客户端只接收和显示文字和链接地址;2) Custom calculation. The cloud computing platform provides a series of background computing service programs and their interfaces. You only need to submit the input parameters of the calculation on the web page, and the cloud computing platform will automatically enter the calculation. The calculation process and results are sent to the customer in the form of various messages In particular, the calculated results can be visually viewed and downloaded in the form of pictures and links in the client dialog box; the Windows client receives and displays all instant messages, and the iOS client and Andriod client only receive and display text and links address;

客户端通过点击应用图标,可以跳转到对应的网站,网址带有用户的信息;The client can jump to the corresponding website by clicking the application icon, and the website contains the user's information;

用户在带有用户信息的网站上,进行消息订阅选择操作,网站将用户特定的订阅消息种类保存到数据库中;The user performs message subscription selection operation on the website with user information, and the website saves the user-specific subscription message type in the database;

用户在带有用户信息的网站上,进行自助计算操作,网站处理自助计算的消息,并立即向高性能云计算集群发送消息处理的请求,高性能云计算集群接收到这个请求后,根据计算量进行资源的分配并进行计算,将计算的过程和计算的结果,通过JSON格式的消息发送到即时消息发布后台系统,即时消息发布后台系统按照消息发送的方式直接发给对应用户的客户端;The user performs self-service computing operations on the website with user information. The website processes the self-service computing message and immediately sends a message processing request to the high-performance cloud computing cluster. After receiving the request, the high-performance cloud computing cluster Allocate resources and perform calculations, and send the calculation process and calculation results to the instant message publishing background system through JSON format messages, and the instant message publishing background system directly sends them to the corresponding user's client according to the message sending method;

用户直接点击客户端中的链接地址时,会在浏览器中显示存储系统中对应的图片、动画,或者网站上的背景知识和其他信息。When the user directly clicks the link address in the client, the browser will display the corresponding picture, animation in the storage system, or background knowledge and other information on the website.

用户的第三方程序通过消息接口发布的内容,会自动转化为JSON格式的消息发送到即时消息发布后台系统,即时消息发布后台系统根据其内在的消息发送规则,将消息发送到对应的客户端。The content published by the user's third-party program through the message interface will be automatically converted into a message in JSON format and sent to the instant message publishing background system. The instant message publishing background system will send the message to the corresponding client according to its internal message sending rules.

综上,本发明的优点可以总结如下:In summary, the advantages of the present invention can be summarized as follows:

1、参与实验的人员只需要一个账号和一个客户端,无论在局域网还是在广域网都可以与在中控大厅的实验人员同时获得当前的实验信息;1. The personnel participating in the experiment only need one account and one client, and can obtain the current experiment information at the same time as the experimenters in the central control hall no matter in the local area network or in the wide area network;

2、展示内容,没有限制,全部都显示在客户端中;2. There is no limit to display content, all of which are displayed in the client;

3、可以只显示感兴趣的内容;3. You can only display the content you are interested in;

4、提供各种格式的消息,内容丰富,格式多样,直观性强;4. Provide messages in various formats, rich in content, diverse in format, and intuitive;

5、可以显示各种现有的方案不能显示的内容,例如经过大规模的计算后得到的物理信息、综合分析信息等等;5. It can display content that cannot be displayed by various existing solutions, such as physical information obtained after large-scale calculations, comprehensive analysis information, etc.;

6、扩展性极强,增加一个新的消息内容,只需要将算法放入集群中即可,无需额外的硬件投资。6. The scalability is extremely strong. To add a new message content, you only need to put the algorithm into the cluster without additional hardware investment.

7、开放性强,利用二次开发接口,用户可以自定义消息并且发给指定的用户;7. Strong openness, using the secondary development interface, users can customize messages and send them to designated users;

8、提供通用化和个性化的计算服务。除了接收系统内置的实验实时消息外,系统还提供了一系列的自助计算的接口,在实验期间,用户可以通过此接口,将特定的计算提交到云计算平台,云计算平台将计算过程和结果发送到用户的客户端上。8. Provide generalized and personalized computing services. In addition to receiving the experimental real-time messages built in the system, the system also provides a series of self-service computing interfaces. During the experiment, users can submit specific calculations to the cloud computing platform through this interface, and the cloud computing platform will calculate the calculation process and results. sent to the user's client.

本领域的普通技术人员将会意识到,这里所述的实施例是为了帮助读者理解本发明的原理,应被理解为本发明的保护范围并不局限于这样的特别陈述和实施例。本领域的普通技术人员科研根据本发明公开的这些技术启示做出各种不脱离本发明实质的其它各种具体变形和组合,这些变形和组合仍然在本发明的保护范围内。Those skilled in the art will appreciate that the embodiments described here are to help readers understand the principles of the present invention, and it should be understood that the protection scope of the present invention is not limited to such specific statements and embodiments. Those skilled in the art can research and make various other specific modifications and combinations based on the technical revelations disclosed in the present invention without departing from the essence of the present invention, and these modifications and combinations are still within the protection scope of the present invention.

Claims (10)

1.即时消息发布系统,其特征在于,包括消息收集和处理系统、云计算平台、存储系统、即时信息发布后台系统和至少一个客户端,其中: 1. The instant message release system is characterized in that it includes a message collection and processing system, a cloud computing platform, a storage system, an instant message release background system and at least one client, wherein: 所述消息收集和处理系统,通过设置相应的通讯手段和协议接收来自所有受监控设备的消息,其一直处于监听状态,并在接收到预先设定的消息且满足对应的条件时向所述云计算平台发送消息处理的计算请求; The message collection and processing system receives messages from all monitored devices by setting corresponding communication means and protocols, and it is always in a monitoring state, and sends a message to the cloud when a preset message is received and the corresponding conditions are met. The computing platform sends computing requests for message processing; 所述云计算平台上预置有计算策略,在接收到上述计算请求后,所述云计算平台根据预置的计算策略启动相应的计算线程进行计算、在计算完成后将计算结果生成预设的各种展现形式存入所述存储系统,并向所述即时信息发布后台系统发送消息; The computing strategy is preset on the cloud computing platform, and after receiving the above computing request, the cloud computing platform starts the corresponding computing thread to perform calculation according to the preset computing strategy, and generates a preset computing result after the computing is completed. Various display forms are stored in the storage system, and messages are sent to the instant message release background system; 所述即时信息发布后台系统解析所述云计算平台发送的消息,并根据解析结果获取本条消息对应的上述各种展现形式的计算结果并以消息方式向至少一个所述客户端推送; The instant message publishing background system analyzes the message sent by the cloud computing platform, and obtains the calculation results of the above-mentioned various presentation forms corresponding to this message according to the analysis result, and pushes it to at least one of the clients in the form of a message; 所述客户端包括消息对话框接口模块,所述消息对话框接口模块接收并向用户展示所述即时信息发布后台系统推送过来的消息。 The client includes a message dialog interface module, and the message dialog interface module receives and displays to the user the messages pushed by the instant message publishing background system. 2.如权利要求1所述即时消息发布系统,其特征在于:所述存储系统包括存储子系统和结构化数据库系统: 2. instant message distribution system as claimed in claim 1, is characterized in that: described storage system comprises storage subsystem and structured database system: 所述云计算平台将计算结果的各种展现形式中的非结构化数据存储至所述存储子系统中,并将结构化数据以及非结构化数据的存储地址存储至所述结构化数据库系统,所述云计算平台向所述即时信息发布后台系统发送的消息中包括结构化数据以及非结构化数据的存储地址,所述即时信息发布后台系统解析收到的消息得到非结构化数据的存储地址以及结构化数据,并从该存储地址读取非结构化数据和结构化数据一起发送至所述客户端。 The cloud computing platform stores unstructured data in various presentation forms of calculation results in the storage subsystem, and stores the structured data and the storage address of the unstructured data in the structured database system, The message sent by the cloud computing platform to the instant message release background system includes storage addresses of structured data and unstructured data, and the instant message release background system parses the received message to obtain the storage address of the unstructured data and structured data, and read unstructured data and structured data from the storage address and send them to the client. 3.如权利要求2所述即时消息发布系统,其特征在于: 3. instant message release system as claimed in claim 2, is characterized in that: 所述即时消息发布系统还包括网站系统,所述网站系统上设置有若干应用模块; The instant message publishing system also includes a website system, and the website system is provided with several application modules; 所述客户端还包括定制模块,所述定制模块中设置与所述网站系统的应用模块对应的配置接口模块; The client also includes a customization module, and a configuration interface module corresponding to the application module of the website system is set in the customization module; 所述配置接口模块经用户触发调用所述网站系统的相应应用模块完成功能。 The configuration interface module is triggered by the user to call the corresponding application module of the website system to complete the function. 4.如权利要求3所述即时消息发布系统,其特征在于:所述应用模块包括消息配置模块,与之对应,所述配置接口模块包括消息配置接口模块,所述消息配置接口模块受用户触发调用所述消息配置模块,同时将当前用户信息发送至所述消息配置模块,所述消息配置模块将接收到的用户信息嵌入消息配置窗口文件返回至当前用户所在客户端,接收用户配置信息,并将接收的配置信息存入所述结构化数据库; 4. instant message distribution system as claimed in claim 3, is characterized in that: described application module comprises message configuration module, and corresponding thereto, described configuration interface module comprises message configuration interface module, and described message configuration interface module is triggered by user Call the message configuration module, and send the current user information to the message configuration module, and the message configuration module embeds the received user information into the message configuration window file and returns it to the client where the current user is located, receives the user configuration information, and storing the received configuration information into the structured database; 所述即时信息发布后台系统在接收到来自所述云计算平台的消息后,从所述结构化数据库中调取对相应的配置信息获取定制该消息的用户的信息,并将解析后获取的各种展现形式的计算结果以消息方式向定制该消息的用户所在的所述客户端推送。 After receiving the message from the cloud computing platform, the instant message release background system retrieves the corresponding configuration information from the structured database to obtain the information of the user who customizes the message, and parses the obtained The calculation results of the presentation forms are pushed to the client where the user who customizes the message is located in the form of a message. 5.如权利要求4所述即时消息发布系统,其特征在于: 5. instant message release system as claimed in claim 4, is characterized in that: 所述应用模块还包括自助计算服务模块,所述自助计算服务模块内预设有对应若干自助运算程序; The application module also includes a self-service calculation service module, and a number of corresponding self-service calculation programs are preset in the self-service calculation service module; 与之对应,所述配置接口模块包括自助计算服务接口模块,所述自助计算服务接口模块受用户触发调用所述自助计算服务模块,同时将当前用户信息发送至所述自助计算服务模块; Correspondingly, the configuration interface module includes a self-service computing service interface module, the self-service computing service interface module is triggered by a user to invoke the self-service computing service module, and at the same time, sends current user information to the self-service computing service module; 所述自助计算服务模块接收用户输入的计算参数,并向所述云计算平台发送包含用户信息的计算请求,所述云计算平台完成计算后将计算结果以及用户信息以消息方式发送至所述即时信息发布后台系统,所述即时信息发布后台系统解析消息中包含的当前用户的用户信息并将接收到的消息返回当前用户所在的所述客户端。 The self-service calculation service module receives the calculation parameters input by the user, and sends a calculation request containing user information to the cloud computing platform, and the cloud computing platform sends the calculation result and user information to the instant An information release background system, the instant information release background system parses the user information of the current user included in the message and returns the received message to the client where the current user is located. 6.如权利要求5所述即时消息发布系统,其特征在于:所述即时信息发布后台系统设置有队列机制,所述云计算平台发送过来的消息根据优先级和到达的先后顺序进行排队,按排队顺序取出消息进行解析。 6. instant message release system as claimed in claim 5, is characterized in that: described instant message release background system is provided with queue mechanism, and the message that described cloud computing platform sends over is queued up according to priority and the order of arrival, press Queue order to fetch messages for parsing. 7.如权利要求6所述即时消息发布系统,其特征在于: 7. instant message release system as claimed in claim 6, is characterized in that: 在所述网站系统上设置有历史消息查询模块,所述即时信息发布后台系统将解析之后的消息保存到所述结构化数据库中,所述历史消息查询模块接收用户的查询指令从所述结构化数据库中找到符合条件的历史消息,对于带有链接地址的消息,按照地址从所述存储系统中获取相应的文件,并显示在当前查询 用户所在的所述客户端的网页中。 A historical message query module is provided on the website system, and the instant message release background system saves the parsed message in the structured database, and the historical message query module receives user query instructions from the structured database. Find the qualified historical message in the database, and for the message with the link address, obtain the corresponding file from the storage system according to the address, and display it on the webpage of the client where the querying user is currently located. 8.如权利要求7所述即时消息发布系统,其特征在于:在所述即时消息发布后台系统上设置有第三方程序接口模块,所述即时消息发布后台系统接收用户的第三方程序通过该第三方程序接口模块发布的内容,并根据其预设的消息发送规则,将消息发送到对应的所述客户端。 8. The instant message distribution system as claimed in claim 7, characterized in that: a third-party program interface module is arranged on the said instant message distribution background system, and said instant message distribution background system receives the user's third-party program through the third-party program The third-party program interface module publishes the content, and sends the message to the corresponding client according to its preset message sending rules. 9.如权利要求8所述即时消息发布系统,其特征在于:所述结构化数据包括文字、链接信息,所述非结构化数据包括图片、动画,所述链接信息包括所述网站上背景知识的链接信息,所述云计算平台在接收到计算请求后,找到与当前消息相关的背景知识的链接和其它信息一起发送至所述即时信息发布后台系统。 9. The instant message publishing system as claimed in claim 8, characterized in that: said structured data includes text and link information, said unstructured data includes pictures and animations, and said link information includes background knowledge on said website After receiving the calculation request, the cloud computing platform finds the link of the background knowledge related to the current message and sends it to the instant message release background system together with other information. 10.如权利要求1至9中任一项所述即时消息发布系统,其特征在于:所述云计算平台向所述即时消息发布后台系统发送的消息采用JSON格式,所述客户端包括Windows客户端、iOS客户端和Andriod客户端,所述即时信息发布后台系统根据当前登录用户的客户端种类选择推送至客户端进行显示的即时消息的内容,所述云计算平台采用基于Matlab的并行计算和分布式计算策略。 10. The instant message publishing system according to any one of claims 1 to 9, characterized in that: the message sent by the cloud computing platform to the instant message publishing background system adopts JSON format, and the client includes a Windows client terminal, iOS client and Andriod client, the instant message release background system selects the content of the instant message pushed to the client for display according to the client type of the currently logged-in user, and the cloud computing platform adopts Matlab-based parallel computing and Distributed Computing Strategies.
CN201510362340.3A 2015-06-26 2015-06-26 Instant message delivery system Pending CN106302102A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201510362340.3A CN106302102A (en) 2015-06-26 2015-06-26 Instant message delivery system

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201510362340.3A CN106302102A (en) 2015-06-26 2015-06-26 Instant message delivery system

Publications (1)

Publication Number Publication Date
CN106302102A true CN106302102A (en) 2017-01-04

Family

ID=57650926

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201510362340.3A Pending CN106302102A (en) 2015-06-26 2015-06-26 Instant message delivery system

Country Status (1)

Country Link
CN (1) CN106302102A (en)

Cited By (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108234600A (en) * 2017-12-06 2018-06-29 中国航空工业集团公司西安航空计算技术研究所 A kind of data automatic push method implementation method in Air-Ground data transmission
CN110493354A (en) * 2019-09-06 2019-11-22 达疆网络科技(上海)有限公司 A kind of cross-domain self-service ordering system of real-time messages businessman based on WEB
CN112351331A (en) * 2020-10-27 2021-02-09 深圳Tcl新技术有限公司 Message prompting method and device, display equipment and computer readable storage medium
CN113867939A (en) * 2021-09-06 2021-12-31 核工业西南物理研究院 Real-time processing and large-screen display system and method for fusion experimental data

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1696940A (en) * 2004-05-25 2005-11-16 中国科学院等离子体物理研究所 Computer Aided Fusion Reactor Conceptual Design System and Method
CN102201908A (en) * 2011-03-24 2011-09-28 中国科学院等离子体物理研究所 EAST central timing system based on PXI (extension for instrumentation)
CN102546727A (en) * 2010-12-31 2012-07-04 上海博泰悦臻电子设备制造有限公司 Full-time on-line system and method of vehicle
CN104599191A (en) * 2015-01-10 2015-05-06 国家电网公司 Smart phone-based transformer station storage battery status cloud service monitoring system and method
CN104601665A (en) * 2014-12-22 2015-05-06 西安电子科技大学 System and method for real-time cloud simulation on Internet of things sensing device
CN104618462A (en) * 2015-01-16 2015-05-13 国家电网公司 Smart phone based cloud service monitoring system and method for storage battery state of transformer substation

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1696940A (en) * 2004-05-25 2005-11-16 中国科学院等离子体物理研究所 Computer Aided Fusion Reactor Conceptual Design System and Method
CN102546727A (en) * 2010-12-31 2012-07-04 上海博泰悦臻电子设备制造有限公司 Full-time on-line system and method of vehicle
CN102201908A (en) * 2011-03-24 2011-09-28 中国科学院等离子体物理研究所 EAST central timing system based on PXI (extension for instrumentation)
CN104601665A (en) * 2014-12-22 2015-05-06 西安电子科技大学 System and method for real-time cloud simulation on Internet of things sensing device
CN104599191A (en) * 2015-01-10 2015-05-06 国家电网公司 Smart phone-based transformer station storage battery status cloud service monitoring system and method
CN104618462A (en) * 2015-01-16 2015-05-13 国家电网公司 Smart phone based cloud service monitoring system and method for storage battery state of transformer substation

Non-Patent Citations (2)

* Cited by examiner, † Cited by third party
Title
律智坚等: "《消息推送在移动高级应用中的研究与实现》", 《广东电力》 *
李光等: "《J_TEXT远程参与实验系统的设计与实现》", 《核聚变与等离子体物理》 *

Cited By (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108234600A (en) * 2017-12-06 2018-06-29 中国航空工业集团公司西安航空计算技术研究所 A kind of data automatic push method implementation method in Air-Ground data transmission
CN110493354A (en) * 2019-09-06 2019-11-22 达疆网络科技(上海)有限公司 A kind of cross-domain self-service ordering system of real-time messages businessman based on WEB
CN112351331A (en) * 2020-10-27 2021-02-09 深圳Tcl新技术有限公司 Message prompting method and device, display equipment and computer readable storage medium
CN113867939A (en) * 2021-09-06 2021-12-31 核工业西南物理研究院 Real-time processing and large-screen display system and method for fusion experimental data

Similar Documents

Publication Publication Date Title
WO2023246347A1 (en) Digital twin processing method and digital twin system
CN105512162B (en) A kind of flow data real-time intelligentization processing frame based on Storm
CN111290763B (en) Event stream processing cluster manager
US8782127B2 (en) Notification based web applications
CN104951996B (en) Power distribution network operational monitoring method based on scalable vector graphics
CN110222923A (en) Dynamically configurable big data analysis system
CN103685309B (en) Method for establishing an asynchronous request queue for map visualization tile service access
US20130086102A1 (en) Asynchronous Communication in Web Applications
US8788627B2 (en) Interactive web application framework
CN110110002A (en) Big data virtual interactive interface system
CA2948700A1 (en) Systems and methods for websphere mq performance metrics analysis
WO2011151112A1 (en) Method and system for executing a graphics application
US9524322B2 (en) Composite active reports
CN106302102A (en) Instant message delivery system
CN103237048A (en) Real-time warning system and real-time warning method of B/S framework in electrical power system
CN114372084A (en) Real-time processing system for sensing stream data
CN109636669A (en) A kind of substation's on-line monitoring method based on multi-process framework
US9614900B1 (en) Multi-process architecture for a split browser
CN106648905A (en) Electric power big data distributed control system and building method thereof
CN104270443B (en) A kind of cloud computing system and method for being capable of dynamic analysis Web applications
WO2014036073A2 (en) Method and apparatus for browsing large data network topology trees
CN107196818A (en) A kind of system and method for Linux cluster monitorings
CN109766236A (en) KAFKA message queue number monitoring method, device, electronic equipment and storage medium
CN107820135B (en) System and method for digital television notification service
CN111651283B (en) A Real-time Collaborative Driving Method of Distributed GIS

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
RJ01 Rejection of invention patent application after publication
RJ01 Rejection of invention patent application after publication

Application publication date: 20170104