Granted Patent B2

US 12,506,814 · App. 18/237,106 · Granted Dec 23, 2025

Inventor: Zhenjiang Yu (Beijing, CN)

Assignee: Beijing Jingdong Tuoxian Technology Co., Ltd.

H04L67/55H04L67/12

Abstract

Claims (82)

1 . A message processing method, applied to an acquisition server, comprising:

acquiring a first device message sent by an Internet-of-Things device, wherein the first device message comprises a target message transmission topic name and target device data generated by the Internet-of-Things device; wherein the target message transmission topic name refers to a data transmission topic name corresponding to the target device data generated by the Internet-of-Things device;

acquiring topic mapping relationship configuration information in a configuration database, wherein each stream processing topic name in the topic mapping relationship configuration information corresponds to at least one message transmission topic name; wherein the each stream processing topic name refers to a topic name in a stream processing server;

determining a target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information; wherein the target message transmission topic name corresponds to one of the at least one message transmission topic name; and

generating a second device message based on the target device data and the target stream processing topic name, and sending the second device message to a stream processing server corresponding to the target stream processing topic name so that the stream processing server corresponding to the target stream processing topic name processes the second device message.

2 . The method according to claim 1 , wherein determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information comprises:

matching the target message transmission topic name with message transmission topic prefix information in the topic mapping relationship configuration information to determine successfully matched target message transmission topic prefix information; and

determining the target stream processing topic name corresponding to the Internet-of-Things device based on a stream processing topic name corresponding to the target message transmission topic prefix information in the topic mapping relationship configuration information.

3 . The method according to claim 2 , wherein determining the target stream processing topic name corresponding to the Internet-of-Things device based on the stream processing topic name corresponding to the target message transmission topic prefix information in the topic mapping relationship configuration information comprises:

in a case where at least two pieces of target message transmission topic prefix information exist, acquiring priority configuration information corresponding to each of the at least two pieces of target message transmission topic prefix information;

determining target matching prefix information from the at least two pieces of target message transmission topic prefix information based on the priority configuration information; and

determining a stream processing topic name corresponding to the target matching prefix information in the topic mapping relationship configuration information as the target stream processing topic name corresponding to the Internet-of-Things device.

4 . The method according to claim 1 , wherein generating the second device message based on the target device data and the target stream processing topic name comprises:

acquiring a target message coding configuration scheme corresponding to the target stream processing topic name;

performing coding processing on the target device data based on the target message coding configuration scheme to determine target device coded data; and

generating the second device message based on the target device coded data and the target stream processing topic name.

5 . The method according to claim 1 , wherein acquiring the first device message sent by the Internet-of-Things device comprises:

calling a message monitoring module in a preloaded message processing plug-in to acquire the first device message sent by the Internet-of-Things device;

wherein acquiring the topic mapping relationship configuration information in the configuration database, and determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information comprise:

calling a rule engine module in the message processing plug-in to acquire the topic mapping relationship configuration information in the configuration database, and determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information; and

wherein generating the second device message based on the target device data and the target stream processing topic name, and sending the second device message to the stream processing server corresponding to the target stream processing topic name comprise:

calling a stream processing client module in the message processing plug-in to generate the second device message based on the target device data and the target stream processing topic name, and sending the second device message to the stream processing server corresponding to the target stream processing topic name.

6 . The method according to claim 1 , wherein the acquisition server is a target acquisition server in an acquisition server cluster, and the target acquisition server is connected to the Internet-of-Things device; and

wherein after acquiring the first device message sent by the Internet-of-Things device, the method further comprises:

determining an allowed acquisition server corresponding to the first device message based on the target message transmission topic name and an allowed message transmission topic name corresponding to each acquisition server in the acquisition server cluster; and

in a case where the target acquisition server is not the allowed acquisition server, sending the first device message to the allowed acquisition server so that the allowed acquisition server performs message processing on the first device message.

7 . The method according to claim 1 , wherein sending the second device message to the stream processing server corresponding to the target stream processing topic name so that the stream processing server corresponding to the target stream processing topic name processes the second device message comprises:

