CN106412018B - Message pushing method and device - Google Patents
Message pushing method and device Download PDFInfo
- Publication number
- CN106412018B CN106412018B CN201610788992.8A CN201610788992A CN106412018B CN 106412018 B CN106412018 B CN 106412018B CN 201610788992 A CN201610788992 A CN 201610788992A CN 106412018 B CN106412018 B CN 106412018B
- Authority
- CN
- China
- Prior art keywords
- terminal
- identification
- message
- identifier
- preset information
- 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.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 32
- 238000005192 partition Methods 0.000 claims description 62
- 238000013507 mapping Methods 0.000 claims description 32
- 238000000638 solvent extraction Methods 0.000 claims description 18
- 238000010586 diagram Methods 0.000 description 5
- 230000006870 function Effects 0.000 description 4
- 238000004891 communication Methods 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 230000008569 process Effects 0.000 description 2
- 230000004075 alteration Effects 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 238000012545 processing Methods 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/55—Push-based network services
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/02—Details
- H04L12/16—Arrangements for providing special services to substations
- H04L12/18—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast
- H04L12/1859—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast adapted to provide push services, e.g. data channels
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Information Transfer Between Computers (AREA)
- Mobile Radio Communication Systems (AREA)
Abstract
The invention provides a message pushing method and a device, wherein the message pushing method comprises the steps of receiving a message to be pushed, and the message to be pushed comprises the following steps: a message body and a target group identity; reading a terminal identification corresponding to each target group identification from an information base, and reading preset information of each terminal identification according to the corresponding terminal identification; and pushing the message to be pushed to the terminal corresponding to each terminal identification in parallel according to the preset information. The method and the device can effectively improve the timeliness of pushing the message to be pushed, avoid the limitation of the number of the terminals in the group and improve the user experience.
Description
Technical Field
The present invention relates to the field of network communication technologies, and in particular, to a message pushing method and apparatus.
Background
With the continuous development of network communication technology, instant messaging is used as a common network communication mode. In the related art, instant messages mainly have two types of sending modes: the push method comprises a push mode and a pull mode, wherein the push mode is that after a sending end sends a message to be pushed, a server pushes the message to be pushed to all terminal users in a group in real time; the pull mode is that after the sending end sends the message to be pushed, the message to be pushed is stored in the message storage device of the server, and the terminal user in the group pulls the message to be pushed regularly.
In this way, the number of people who can be online at the same time supported by the push mode is limited, and the number of people in the group receiving the message to be pushed is below ten thousand; the message to be pushed sent in the pull mode has low instantaneity, and when no person in the group speaks, a large amount of invalid accesses are caused, and the flow of the user is wasted.
Disclosure of Invention
The present invention is directed to solving, at least to some extent, one of the technical problems in the related art.
Therefore, an object of the present invention is to provide a message pushing method, which can effectively improve the timeliness of pushing a message to be pushed, avoid the limitation of the number of terminals in a group, and improve user experience.
Another object of the present invention is to provide a message pushing apparatus.
In order to achieve the above object, an embodiment of the first aspect of the present invention provides a message pushing method, including: receiving a message to be pushed, wherein the message to be pushed comprises: a message body and a target group identity; reading a terminal identification corresponding to each target group identification from an information base, and reading preset information of each terminal identification according to the corresponding terminal identification; and pushing the message to be pushed to the terminal corresponding to each terminal identification in parallel according to the preset information.
According to the message pushing method provided by the embodiment of the first aspect of the invention, the terminal identification corresponding to each target group identification is read from the information base, the preset information of each terminal identification is read according to the corresponding terminal identification, and the message to be pushed is pushed to the terminal corresponding to each terminal identification in parallel according to the preset information, so that the timeliness of pushing the message to be pushed can be effectively improved, the limitation of the number of terminals in the group is avoided, and the user experience is improved.
In order to achieve the above object, an embodiment of the second aspect of the present invention provides an apparatus, including: a first receiving module, configured to receive a message to be pushed, where the message to be pushed includes: a message body and a target group identity; the reading module is used for reading the terminal identification corresponding to each target group identification from the information base and reading the preset information of each terminal identification according to the corresponding terminal identification; and the pushing module is used for pushing the message to be pushed to the terminal corresponding to each terminal identification in parallel according to the preset information.
According to the message pushing device provided by the embodiment of the second aspect of the invention, the terminal identification corresponding to each target group identification is read from the information base, the preset information of each terminal identification is read according to the corresponding terminal identification, and the message to be pushed is pushed to the terminal corresponding to each terminal identification in parallel according to the preset information, so that the timeliness of pushing the message to be pushed can be effectively improved, the limitation of the number of terminals in the group is avoided, and the user experience is improved.
Additional aspects and advantages of the invention will be set forth in part in the description which follows and, in part, will be obvious from the description, or may be learned by practice of the invention.
Drawings
The foregoing and/or additional aspects and advantages of the present invention will become apparent and readily appreciated from the following description of the embodiments, taken in conjunction with the accompanying drawings of which:
fig. 1 is a schematic flowchart of a message pushing method according to an embodiment of the present invention;
fig. 2 is a flowchart illustrating a message pushing method according to another embodiment of the present invention;
fig. 3 is a schematic diagram of a mapping relationship between a group identifier and a terminal identifier in the embodiment of the present invention;
fig. 4 is a flowchart illustrating a message pushing method according to another embodiment of the present invention;
fig. 5 is a flowchart illustrating a message pushing method according to another embodiment of the present invention;
fig. 6 is a schematic structural diagram of a message pushing apparatus according to an embodiment of the present invention;
fig. 7 is a schematic structural diagram of a message pushing apparatus according to another embodiment of the present invention.
Detailed Description
Reference will now be made in detail to embodiments of the present invention, examples of which are illustrated in the accompanying drawings, wherein like or similar reference numerals refer to the same or similar elements or elements having the same or similar function throughout. The embodiments described below with reference to the accompanying drawings are illustrative only for the purpose of explaining the present invention, and are not to be construed as limiting the present invention. On the contrary, the embodiments of the invention include all changes, modifications and equivalents coming within the spirit and terms of the claims appended hereto.
Fig. 1 is a flowchart illustrating a message pushing method according to an embodiment of the present invention. This message push method is exemplified by being configured as a message push apparatus. The message pushing method can be applied to a server.
Referring to fig. 1, the message push method includes:
s11: receiving a message to be pushed, wherein the message to be pushed comprises: a message body and a target group identification.
In an embodiment of the present invention, the target group identification is at least one.
In the embodiment of the present invention, the message to be pushed may be a message that the sending end needs to push.
In an embodiment of the present invention, the message body includes, but is not limited to, sender identification (e.g., sender ID), message content, and target group identification (e.g., target group ID), etc. information.
Optionally, the sending end sends a message to be pushed to the server, and the server receives the message to be pushed sent by the sending end, so as to read the terminal identifier corresponding to the message from the information base according to the target group identifier in the message to be pushed, and thus, the message to be pushed is pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information of the terminal identifier.
S12: and reading the terminal identification corresponding to each target group identification from the information base, and reading the preset information of each terminal identification according to the corresponding terminal identification.
In the embodiment of the invention, the terminal identifier corresponding to each target group identifier is at least one.
In embodiments of the present invention, the information base may be pre-established.
In the embodiment of the present invention, the preset information is long connection information, and the information base includes: and the mapping relation among the long connection information base, the group identification and the terminal identification.
In the embodiment of the present invention, the partition identifier corresponding to each target group identifier may be obtained according to a mapping relationship between the group identifier and the terminal identifier, where the target group identifier is at least one and the corresponding partition identifier is at least one; acquiring a terminal identifier corresponding to each partition identifier according to a mapping relation between the group identifier and the terminal identifier, wherein the number of the corresponding terminal identifiers is at least one; and reading the preset information of each terminal identification from the long connection information base according to the corresponding terminal identification.
Alternatively, in some embodiments, referring to fig. 2, the information base is established by:
s21: receiving a request message sent by a terminal, wherein the request message comprises: the system comprises a terminal identification, a target group identification and preset information of the terminal.
Optionally, a request message sent by the terminal is received, where the request message includes: a terminal identification (e.g., a terminal ID), a target group identification (e.g., a target group ID), and preset information of the terminal (e.g., long connection information of the terminal) to determine whether the preset information of the terminal is in the long connection information base according to the terminal identification in the request message.
S22: and judging whether the preset information of the terminal is in the long connection information base or not according to the terminal identification, if so, executing S24, and if not, executing S23.
Optionally, it is determined whether the preset information of the terminal is in the long connection information base according to the terminal identifier, for example, it is determined whether the long connection information of the terminal already exists in the long connection information base according to the terminal ID, so as to trigger the subsequent step.
S23: and adding the preset information of the terminal into the long connection information base.
Optionally, when the preset information of the terminal is not in the long connection information base, the preset information of the terminal is added to the long connection information base, that is, the long connection information of the terminal is added to the long connection information base, and the terminal identifier serves as a unique identifier of the stored information, that is, whether the preset information of the terminal is in the long connection information base may be determined according to the terminal identifier.
S24: and partitioning the terminal identification according to a preset rule, and acquiring a partition identification.
In an embodiment of the present invention, the preset rule is determined according to any one of the following ways: partitioning according to a Hash algorithm; according to the mode of terminal memory partitioning; and partitioning the area according to the mode of the terminal.
Optionally, when the preset information of the terminal is in the long connection information base or the preset information of the terminal is added to the long connection information base, partitioning the terminal identifier according to a preset rule, and acquiring a partition identifier (e.g., a partition ID), so as to generate a mapping relationship between the group identifier and the terminal identifier according to the terminal identifier, the partition identifier, the target group identifier, and the preset information of the terminal.
S25: and generating a mapping relation between the group identification and the terminal identification according to the terminal identification, the partition identification, the target group identification and the preset information of the terminal.
Optionally, a mapping relationship between the group identifier and the terminal identifier is generated according to the terminal identifier, the partition identifier, the target group identifier, and the preset information of the terminal, so that the terminal identifier corresponding to each target group identifier is conveniently read, and the time for identifying the terminal identifier is shortened.
As an example, referring to fig. 3, fig. 3 is a schematic diagram of a mapping relationship between a group identifier and a terminal identifier in the embodiment of the present invention, where a root node is the group identifier, a next layer of the group identifier includes a partition identifier, a next layer of the partition identifier is the terminal identifier, and each terminal identifier corresponds to unique preset information of a terminal, that is, long connection information of the terminal.
S26: and storing the mapping relation between the group identification and the terminal identification in an information base.
Optionally, the mapping relationship between the group identifier and the terminal identifier is stored in an information base, so that the server reads the terminal identifier corresponding to each target group identifier from the information base.
In the embodiment, the terminal identification is partitioned according to the preset rule, the partition identification is obtained, the mapping relation between the group identification and the terminal identification is generated according to the terminal identification, the partition identification, the target group identification and the preset information of the terminal, and the mapping relation between the group identification and the terminal identification is stored in the information base, so that the terminal identification corresponding to each target group identification can be conveniently read from the information base, the time for identifying the terminal identification is shortened, and the timeliness for pushing the message to be pushed is effectively improved.
Optionally, in some embodiments, referring to fig. 4, step S12 specifically includes:
s41: and acquiring the partition identifier corresponding to each target group identifier according to the mapping relation between the group identifiers and the terminal identifiers, wherein the number of the target group identifiers is at least one, and the number of the corresponding partition identifiers is at least one.
For example, referring to fig. 3, the partition identifier corresponding to each target group identifier may be obtained according to the mapping relationship between the group identifier and the terminal identifier, and as can be seen from fig. 3, the partition identifier corresponding to each target group identifier is at least one.
S42: and acquiring a terminal identifier corresponding to each partition identifier according to the mapping relation between the group identifiers and the terminal identifiers, wherein the number of the corresponding terminal identifiers is at least one.
For example, referring to fig. 3, the terminal identifier corresponding to each partition identifier may be obtained according to a mapping relationship between the group identifier and the terminal identifier, and as can be seen from fig. 3, the terminal identifier corresponding to each partition identifier is at least one.
S43: and reading the preset information of each terminal identification from the long connection information base according to the corresponding terminal identification.
For example, referring to fig. 3, each terminal identifier corresponds to unique preset information, and the preset information of each terminal identifier may be read from the long connection information base according to the corresponding terminal identifier, so as to push the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information.
In this embodiment, the terminal identifier corresponding to each partition identifier is obtained according to the mapping relationship between the group identifier and the terminal identifier, the preset information of each terminal identifier is read from the long connection information base according to the corresponding terminal identifier, and the message to be pushed can be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information, so that the timeliness of pushing the message to be pushed is effectively improved, and the limitation of the number of the group terminals is avoided.
S13: and pushing the message to be pushed to the terminal corresponding to each terminal identification in parallel according to the preset information.
Optionally, referring to fig. 3, as can be seen from fig. 3, since each terminal identifier corresponds to unique preset information, the server may push the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information of each terminal identifier.
Optionally, in some embodiments, referring to fig. 5, step S13 specifically includes:
s51: and establishing a push task for each partition identifier, wherein the number of the push tasks is the same as that of the corresponding partition identifiers, and at least one push task is executed in parallel.
Optionally, the server acquires all partition identifiers in the group according to the group identifier, referring to fig. 3, and establishes a parallel push task according to the number of the partition identifiers, where the push task is responsible for acquiring preset information of all terminals in the partition according to the partition identifiers, so as to push the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information.
S52: and parallelly executing the pushing task of each partition identifier in the corresponding partition identifier so as to parallelly push the message to be pushed to the terminal corresponding to each terminal identifier according to the preset information.
Optionally, the pushing task of each partition identifier in the partition identifiers corresponding to the group identifier is executed in parallel, so that the message to be pushed is pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information, the timeliness of pushing the message to be pushed can be effectively improved, and the limitation of the number of the terminals in the group is avoided.
In this embodiment, a push task is established for each partition identifier, and the push task of each partition identifier in the corresponding partition identifiers is executed in parallel, so that the message to be pushed is pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information, the timeliness of the message to be pushed can be effectively improved, the limitation of the number of terminals in a group is avoided, and the user experience is improved.
In this embodiment, the terminal identifier corresponding to each target group identifier is read from the information base, the preset information of each terminal identifier is read according to the corresponding terminal identifier, and the message to be pushed is pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information, so that the timeliness of pushing the message to be pushed can be effectively improved, the limitation of the number of terminals in the group is avoided, and the user experience is improved.
Fig. 6 is a schematic structural diagram of a message pushing apparatus according to an embodiment of the present invention. The message pushing device 60 may be implemented by software, hardware or a combination of the two, and the message pushing device 60 may include: a first receiving module 601, a reading module 602, and a pushing module 603. Wherein,
a first receiving module 601, configured to receive a message to be pushed, where the message to be pushed includes: a message body and a target group identification.
A reading module 602, configured to read a terminal identifier corresponding to each target group identifier from the information base, and read preset information of each terminal identifier according to the corresponding terminal identifier.
Optionally, the preset information is long connection information, and the information base includes: and the mapping relation among the long connection information base, the group identification and the terminal identification.
The pushing module 603 is configured to push the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information.
In some embodiments, referring to fig. 7, the message pushing device 60 may further include:
optionally, the reading module 602 includes:
the first obtaining submodule 6021 is configured to obtain, according to a mapping relationship between the group identifier and the terminal identifier, a partition identifier corresponding to each target group identifier, where the target group identifier is at least one and the corresponding partition identifier is at least one.
The second obtaining submodule 6022 is configured to obtain, according to a mapping relationship between the group identifier and the terminal identifier, a terminal identifier corresponding to each partition identifier, where the number of the corresponding terminal identifiers is at least one.
The reading sub-module 6023 is configured to read preset information of each terminal identifier from the long connection information base according to the corresponding terminal identifier.
Optionally, the pushing module 603 includes:
the establishing submodule 6031 is configured to establish a push task for each partition identifier, where the number of the push tasks is the same as that of the corresponding partition identifiers, and at least one of the push tasks is executed in parallel.
And the execution sub-module 6032 is configured to execute the pushing task of each partition identifier in the corresponding partition identifier in parallel, so as to push the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information.
Optionally, the information base is built by:
a second receiving module 604, configured to receive a request message sent by a terminal, where the request message includes: the system comprises a terminal identification, a target group identification and preset information of the terminal.
The determining module 605 is configured to determine whether the preset information of the terminal is in the long connection information base according to the terminal identifier.
An adding module 606, configured to add the preset information of the terminal to the long connection information base when the preset information of the terminal is not in the long connection information base.
The partitioning module 607 is configured to partition the terminal identifier according to a preset rule and obtain the partition identifier when the preset information of the terminal is in the long connection information base or the preset information of the terminal is added to the long connection information base.
Optionally, the preset rule is determined according to any one of the following ways: partitioning according to a Hash algorithm; according to the mode of terminal memory partitioning; and partitioning the area according to the mode of the terminal.
The generating module 608 is configured to generate a mapping relationship between the group identifier and the terminal identifier according to the terminal identifier, the partition identifier, the target group identifier, and preset information of the terminal.
A storing module 609, configured to store the mapping relationship between the group identifier and the terminal identifier in the information base.
It should be noted that the explanation of the message pushing method in the foregoing embodiments of fig. 1 to fig. 5 also applies to the message pushing apparatus 60 of this embodiment, and the implementation principle is similar, and is not described again here.
In this embodiment, the terminal identifier corresponding to each target group identifier is read from the information base, the preset information of each terminal identifier is read according to the corresponding terminal identifier, and the message to be pushed is pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information, so that the timeliness of pushing the message to be pushed can be effectively improved, the limitation of the number of terminals in the group is avoided, and the user experience is improved.
It should be noted that the terms "first," "second," and the like in the description of the present invention are used for descriptive purposes only and are not to be construed as indicating or implying relative importance. In addition, in the description of the present invention, "a plurality" means two or more unless otherwise specified.
Any process or method descriptions in flow charts or otherwise described herein may be understood as representing modules, segments, or portions of code which include one or more executable instructions for implementing specific logical functions or steps of the process, and alternate implementations are included within the scope of the preferred embodiment of the present invention in which functions may be executed out of order from that shown or discussed, including substantially concurrently or in reverse order, depending on the functionality involved, as would be understood by those reasonably skilled in the art of the present invention.
It should be understood that portions of the present invention may be implemented in hardware, software, firmware, or a combination thereof. In the above embodiments, the various steps or methods may be implemented in software or firmware stored in memory and executed by a suitable instruction execution system. For example, if implemented in hardware, as in another embodiment, any one or combination of the following techniques, which are known in the art, may be used: a discrete logic circuit having a logic gate circuit for implementing a logic function on a data signal, an application specific integrated circuit having an appropriate combinational logic gate circuit, a Programmable Gate Array (PGA), a Field Programmable Gate Array (FPGA), or the like.
It will be understood by those skilled in the art that all or part of the steps carried by the method for implementing the above embodiments may be implemented by hardware related to instructions of a program, which may be stored in a computer readable storage medium, and when the program is executed, the program includes one or a combination of the steps of the method embodiments.
In addition, functional units in the embodiments of the present invention may be integrated into one processing module, or each unit may exist alone physically, or two or more units are integrated into one module. The integrated module can be realized in a hardware mode, and can also be realized in a software functional module mode. The integrated module, if implemented in the form of a software functional module and sold or used as a stand-alone product, may also be stored in a computer readable storage medium.
The storage medium mentioned above may be a read-only memory, a magnetic or optical disk, etc.
In the description herein, references to the description of the term "one embodiment," "some embodiments," "an example," "a specific example," or "some examples," etc., mean that a particular feature, structure, material, or characteristic described in connection with the embodiment or example is included in at least one embodiment or example of the invention. In this specification, the schematic representations of the terms used above do not necessarily refer to the same embodiment or example. Furthermore, the particular features, structures, materials, or characteristics described may be combined in any suitable manner in any one or more embodiments or examples.
Although embodiments of the present invention have been shown and described above, it is understood that the above embodiments are exemplary and should not be construed as limiting the present invention, and that variations, modifications, substitutions and alterations can be made to the above embodiments by those of ordinary skill in the art within the scope of the present invention.
Claims (8)
1. A message pushing method, comprising the steps of:
receiving a message to be pushed, wherein the message to be pushed comprises: a message body and a target group identity;
reading a terminal identification corresponding to each target group identification from an information base, and reading preset information of each terminal identification according to the corresponding terminal identification;
according to the preset information, the message to be pushed is pushed to the terminal corresponding to each terminal identification in parallel;
the preset information is long connection information, and the information base comprises: mapping relation of the long connection information base, the group identification and the terminal identification;
the reading of the terminal identification corresponding to each target group identification from the information base and the reading of the preset information of each terminal identification according to the corresponding terminal identification comprises the following steps:
acquiring a partition identifier corresponding to each target group identifier according to the mapping relation between the group identifiers and the terminal identifiers, wherein the number of the target group identifiers is at least one, and the number of the corresponding partition identifiers is at least one;
acquiring a terminal identifier corresponding to each partition identifier according to the mapping relation between the group identifiers and the terminal identifiers, wherein the number of the corresponding terminal identifiers is at least one; and
and reading the preset information of each terminal identification from the long connection information base according to the corresponding terminal identification.
2. The message pushing method according to claim 1, wherein the pushing the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information comprises:
establishing a push task for each partition identifier, wherein the number of the push tasks is the same as that of the corresponding partition identifiers, and at least one push task is executed in parallel;
and executing the pushing task of each partition identifier in the corresponding partition identifier in parallel, so as to push the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information.
3. The message pushing method of claim 1, wherein the information base is established by:
receiving a request message sent by a terminal, wherein the request message comprises: the method comprises the steps of identifying a terminal, identifying a target group and presetting information of the terminal;
judging whether preset information of the terminal is in the long connection information base or not according to the terminal identification;
if the preset information of the terminal is not in the long connection information base, adding the preset information of the terminal into the long connection information base;
if the preset information of the terminal is in the long connection information base or the preset information of the terminal is added into the long connection information base, partitioning the terminal identification according to a preset rule, and acquiring a partition identification;
generating a mapping relation between the group identification and the terminal identification according to the terminal identification, the partition identification, the target group identification and preset information of the terminal;
and storing the mapping relation between the group identification and the terminal identification in the information base.
4. The message pushing method of claim 3, wherein the preset rule is determined according to any one of the following ways:
partitioning according to a Hash algorithm;
according to the mode of terminal memory partitioning;
and partitioning the area according to the mode of the terminal.
5. A message push apparatus, comprising:
a first receiving module, configured to receive a message to be pushed, where the message to be pushed includes: a message body and a target group identity;
the reading module is used for reading the terminal identification corresponding to each target group identification from the information base and reading the preset information of each terminal identification according to the corresponding terminal identification;
the pushing module is used for pushing the message to be pushed to the terminal corresponding to each terminal identification in parallel according to the preset information;
the preset information is long connection information, and the information base comprises: mapping relation of the long connection information base, the group identification and the terminal identification;
the reading module includes:
the first obtaining submodule is used for obtaining the partition identification corresponding to each target group identification according to the mapping relation between the group identification and the terminal identification, wherein the number of the target group identifications is at least one, and the number of the corresponding partition identifications is at least one;
the second obtaining submodule is used for obtaining a terminal identifier corresponding to each partition identifier according to the mapping relation between the group identifier and the terminal identifier, wherein the number of the corresponding terminal identifiers is at least one; and
and the reading submodule is used for reading the preset information of each terminal identification from the long connection information base according to the corresponding terminal identification.
6. The message pushing apparatus of claim 5, wherein the pushing module comprises:
the establishing submodule is used for establishing a push task for each partition identifier, wherein the number of the push tasks is the same as that of the corresponding partition identifiers, and at least one push task is executed in parallel;
and the execution submodule is used for executing the pushing task of each partition identifier in the corresponding partition identifier in parallel so as to push the message to be pushed to the terminal corresponding to each terminal identifier in parallel according to the preset information.
7. The message pushing apparatus of claim 5, wherein the information base is established by:
a second receiving module, configured to receive a request message sent by a terminal, where the request message includes: the method comprises the steps of identifying a terminal, identifying a target group and presetting information of the terminal;
the judging module is used for judging whether the preset information of the terminal is in the long connection information base or not according to the terminal identification;
the adding module is used for adding the preset information of the terminal into the long connection information base when the preset information of the terminal is not in the long connection information base;
the partitioning module is used for partitioning the terminal identifier according to a preset rule and acquiring a partition identifier when the preset information of the terminal is in the long connection information base or is added into the long connection information base;
the generating module is used for generating a mapping relation between the group identification and the terminal identification according to the terminal identification, the partition identification, the target group identification and the preset information of the terminal;
and the storage module is used for storing the mapping relation between the group identification and the terminal identification in the information base.
8. The message pushing apparatus as claimed in claim 7, wherein the preset rule is determined according to any one of the following ways:
partitioning according to a Hash algorithm;
according to the mode of terminal memory partitioning;
and partitioning the area according to the mode of the terminal.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610788992.8A CN106412018B (en) | 2016-08-31 | 2016-08-31 | Message pushing method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610788992.8A CN106412018B (en) | 2016-08-31 | 2016-08-31 | Message pushing method and device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN106412018A CN106412018A (en) | 2017-02-15 |
| CN106412018B true CN106412018B (en) | 2020-01-07 |
Family
ID=58001852
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201610788992.8A Active CN106412018B (en) | 2016-08-31 | 2016-08-31 | Message pushing method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN106412018B (en) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110324377B (en) * | 2018-03-30 | 2022-03-25 | 武汉斗鱼网络科技有限公司 | Push interaction method and device, electronic equipment and medium |
| CN112367246B (en) * | 2020-10-30 | 2022-06-17 | 深圳壹账通智能科技有限公司 | Message pushing method and device, electronic equipment and storage medium |
Family Cites Families (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN100488135C (en) * | 2003-06-16 | 2009-05-13 | 华为技术有限公司 | Method of dynamic download of network group identifier |
| CN101827309A (en) * | 2009-03-06 | 2010-09-08 | 华为技术有限公司 | Method, terminal, server and system for sending push massage |
| CN103036926B (en) * | 2011-09-29 | 2017-02-15 | 中国电信股份有限公司 | Business push system and method |
| CN104702484A (en) * | 2013-12-06 | 2015-06-10 | 中兴通讯股份有限公司 | Push method and device |
| CN103874032B (en) * | 2014-03-24 | 2017-06-06 | 北京奇虎科技有限公司 | Information-pushing method and device based on mobile terminal |
| CN105227386B (en) * | 2014-06-13 | 2019-03-15 | 阿里巴巴集团控股有限公司 | For dividing the method, apparatus and system of population statistics online user number |
-
2016
- 2016-08-31 CN CN201610788992.8A patent/CN106412018B/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| CN106412018A (en) | 2017-02-15 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| WO2017181709A1 (en) | Method and device for acquiring message to be pushed, and method and device for pushing message | |
| KR20190093598A (en) | Service processing and agreement method and device | |
| CN105847447B (en) | Message pushing method and device | |
| US20170163479A1 (en) | Method, Device and System of Renewing Terminal Configuration In a Memcached System | |
| CN108881354B (en) | Push information storage method and device, server and computer storage medium | |
| CN115516840B (en) | Information processing method, device, system, medium, chip and program product | |
| CN110022260B (en) | Cross-environment receipt message processing method and system | |
| CN110581784A (en) | node health check method, device and equipment | |
| CN106412018B (en) | Message pushing method and device | |
| CN111191080A (en) | Data processing method and device | |
| CN104967646A (en) | File downloading method and apparatus | |
| CN106899605B (en) | Communication method and device based on STOMP protocol | |
| CN110769064B (en) | System, method and equipment for offline message pushing | |
| CN106790354B (en) | Communication method and device for preventing data congestion | |
| CN103327026B (en) | A kind of data-updating method and the system of renewal | |
| US11357020B2 (en) | Connecting computer processing systems and transmitting data | |
| US11405766B2 (en) | Connecting computer processing systems and transmitting data | |
| US11290575B2 (en) | Connecting computer processing systems and transmitting data | |
| CN113612825A (en) | Internet of things message middleware server cluster expansion method and system | |
| CN105988890B (en) | Information backup method and device | |
| CN111800491A (en) | Data transmission method, system, computing device and storage medium | |
| WO2019242279A1 (en) | Message processing method and device | |
| CN105634931A (en) | Messaging service processing method and instant messaging server | |
| CN104735643A (en) | Information processing method and data server | |
| CN110545296A (en) | Log data acquisition method, device and equipment |
Legal Events
| 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 |