Movatterモバイル変換


[0]ホーム

URL:


CN107632894A - A kind of implementation method and device for power market transaction service call - Google Patents

A kind of implementation method and device for power market transaction service call
Download PDF

Info

Publication number
CN107632894A
CN107632894ACN201710673388.5ACN201710673388ACN107632894ACN 107632894 ACN107632894 ACN 107632894ACN 201710673388 ACN201710673388 ACN 201710673388ACN 107632894 ACN107632894 ACN 107632894A
Authority
CN
China
Prior art keywords
service
message
message queue
queue
caller
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
CN201710673388.5A
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.)
China Electric Power Research Institute Co Ltd CEPRI
Electric Power Research Institute of State Grid Jiangsu Electric Power Co Ltd
State Grid Corp of China SGCC
Original Assignee
China Electric Power Research Institute Co Ltd CEPRI
Electric Power Research Institute of State Grid Jiangsu Electric Power Co Ltd
State Grid Corp of China SGCC
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 China Electric Power Research Institute Co Ltd CEPRI, Electric Power Research Institute of State Grid Jiangsu Electric Power Co Ltd, State Grid Corp of China SGCCfiledCriticalChina Electric Power Research Institute Co Ltd CEPRI
Priority to CN201710673388.5ApriorityCriticalpatent/CN107632894A/en
Publication of CN107632894ApublicationCriticalpatent/CN107632894A/en
Pendinglegal-statusCriticalCurrent

Links

Landscapes

Abstract

Translated fromChinese

本发明提供一种用于电力市场交易服务调用的实现方法及装置,包括:服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;服务提供端执行所述服务请求消息对应的服务,将所述对应的服务执行结果发送到消息队列中;服务调用端监听消息队列的执行结果消息。通过跨语言标准序列化组件完成调用请求和结果应答的序列化/反序列化,屏蔽程序语言差异,实现电力市场交易平台跨平台、跨应用的高效服务调用和跨语言数据通信。

The present invention provides a method and device for invoking transaction services in the electricity market, including: the service provider creates a message queue on the message bus of the electricity market transaction platform, listens to the service request message in the message queue, and completes the service registration; The caller generates a service request message from the service call request and sends it to the message queue; the service provider executes the service corresponding to the service request message, and sends the corresponding service execution result to the message queue; the service caller monitors the message queue The execution result message. The serialization/deserialization of call requests and result responses is completed through cross-language standard serialization components, shielding program language differences, and realizing cross-platform, cross-application efficient service calls and cross-language data communication of the electricity market trading platform.

Description

Translated fromChinese
一种用于电力市场交易服务调用的实现方法及装置A realization method and device for power market transaction service call

技术领域technical field

本发明属于电力系统自动化技术领域,具体涉及一种用于电力市场交易服务调用的实现方法及装置。The invention belongs to the technical field of electric power system automation, and in particular relates to a method and a device for realizing transaction service calls in electric power markets.

背景技术Background technique

电力市场交易平台不同应用之间以及电力市场交易平台与调度平台应用之间都存在服务调用需求。目前电力交易平台内部不同应用之间,如交易与合同、计划与结算以及各应用与模型之间的访问需求都是基于程序编码和数据库紧耦合实现;电力交易平台与调度平台之间也存在联络线发输电能力计算、安全校核等服务调用需求,目前是通过系统外人工确认实现。由于电力市场交易平台内部以及与调度平台间缺少一种服务调用机制,导致电力交易平台内部应用之间以及与调度平台间通信效率和信息交互复用性低,而程序耦合度和出错机率高。There are service call requirements between different applications of the power market trading platform and between the power market trading platform and dispatching platform applications. At present, the access requirements between different applications in the power trading platform, such as transactions and contracts, planning and settlement, and between applications and models, are all based on program codes and tight coupling of databases; there is also a connection between the power trading platform and the dispatching platform. Service call requirements such as line generation and transmission capacity calculation and safety verification are currently realized through manual confirmation outside the system. Due to the lack of a service call mechanism within the power market trading platform and between the dispatching platform, the communication efficiency and information interaction reusability between the internal applications of the power trading platform and between the dispatching platform are low, while the program coupling degree and error rate are high.

发明内容Contents of the invention

为了克服上述现有技术的不足,本发明提供一种用于电力市场交易服务调用的实现方法及装置。实现电力市场交易平台间应用解耦,提升了应用复用性以及提高交易平台和调度平台服务通信效率;缩减了电力市场交易平台java语言环境和调度平台C++语言环境的差异。In order to overcome the deficiencies of the above-mentioned prior art, the present invention provides a method and device for invoking transaction services in the electricity market. Realize the application decoupling between the electricity market trading platforms, improve the application reusability and improve the service communication efficiency between the trading platform and the dispatching platform; reduce the difference between the Java language environment of the electricity market trading platform and the C++ language environment of the dispatching platform.