sending the second device message to a stream processing server cluster so that a target stream processing server corresponding to the target stream processing topic name in the stream processing server cluster processes the second device message.

8 . A non-transitory computer-readable storage medium storing a computer program, wherein the computer program, when executed by a processor, implements the message processing method according to claim 1 .

9 . A message processing system, comprising an Internet-of-Things device, an acquisition server and a stream processing server; wherein the acquisition server is configured to implement:

acquiring a first device message sent by an Internet-of-Things device, wherein the first device message comprises a target message transmission topic name and target device data generated by the Internet-of-Things device; wherein the target message transmission topic name refers to a data transmission topic name corresponding to the target device data generated by the Internet-of-Things device;

acquiring topic mapping relationship configuration information in a configuration database, wherein each stream processing topic name in the topic mapping relationship configuration information corresponds to at least one message transmission topic name; wherein the each stream processing topic name refers to a topic name in a stream processing server;

determining a target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information; wherein the target message transmission topic name corresponds to one of the at least one message transmission topic name; and

generating a second device message based on the target device data and the target stream processing topic name, and sending the second device message to a stream processing server corresponding to the target stream processing topic name so that the stream processing server corresponding to the target stream processing topic name processes the second device message.

10 . The message processing system according to claim 9 , wherein the acquisition server is configured to implement determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information in the following way:

matching the target message transmission topic name with message transmission topic prefix information in the topic mapping relationship configuration information to determine successfully matched target message transmission topic prefix information; and

determining the target stream processing topic name corresponding to the Internet-of-Things device based on a stream processing topic name corresponding to the target message transmission topic prefix information in the topic mapping relationship configuration information.

11 . The message processing system according to claim 10 , wherein the acquisition server is configured to implement determining the target stream processing topic name corresponding to the Internet-of-Things device based on the stream processing topic name corresponding to the target message transmission topic prefix information in the topic mapping relationship configuration information in the following way:

in a case where at least two pieces of target message transmission topic prefix information exist, acquiring priority configuration information corresponding to each of the at least two pieces of target message transmission topic prefix information;

determining target matching prefix information from the at least two pieces of target message transmission topic prefix information based on the priority configuration information; and

determining a stream processing topic name corresponding to the target matching prefix information in the topic mapping relationship configuration information as the target stream processing topic name corresponding to the Internet-of-Things device.

12 . The message processing system according to claim 9 , wherein the acquisition server is configured to implement generating the second device message based on the target device data and the target stream processing topic name in the following way:

acquiring a target message coding configuration scheme corresponding to the target stream processing topic name;

performing coding processing on the target device data based on the target message coding configuration scheme to determine target device coded data; and

generating the second device message based on the target device coded data and the target stream processing topic name.

13 . The message processing system according to claim 9 , wherein the acquisition server is configured to implement acquiring the first device message sent by the Internet-of-Things device in the following way:

calling a message monitoring module in a preloaded message processing plug-in to acquire the first device message sent by the Internet-of-Things device;

wherein the acquisition server is configured to implement acquiring the topic mapping relationship configuration information in the configuration database, and determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information in the following way:

calling a rule engine module in the message processing plug-in to acquire the topic mapping relationship configuration information in the configuration database, and determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information; and

wherein the acquisition server is configured to implement generating the second device message based on the target device data and the target stream processing topic name, and sending the second device message to the stream processing server corresponding to the target stream processing topic name in the following way:

calling a stream processing client module in the message processing plug-in to generate the second device message based on the target device data and the target stream processing topic name, and sending the second device message to the stream processing server corresponding to the target stream processing topic name.

14 . The message processing system according to claim 9 , wherein the acquisition server is a target acquisition server in an acquisition server cluster, and the target acquisition server is connected to the Internet-of-Things device; and

wherein after acquiring the first device message sent by the Internet-of-Things device, the acquisition server is further configured to implement:

determining an allowed acquisition server corresponding to the first device message based on the target message transmission topic name and an allowed message transmission topic name corresponding to each acquisition server in the acquisition server cluster; and

in a case where the target acquisition server is not the allowed acquisition server, sending the first device message to the allowed acquisition server so that the allowed acquisition server performs message processing on the first device message.

