Apparatuses and methods for a distributed message service in a virtualized computing system

Abstract

Examples of a distributed message service include a virtualized file system including a virtual disk configured to store messages for a message topic, and a broker logically allocated to the message topic. The broker is configured to cause a message directed to the message topic provided from a publisher to be stored at the virtual disk, and to route the message to a subscriber of the message topic that is registered with the broker. The distributed message service further includes an operating system configured to manage the virtualized file system and includes a message service configured to manage logical allocation of the broker and manage allocation of the virtual disk to the message topic.

1 . At least one non-transitory computer-readable storage medium including instructions that when executed by a computing node of a computing node cluster, causes the computing node to:
 receive, from a publisher, a first message directed to a first partition of a message topic at a first message service;   store, via a first broker of the message service that is logically allocated to the first partition of the message topic, the first message at a first partition of a virtual disk of a virtualized file system hosted on the computing node cluster;   receive, from the publisher, a second message directed to a second partition of the message topic at the message service;   store, via a second broker of the message service that is logically allocated to the second partition of the message topic, the second message at a second partition of the virtual disk; and   in response to failure of the first broker of the message service, instantiate a new first broker of the message service that is logically allocated to the first partition of the message topic.   
     
     
         2 . (canceled) 
     
     
         3 . The at least one non-transitory computer-readable storage medium of  claim 1 , further including instructions which cause the computing node to append the first message to the first partition of the virtual disk to store the first message. 
     
     
         4 . The at least one non-transitory computer-readable storage medium of  claim 1 , further including instructions to route, via the first broker and the second broker, the first message and the second message, respectively, to a subscriber. 
     
     
         5 . The at least one non-transitory computer-readable storage medium of  claim 1  further including instructions to route the first message to a subscriber in response to the subscriber being included in a subscriber list corresponding to the message topic. 
     
     
         6 . The at least one non-transitory computer-readable storage medium of  claim 5 , further including instructions to add the subscriber to the subscriber list in response to receipt of a request from the subscriber. 
     
     
         7 . The at least one non-transitory computer-readable storage medium of  claim 1 , further including instructions to convert the first message from a first application programming interface (API) type to a second API type prior to storing the first message at the first partition of the virtual disk. 
     
     
         8 . The at least one non-transitory computer-readable storage medium of  claim 1 , further including instructions to increase a size of the virtual disk in response to available storage being less than an available storage threshold. 
     
     
         9 . The at least one non-transitory computer-readable storage medium of  claim 1 , further including instructions which cause the computing node to logically allocate a third broker of the message service to a partition of a second topic in response to receiving a registration request from the third broker. 
     
     
         10 . The at least one non-transitory computer-readable storage medium of  claim 1 , further including instructions to manage a lifecycle of the first broker using a containerized architecture. 
     
     
         11 . A computing node cluster, comprising one or more processors and memory configured to cause the computing node cluster to host:
 a virtualized file system including a virtual disk configured to store messages for a message topic;   a broker logically allocated to the message topic, wherein the broker is configured to cause a message directed to the message topic provided from a publisher to be stored at the virtual disk, wherein the broker is further configured to route the message to a subscriber of the message topic that is registered with the broker; and   an operating system configured to manage the virtualized file system, the operating system including a message service configured to manage logical allocation of the broker and manage allocation of the virtual disk to the message topic, wherein, in response to failure of the broker, the operating system is configured to instantiate a new broker that is logically allocated to the message topic.   
     
     
         12 . (canceled) 
     
     
         13 . The computing node cluster of  claim 10 , wherein the new broker is configured to cause a second message directed to the message topic provided from the publisher to be stored at the virtual disk. 
     
     
         14 . The computing node cluster of  claim 11 , wherein the broker is configured to append the message to the virtual disk. 
     
     
         15 . The computing node cluster of  claim 11 , wherein the broker is configured to provide the message to a subscriber in response to the subscriber being included in a subscriber list corresponding to the message topic. 
     
     
         16 . The computing node cluster of  claim 15 , wherein the message service is configured to add the subscriber to the subscriber list in response to receipt of a request from the subscriber. 
     
     
         17 . The computing node cluster of  claim 11 , wherein the broker is configured to convert the message from a first application programming interface (API) type to a second API type prior to storing the message at the virtual disk. 
     
     
         18 . The computing node cluster of  claim 11 , wherein the message service is configured to increase a size of the virtual disk in response to available storage being less than an available storage threshold. 
     
     
         19 . The computing node cluster of  claim 11 , wherein the message service is configured to logically allocate the broker to a first partition of the message topic and a second broker to a second partition of the message topic in response to receiving a registration request from the second broker. 
     
     
         20 . The computing node cluster of  claim 11 , wherein the message service is configured to instantiate the broker using a containerized architecture. 
     
     
         21 . A method, comprising:
 receiving, from a publisher, a first message directed to a first partition of a message topic at a first message service hosted on a first computing node of a computing node cluster;   storing, via a broker of the first message service that is logically allocated to the first partition of the message topic, the first message at a first partition of a virtual disk of a virtualized file system hosted on the computing node cluster;   receiving, from the publisher, a second message directed to a second partition of the message topic at a second message service hosted on a second computing node of the computing node cluster; and   storing, via a broker of the second message service that is logically allocated to the second partition of the message topic, the second message at a second partition of the virtual disk; and   in response to failure of the broker of the first message, instantiating a new broker of the first message service that is logically allocated to the first partition of the message topic.   
     
     
         22 . (canceled) 
     
     
         23 . The method of  claim 21 , further comprising routing, via the broker of the first message service and the broker of the second message service, the first message and the second message, respectively, to a subscriber in response to the subscriber being included in a subscriber list corresponding to the message topic. 
     
     
         24 . The method of  claim 21 , further comprising converting the first message from a first application programming interface (API) type to a second API type prior to storing the first message at the first partition of the virtual disk. 
     
     
         25 . The method of  claim 21 ., further comprising managing a lifecycle of the broker of the first message service using a containerized architecture. 
     
     
         26 . The method of  claim 21 , further including increasing a size of the virtual disk in response to available storage being less than an available storage threshold. 
     
     
         27 . The at least one non-transitory computer-readable storage medium of  claim 1 , further including instructions to resume storage of subsequent messages directed to the first partition of the message topic to the first partition of the virtual disk where the first broker left off via the new first broker. 
     
     
         28 . The method of  claim 21 , further comprising resuming storage of subsequent messages directed to the first partition of the message topic to the first partition of the virtual disk where the first broker left off via the new first broker.