[go: up one dir, main page]

CN107370663A - 一种浏览器即时通讯服务分布式部署方法 - Google Patents

一种浏览器即时通讯服务分布式部署方法 Download PDF

Info

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
Application number
CN201710531428.2A
Other languages
English (en)
Inventor
衡星辰
李绪光
林成虎
李玉辉
杜旭
张鑫
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Southern Power Grid Co Ltd
Kunming Enersun Technology Co Ltd
Original Assignee
China Southern Power Grid Co Ltd
Kunming Enersun Technology Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by China Southern Power Grid Co Ltd, Kunming Enersun Technology Co Ltd filed Critical China Southern Power Grid Co Ltd
Priority to CN201710531428.2A priority Critical patent/CN107370663A/zh
Publication of CN107370663A publication Critical patent/CN107370663A/zh
Pending legal-status Critical Current

Links

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

一种浏览器即时通讯服务分布式部署方法，通过websocket集群部署nginx代理redis发布订阅，采用nginx作为统一代理，负载均衡到各个服务器节点，通过redis发布订阅通讯各个websocket节点达到高可用，快速处理待办信息的能力；本发明的有益效果是：能达到负载均衡的目标；能够快速动态横向提高待办消息服务器的处理能力，能够通过快速增加服务器节点的手段来提高待办信息处理能力；可以解决目前工作台待办消息处理速度慢，当遇到待办消息剧增时候会宕机的问题，在以后的项目中如是遇到浏览器即时通讯需要高可用，大并发的需求可以采用该方案解决。降低了达到即时消息高可用，大并发的技术难度。

Description

一种浏览器即时通讯服务分布式部署方法
技术领域
本发明属一种浏览器即时通讯服务分布式部署方法技术。
背景技术
工作台的统一待办是工作台重点功能之一，通过与6+1其它业务系统集成，工作台将来自于6+1业务系统的待办工作集中进行展现，为用户提供跨平台的工作办理功能。用户登录工作台后，在工作台统一待办功能中不仅可以看见与自己相关的，来自于各个业务系统中的待办工作，还可以直接进行工作的处理。从而免去了以往只有登录各个业务系统才能处理完毕所有待办工作的麻烦，提高了整体的工作效率。
可见工作台的待办数量是6+1其它业务系统待办之和，数量庞大，待办具有实时性，需要第一时间通知用户，通知用户的手段包含浏览器在线用户通知和手机短信通知。如何处理如此庞大的信息并且及时通知用户是一个难题，自工作台建设之日起，专门新建了项目来处理这些待办信息，采用websocket技术即时通知用户，由于websocket技术的特殊性该工程起初并没有采用分布式集群部署方案。工作台自上线之后，随着使用用户数增加，待办数量开始剧增，消息处理模块无法承担如此巨大的待办信息，导致用户无法正常接收待办通知。
发明内容
本发明的目的正是为了克服上述现有技术存在的缺陷和不足而提供一种浏览器即时通讯服务分布式部署方案。
本发明的目的是通过如下技术方案来实现的。
一种浏览器即时通讯服务分布式部署方法，
通过websocket集群部署nginx代理redis发布订阅，采用nginx作为统一代理，负载均衡到各个服务器节点，通过redis发布订阅通讯各个websocket节点达到高可用，快速处理待办信息的能力；
用户的websocket链接被负载均衡到不同服务器，当服务器节点足够多的时候，就能够接受更多用户的websocket请求链接，从而接受更多用户同时在线，在业务繁忙时期不至于宕机；因为websocket服务器分布式部署之后随之而来的挑战是即时消息受到影响，当用户A链接在在SA服务器节点，需要给用户B在SB服务器节点发送消息时，无法发送；采用redis发布订阅很好的解决了该问题，使待办消息能够准确发送给用户；
每一个服务器节点都订阅自己的频道，当用户websocket链接到一台服务器的时候，将信息存到内存，包含自己所在的服务器；当别的用户给该用户发送消息的时候，先到内存中拿到用户所在的服务器，并且将消息发送到该服务器所在的频道中；目标服务器监听到消息之后，处理该消息并且给用户浏览器发送消息如果用户在线，随后发送短信通知。
本发明的优点或好处：
本发明的有益效果是，由于采用nginx作为websocket请求的代理，将来自用户浏览器的websocket请求分发到各个服务器几点，达到负载均衡的目标；能够快速动态横向提高待办消息服务器的处理能力，当系统上线发现少数节点分布式部署无法处理数量庞大的待办信息时候，能够通过快速增加服务器节点的手段来提高待办信息处理能力；本发明技术可以解决目前工作台待办消息处理速度慢，当遇到待办消息剧增时候会宕机的问题，在以后的项目中如是遇到浏览器即时通讯需要高可用，大并发的需求可以采用该方案解决。降低了达到即时消息高可用，大并发的技术难度。
附图说明
图1为websocket服务器交互示意图。
具体实施方式
见图1，一种浏览器即时通讯服务分布式部署方法，
通过websocket集群部署nginx代理redis发布订阅，采用nginx作为统一代理，负载均衡到各个服务器节点，通过redis发布订阅通讯各个websocket节点达到高可用，快速处理待办信息的能力；
用户的websocket链接被负载均衡到不同服务器，当服务器节点足够多的时候，就能够接受更多用户的websocket请求链接，从而接受更多用户同时在线，在业务繁忙时期不至于宕机；因为websocket服务器分布式部署之后随之而来的挑战是即时消息受到影响，当用户A链接在在SA服务器节点，需要给用户B在SB服务器节点发送消息时，无法发送；采用redis发布订阅很好的解决了该问题，使待办消息能够准确发送给用户；
每一个服务器节点都订阅自己的频道，当用户websocket链接到一台服务器的时候，将信息存到内存，包含自己所在的服务器；当别的用户给该用户发送消息的时候，先到内存中拿到用户所在的服务器，并且将消息发送到该服务器所在的频道中；目标服务器监听到消息之后，处理该消息并且给用户浏览器发送消息如果用户在线，随后发送短信通知。