为了实现上述发明目的,本发明采取如下技术方案:In order to realize the above-mentioned purpose of the invention, the present invention takes the following technical solutions:

一种用于电力市场交易服务调用的实现方法,包括:An implementation method for invoking electricity market transaction services, including:

服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;The service provider creates a message queue on the message bus of the electricity market trading platform, monitors the service request messages in the message queue, and completes the service registration;

服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;The service caller generates a service request message from the service call request and sends it to the message queue;

服务提供端执行所述服务请求消息对应的服务,将所述对应的服务执行结果发送到消息队列中;The service provider executes the service corresponding to the service request message, and sends the corresponding service execution result to the message queue;

服务调用端监听消息队列的执行结果消息。The service caller monitors the execution result message of the message queue.

优选的,所述服务调用端将服务调用请求生成服务请求消息,包括:设定消息类型为请求消息。Preferably, the service caller generates a service request message from the service call request, including: setting the message type as a request message.

优选的,所述服务调用端将服务调用请求生成服务请求消息,发送到消息队列中,包括:设定消息类型为应答消息。Preferably, the service caller generates a service request message from the service call request and sends it to the message queue, including: setting the message type as a response message.

优选的,所述服务调用端将服务调用请求生成服务请求消息,发送到对应的消息队列中,包括:Preferably, the service caller generates a service request message from the service call request and sends it to the corresponding message queue, including:

服务提供端通过服务程序确认当前服务队列上是否有服务程序监听,如果有,通过服务程序获取服务的接口函数、参数类型以及参数值封装为服务请求消息,序列化后发送到消息队列;否则返回失败。The service provider confirms whether there is a service program listening on the current service queue through the service program, and if so, obtains the service interface function, parameter type, and parameter value through the service program and encapsulates it into a service request message, which is serialized and sent to the message queue; otherwise, returns fail.

优选的,所述将对应的服务执行结果发送到消息队列中,包括:服务提供端将接口函数、参数类型以及参数值反序列化解析后调用本地函数,然后将结果序列化后发送到消息队列。Preferably, sending the corresponding service execution result to the message queue includes: the service provider deserializes and parses the interface function, parameter type and parameter value, calls the local function, and then serializes the result and sends it to the message queue .

进一步地,所述服务的接口函数包含服务语言标识,所述语言标识包括Java和C++;Further, the interface function of the service includes a service language identifier, and the language identifier includes Java and C++;

当所述服务程序采用java实现时,所述服务语言标识为java;当所述服务程序采用C++实现时,所述服务语言标识为C++。When the service program is realized by java, the service language is identified as java; when the service program is implemented by C++, the service language is identified as C++.

优选的,所述对应的服务包括:本地服务和/或调度平台的调度应用服务。Preferably, the corresponding services include: local services and/or scheduling application services of the scheduling platform.

进一步地,所述对应的服务是调度平台安全校核服务;Further, the corresponding service is a dispatching platform security checking service;

服务提供端在消息总线上创建一个安全校核消息队列,监听消息队列中的服务请求消息,完成服务注册;The service provider creates a security verification message queue on the message bus, monitors the service request messages in the message queue, and completes the service registration;

服务调用端将服务调用请求生成安全校核服务请求消息,发送到消息队列中;The service caller generates a security verification service request message from the service call request and sends it to the message queue;

服务提供端执行所述服务请求消息对应的安全校核服务,将所述对应的安全校核服务执行结果发送到消息队列中;The service provider executes the security check service corresponding to the service request message, and sends the execution result of the corresponding security check service to the message queue;

服务调用端监听消息队列的执行结果消息。The service caller monitors the execution result message of the message queue.

进一步地,所述安全校核服务的声明包括:Further, the statement of the security check service includes:

服务提供端在消息队列上注册安全校核服务代理监听程序,监听服务调用端发送的服务请求消息;安全校核服务服务调用端通过客户端安全校核接口发送服务请求消息,安全校核服务代理监听程序执行本地安全校核服务,并将结果发送到安全校核队列;服务调用端接收服务结果消息并反序列化处理获取安全校核结果。The service provider registers the security check service proxy listener program on the message queue, and monitors the service request message sent by the service caller; the security check service service caller sends a service request message through the client security check interface, and the security check service agent The listener executes the local security check service and sends the result to the security check queue; the service caller receives the service result message and deserializes it to obtain the security check result.

一种用于电力市场交易服务调用的实现装置,所述装置包括:An implementation device for invoking transaction services in an electricity market, the device comprising:

注册模块,用于服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;The registration module is used for the service provider to create a message queue on the message bus of the electricity market trading platform, monitor the service request message in the message queue, and complete the service registration;

发送模块,用于服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;The sending module is used for the service caller to generate a service request message from the service call request and send it to the message queue;

调用模块,用于服务提供端执行所述服务请求消息对应的服务,将所述对应的服务执行结果发送到消息队列中;The calling module is used for the service provider to execute the service corresponding to the service request message, and send the corresponding service execution result to the message queue;

