CN107370663A - A kind of browser instant messaging services distributed deployment method - Google Patents
A kind of browser instant messaging services distributed deployment method Download PDFInfo
- Publication number
- CN107370663A CN107370663A CN201710531428.2A CN201710531428A CN107370663A CN 107370663 A CN107370663 A CN 107370663A CN 201710531428 A CN201710531428 A CN 201710531428A CN 107370663 A CN107370663 A CN 107370663A
- Authority
- CN
- China
- Prior art keywords
- server
- user
- message
- websocket
- pending
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 7
- 238000009826 distribution Methods 0.000 claims abstract description 15
- 230000003111 delayed effect Effects 0.000 abstract description 2
- 230000010365 information processing Effects 0.000 abstract description 2
- 230000009286 beneficial effect Effects 0.000 abstract 1
- 238000005516 engineering process Methods 0.000 description 4
- 230000008901 benefit Effects 0.000 description 3
- 230000006870 function Effects 0.000 description 3
- 230000000712 assembly Effects 0.000 description 1
- 238000000429 assembly Methods 0.000 description 1
- 230000007547 defect Effects 0.000 description 1
- 230000007812 deficiency Effects 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
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/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L51/00—User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
- H04L51/04—Real-time or near real-time messaging, e.g. instant messaging [IM]
-
- 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/56—Provisioning of proxy services
-
- 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/56—Provisioning of proxy services
- H04L67/568—Storing data temporarily at an intermediate stage, e.g. caching
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Information Transfer Between Computers (AREA)
Abstract
A kind of browser instant messaging services distributed deployment method, redis distribution subscriptions are acted on behalf of by websocket clustered deploy(ment)s nginx, using nginx as unified agent, load balancing is to each server node, each websocket nodes are communicated by redis distribution subscriptions and reach High Availabitity, quickly handle the ability of pending information；The beneficial effects of the invention are as follows：The target of load balancing can be reached；The disposal ability of pending message server quickly dynamically can be laterally improved, pending information processing capability can be improved by quickly increasing the means of server node；It is slow can to solve the pending Message Processing speed of current workbench, can be delayed when running into pending message and increasing severely machine the problem of, running into browser instant messaging in this way in project afterwards needs High Availabitity, and big concurrent demand can use the program to solve.Reduce and reach instant message High Availabitity, big concurrent technical difficulty.
Description
Technical field
The invention belongs to a kind of browser instant messaging to service distributed deployment method and technology.
Background technology
The pending unification of workbench is one of workbench priority function, by being integrated with the other operation systems of 6+1, workbench
The outstanding work for coming from 6+1 operation systems is concentrated and showed, cross-platform work is provided the user and handles function.User
It after logging in workbench, not only can see that in the unified pending function of workbench related to oneself, come from each business system
Outstanding work in system, the processing that can also be directly operated.Each operation system is only logged in the past just so as to eliminate
Can be disposed the troubles of all outstanding works, improve overall operating efficiency.
It can be seen that the pending quantity of workbench is the pending sum of the other operation systems of 6+1, substantial amounts are pending to have in real time
Property, it is necessary to the very first time notify user, notify user means include browser online user notice and SMS notice.Such as
Where manages so huge information and notifies that user is a problem in time, special newly-built from being built from workbench
Project handles these pending information, using websocket technologies notifies user immediately, special due to websocket technologies
Property the engineering originally do not use distributed type assemblies deployment scheme.Workbench is after reach the standard grade, with being increased using number of users,
Pending quantity starts to increase severely, and message processing module can not undertake so huge pending information, cause user not normally receive
Pending notice.
The content of the invention
The purpose of the present invention precisely in order to the defects of overcoming above-mentioned prior art to exist and deficiency and a kind of browser is provided
Instant messaging services distributed deployment scheme.
The purpose of the present invention is achieved by the following technical solution.
A kind of browser instant messaging services distributed deployment method,
Redis distribution subscriptions are acted on behalf of by websocket clustered deploy(ment)s nginx, using nginx as unified agent, born
Load is balanced to each server node, and communicating each websocket nodes by redis distribution subscriptions reaches High Availabitity, quickly
Handle the ability of pending information；
The websocket links of user, which are supported, is balanced to different server, when server node is enough, just
The websocket hyperlink requests of more users can be received, so as to receive more users simultaneously it is online, heavy traffic period not
As for the machine of delaying；Because thing followed challenge is that instant message is affected after the deployment of websocket server distributions formula, when
User A is linked in SA server nodes, it is necessary to user B when SB server nodes send message, can not be sent；Using
Redis distribution subscriptions solve the problem well, pending message is accurately sent to user；
Each server node subscribes to the channel of oneself, when user websocket is linked to a server
Wait, information is stored to internal memory, includes the server where oneself；When other user sends message to the user, arrive first
The server where user is taken in internal memory, and is sent a message in the channel where the server；Destination server is supervised
After hearing message, if handle the message and to user browser send message user it is online, then send SMS notification.
Advantages of the present invention or benefit：
The invention has the advantages that due to the agency asked using nginx as websocket, it is clear user will to be come from
Look at device websocket requests be distributed to each server some, reach the target of load balancing；Quickly dynamic can laterally it carry
The disposal ability of high pending message server, when online implementing finds that a small number of Node distribution formula deployment can not handle substantial amounts
When pending information, pending information processing capability can be improved by quickly increasing the means of server node；Skill of the present invention
It is slow that art can solve the pending Message Processing speed of current workbench, can be delayed when running into pending message and increasing severely machine the problem of,
Running into browser instant messaging in later project in this way needs High Availabitity, and big concurrent demand can use the program to solve.
Reduce and reach instant message High Availabitity, big concurrent technical difficulty.
Brief description of the drawings
Fig. 1 is websocket server interaction schematic diagrames.
Embodiment
See Fig. 1, a kind of browser instant messaging services distributed deployment method,
Redis distribution subscriptions are acted on behalf of by websocket clustered deploy(ment)s nginx, using nginx as unified agent, born
Load is balanced to each server node, and communicating each websocket nodes by redis distribution subscriptions reaches High Availabitity, quickly
Handle the ability of pending information；
The websocket links of user, which are supported, is balanced to different server, when server node is enough, just
The websocket hyperlink requests of more users can be received, so as to receive more users simultaneously it is online, heavy traffic period not
As for the machine of delaying；Because thing followed challenge is that instant message is affected after the deployment of websocket server distributions formula, when
User A is linked in SA server nodes, it is necessary to user B when SB server nodes send message, can not be sent；Using
Redis distribution subscriptions solve the problem well, pending message is accurately sent to user；
Each server node subscribes to the channel of oneself, when user websocket is linked to a server
Wait, information is stored to internal memory, includes the server where oneself；When other user sends message to the user, arrive first
The server where user is taken in internal memory, and is sent a message in the channel where the server；Destination server is supervised
After hearing message, if handle the message and to user browser send message user it is online, then send SMS notification.
Claims (1)
1. a kind of browser instant messaging services distributed deployment method, it is characterised in that passes through websocket clustered deploy(ment)s
Nginx acts on behalf of redis distribution subscriptions, is passed through using nginx as unified agent, load balancing to each server node
Redis distribution subscriptions communicate each websocket nodes and reach High Availabitity, quickly handle the ability of pending information；
The websocket links of user, which are supported, is balanced to different server, when server node is enough, it becomes possible to
Receive the websocket hyperlink requests of more users, it is simultaneously online so as to receive more users, it is unlikely in heavy traffic period
Delay machine；Because thing followed challenge is that instant message is affected after the deployment of websocket server distributions formula, work as user
A is linked in SA server nodes, it is necessary to user B when SB server nodes send message, can not be sent；Using redis
Distribution subscription solves the problem well, pending message is accurately sent to user；
Each server node subscribes to the channel of oneself, will when user websocket is linked to a server
Information is stored to internal memory, includes the server where oneself；When other user sends message to the user, arrive first in internal memory
The server where user is taken, and is sent a message in the channel where the server；Destination server, which listens to, to disappear
After breath, if handle the message and to user browser send message user it is online, then send SMS notification.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710531428.2A CN107370663A (en) | 2017-07-03 | 2017-07-03 | A kind of browser instant messaging services distributed deployment method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710531428.2A CN107370663A (en) | 2017-07-03 | 2017-07-03 | A kind of browser instant messaging services distributed deployment method |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN107370663A true CN107370663A (en) | 2017-11-21 |
Family
ID=60306295
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201710531428.2A Pending CN107370663A (en) | 2017-07-03 | 2017-07-03 | A kind of browser instant messaging services distributed deployment method |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN107370663A (en) |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN108322385A (en) * | 2018-01-19 | 2018-07-24 | 论客科技（广州）有限公司 | A kind of new mail arrival notice method, system and device |
| CN109308221A (en) * | 2018-08-02 | 2019-02-05 | 南京邮电大学 | A Nginx dynamic load balancing method based on WebSocket long connection |
| CN109831404A (en) * | 2017-11-23 | 2019-05-31 | 惠州臻享云科技有限公司 | A kind of instant communicating system and method for compatible multiple terminals |
| CN111031058A (en) * | 2019-12-23 | 2020-04-17 | 集奥聚合(北京)人工智能科技有限公司 | Websocket-based distributed server cluster interaction method and device |
| CN111565229A (en) * | 2020-04-29 | 2020-08-21 | 创盛视联数码科技（北京）有限公司 | Communication system distributed method based on Redis |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20040019645A1 (en) * | 2002-07-26 | 2004-01-29 | International Business Machines Corporation | Interactive filtering electronic messages received from a publication/subscription service |
| CN104717133A (en) * | 2015-03-16 | 2015-06-17 | 墨仕（厦门）电子商务有限公司 | Distributed message push system and method |
| CN104754052A (en) * | 2015-04-01 | 2015-07-01 | 贵州电网公司信息通信分公司 | Message pushing method based on Websocket |
| CN104811459A (en) * | 2014-01-23 | 2015-07-29 | 阿里巴巴集团控股有限公司 | Processing method, processing device and system for message services and message service system |
| CN106170016A (en) * | 2016-07-28 | 2016-11-30 | 深圳市创梦天地科技有限公司 | A kind of method and system processing high concurrent data requests |
-
2017
- 2017-07-03 CN CN201710531428.2A patent/CN107370663A/en active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20040019645A1 (en) * | 2002-07-26 | 2004-01-29 | International Business Machines Corporation | Interactive filtering electronic messages received from a publication/subscription service |
| CN104811459A (en) * | 2014-01-23 | 2015-07-29 | 阿里巴巴集团控股有限公司 | Processing method, processing device and system for message services and message service system |
| CN104717133A (en) * | 2015-03-16 | 2015-06-17 | 墨仕（厦门）电子商务有限公司 | Distributed message push system and method |
| CN104754052A (en) * | 2015-04-01 | 2015-07-01 | 贵州电网公司信息通信分公司 | Message pushing method based on Websocket |
| CN106170016A (en) * | 2016-07-28 | 2016-11-30 | 深圳市创梦天地科技有限公司 | A kind of method and system processing high concurrent data requests |
Cited By (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109831404A (en) * | 2017-11-23 | 2019-05-31 | 惠州臻享云科技有限公司 | A kind of instant communicating system and method for compatible multiple terminals |
| CN109831404B (en) * | 2017-11-23 | 2021-08-03 | 广东臻享云物联网科技有限公司 | Instant communication system and method compatible with multiple terminals |
| CN108322385A (en) * | 2018-01-19 | 2018-07-24 | 论客科技（广州）有限公司 | A kind of new mail arrival notice method, system and device |
| CN109308221A (en) * | 2018-08-02 | 2019-02-05 | 南京邮电大学 | A Nginx dynamic load balancing method based on WebSocket long connection |
| CN109308221B (en) * | 2018-08-02 | 2022-06-10 | 南京邮电大学 | A Nginx dynamic load balancing method based on WebSocket long connection |
| CN111031058A (en) * | 2019-12-23 | 2020-04-17 | 集奥聚合(北京)人工智能科技有限公司 | Websocket-based distributed server cluster interaction method and device |
| CN111565229A (en) * | 2020-04-29 | 2020-08-21 | 创盛视联数码科技（北京）有限公司 | Communication system distributed method based on Redis |
| CN111565229B (en) * | 2020-04-29 | 2020-11-27 | 创盛视联数码科技（北京）有限公司 | Communication system distributed method based on Redis |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107370663A (en) | A kind of browser instant messaging services distributed deployment method | |
| CN103051534B (en) | A kind of message processing method and device | |
| JP2020512719A5 (en) | ||
| CN102790798B (en) | Transparent proxy implementation, equipment and system in a kind of content distributing network | |
| US10567483B2 (en) | Method and apparatus for high performance low latency real time notification delivery | |
| JP2016536939A (en) | Diameter load and overload information and methods, systems and computer readable media for virtualization | |
| CN103873293B (en) | A kind of healthprobe device and method | |
| CN107517143A (en) | A kind of network traffics collection and monitoring method based on bgp protocol | |
| CN102932269A (en) | Method and device for balancing load | |
| CN105429881A (en) | Multicast message forwarding method and device | |
| CN104301241B (en) | A kind of SOA dynamic load distributing methods and system | |
| CN104980408A (en) | Blocking method, device and system for malicious website | |
| CN106648922A (en) | Data collecting method based on XMPP | |
| CN103533001A (en) | Communication method and communication system based on HTTP multi-proxy, and intermediate proxy server | |
| EP3146672B1 (en) | Event reporting in a service function chain | |
| US20080301243A1 (en) | Real time messaging framework hub | |
| Montazerolghaem et al. | SIP overload control testbed: Design, building and Evaluation | |
| CN115883559A (en) | Stateless network load balancing method, device and storage medium | |
| CN115087025A (en) | Private network data collection method, equipment and storage medium | |
| Guduru et al. | Queuing strategies for self overload control in SIP servers | |
| CN106487890A (en) | A kind of cross-node communication network requesting method based on XMPP | |
| CN106998287A (en) | A kind of instant messaging group's message coalescing retransmission method for isolation network environment | |
| CN104579914A (en) | Method and device for subscribing to state for system | |
| Schuster et al. | Mobilis–Comprehensive Developer Support for Building Pervasive Social Computing Applications | |
| Pothuganti | Overview on Application Layer routing Protocols for the Internet of Things |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| WD01 | Invention patent application deemed withdrawn after publication | ||
| WD01 | Invention patent application deemed withdrawn after publication |
Application publication date: 20171121 |