技术领域technical field
本发明涉及分布式服务技术领域，更具体的说，是涉及一种基于RabbitMQ和Socket.io的平台级联方法和系统。The present invention relates to the technical field of distributed services, and more specifically, relates to a platform cascading method and system based on RabbitMQ and Socket.io.
背景技术Background technique
在公安行业大型信息系统实施部署过程中，往往需要分布式部署多级平台(国家级、省级、市级、区县级)，而且往往这些平台是异构的或由不同厂商提供的，因此，在这些跨区域的、异构的多级平台之间建立数据交换功能显得尤为重要。在以往传统的平台数据交换方法中，往往是通过数据库同步、ftp、WebService等技术进行数据交换，在数据安全性、数据保密性、系统性能、系统集成度和并发性等方面都比较欠缺，尤其是在异构平台之间实现方式比较复杂，需要一一进行集成，平台之间相互依赖，耦合度过高，平台一方发生网络故障、宕机或维护期间容易导致其他平台出现故障。In the deployment process of large-scale information systems in the public security industry, distributed deployment of multi-level platforms (national, provincial, municipal, district and county levels) is often required, and these platforms are often heterogeneous or provided by different vendors, so , it is particularly important to establish a data exchange function between these cross-regional, heterogeneous multi-level platforms. In the traditional platform data exchange methods in the past, data exchange is often carried out through database synchronization, ftp, WebService and other technologies, which are relatively deficient in data security, data confidentiality, system performance, system integration and concurrency, etc., especially The implementation method between heterogeneous platforms is relatively complicated and needs to be integrated one by one. The platforms are interdependent and the coupling is too high. Network failure, downtime or maintenance of one platform may easily lead to failure of other platforms.
发明内容Contents of the invention
有鉴于此，有必要针对上述问题，提供一种RabbitMQ和Socket.io的平台级联方法和系统，能够实现在跨区域、异构的多级平台之间进行任务协作、信息反馈以及部分业务数据交换功能，满足公安部门在合成作战过程中无缝的数据需求。In view of this, it is necessary to provide a RabbitMQ and Socket.io platform cascading method and system for the above problems, which can realize task collaboration, information feedback and partial business data between cross-regional, heterogeneous multi-level platforms The exchange function meets the seamless data requirements of the public security department in the process of synthetic operations.
为了实现上述目的，本发明的技术方案如下：In order to achieve the above object, the technical scheme of the present invention is as follows:
一种基于RabbitMQ和Socket.io的平台级联方法，包括以下步骤：A platform cascading method based on RabbitMQ and Socket.io, comprising the following steps:
S1、使用行政区域划代码+平台代码作为队列名称和路由键，发起任务协助或反馈协助信息时，通过指定路由键将消息发送给指定队列；各级平台读取任务协助/反馈消息时，通过指定路由键从自己的队列里读取消息；S1. Use the administrative division code + platform code as the queue name and routing key. When initiating task assistance or feedback assistance information, send the message to the designated queue through the specified routing key; when platforms at all levels read task assistance/feedback messages, pass Specify the routing key to read messages from its own queue;
S2、基于Node.js环境搭建socket.io消息实时推送后台服务，其他服务端应用程序或客户端将需要推送的消息以JSON格式提交给socket.io后台服务，再由socket.io后台服务将消息推送或广播给客户端。S2. Build socket.io message real-time push background service based on Node.js environment. Other server applications or clients will submit the message to be pushed to the socket.io background service in JSON format, and then the socket.io background service will send the message Push or broadcast to clients.
作为优选的，所述步骤S1具体包括：As preferably, the step S1 specifically includes:
S11、安装erlang运行环境和RabbitMQ；S11. Install the erlang operating environment and RabbitMQ;
S12、初始化RabbitMQ，创建相关队列并绑定路由键；S12. Initialize RabbitMQ, create relevant queues and bind routing keys;
S13、定制开发消息发送和消息消费方法，并集成到服务端应用程序。S13. Customize and develop message sending and message consumption methods, and integrate them into the server application program.
作为优选的，所述步骤S12具体包括：通过命令窗口调用rabbitmqctl命令及相关参数依次启动应用、创建虚拟机、添加用户和绑定权限、启动web管理程序，完成RabbitMQ初始化基本配置；然后进入web管理程序，根据级联平台的实际情况，结合以上队列及路由键命名规则，创建相关队列并绑定路由键。Preferably, the step S12 specifically includes: calling the rabbitmqctl command and related parameters through the command window to start the application in sequence, create a virtual machine, add users and binding permissions, start the web management program, and complete the RabbitMQ initialization basic configuration; then enter the web management The program, according to the actual situation of the cascading platform, combined with the above queue and routing key naming rules, creates related queues and binds routing keys.
作为优选的，所述S12还包括，添加用户并绑定权限。Preferably, said S12 also includes adding users and binding permissions.
作为优选的，所述步骤S2具体包括：As preferably, said step S2 specifically includes:
S21、安装Node.js和Socket.io模块；S21, installing Node.js and Socket.io modules;
S22、编写Socket.io服务端脚本socketio_server.js，并将该脚本文件放到Node.js安装根目录下，然后在命令行窗口运行node socketio_server.js启动消息实时推送后台服务；S22. Write the Socket.io server script socketio_server.js, and put the script file in the root directory of Node.js installation, and then run node socketio_server.js in the command line window to start the message and push the background service in real time;
S23、服务端应用程序和客户端通过socket.io提供的跨平台的api接口，连接socket.io服务端，并推送或接收消息。S23. The server application and the client connect to the socket.io server through the cross-platform api interface provided by socket.io, and push or receive messages.
作为优选的，所述步骤S21具体包括：获取Node.js安装包并进行安装，在联网环境下通过命令行窗口执行npm install socket.io命令安装Socket.io模块，执行npminstall express安装web容器；或直接拷贝socket.io和express离线包到Node.js安装目录下的node_modules子目录进行离线安装。Preferably, the step S21 specifically includes: obtaining the Node.js installation package and installing it, executing the npm install socket.io command to install the Socket.io module through a command line window in a networked environment, and executing npminstall express to install the web container; or Directly copy the socket.io and express offline packages to the node_modules subdirectory under the Node.js installation directory for offline installation.
作为优选的，所述步骤S22具体包括：As preferably, said step S22 specifically includes:
S221、加载express、http、socket.io三个模块，通过http和express两个模块实现web容器功能，通过io对象的of方法绑定路由notify，通过io的on方法监听connection事件；S221, load express, http, socket.io three modules, implement the web container function through the two modules of http and express, bind the route notify through the of method of the io object, and monitor the connection event through the on method of io;
S222、在io的connection事件回调函数里，给回调参数socket对象绑定join、newmessage、broadcast、disconnect四个事件；通过join事件监听客户端的加入，参数为用户id、用户名；通过new message监听客户端通过emit方法提交的需要发送的消息，并将消息发送给指定的用户，参数为用户id列表和消息内容；通过broadcast广播消息给所有在线用户，参数为消息内容；通过disconnect监听下线的用户。S222. In the connection event callback function of io, bind four events of join, newmessage, broadcast, and disconnect to the callback parameter socket object; monitor the joining of the client through the join event, and the parameters are user id and user name; monitor the client through the new message The terminal submits the message to be sent through the emit method, and sends the message to the specified user. The parameters are the user id list and the message content; broadcast the message to all online users through broadcast, and the parameter is the message content; monitor the offline users through disconnect .
作为优选的，所述步骤S23中，推送或接收消息具体包括：通过join方法加入会话，并向服务器提供用户信息；通过emit方法提交需要发送的消息，参数为事件名称、用户列表和消息内容；通过绑定new message、broadcast事件接收消息。As preferably, in the step S23, pushing or receiving the message specifically includes: joining the session through the join method, and providing user information to the server; submitting the message to be sent through the emit method, and the parameters are event name, user list and message content; Receive messages by binding new message and broadcast events.
一种根据上述方法进行平台级联的系统，包括RabbitMQ消息中心、客户端、服务端应用程序；所述RabbitMQ消息中心用于在Node.js环境下通过Socket.io实现跨平台的消息实时推送，所述客户端和服务端应用程序通过socket.io提供的跨平台的api接口连接RabbitMQ消息中心，并通过join方法加入会话，并向服务器提供用户信息；通过emit方法提交需要发送的消息，参数为事件名称(newmessage、broadcast)、用户列表和消息内容；通过绑定new message、broadcast事件接收消息。A system that carries out platform cascading according to the above-mentioned method, comprises RabbitMQ message center, client, service end application program; Described RabbitMQ message center is used to push in real time by Socket.io cross-platform message under Node.js environment, The client and the server application program are connected to the RabbitMQ message center through the cross-platform api interface provided by socket.io, and join the session through the join method, and provide user information to the server; submit the message that needs to be sent through the emit method, and the parameters are Event name (newmessage, broadcast), user list and message content; receive messages by binding new message and broadcast events.
与现有技术相比，本发明的有益效果在于：通过基于Node.js环境的Socket.io实现跨平台的消息实时推送，通过基于Node.js环境的Express实现基于事件驱动非阻塞I/O模型的Web容器，通过JSON实现轻量级的数据交换，克服了传统数据交换方法在数据安全性、数据保密性、系统性能、系统集成度和并发性等方面的缺点，提供了一种基于RabbitMQ和Socket.io的平台级联方法，该方法能够实现在跨区域、异构的多级平台之间进行任务协作、信息反馈以及部分业务数据交换功能，满足公安部门在合成作战过程中无缝的数据需求。Compared with the prior art, the beneficial effect of the present invention is: Realize cross-platform message real-time push through Socket.io based on Node.js environment, realize event-driven non-blocking I/O model through Express based on Node.js environment The Web container implements lightweight data exchange through JSON, overcomes the shortcomings of traditional data exchange methods in terms of data security, data confidentiality, system performance, system integration and concurrency, etc., and provides a data exchange based on RabbitMQ and Socket.io's platform cascading method, which can realize task collaboration, information feedback and some business data exchange functions between cross-regional and heterogeneous multi-level platforms, satisfying the seamless data integration of public security departments in the process of synthetic operations need.
附图说明Description of drawings
图1为本发明实施例方法流程图；Fig. 1 is the flow chart of the method of the embodiment of the present invention;
图2为本发明实施例系统实施示意图；Fig. 2 is the implementation schematic diagram of the system of the embodiment of the present invention;
图3为本发明实施例系统结构框图。Fig. 3 is a block diagram of the system structure of the embodiment of the present invention.
具体实施方式detailed description
下面结合附图和实施例对本发明所述的一种RabbitMQ和Socket.io的平台级联方法和系统作进一步说明。A method and system for cascading RabbitMQ and Socket.io platforms according to the present invention will be further described below in conjunction with the accompanying drawings and embodiments.
以下是本发明所述的一种RabbitMQ和Socket.io的平台级联方法和系统的最佳实例，并不因此限定本发明的保护范围。The following is a best example of a RabbitMQ and Socket.io platform cascading method and system described in the present invention, which does not limit the protection scope of the present invention.
图1示出了一种基于RabbitMQ和Socket.io的平台级联方法，如图2所示，平台一服务器和平台二服务器通过RabbitMQ实现应用程序对应用程序的通信，通过基于Node.js环境的Socket.io实现跨平台的消息实时推送，通过基于Node.js环境的Express实现基于事件驱动非阻塞I/O模型的Web容器，通过JSON实现轻量级的数据交换，包括以下步骤：Figure 1 shows a platform cascading method based on RabbitMQ and Socket.io. As shown in Figure 2, the platform-1 server and platform-2 server implement application-to-application communication through RabbitMQ, and through Node.js-based environment Socket.io implements cross-platform real-time message push, implements a web container based on event-driven non-blocking I/O model through Express based on Node.js environment, and implements lightweight data exchange through JSON, including the following steps:
S1、使用行政区域划代码(6位)+平台代码(2位)作为队列名称和路由键(RoutingKey)，发起任务协助或反馈协助信息时，通过指定RoutingKey将消息发送给指定队列(queue)；各级平台读取任务协助/反馈消息时，通过指定RoutingKey从自己的队列(queue)里读取消息；S1. Use the administrative division code (6 digits) + platform code (2 digits) as the queue name and routing key (RoutingKey), when initiating task assistance or feedback assistance information, send the message to the designated queue (queue) by specifying the RoutingKey; When platforms at all levels read task assistance/feedback messages, they read messages from their own queues by specifying the RoutingKey;
S2、基于Node.js环境搭建socket.io消息实时推送后台服务，其他服务端应用程序或客户端将需要推送的消息以JSON格式提交给socket.io后台服务，再由socket.io后台服务将消息推送或广播给客户端。S2. Build socket.io message real-time push background service based on Node.js environment. Other server applications or clients will submit the message to be pushed to the socket.io background service in JSON format, and then the socket.io background service will send the message Push or broadcast to clients.
作为优选的，所述步骤S1具体包括：As preferably, the step S1 specifically includes:
S11、安装erlang运行环境和RabbitMQ；从官方网站获取erlang和RabbitMQ安装包，然后依次安装erlang运行环境和RabbitMQ；S11, install the erlang operating environment and RabbitMQ; obtain the erlang and RabbitMQ installation packages from the official website, and then install the erlang operating environment and RabbitMQ in sequence;
S12、初始化RabbitMQ，创建相关队列并绑定路由键；S12. Initialize RabbitMQ, create relevant queues and bind routing keys;
S13、定制开发消息发送和消息消费方法，通过RabbitMQ官方提供的api(c++、java或c#.net等开发语言)定制开发消息发送和消息消费两个方法，并集成到服务端应用程序。S13. Customize and develop message sending and message consumption methods, customize and develop two methods of message sending and message consumption through the API (c++, java or c#.net and other development languages) officially provided by RabbitMQ, and integrate them into the server application.
作为优选的，所述步骤S12具体包括：通过命令行窗口调用rabbitmqctl命令及相关参数依次启动应用、创建虚拟机、添加用户和绑定权限、启动web管理程序(端口为15672，后台服务端口为5672)，完成RabbitMQ初始化基本配置；然后进入web管理程序，根据级联平台的实际情况和以上队列和路由键命名规则，创建相关队列并绑定路由键。Preferably, the step S12 specifically includes: calling the rabbitmqctl command and related parameters through the command line window to start the application in sequence, create a virtual machine, add users and bind permissions, start the web management program (the port is 15672, and the background service port is 5672 ), complete the basic configuration of RabbitMQ initialization; then enter the web management program, create relevant queues and bind routing keys according to the actual situation of the cascading platform and the above naming rules for queues and routing keys.
作为优选的，所述S12还包括，添加用户并绑定权限。Preferably, said S12 also includes adding users and binding permissions.
作为优选的，所述步骤S2具体包括：As preferably, said step S2 specifically includes:
S21、安装Node.js和Socket.io模块；基于Node.js环境搭建socket.io消息实时推送后台服务，其他服务端应用程序或客户端将需要推送的消息以JSON格式提交给socket.io后台服务，再由socket.io后台服务将消息推送或广播给客户端，包括移动终端(android、ios)、C/S客户端、B/S客户端等；S21. Install Node.js and Socket.io modules; build a socket.io message real-time push background service based on the Node.js environment, and other server applications or clients submit messages that need to be pushed to the socket.io background service in JSON format , and then the socket.io background service pushes or broadcasts messages to clients, including mobile terminals (android, ios), C/S clients, B/S clients, etc.;
S22、编写Socket.io服务端脚本socketio_server.js，并将该脚本文件放到Node.js安装根目录下，然后在命令行窗口运行node socketio_server.js启动消息实时推送后台服务(端口为15670)；S22, write the Socket.io server script socketio_server.js, and put the script file under the Node.js installation root directory, then run node socketio_server.js in the command line window to start the message and push the background service in real time (the port is 15670);
S23、服务端应用程序和客户端通过socket.io提供的跨平台的api接口，连接socket.io服务端，并推送或接收消息。S23. The server application and the client connect to the socket.io server through the cross-platform api interface provided by socket.io, and push or receive messages.
作为优选的，所述步骤S21具体包括：从官方网站获取获取Node.js安装包并进行安装，在联网环境下通过命令行窗口执行npm install socket.io命令安装Socket.io模块，执行npm install express安装web容器；或直接拷贝socket.io和express离线包到Node.js安装目录下的node_modules子目录进行离线安装(内网环境)。Preferably, the step S21 specifically includes: obtaining and installing the Node.js installation package from the official website, executing the npm install socket.io command to install the Socket.io module through a command line window in a networked environment, and executing npm install express Install the web container; or directly copy the socket.io and express offline packages to the node_modules subdirectory under the Node.js installation directory for offline installation (intranet environment).
作为优选的，所述步骤S22具体包括：As preferably, said step S22 specifically includes:
S221、通过http和express两个模块实现web容器功能：实例化express对象(变量名为app)，通过http的createServer方法(参数为app)实例化server对象(变量名为server)，通过server对象的listen方法监听15670端口，接收客户端请求；实例化socket.io对象(变量名为io，参数为server)，通过io对象的of方法绑定路由notify，通过io的on方法监听connection事件；S221, implement the web container function through two modules of http and express: instantiate the express object (the variable name is app), instantiate the server object (the variable name is server) through the createServer method of http (the parameter is app), and pass the server object The listen method listens to port 15670 and receives client requests; instantiates the socket.io object (the variable name is io, and the parameter is server), binds the route notify through the of method of the io object, and listens to the connection event through the on method of io;
S222、在io的connection事件回调函数里，给回调参数socket对象绑定join、newmessage、broadcast、disconnect四个事件。通过join事件监听客户端的加入，参数为用户id、用户名；通过new message监听客户端通过emit方法提交的需要发送的消息，并将消息发送给指定的用户，参数为用户id列表和消息内容；通过broadcast广播消息给所有在线用户，参数为消息内容；通过disconnect监听下线的用户。S222. In the connection event callback function of io, bind four events of join, newmessage, broadcast and disconnect to the callback parameter socket object. Monitor the joining of the client through the join event, the parameters are user id and user name; monitor the message to be sent by the client through the emit method through the new message, and send the message to the specified user, the parameter is the user id list and message content; Broadcast a message to all online users through broadcast, and the parameter is the content of the message; monitor offline users through disconnect.
作为优选的，所述步骤S23中，推送或接收消息具体包括：服务端应用程序和客户端(web客户端、移动客户端、C/S客户端)通过socket.io提供的跨平台的api接口，连接socket.io服务端：通过join方法加入会话，并向服务器提供用户信息；通过emit方法提交需要发送的消息，参数为事件名称(new message、broadcast)、用户列表和消息内容；通过绑定new message、broadcast事件接收消息。As preferably, in the step S23, pushing or receiving the message specifically includes: a cross-platform api interface provided by the server application program and the client (web client, mobile client, C/S client) through socket.io , connect to the socket.io server: join the session through the join method, and provide user information to the server; submit the message to be sent through the emit method, and the parameters are event name (new message, broadcast), user list and message content; through binding The new message and broadcast events receive messages.
图3示出了一种根据上述方法进行平台级联的系统，包括RabbitMQ消息中心、客户端、服务端应用程序；所述RabbitMQ消息中心用于在Node.js环境下通过Socket.io实现跨平台的消息实时推送，所述客户端和服务端应用程序通过socket.io提供的跨平台的api接口连接RabbitMQ消息中心，并通过join方法加入会话，并向服务器提供用户信息；通过emit方法提交需要发送的消息，参数为事件名称(new message、broadcast)、用户列表和消息内容；通过绑定newmessage、broadcast事件接收消息。Fig. 3 shows a kind of system that carries out platform cascading according to above-mentioned method, comprises RabbitMQ message center, client, service end application program; Described RabbitMQ message center is used to realize cross-platform by Socket.io under Node.js environment The message is pushed in real time. The client and server applications connect to the RabbitMQ message center through the cross-platform api interface provided by socket.io, join the session through the join method, and provide user information to the server; submit through the emit method to send The parameters are event name (new message, broadcast), user list and message content; receive messages by binding newmessage and broadcast events.
与现有技术相比，本发明的有益效果在于：通过基于Node.js环境的Socket.io实现跨平台的消息实时推送，通过基于Node.js环境的Express实现基于事件驱动非阻塞I/O模型的Web容器，通过JSON实现轻量级的数据交换，克服了传统数据交换方法在数据安全性、数据保密性、系统性能、系统集成度和并发性等方面的缺点，提供了一种基于RabbitMQ和Socket.io的平台级联方法，该方法能够实现在跨区域、异构的多级平台之间进行任务协作、信息反馈以及部分业务数据交换功能，满足公安部门在合成作战过程中无缝的数据需求。Compared with the prior art, the beneficial effect of the present invention is: Realize cross-platform message real-time push through Socket.io based on Node.js environment, realize event-driven non-blocking I/O model through Express based on Node.js environment The Web container implements lightweight data exchange through JSON, overcomes the shortcomings of traditional data exchange methods in terms of data security, data confidentiality, system performance, system integration and concurrency, etc., and provides a data exchange based on RabbitMQ and Socket.io's platform cascading method, which can realize task collaboration, information feedback and some business data exchange functions between cross-regional and heterogeneous multi-level platforms, satisfying the seamless data integration of public security departments in the process of synthetic operations need.
以上所述实施例仅表达了本发明的几种实施方式，其描述较为具体和详细，但并不能因此而理解为对本发明专利范围的限制。应当指出的是，对于本领域的普通技术人员来说，在不脱离本发明构思的前提下，还可以做出若干变形和改进，这些都属于本发明的保护范围。因此，本发明专利的保护范围应以所附权利要求为准。The above-mentioned embodiments only express several implementation modes of the present invention, and the description thereof is relatively specific and detailed, but should not be construed as limiting the patent scope of the present invention. It should be pointed out that those skilled in the art can make several modifications and improvements without departing from the concept of the present invention, and these all belong to the protection scope of the present invention. Therefore, the protection scope of the patent for the present invention should be based on the appended claims.
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610877158.6ACN106445705B (en) | 2016-10-08 | 2016-10-08 | Platform cascading method and system based on RabbitMQ and socket |
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610877158.6ACN106445705B (en) | 2016-10-08 | 2016-10-08 | Platform cascading method and system based on RabbitMQ and socket |
| Publication Number | Publication Date |
|---|---|
| CN106445705Atrue CN106445705A (en) | 2017-02-22 |
| CN106445705B CN106445705B (en) | 2020-06-02 |
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201610877158.6AExpired - Fee RelatedCN106445705B (en) | 2016-10-08 | 2016-10-08 | Platform cascading method and system based on RabbitMQ and socket |
| Country | Link |
|---|---|
| CN (1) | CN106445705B (en) |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107797874A (en)* | 2017-10-12 | 2018-03-13 | 南京中新赛克科技有限责任公司 | A kind of resource management-control method based on embedded jetty and spark on yarn frameworks |
| CN108337116A (en)* | 2018-01-30 | 2018-07-27 | 新华三技术有限公司 | Message order-preserving method and device |
| CN108712272A (en)* | 2018-05-11 | 2018-10-26 | 珠海横琴盛达兆业科技投资有限公司 | Realize that chatroom has new user to enter the method reminded in real time under B/S framework based on nodeJs |
| CN108900485A (en)* | 2018-06-15 | 2018-11-27 | 郑州信大壹密科技有限公司 | Multistage control communication means based on Domestic Platform |
| CN109241226A (en)* | 2018-08-29 | 2019-01-18 | 武汉市星盟科技有限公司 | A kind of synthesis optimal in structure Map Analysis System |
| CN109302337A (en)* | 2018-08-29 | 2019-02-01 | 武汉市星盟科技有限公司 | A kind of chat system fought based on synthesis |
| CN109885410A (en)* | 2019-01-09 | 2019-06-14 | 广州视源电子科技股份有限公司 | Message sending method, device, computer equipment and storage medium |
| CN111211971A (en)* | 2020-01-03 | 2020-05-29 | 西安新能技术有限公司 | A clustered instant messaging system supporting internet consultation service and its implementation method |
| CN111488339A (en)* | 2019-01-25 | 2020-08-04 | 上海哔哩哔哩科技有限公司 | NoSQ L database based on node.JS, and establishing and processing method |
| CN112579309A (en)* | 2019-09-29 | 2021-03-30 | 先临三维科技股份有限公司 | Communication method, communication apparatus, computer device, and computer-readable storage medium |
| CN112671760A (en)* | 2020-12-22 | 2021-04-16 | 平安普惠企业管理有限公司 | Socket-based client cross-platform network communication method and related equipment thereof |
| CN113395321A (en)* | 2021-05-08 | 2021-09-14 | 中山亿联智能科技有限公司 | System supporting multi-system-format pushing and calling of project |
| CN114979056A (en)* | 2022-05-20 | 2022-08-30 | 甬矽电子(宁波)股份有限公司 | E-mail processing method and device, storage medium and electronic equipment |
| CN119937989A (en)* | 2024-11-06 | 2025-05-06 | 中国人民解放军火箭军指挥学院 | A method for constructing a distributed 3D map simulation system based on CesiumJS |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102097014A (en)* | 2011-02-14 | 2011-06-15 | 北京民航中天科技有限责任公司 | Flight ground support service commanding and dispatching system |
| CN104378436A (en)* | 2014-11-20 | 2015-02-25 | 深圳市远行科技有限公司 | Information push system and method based on server push |
| CN105262816A (en)* | 2015-10-27 | 2016-01-20 | 北京天华星航科技有限公司 | Heterogeneous management method based on cloud management platform |
| CN105763426A (en)* | 2016-04-12 | 2016-07-13 | 北京理工大学 | Multiprotocol instant messaging system-based Internet of Things business processing system |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102097014A (en)* | 2011-02-14 | 2011-06-15 | 北京民航中天科技有限责任公司 | Flight ground support service commanding and dispatching system |
| CN104378436A (en)* | 2014-11-20 | 2015-02-25 | 深圳市远行科技有限公司 | Information push system and method based on server push |
| CN105262816A (en)* | 2015-10-27 | 2016-01-20 | 北京天华星航科技有限公司 | Heterogeneous management method based on cloud management platform |
| CN105763426A (en)* | 2016-04-12 | 2016-07-13 | 北京理工大学 | Multiprotocol instant messaging system-based Internet of Things business processing system |
| Title |
|---|
| 丁静: "基于Socket 和消息队列的中后台接口通讯软件的设计", 《学报 大连民族学院》* |
| 叶宁: "Unix杯境下利用Socket和消息队列构建应用通信平台", 《网络技术与资讯》* |
| 朱晓宇等: "基于Socket.io构建Web协同标绘应用", 《软件》* |
| 陈希球: "基于Ｓｏｃｋｅｔ．ＩＯ框架的服务器与浏览器双向实时通信的实现", 《长江工程职业技术学院学报》* |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107797874B (en)* | 2017-10-12 | 2021-04-27 | 南京中新赛克科技有限责任公司 | Resource management and control method based on embedded jetty and spark on grow framework |
| CN107797874A (en)* | 2017-10-12 | 2018-03-13 | 南京中新赛克科技有限责任公司 | A kind of resource management-control method based on embedded jetty and spark on yarn frameworks |
| CN108337116A (en)* | 2018-01-30 | 2018-07-27 | 新华三技术有限公司 | Message order-preserving method and device |
| CN108337116B (en)* | 2018-01-30 | 2021-05-28 | 新华三技术有限公司 | Message order-preserving method and device |
| CN108712272A (en)* | 2018-05-11 | 2018-10-26 | 珠海横琴盛达兆业科技投资有限公司 | Realize that chatroom has new user to enter the method reminded in real time under B/S framework based on nodeJs |
| CN108900485A (en)* | 2018-06-15 | 2018-11-27 | 郑州信大壹密科技有限公司 | Multistage control communication means based on Domestic Platform |
| CN109241226A (en)* | 2018-08-29 | 2019-01-18 | 武汉市星盟科技有限公司 | A kind of synthesis optimal in structure Map Analysis System |
| CN109302337A (en)* | 2018-08-29 | 2019-02-01 | 武汉市星盟科技有限公司 | A kind of chat system fought based on synthesis |
| CN109885410A (en)* | 2019-01-09 | 2019-06-14 | 广州视源电子科技股份有限公司 | Message sending method, device, computer equipment and storage medium |
| CN111488339A (en)* | 2019-01-25 | 2020-08-04 | 上海哔哩哔哩科技有限公司 | NoSQ L database based on node.JS, and establishing and processing method |
| CN111488339B (en)* | 2019-01-25 | 2023-10-27 | 上海哔哩哔哩科技有限公司 | NoSQL database based on node.JS, establishing and processing method |
| CN112579309A (en)* | 2019-09-29 | 2021-03-30 | 先临三维科技股份有限公司 | Communication method, communication apparatus, computer device, and computer-readable storage medium |
| CN111211971A (en)* | 2020-01-03 | 2020-05-29 | 西安新能技术有限公司 | A clustered instant messaging system supporting internet consultation service and its implementation method |
| CN111211971B (en)* | 2020-01-03 | 2021-11-05 | 西安新能技术有限公司 | Cluster type instant message system supporting internet inquiry service and implementation method thereof |
| CN112671760A (en)* | 2020-12-22 | 2021-04-16 | 平安普惠企业管理有限公司 | Socket-based client cross-platform network communication method and related equipment thereof |
| CN113395321A (en)* | 2021-05-08 | 2021-09-14 | 中山亿联智能科技有限公司 | System supporting multi-system-format pushing and calling of project |
| CN114979056A (en)* | 2022-05-20 | 2022-08-30 | 甬矽电子(宁波)股份有限公司 | E-mail processing method and device, storage medium and electronic equipment |
| CN114979056B (en)* | 2022-05-20 | 2023-12-29 | 甬矽电子(宁波)股份有限公司 | E-mail processing method and device, storage medium and electronic equipment |
| CN119937989A (en)* | 2024-11-06 | 2025-05-06 | 中国人民解放军火箭军指挥学院 | A method for constructing a distributed 3D map simulation system based on CesiumJS |
| Publication number | Publication date |
|---|---|
| CN106445705B (en) | 2020-06-02 |
| Publication | Publication Date | Title |
|---|---|---|
| CN106445705A (en) | Platform cascading method and system based on Rabbit MQ and Socket.io | |
| CN106850788B (en) | Integration framework and integration method for multi-source heterogeneous geographic information resources | |
| CN107291523B (en) | Web front-end message bus system | |
| US8990362B2 (en) | Virtual machine provisioning engine | |
| CN101227428B (en) | Application server and remote control method thereof | |
| CN104618435B (en) | Method for realizing remote desktop and remote desktop management system | |
| KR102000990B1 (en) | Micro grid energy management system using dds middleware | |
| JP2010231759A (en) | Mobile terminal device equipped with mobile cloud platform | |
| CN101854338A (en) | Subscriber equipment and its subscription management method, real-time communication method and system | |
| US8356075B2 (en) | Distributed business process management system with local resource utilization | |
| WO2016145747A1 (en) | Smart gateway functional plug-in management method, client terminal and system | |
| CN102833080A (en) | Process-to-process communication method of application software and system | |
| US20210034338A1 (en) | Communications Enablement Platform, System, and Method | |
| CN105183452A (en) | Spring AOP based remote protocol service middleware for monitoring power distribution device | |
| US8117437B2 (en) | System for providing services for applications available under different protocols | |
| CN101448004A (en) | Method, server and system based on instant messaging for releasing user state | |
| CN104301401A (en) | Mobile application platform based on rapid service encapsulation | |
| WO2019205555A1 (en) | Method and apparatus for pushing message | |
| CN114301980A (en) | Method, device and system for scheduling container cluster and computer readable medium | |
| US9513878B2 (en) | Component integration by distribution of schema definition on heterogenous platforms | |
| CN103235813A (en) | Ufida financial core system and activity based costing system data synchronization method | |
| CN112559472B (en) | File transmission method, device, computer equipment and storage medium | |
| CN105897884A (en) | Android mobile phone push platform based on eXtensive messaging presence protocol (XMPP) | |
| CN106488269A (en) | System and method to television equipment control is realized based on third-party application platform | |
| CN114116111B (en) | Method, device, equipment and medium for configuring flow node and data processing |
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| CF01 | Termination of patent right due to non-payment of annual fee | Granted publication date:20200602 |