A distributed method of communication system based on redis

Abstract

The invention provides a distributed method of a communication system based on Redis, the client establishes a Websocket long connection through the Nginx cluster and the gateway layer of the Gateway gateway cluster; the Gateway gateway cluster obtains the message processor cluster to obtain a node list, and requests the message processor to establish a connection ;The client sends a message, forwards the message request to the message processor, and the message processor publishes a message to Redis; for the subscribed client, the publisher Redis Stream structure will create a corresponding Consumer Group through xadd, and then other clients through xreadgroup and The ack mechanism ensures that messages are reliably consumed. The invention integrates message push and subscription services to form a message processor cluster separately, monitors the health status of each node through the Eureka registration center cluster, and deploys the cluster to achieve high-availability and efficient service mode of distributed cluster deployment.

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] like 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. D...

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