接收模块,用于服务调用端监听消息队列的执行结果消息。The receiving module is used for the service caller to monitor the execution result message of the message queue.

优选的,所述调用模块,包括:Preferably, the calling module includes:

判断单元,用于服务调用端通过服务程序确认当前服务队列上是否有服务程序监听,如果有,通过服务程序获取服务的接口函数、参数类型以及参数值,序列化后发送到服务提供端;否则返回失败。The judging unit is used for the service caller to confirm whether there is a service program listening on the current service queue through the service program. If so, obtain the interface function, parameter type and parameter value of the service through the service program, and send it to the service provider after serialization; otherwise Return failure.

处理单元,用于服务提供端将接口函数、参数类型以及参数值反序列化解析后调用本地函数,然后将结果发送到消息队列。The processing unit is used for the service provider to call the local function after deserializing and parsing the interface function, parameter type and parameter value, and then send the result to the message queue.

与最接近的现有技术比,本发明的有益效果为:Compared with the closest prior art, the beneficial effects of the present invention are:

为实现电力市场交易平台间应用解耦、提升应用复用性以及提高交易平台和调度平台服务通信效率,同时考虑到电力市场交易平台java语言环境和调度平台C++语言环境的差异,本发明提供一种用于电力市场交易服务调用的实现方法及装置,可应用于统一电力市场支撑平台,提供跨平台、跨应用服务调用降低电力交易平台应用耦合度,拓展电力交易平台功能。In order to realize application decoupling between trading platforms in the power market, improve application reusability, and improve service communication efficiency between the trading platform and dispatching platform, while taking into account the difference between the Java language environment of the power market trading platform and the C++ language environment of the dispatching platform, the present invention provides a A realization method and device for power market transaction service calls can be applied to a unified power market support platform, provide cross-platform and cross-application service calls, reduce the application coupling degree of the power trading platform, and expand the functions of the power trading platform.

为了响应电力市场交易服务调用端的服务调用请求,服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;In order to respond to the service call request from the power market trading service caller, the service provider creates a message queue on the message bus of the power market trading platform, listens to the service request message in the message queue, and completes the service registration;

服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;服务提供端执行所述服务请求消息对应的服务,将对应的服务执行结果发送到消息队列中;服务调用端监听消息队列的执行结果消息。The service caller generates a service request message from the service call request and sends it to the message queue; the service provider executes the service corresponding to the service request message, and sends the corresponding service execution result to the message queue; the service caller listens to the messages in the message queue Execution result message.

通过以上方案屏蔽了程序语言差异,使得电力市场交易系统内部应用程序之间以及与其它平台之间实现高效服务调用和跨语言数据通信。在整个调度过程中,通过存放至消息队列中等待消息接收者根据自身的负载处理能力控制处理消息的处理速度,可以降低耦合,减小在大并发访问时候的压力。The program language differences are shielded through the above schemes, enabling efficient service calls and cross-language data communication between internal applications of the power market trading system and with other platforms. During the entire scheduling process, by storing in the message queue and waiting for the message receiver to control the processing speed of the message according to its own load processing capacity, the coupling can be reduced and the pressure during large concurrent access can be reduced.

本发明的提出提高了交易平台业务处理效率,适应新一轮电力市场改革,为交易平台逐渐过渡至电力市场交易和生产调度紧密结合的新型电力交易平台提供技术支撑。The proposal of the present invention improves the business processing efficiency of the trading platform, adapts to a new round of power market reform, and provides technical support for the trading platform to gradually transition to a new type of power trading platform that is closely integrated with power market transactions and production scheduling.

附图说明Description of drawings

图1是本发明实施例中电力市场交易服务调用方法实现结构图;FIG. 1 is a structural diagram of an implementation of a power market transaction service calling method in an embodiment of the present invention;

图2是本发明实施例中电力市场交易系统对机组月度发电计划安全校核的方法实现示意图。Fig. 2 is a schematic diagram of the implementation of the method for safety checking of the monthly power generation plan of the unit by the power market transaction system in the embodiment of the present invention.

具体实施方式detailed description

下面结合附图对本发明作进一步详细说明。The present invention will be described in further detail below in conjunction with the accompanying drawings.

如图1所示,电力市场交易跨平台跨应用服务调用方法实现结构图,总体上分为三部分,即消息总线、电力市场交易平台客户端和调度平台。As shown in Figure 1, the implementation structure diagram of the cross-platform cross-application service call method for electricity market transactions is generally divided into three parts, namely, the message bus, the client terminal of the electricity market transaction platform, and the dispatching platform.

左边框图:表示跨语言消息总线,为电力市场交易平台服务注册端提供C++和JAVA两种语言的客户端API接口,为服务注册端和服务客户端提供基于消息的通信功能;The left frame diagram: represents the cross-language message bus, which provides C++ and JAVA client API interfaces for the service registration terminal of the electricity market trading platform, and provides message-based communication functions for the service registration terminal and the service client;

