+

WO2019158969A1 - Service centralisé de mise en file d'attente de messages - Google Patents

Service centralisé de mise en file d'attente de messages Download PDF

Info

Publication number
WO2019158969A1
WO2019158969A1 PCT/IB2018/050898 IB2018050898W WO2019158969A1 WO 2019158969 A1 WO2019158969 A1 WO 2019158969A1 IB 2018050898 W IB2018050898 W IB 2018050898W WO 2019158969 A1 WO2019158969 A1 WO 2019158969A1
Authority
WO
WIPO (PCT)
Prior art keywords
virtual machine
queueing
service
chain
centralized
Prior art date
Application number
PCT/IB2018/050898
Other languages
English (en)
Inventor
Pratik Sharma
Original Assignee
Pratik Sharma
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 Pratik Sharma filed Critical Pratik Sharma
Priority to PCT/IB2018/050898 priority Critical patent/WO2019158969A1/fr
Publication of WO2019158969A1 publication Critical patent/WO2019158969A1/fr

Links

Classifications

    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/44—Arrangements for executing specific programs
    • G06F9/455—Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
    • G06F9/45533—Hypervisors; Virtual machine monitors
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46—Multiprogramming arrangements
    • G06F9/54—Interprogram communication
    • G06F9/546—Message passing systems or structures, e.g. queues
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/30—Definitions, standards or architectural aspects of layered protocol stacks
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F2209/00—Indexing scheme relating to G06F9/00
    • G06F2209/54—Indexing scheme relating to G06F9/54
    • G06F2209/548—Queue

Definitions

  • Centralized message queueing service then queues the object taking into account the current active virtual machine in the chain for insertion or queueing purposes, IP address of that virtual machine and process identifier providing the queueing service and the tail pointer of the queue for that virtual machine, and finally updates the centralized message queueing service with tail pointer updates for that virtual machine and count of objects queued for that virtual machine (after incrementing the count), etc.
  • Receiver processes running on different virtual machines register with the centralized message queueing service daemon for receiving and removing or just receiving different objects.
  • Centralized message queueing service then queues the object taking into account the first virtual machine in the chain for deletion or notification purposes, IP address of that virtual machine and process identifier providing the queueing service and the head pointer of the queue for that virtual machine, and finally updates the centralized message queueing service with head pointer updates for that virtual machine and count of objects queued for that virtual machine (after decrementing the count), etc.