Claims (1)

1.一种浏览器即时通讯服务分布式部署方法，其特征在于，通过websocket集群部署nginx代理redis发布订阅，采用nginx作为统一代理，负载均衡到各个服务器节点，通过redis发布订阅通讯各个websocket节点达到高可用，快速处理待办信息的能力；
用户的websocket链接被负载均衡到不同服务器，当服务器节点足够多的时候，就能够接受更多用户的websocket请求链接，从而接受更多用户同时在线，在业务繁忙时期不至于宕机；因为websocket服务器分布式部署之后随之而来的挑战是即时消息受到影响，当用户A链接在在SA服务器节点，需要给用户B在SB服务器节点发送消息时，无法发送；采用redis发布订阅很好的解决了该问题，使待办消息能够准确发送给用户；
每一个服务器节点都订阅自己的频道，当用户websocket链接到一台服务器的时候，将信息存到内存，包含自己所在的服务器；当别的用户给该用户发送消息的时候，先到内存中拿到用户所在的服务器，并且将消息发送到该服务器所在的频道中；目标服务器监听到消息之后，处理该消息并且给用户浏览器发送消息如果用户在线，随后发送短信通知。
CN201710531428.2A 2017-07-03 2017-07-03 一种浏览器即时通讯服务分布式部署方法 Pending CN107370663A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201710531428.2A CN107370663A (zh) 2017-07-03 2017-07-03 一种浏览器即时通讯服务分布式部署方法

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201710531428.2A CN107370663A (zh) 2017-07-03 2017-07-03 一种浏览器即时通讯服务分布式部署方法

Publications (1)

Publication Number Publication Date
CN107370663A true CN107370663A (zh) 2017-11-21

Family

ID=60306295

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201710531428.2A Pending CN107370663A (zh) 2017-07-03 2017-07-03 一种浏览器即时通讯服务分布式部署方法

Country Status (1)

Country Link
CN (1) CN107370663A (zh)

