标签：

安装Redis

同样我这边再次使用Docker, 方便快捷:

# 拉取镜像 docker pull redis # 运行镜像 docker run -d -p 6379:6379 --name redisapp redis 创建项目

这边依旧使用VS, 项目源码在Gitee.

连接驱动这里选择StackExchange.Redis，之前一直是用ServiceStack.Redis, 但是它已经逐渐商业化，4.0及以上版本都具有限制.

这里的发布订阅只是Redis功能的一部分, 所以我新建一个类把代码剥离出来:

public class Publish_Subscribe { public Publish_Subscribe(bool isPublisher) { //创建连接 using (ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost:6379")) { ISubscriber sub = redis.GetSubscriber(); if (isPublisher) Publisher(sub); else Subscriber(sub); } } private void Publisher(ISubscriber sub) { Console.WriteLine("Please Enter Message or ‘q’ to Exit"); string input; do { input = Console.ReadLine(); sub.Publish("messages", input); } while (input != "q"); } private void Subscriber(ISubscriber sub) { //订阅名为 messages 的通道 sub.Subscribe("messages", (channel, message) => { //输出收到的消息 Console.WriteLine($"[{DateTime.Now:HH:mm:ss}] {message}"); }); Console.WriteLine("Already Subscribe ‘messages’"); Console.ReadKey(); } }

然后修改启动函数:

static void Main(string[] args) { var ps = new Publish_Subscribe((args.Length > 0 && args[0] == "p")); //Console.WriteLine("Hello World!"); }

启动的时候加一个参数p则是启动生产者, 否则启动的就是消费者.

总结

我们可以启动多个发布者, 多个订阅者, 任何一个发布者发布的的消息都可以同时被所有订阅者收到. 后加入的订阅者不能收到之前发布的历史消息.