右上方图:表示服务注册端,为电力市场应用和调度应用提供服务注册功能。其中,电力市场交易应用服务通过JAVA对象序列化与交易平台客户端通信,而调度平台应用服务通过跨语言数据结构序列化组件与交易平台客户端服务。Upper right figure: Indicates the service registration terminal, which provides service registration functions for power market applications and dispatching applications. Among them, the power market transaction application service communicates with the trading platform client through JAVA object serialization, and the scheduling platform application service communicates with the trading platform client through cross-language data structure serialization components.

右下方图:表示电力市场交易平台客户端代理,为客户端与服务注册端提供通信代理。客户端代理接口中标识有服务语言信息(C++或JAVA),根据不同标识,JAVA动态代理程序采用不同序列化方式(跨语言数据结构序列化组件或JAVA对象序列化)与注册的服务进行消息通信。Bottom right figure: It represents the client agent of the electricity market trading platform, which provides a communication agent for the client and the service registration terminal. The service language information (C++ or JAVA) is identified in the client agent interface. According to different identifications, the JAVA dynamic agent program uses different serialization methods (cross-language data structure serialization components or JAVA object serialization) to communicate with registered services. .

本发明提供实施例适用于电力市场交易系统对机组月度发电计划进行安全校核的实施方案,如图2所示。该实施例中,提出一种用于电力市场交易服务调用的实现方法,包括:The present invention provides an implementation scheme suitable for the power market trading system to perform safety check on the unit's monthly power generation plan, as shown in FIG. 2 . In this embodiment, an implementation method for power market transaction service invocation is proposed, including:

S1服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;The S1 service provider creates a message queue on the message bus of the electricity market trading platform, monitors the service request messages in the message queue, and completes the service registration;

S2服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;The S2 service caller generates a service request message from the service call request and sends it to the message queue;

S3服务提供端执行所述服务请求消息对应的服务,将所述对应的服务执行结果发送到消息队列中;The S3 service provider executes the service corresponding to the service request message, and sends the corresponding service execution result to the message queue;

其中,服务调用端监听消息队列的执行结果消息。Wherein, the service caller listens to the execution result message of the message queue.

S2中,服务调用端将服务调用请求生成服务请求消息,包括:设定消息类型为请求消息。In S2, the service caller generates a service request message from the service call request, including: setting the message type as a request message.

服务调用端将服务调用请求生成服务请求消息,发送到消息队列中,包括:设定消息类型为应答消息。请求消息和应答消息均按照自定义的通信规约进行传输,其中请求消息自定义通信规约中至少包括电网模型、机组发电计划、设备检修计划信息;应答消息中自定义通信规约中至少包括安全校核是否通过、越限设备信息。The service caller generates a service request message from the service call request and sends it to the message queue, including: setting the message type as a response message. Both the request message and the response message are transmitted according to the self-defined communication protocol, where the request message self-defined communication protocol includes at least the power grid model, unit power generation plan, and equipment maintenance plan information; the self-defined communication protocol in the response message includes at least safety check Whether to pass and exceed the limit equipment information.

请求消息和应答消息基于跨语言序列化组件消息处理流程包括:Request messages and response messages are based on cross-language serialization component message processing flow including:

1)交易平台通过跨语言序列化组件对请求进行序列化处理;1) The trading platform serializes the request through the cross-language serialization component;

2)调度平台安全校核服务监听程序通过跨语言序列化组件对请求消息进行反序列化处理;2) The dispatching platform security verification service listener deserializes the request message through the cross-language serialization component;

3)调度平台安全校核服务监听程序本地安全校核服务调用结果进行序列化处理;3) The dispatching platform security check service listener program performs serialization processing on the calling result of the local security check service;

4)交易平台对结果消息进行反序列化处理获得结果。4) The trading platform deserializes the result message to obtain the result.

服务调用端将服务调用请求生成服务请求消息,发送到对应的消息队列中,包括:The service caller generates a service request message from the service call request and sends it to the corresponding message queue, including:

服务调用端确认当前服务队列上是否有服务程序监听,如果有,将服务接口函数、参数类型以及参数值封装成请求消息,序列化后发送到服务提供端;否则返回失败。The service caller confirms whether there is a service program listening on the current service queue, and if so, encapsulates the service interface function, parameter type, and parameter value into a request message, serializes it and sends it to the service provider; otherwise, returns failure.

S3中,将对应的服务执行结果发送到消息队列中,包括:服务提供端将接口函数、参数类型以及参数值反序列化解析后调用本地函数,然后将结果序列化后发送到消息队列。In S3, the corresponding service execution result is sent to the message queue, including: the service provider deserializes and parses the interface function, parameter type, and parameter value, calls the local function, and then serializes the result and sends it to the message queue.

服务的接口函数包含服务语言标识,所述语言标识包括Java和C++;The interface function of the service includes the service language identification, and the language identification includes Java and C++;