Landscapes

  • Engineering & Computer Science (AREA)
  • Software Systems (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Computer Security & Cryptography (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer And Data Communications (AREA)

Abstract

L'invention concerne une chaîne de machines virtuelles dans laquelle un service de messagerie centralisé peut maintenir des objets de message en file d'attente. Lorsque les files d'attente pour toutes les machines virtuelles dans la chaîne sont pleines, on procède à une extension en ajoutant plus de machines virtuelles dans la grappe à l'extrémité de la chaîne. Pour chaque machine virtuelle dans la grappe de mise en file d'attente, on maintient séparément la configuration dynamique de sa position dans la chaîne, l'adresse IP de machine virtuelle, un identifiant de processus exécuté sur la machine virtuelle fournissant le service de mise en file d'attente, un pointeur vers la tête de la file d'attente dans la machine virtuelle, et le pointeur vers la queue de la file d'attente dans la machine virtuelle. Les informations susmentionnées sont maintenues séparément par un daemon de service de messagerie centralisé s'exécutant sur une machine virtuelle. Des processus d'expéditeur et de destinataire s'exécutant sur différentes machines virtuelles s'enregistrent auprès du daemon de service de messagerie centralisé pour envoyer et recevoir différents objets.
PCT/IB2018/050898 2018-02-14 2018-02-14 Service centralisé de mise en file d'attente de messages WO2019158969A1 (fr)

Priority Applications (1)

Application Number Priority Date Filing Date Title
PCT/IB2018/050898 WO2019158969A1 (fr) 2018-02-14 2018-02-14 Service centralisé de mise en file d'attente de messages

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
PCT/IB2018/050898 WO2019158969A1 (fr) 2018-02-14 2018-02-14 Service centralisé de mise en file d'attente de messages

Publications (1)

Publication Number Publication Date
WO2019158969A1 true WO2019158969A1 (fr) 2019-08-22

Family

ID=67619800

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/IB2018/050898 WO2019158969A1 (fr) 2018-02-14 2018-02-14 Service centralisé de mise en file d'attente de messages

Country Status (1)

Country Link
WO (1) WO2019158969A1 (fr)

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20100332593A1 (en) * 2009-06-29 2010-12-30 Igor Barash Systems and methods for operating an anti-malware network on a cloud computing platform
CN102404385A (zh) * 2011-10-25 2012-04-04 华中科技大学 面向高性能计算的虚拟集群部署系统和部署方法
US20130111468A1 (en) * 2011-10-27 2013-05-02 Verizon Patent And Licensing Inc. Virtual machine allocation in a computing on-demand system

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20100332593A1 (en) * 2009-06-29 2010-12-30 Igor Barash Systems and methods for operating an anti-malware network on a cloud computing platform
CN102404385A (zh) * 2011-10-25 2012-04-04 华中科技大学 面向高性能计算的虚拟集群部署系统和部署方法
US20130111468A1 (en) * 2011-10-27 2013-05-02 Verizon Patent And Licensing Inc. Virtual machine allocation in a computing on-demand system

Similar Documents

Publication Publication Date Title
CN107959636B (zh) Bgp消息的发送方法及装置
KR100716184B1 (ko) 네트워크 프로세서에서의 큐 관리 방법 및 그 장치
US8505038B2 (en) Method and system for enhancing MS exchange (MAPI) end user experiences in a split proxy environment
JP5128111B2 (ja) メッセージに関連付けられた順序を保存するためのシステム、並びに、その方法及びコンピュータ・プログラム
US20070078935A1 (en) Retrieval of offline instant messages
EP3754920A1 (fr) Coalescence de petites charges utiles
JP2005521938A5 (fr)
CN114035924B (zh) 一种分布式限速队列实现方法及装置
CN105159779B (zh) 提高多核cpu数据处理性能的方法和系统
EP3806410A1 (fr) Procédé de commande de message, procédé de mise à jour de table de flux et dispositif de noeud
CN113806177A (zh) 集群监控的方法、装置、电子设备及存储介质
US9268621B2 (en) Reducing latency in multicast traffic reception
WO2014075488A1 (fr) Procédé et appareil de gestion de file d'attente
EP2417737B1 (fr) Processeur de mise a l'échelle côté transmission et procédé pour le traitement de paquets d'information sortants mettant en oeuvre des files d'attente à base de fil
CN108092914B (zh) 网络流量负载均衡调度方法和装置
WO2019158969A1 (fr) Service centralisé de mise en file d'attente de messages
CN113157465B (zh) 基于指针链表的消息发送方法及装置
CN113626221A (zh) 一种消息入队方法及装置
US9652310B1 (en) Method and apparatus for using consistent-hashing to ensure proper sequencing of message processing in a scale-out environment
US10439952B1 (en) Providing source fairness on congested queues using random noise
CN109450941B (zh) 一种抗DDoS的SDN控制器消息调度方法
CN109474525B (zh) 报文的处理方法、装置、设备及可读存储介质
US20100309928A1 (en) Asynchronous communication in an unstable network
WO2017032110A1 (fr) Système et procédé de traitement de messages d'applications, et dispositif d'application
US10560394B2 (en) Dynamic transmission side scaling

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 18906616

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 18906616

Country of ref document: EP

Kind code of ref document: A1

点击 这是indexloc提供的php浏览器服务，不要输入任何密码和下载