15 . The message processing system according to claim 9 , the acquisition server is configured to implement sending the second device message to the stream processing server corresponding to the target stream processing topic name so that the stream processing server corresponding to the target stream processing topic name processes the second device message in the following way:

sending the second device message to a stream processing server cluster so that a target stream processing server corresponding to the target stream processing topic name in the stream processing server cluster processes the second device message.

16 . An electronic device, comprising:

at least one processor; and

a memory, which is configured to store at least one program;

wherein the at least one program, when executed by the at least one processor, causes the at least one processor to implement:

acquiring a first device message sent by an Internet-of-Things device, wherein the first device message comprises a target message transmission topic name and target device data generated by the Internet-of-Things device; wherein the target message transmission topic name refers to a data transmission topic name corresponding to the target device data generated by the Internet-of-Things device;

acquiring topic mapping relationship configuration information in a configuration database, wherein each stream processing topic name in the topic mapping relationship configuration information corresponds to at least one message transmission topic name; wherein the each stream processing topic name refers to a topic name in a stream processing server;

determining a target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information; wherein the target message transmission topic name corresponds to one of the at least one message transmission topic name; and

generating a second device message based on the target device data and the target stream processing topic name, and sending the second device message to a stream processing server corresponding to the target stream processing topic name so that the stream processing server corresponding to the target stream processing topic name processes the second device message.

17 . The electronic device according to claim 16 , wherein the at least one program, when executed by the at least one processor, causes the at least one processor to implement determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information in the following way:

matching the target message transmission topic name with message transmission topic prefix information in the topic mapping relationship configuration information to determine successfully matched target message transmission topic prefix information; and

determining the target stream processing topic name corresponding to the Internet-of-Things device based on a stream processing topic name corresponding to the target message transmission topic prefix information in the topic mapping relationship configuration information.

18 . The electronic device according to claim 17 , wherein the at least one program, when executed by the at least one processor, causes the at least one processor to implement determining the target stream processing topic name corresponding to the Internet-of-Things device based on the stream processing topic name corresponding to the target message transmission topic prefix information in the topic mapping relationship configuration information in the following way:

in a case where at least two pieces of target message transmission topic prefix information exist, acquiring priority configuration information corresponding to each of the at least two pieces of target message transmission topic prefix information;

determining target matching prefix information from the at least two pieces of target message transmission topic prefix information based on the priority configuration information; and

determining a stream processing topic name corresponding to the target matching prefix information in the topic mapping relationship configuration information as the target stream processing topic name corresponding to the Internet-of-Things device.

19 . The electronic device according to claim 16 , wherein the at least one program, when executed by the at least one processor, causes the at least one processor to implement generating the second device message based on the target device data and the target stream processing topic name in the following way:

acquiring a target message coding configuration scheme corresponding to the target stream processing topic name;

performing coding processing on the target device data based on the target message coding configuration scheme to determine target device coded data; and

generating the second device message based on the target device coded data and the target stream processing topic name.

20 . The electronic device according to claim 16 , wherein the at least one program, when executed by the at least one processor, causes the at least one processor to implement acquiring the first device message sent by the Internet-of-Things device in the following way:

calling a message monitoring module in a preloaded message processing plug-in to acquire the first device message sent by the Internet-of-Things device;

wherein the at least one program, when executed by the at least one processor, causes the at least one processor to implement acquiring the topic mapping relationship configuration information in the configuration database, and determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information in the following way:

calling a rule engine module in the message processing plug-in to acquire the topic mapping relationship configuration information in the configuration database, and determining the target stream processing topic name corresponding to the Internet-of-Things device according to the target message transmission topic name and the topic mapping relationship configuration information; and

wherein the at least one program, when executed by the at least one processor, causes the at least one processor to implement generating the second device message based on the target device data and the target stream processing topic name, and sending the second device message to the stream processing server corresponding to the target stream processing topic name in the following way:

calling a stream processing client module in the message processing plug-in to generate the second device message based on the target device data and the target stream processing topic name, and sending the second device message to the stream processing server corresponding to the target stream processing topic name.

Assignments (1)

Priority Claims (1)

Continuity (1)

References Cited (21)