当服务程序采用java实现时,所述服务接口语言标识为java;当所述服务程序采用C++实现时,服务接口语言标识为C++。对应的服务包括:本地服务和/或调度平台的调度应用服务。When the service program is realized by java, the service interface language is identified as java; when the service program is implemented by C++, the service interface language is identified as C++. The corresponding services include: local services and/or scheduling application services of the scheduling platform.

其中,对应的服务是调度平台安全校核服务;Among them, the corresponding service is the security verification service of the dispatching platform;

服务提供端在消息总线上创建一个安全校核消息队列,监听消息队列中的服务请求消息,完成服务注册;The service provider creates a security verification message queue on the message bus, monitors the service request messages in the message queue, and completes the service registration;

服务调用端将服务调用请求生成安全校核服务请求消息,发送到消息队列中;The service caller generates a security verification service request message from the service call request and sends it to the message queue;

服务提供端执行所述服务请求消息对应的安全校核服务,将所述对应的安全校核服务执行结果发送到消息队列中;The service provider executes the security check service corresponding to the service request message, and sends the execution result of the corresponding security check service to the message queue;

服务调用端监听消息队列的执行结果消息。The service caller monitors the execution result message of the message queue.

其中,安全校核服务的声明包括:Among them, the statement of security check service includes:

服务提供端在消息队列上注册安全校核服务代理监听程序,监听服务调用端发送的服务请求消息;安全校核服务服务调用端通过客户端安全校核接口发送服务请求消息,安全校核服务代理监听程序执行本地安全校核服务,并将结果发送到安全校核队列;服务调用端接收服务结果消息并反序列化处理获取安全校核结果。The service provider registers the security check service proxy listener program on the message queue, and monitors the service request message sent by the service caller; the security check service service caller sends a service request message through the client security check interface, and the security check service agent The listener executes the local security check service and sends the result to the security check queue; the service caller receives the service result message and deserializes it to obtain the security check result.

本发明还提供一种用于电力市场交易服务调用的装置,包括:The present invention also provides a device for invoking electricity market transaction services, including:

注册模块,用于服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;The registration module is used for the service provider to create a message queue on the message bus of the electricity market trading platform, monitor the service request message in the message queue, and complete the service registration;

发送模块,用于服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;The sending module is used for the service caller to generate a service request message from the service call request and send it to the message queue;

调用模块,用于服务提供端执行所述服务请求消息对应的服务,将所述对应的服务执行结果发送到消息队列中;The calling module is used for the service provider to execute the service corresponding to the service request message, and send the corresponding service execution result to the message queue;

接收模块,用于服务调用端监听消息队列的执行结果消息。The receiving module is used for the service caller to monitor the execution result message of the message queue.

调用模块,包括:Call modules, including:

判断单元,用于服务调用端通过服务程序确认当前服务队列上是否有服务程序监听,如果有,通过服务程序获取服务的接口函数、参数类型以及参数值,序列化后发送到服务提供端;否则返回失败。The judging unit is used for the service caller to confirm whether there is a service program listening on the current service queue through the service program. If so, obtain the interface function, parameter type and parameter value of the service through the service program, and send it to the service provider after serialization; otherwise Return failure.

处理单元,用于服务提供端将接口函数、参数类型以及参数值反序列化解析后调用本地函数,然后将结果发送到消息队列。The processing unit is used for the service provider to call the local function after deserializing and parsing the interface function, parameter type and parameter value, and then send the result to the message queue.

本领域内的技术人员应明白,本申请的实施例可提供为方法、系统、或计算机程序产品。因此,本申请可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本申请可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。Those skilled in the art should understand that the embodiments of the present application may be provided as methods, systems, or computer program products. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including but not limited to disk storage, CD-ROM, optical storage, etc.) having computer-usable program code embodied therein.

本申请是参照根据本申请实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The present application is described with reference to flowcharts and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the present application. It should be understood that each procedure and/or block in the flowchart and/or block diagram, and a combination of procedures and/or blocks in the flowchart and/or block diagram can be realized by computer program instructions. These computer program instructions may be provided to a general purpose computer, special purpose computer, embedded processor, or processor of other programmable data processing equipment to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing equipment produce a An apparatus for realizing the functions specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to operate in a specific manner, such that the instructions stored in the computer-readable memory produce an article of manufacture comprising instruction means, the instructions The device realizes the function specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions can also be loaded onto a computer or other programmable data processing device, causing a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process, thereby The instructions provide steps for implementing the functions specified in the flow chart or blocks of the flowchart and/or the block or blocks of the block diagrams.

