How to use redis' publish subscribe (MQ) in.Netcore 3.1 project

1.Redis Publish subscribe ( understand )

Redis Publish subscribe (pub/sub) It's a message communication mode ： sender (pub) Send a message , subscriber (sub) receive messages .
Redis Clients can subscribe to any number of channels .
The picture below shows the channel channel1 , And three clients that subscribe to this channel —— client2 、 client5 and client1 The relationship between ：

When new news passes PUBLISH Command to channel channel1 when , This message will be sent to the three clients who subscribe to it ：

2. Turn on Redis service （ Virtual system CentOS7 Up operation ）

3. dotnetCore 3.1 Project main code

1. Subscribers （ Get message , Perform some operations according to the message ）

using System;
using StackExchange.Redis;

namespace Sub
{
    class Program
    {
        static void Main(string[] args)
        {
	        // Create connection 
	        using (ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("192.168.153.131:6379"))
	        {
				ISubscriber sub = redis.GetSubscriber();

		        // The subscription is called  messages  The passage of 

		        sub.Subscribe("redisChat", (channel, message) => {

			        // Output received messages 
			        Console.WriteLine($"[{DateTime.Now:HH:mm:ss}] {message}");

					if (message == "yes")
					{
						todoSomething();
					}
					else
					{
						Console.WriteLine(" The specified information was not obtained , Do nothing ！");
					}
				

				});
				Console.WriteLine(" Subscribed  redisChat");
		        Console.ReadKey();
			}

	        
        }

		/// <summary>
		///  Define what you want to do 
		/// </summary>
		public static void todoSomething()
		{
			Console.WriteLine(" Do what you want to do ....");
		    Console.WriteLine(" You have finished your operation .");
		}
    }
}

2. Publisher （ Release the news , Trigger source ）

using System;
using StackExchange.Redis;

namespace Pub
{
    class Program
    {
        static void Main(string[] args)
        {
			// Create connection 
	        using (ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("192.168.153.131:6379"))
	        {
				ISubscriber sub = redis.GetSubscriber();

		        Console.WriteLine(" Please enter any character , Input exit sign out ");

		        string input;

		        do
		        {
			        input = Console.ReadLine();
			        sub.Publish("redisChat", input);
		        } while (input != "exit");
			}
		}
    }
}

Required in the project NuGet introduce StackExchange package ：

4.redis Disadvantages of message publishing and subscription

The publisher and the acceptor must be online at the same time , Otherwise, there will be Missing information . For example, the receiving end is disconnected , During the offline period, the messages published by the publisher will not be cached until the receiver goes online , But if you miss it completely, there will be no more . So? , For those that want to use MQ Complete important business processing , This is not enough , After all redis The message mechanism in is not professional . Professionals will automatically move to rabbitMQ And other professional message oriented middleware .
There is another drawback , It is said that too many news releases will cause Jam so that it collapses . This is not tested . Also said this bug It has been fixed in the new version .