Communication system distributed method based on Redis

Abstract

The invention provides a communication system distributed method based on Redis. The method comprises the following steps that a client establishes Websocket long connection with a gateway layer of aGateway gateway cluster through an Nginx cluster; the Gateway gateway cluster acquires a message processor cluster acquisition node list and requests a message processor to establish connection; the client sends a message and forwards the message request to a message processor, and the message processor publishes the message to the Redis; for a subscribed client, a publisher Redis Stream structurecan create a corresponding Consumer Group through xadd, and then other clients ensure that a message is reliably consumed through the xadd Group and an ack mechanism. Message pushing and subscriptionservices are integrated to independently form a message processor cluster, and the health state of each node is monitored and subjected to cluster deployment through an Eureka registration center cluster, so an efficient service mode of high availability and distributed cluster deployment is achieved.

Description

technical field [0001] The invention relates to a message system based on a Redis topic subscription mode, in particular to a distributed method of a Redis-based communication system. Background technique [0002] Such as figure 1 As shown, the existing chat system server architecture has largely solved the shortcomings of traditional chat system stand-alone deployment, achieving high availability and dynamic expansion. Using layered thinking, by separating the message flow processor separately, it is used to process the push-pull message flow, forming a separate middleware processor cluster, pushing and subscribing messages to the corresponding channel of the Redis cluster, and then forwarding the message to all other The corresponding client connected to this server. [0003] The deficiencies of prior art solutions: [0004] The existing chat system based on the Redis Pub / Sub topic subscription model still has some shortcomings, which will be analyzed below. [0005] 1...

AI Technical Summary

Problems solved by technology

[0011] The present invention provides a distributed method for a communication system based on Redis, which solves the problems of poor message processing reliability and high risk of loss in the existing RedisPub / Sub topic subscription mode, and its technical solution is as follows:

Images