最后应当说明的是:以上实施例仅用以说明本申请的技术方案而非对其保护范围的限制,尽管参照上述实施例对本申请进行了详细的说明,所属领域的普通技术人员应当理解:本领域技术人员阅读本申请后依然可对申请的具体实施方式进行种种变更、修改或者等同替换,这些变更、修改或者等同替换,其均在其申请待批的权利要求范围之内。Finally, it should be noted that: the above embodiments are only used to illustrate the technical solutions of the present application rather than to limit its protection scope. Although the present application has been described in detail with reference to the above embodiments, those of ordinary skill in the art should understand that: After reading this application, those skilled in the art can still make various changes, modifications or equivalent replacements to the specific implementation methods of the application. These changes, modifications or equivalent replacements are all within the scope of the pending claims of the application.

Claims (11)

Translated fromChinese
1.一种用于电力市场交易服务调用的实现方法,其特征在于,1. An implementation method for invoking electricity market transaction services, characterized in that,服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;The service provider creates a message queue on the message bus of the electricity market trading platform, monitors the service request messages in the message queue, and completes the service registration;服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;The service caller generates a service request message from the service call request and sends it to the message queue;服务提供端执行所述服务请求消息对应的服务,将所述对应的服务执行结果发送到消息队列中;The service provider executes the service corresponding to the service request message, and sends the corresponding service execution result to the message queue;服务调用端监听消息队列的执行结果消息。The service caller monitors the execution result message of the message queue.2.如权利要求1所述方法,其特征在于,所述服务调用端将服务调用请求生成服务请求消息,包括:设定消息类型为请求消息。2 . The method according to claim 1 , wherein the service caller generates a service request message from the service call request, comprising: setting the message type as a request message. 3 .3.如权利要求1所述方法,其特征在于,所述服务调用端将服务调用请求生成服务请求消息,发送到消息队列中,包括:设定消息类型为应答消息。3. The method according to claim 1, wherein the service caller generates a service request message from the service call request and sends it to the message queue, comprising: setting the message type as a response message.4.如权利要求1所述的方法,其特征在于,所述服务调用端将服务调用请求生成服务请求消息,发送到对应的消息队列中,包括:4. The method according to claim 1, wherein the service caller generates a service request message from the service call request and sends it to the corresponding message queue, including:服务提供端通过服务程序确认当前服务队列上是否有服务程序监听,如果有,通过服务程序获取服务的接口函数、参数类型以及参数值封装为服务请求消息,序列化后发送到消息队列;否则返回失败。The service provider confirms whether there is a service program listening on the current service queue through the service program, and if so, obtains the service interface function, parameter type, and parameter value through the service program and encapsulates it into a service request message, which is serialized and sent to the message queue; otherwise, returns fail.5.如权利要求1所述的方法,其特征在于,所述将对应的服务执行结果发送到消息队列中,包括:服务提供端将接口函数、参数类型以及参数值反序列化解析后调用本地函数,然后将结果序列化后发送到消息队列。5. The method according to claim 1, wherein the sending the corresponding service execution result to the message queue comprises: the service provider calls the local function, and then serialize the result and send it to the message queue.6.如权利要求4所述的方法,其特征在于,所述服务的接口函数包含服务语言标识,所述语言标识包括Java和C++;6. The method according to claim 4, wherein the interface function of the service includes a service language identifier, and the language identifier includes Java and C++;当所述服务程序采用java实现时,所述服务语言标识为java;当所述服务程序采用C++实现时,所述服务语言标识为C++。When the service program is realized by java, the service language is identified as java; when the service program is implemented by C++, the service language is identified as C++.7.如权利要求1所述方法,其特征在于,所述对应的服务包括:本地服务和/或调度平台的调度应用服务。7. The method according to claim 1, wherein the corresponding service comprises: a local service and/or a scheduling application service of a scheduling platform.8.如权利要求7所述的方法,其特征在于,所述对应的服务是调度平台安全校核服务;8. The method according to claim 7, wherein the corresponding service is a dispatching platform security checking service;服务提供端在消息总线上创建一个安全校核消息队列,监听消息队列中的服务请求消息,完成服务注册;The service provider creates a security verification message queue on the message bus, monitors the service request messages in the message queue, and completes the service registration;服务调用端将服务调用请求生成安全校核服务请求消息,发送到消息队列中;The service caller generates a security verification service request message from the service call request and sends it to the message queue;服务提供端执行所述服务请求消息对应的安全校核服务,将所述对应的安全校核服务执行结果发送到消息队列中;The service provider executes the security check service corresponding to the service request message, and sends the execution result of the corresponding security check service to the message queue;服务调用端监听消息队列的执行结果消息。The service caller monitors the execution result message of the message queue.9.如权利要求8所述的方法,其特征在于,所述安全校核服务的声明包括:9. The method according to claim 8, wherein the statement of the security check service includes:服务提供端在消息队列上注册安全校核服务代理监听程序,监听服务调用端发送的服务请求消息;安全校核服务服务调用端通过客户端安全校核接口发送服务请求消息,安全校核服务代理监听程序执行本地安全校核服务,并将结果发送到安全校核队列;服务调用端接收服务结果消息并反序列化处理获取安全校核结果。The service provider registers the security check service proxy listener program on the message queue, and monitors the service request message sent by the service caller; the security check service service caller sends a service request message through the client security check interface, and the security check service agent The listener executes the local security check service and sends the result to the security check queue; the service caller receives the service result message and deserializes it to obtain the security check result.10.一种用于电力市场交易服务调用的实现装置,其特征在于,所述装置包括:10. An implementation device for power market transaction service invocation, characterized in that the device comprises:注册模块,用于服务提供端在电力市场交易平台消息总线上创建一个消息队列,监听消息队列中的服务请求消息,完成服务注册;The registration module is used for the service provider to create a message queue on the message bus of the electricity market trading platform, monitor the service request message in the message queue, and complete the service registration;发送模块,用于服务调用端将服务调用请求生成服务请求消息,发送到消息队列中;The sending module is used for the service caller to generate a service request message from the service call request and send it to the message queue;调用模块,用于服务提供端执行所述服务请求消息对应的服务,将所述对应的服务执行结果发送到消息队列中;The calling module is used for the service provider to execute the service corresponding to the service request message, and send the corresponding service execution result to the message queue;接收模块,用于服务调用端监听消息队列的执行结果消息。The receiving module is used for the service caller to monitor the execution result message of the message queue.11.如权利要求10所述的装置,其特征在于,所述调用模块,包括:11. The device according to claim 10, wherein the calling module comprises:判断单元,用于服务调用端通过服务程序确认当前服务队列上是否有服务程序监听,如果有,通过服务程序获取服务的接口函数、参数类型以及参数值,序列化后发送到服务提供端;否则返回失败。The judging unit is used for the service caller to confirm whether there is a service program listening on the current service queue through the service program. If so, obtain the interface function, parameter type and parameter value of the service through the service program, and send it to the service provider after serialization; otherwise Return failure.处理单元,用于服务提供端将接口函数、参数类型以及参数值反序列化解析后调用本地函数,然后将结果发送到消息队列。The processing unit is used for the service provider to call the local function after deserializing and parsing the interface function, parameter type and parameter value, and then send the result to the message queue.
CN201710673388.5A2017-08-092017-08-09A kind of implementation method and device for power market transaction service callPendingCN107632894A (en)