Cited By (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108322385A (zh) * 2018-01-19 2018-07-24 论客科技（广州）有限公司 一种新邮件到达通知方法、系统与装置
CN109308221A (zh) * 2018-08-02 2019-02-05 南京邮电大学 一种基于WebSocket长连接的Nginx动态负载均衡方法
CN109831404A (zh) * 2017-11-23 2019-05-31 惠州臻享云科技有限公司 一种兼容多终端的即时通讯系统及方法
CN111031058A (zh) * 2019-12-23 2020-04-17 集奥聚合(北京)人工智能科技有限公司 基于WebSocket的分布式服务器集群交互方法及装置
CN111565229A (zh) * 2020-04-29 2020-08-21 创盛视联数码科技（北京）有限公司 一种基于Redis的通信系统分布式方法

Citations (5)

* Cited by examiner, † Cited by third party
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 (zh) * 2015-03-16 2015-06-17 墨仕（厦门）电子商务有限公司 一种分布式消息推送系统及方法
CN104754052A (zh) * 2015-04-01 2015-07-01 贵州电网公司信息通信分公司 一种基于Websocket实现消息推送的方法
CN104811459A (zh) * 2014-01-23 2015-07-29 阿里巴巴集团控股有限公司 用于消息服务的处理方法、装置及系统、消息服务系统
CN106170016A (zh) * 2016-07-28 2016-11-30 深圳市创梦天地科技有限公司 一种处理高并发数据请求的方法和系统

Patent Citations (5)

* Cited by examiner, † Cited by third party
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 (zh) * 2014-01-23 2015-07-29 阿里巴巴集团控股有限公司 用于消息服务的处理方法、装置及系统、消息服务系统
CN104717133A (zh) * 2015-03-16 2015-06-17 墨仕（厦门）电子商务有限公司 一种分布式消息推送系统及方法
CN104754052A (zh) * 2015-04-01 2015-07-01 贵州电网公司信息通信分公司 一种基于Websocket实现消息推送的方法
CN106170016A (zh) * 2016-07-28 2016-11-30 深圳市创梦天地科技有限公司 一种处理高并发数据请求的方法和系统

Cited By (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109831404A (zh) * 2017-11-23 2019-05-31 惠州臻享云科技有限公司 一种兼容多终端的即时通讯系统及方法
CN109831404B (zh) * 2017-11-23 2021-08-03 广东臻享云物联网科技有限公司 一种兼容多终端的即时通讯系统及方法
CN108322385A (zh) * 2018-01-19 2018-07-24 论客科技（广州）有限公司 一种新邮件到达通知方法、系统与装置
CN109308221A (zh) * 2018-08-02 2019-02-05 南京邮电大学 一种基于WebSocket长连接的Nginx动态负载均衡方法
CN109308221B (zh) * 2018-08-02 2022-06-10 南京邮电大学 一种基于WebSocket长连接的Nginx动态负载均衡方法
CN111031058A (zh) * 2019-12-23 2020-04-17 集奥聚合(北京)人工智能科技有限公司 基于WebSocket的分布式服务器集群交互方法及装置
CN111565229A (zh) * 2020-04-29 2020-08-21 创盛视联数码科技（北京）有限公司 一种基于Redis的通信系统分布式方法
CN111565229B (zh) * 2020-04-29 2020-11-27 创盛视联数码科技（北京）有限公司 一种基于Redis的通信系统分布式方法

Similar Documents

Publication Publication Date Title
CN107370663A (zh) 一种浏览器即时通讯服务分布式部署方法
US20150085663A1 (en) Methods, systems, and computer readable media for diameter load and overload information and virtualization
CN103051534B (zh) 一种报文处理方法及装置
CN110868349B (zh) 物联网环境下分布式高并发数据采集与处理方法及系统
JP2020512719A5 (zh)
WO2008130709A3 (en) Systems, methods, and computer program products for providing service interaction and mediation in a communications network
US10567483B2 (en) Method and apparatus for high performance low latency real time notification delivery
CN106850782A (zh) 用于日志处理的方法和系统
CN103873293B (zh) 一种健康探测装置及方法
CN106411919B (zh) 一种基于事件总线的web推送方法
CN110582757A (zh) 数据消息网络路由的中间设备
CN102932269A (zh) 负载均衡的实现方法和装置
CN103944784A (zh) 一种面向大规模云数据中心的服务器协同监控方法
CN104301241B (zh) 一种soa动态负载分发方法与系统
CN105429881A (zh) 一种组播报文转发方法和装置
CN104980408A (zh) 恶意网站的封堵方法、装置以及系统
CN103533001A (zh) 基于http多重代理的通信方法和系统、中间代理服务器
EP3146672B1 (en) Event reporting in a service function chain
US20080301243A1 (en) Real time messaging framework hub
US10812355B2 (en) Record compression for a message system
CN105681208B (zh) 一种智能路由器的消息集中处理方法及系统
CN115883559A (zh) 无状态网络负载均衡方法、装置和存储介质
CN115087025A (zh) 专网数据采集方法、设备及存储介质
Guduru et al. Queuing strategies for self overload control in SIP servers
Montazerolghaem et al. SIP overload control testbed: Design, building and Evaluation

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