Priority Applications (1)

Application NumberPriority DateFiling DateTitle
CN201710673388.5ACN107632894A (en)2017-08-092017-08-09A kind of implementation method and device for power market transaction service call

Applications Claiming Priority (1)

Application NumberPriority DateFiling DateTitle
CN201710673388.5ACN107632894A (en)2017-08-092017-08-09A kind of implementation method and device for power market transaction service call

Publications (1)

Publication NumberPublication Date
CN107632894Atrue CN107632894A (en)2018-01-26

Family

ID=61099382

Family Applications (1)

Application NumberTitlePriority DateFiling Date
CN201710673388.5APendingCN107632894A (en)2017-08-092017-08-09A kind of implementation method and device for power market transaction service call

Country Status (1)

CountryLink
CN (1)CN107632894A (en)

Cited By (9)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN109242244A (en)*2018-08-012019-01-18昆明电力交易中心有限责任公司Electricity transaction bus task traffic monitor method and device, blocker
CN110347522A (en)*2019-07-092019-10-18沈阳欧瑞科技有限公司A kind of server-side and the integrated implementation method of client
CN112527535A (en)*2020-12-292021-03-19福州智永信息科技有限公司Interaction method and terminal based on native WebView extended application
CN112579212A (en)*2019-09-292021-03-30北京国双科技有限公司Cross-language calling method, calling party device and called party device
CN112764716A (en)*2021-01-202021-05-07上海敖智信息科技有限公司Software development method and system
CN112860447A (en)*2019-11-272021-05-28北京沃东天骏信息技术有限公司Interaction method and system between different applications
CN113722123A (en)*2021-08-262021-11-30许继集团有限公司Cross-system multi-type data forwarding transmission method and system
CN113900811A (en)*2021-10-112022-01-07万翼科技有限公司Event-driven task scheduling method and device
CN115022406A (en)*2022-05-232022-09-06中国南方电网有限责任公司Communication method, apparatus, device, medium and program product for electric power spot system

Citations (6)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN101976062A (en)*2010-08-122011-02-16华南理工大学Open type control method based on lightweight service-oriented architectures (LSOA) framework
CN102025653A (en)*2010-06-042011-04-20西本新干线股份有限公司Enterprise service bus and message processing method thereof
CN102629939A (en)*2012-03-142012-08-08广东电网公司电力科学研究院Electric power enterprise service bus realization method and device
CN102662778A (en)*2012-04-282012-09-12杭州格畅科技有限公司Callback response method of inter-application communication on online application platform, application and online application platform
CN105320113A (en)*2015-10-192016-02-10国家电网公司Information interaction method between power grid space information service platform and power distribution automatic system
CN105872578A (en)*2016-03-302016-08-17青岛海信电器股份有限公司Invoking method and server

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN102025653A (en)*2010-06-042011-04-20西本新干线股份有限公司Enterprise service bus and message processing method thereof
CN101976062A (en)*2010-08-122011-02-16华南理工大学Open type control method based on lightweight service-oriented architectures (LSOA) framework
CN102629939A (en)*2012-03-142012-08-08广东电网公司电力科学研究院Electric power enterprise service bus realization method and device
CN102662778A (en)*2012-04-282012-09-12杭州格畅科技有限公司Callback response method of inter-application communication on online application platform, application and online application platform
CN105320113A (en)*2015-10-192016-02-10国家电网公司Information interaction method between power grid space information service platform and power distribution automatic system
CN105872578A (en)*2016-03-302016-08-17青岛海信电器股份有限公司Invoking method and server

Cited By (13)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN109242244A (en)*2018-08-012019-01-18昆明电力交易中心有限责任公司Electricity transaction bus task traffic monitor method and device, blocker
CN109242244B (en)*2018-08-012021-11-12昆明电力交易中心有限责任公司Method and device for monitoring task flow of power transaction bus and interceptor
CN110347522A (en)*2019-07-092019-10-18沈阳欧瑞科技有限公司A kind of server-side and the integrated implementation method of client
CN112579212A (en)*2019-09-292021-03-30北京国双科技有限公司Cross-language calling method, calling party device and called party device
CN112860447A (en)*2019-11-272021-05-28北京沃东天骏信息技术有限公司Interaction method and system between different applications
CN112860447B (en)*2019-11-272024-06-18北京沃东天骏信息技术有限公司Interaction method and system between different applications
CN112527535A (en)*2020-12-292021-03-19福州智永信息科技有限公司Interaction method and terminal based on native WebView extended application
CN112527535B (en)*2020-12-292023-05-16宝宝巴士股份有限公司Interaction method and terminal based on native WebView extension application
CN112764716A (en)*2021-01-202021-05-07上海敖智信息科技有限公司Software development method and system
CN113722123A (en)*2021-08-262021-11-30许继集团有限公司Cross-system multi-type data forwarding transmission method and system
CN113722123B (en)*2021-08-262024-05-14许继集团有限公司Cross-system multi-type data forwarding transmission method and system
CN113900811A (en)*2021-10-112022-01-07万翼科技有限公司Event-driven task scheduling method and device
CN115022406A (en)*2022-05-232022-09-06中国南方电网有限责任公司Communication method, apparatus, device, medium and program product for electric power spot system

Similar Documents

PublicationPublication DateTitle
CN107632894A (en)A kind of implementation method and device for power market transaction service call
CN109815025B (en)Service model calling method, device and storage medium
CN108683636B (en)Charging pile communication method and system
WO2020181599A1 (en)Model application method and system, and model management method and server
CN108881111B (en)Method and device for realizing multi-tenant system
TWI650645B (en) Hybrid-based compatible method, adapter, operating device and system
CN110620819B (en)Block chain interaction method and device, computer equipment and readable storage medium
CN114884956B (en) Implementation method, device and multi-cluster architecture system of multi-cluster architecture
CN113703997A (en)Bidirectional asynchronous communication middleware system integrating multiple message agents and implementation method
CN111353880B (en)Transaction service packaging method, device and system
CN112818058B (en)Method and device for trusted data interaction between block chain and off-chain system
CN113746683B (en) Interconnection, Interoperability and Interoperability Simulation Methods in Cross-Domain Environment
CN111786939B (en)Method, device and system for testing management platform of Internet of things
CN115422036A (en)Vehicle-end SOA service call chain tracking method based on OpenTelemetry
CN112181681A (en)Remote calling method and device, computer equipment and storage medium
CN107329809A (en)A kind of distributed transaction processing method and system towards multi-data source
CN105227639A (en)A kind of transformer station's remote pictures transfer approach and the alarm of a kind of transformer station direct transfer method
CN115314540A (en) A method, device, device and medium for processing request response timeout
CN107451059A (en)A kind of method for testing software and test device
CN109683875B (en)Application framework system of MVC (model view controller) pattern in distributed environment and method thereof
CN112202605A (en)Service configuration method, device, equipment and storage medium
CN116319989A (en)Data exchange method, system, equipment and medium of industrial control system
CN102420849A (en)Mobile main body platform model and mobile main body migration method
CN114371947B (en) Distributed application method and device for encapsulating host services into microservices
CN101795237A (en)Workflow integration method and device based on data exchange

Legal Events

DateCodeTitleDescription
PB01Publication
PB01Publication
SE01Entry into force of request for substantive examination
SE01Entry into force of request for substantive examination
RJ01Rejection of invention patent application after publication

Application publication date:20180126

RJ01Rejection of invention patent application after publication

[8]ページ先頭

©2009-2025 Movatter.jp