当前位置：首页 > news >正文

C# (.net6)实现Redis发布和订阅简单案例

news 2025/8/26 17:51:43

概念：

在 .NET 6 中使用 Redis 的/订发布阅模式。发布/订阅（Pub/Sub）是 Redis 支持的一种消息传递模式，其中一个或多个发布者向一个或多个订阅者发送消息,Redis 客户端可以订阅任意数量的频道。

多个客户端可以订阅一个相同的频道如下图所示：

当有新消息通过 PUBLISH 命令发送给频道 channel1 时，这个消息就会被发送给订阅它的三个客户端，一个信息可以通过频道发布给多个客户端：

.net6实现Redis发布订阅

先安装StackExchange.Redis包，引入依赖。

创建连接Redis类RedisConnectionHelper

redis默认用6379端口，前提是本地安装了redis服务

public static class RedisConnectionHelper
{private static Lazy<ConnectionMultiplexer> lazyConnection = new Lazy<ConnectionMultiplexer>(() =>{// 连接到 Redis 服务器，localhost:6379 是本地默认 Redis 服务器地址return ConnectionMultiplexer.Connect("127.0.0.1:6379");});public static ConnectionMultiplexer Connection => lazyConnection.Value;
}

创建发布信息类RedisPublisher ，用来发布订阅信息

public class RedisPublisher{/// <summary>/// 发布/// </summary>/// <param name="channel"></param>/// <param name="message"></param>public void PublishMessage(string channel, string message){// 获取 Redis 连接var redis = RedisConnectionHelper.Connection;// 获取 Redis 数据库var db = redis.GetDatabase();// 发布消息到指定频道//通过 ISubscriber 对象，你可以发布消息，也可以订阅某个频道。ISubscriber sub = redis.GetSubscriber();//channel: 要发布消息的频道名称。频道可以是任何字符串，当发布者发送消息时，所有订阅了这个频道的订阅者都会收到消息。///  message: 发布的消息内容。这可以是任何可以转换为字符串的内容（如纯文本、JSON、XML等）。//当这行代码执行时，消息会被发送到 channel，并通知所有当前订阅了该频道的客户端。sub.Publish(channel, message);Console.WriteLine($"消息已发布到频道 {channel}: {message}");//换句话说，发布者发送的消息被“广播”给所有订阅了该频道的监听者。}}

创建订阅信息类RedisSubscriber，模仿其他服务器节点订阅频道的操作。

   public class RedisSubscriber{/// <summary>/// 订阅/// </summary>/// <param name="channel"></param>public void SubscribeToChannel(string channel){// 获取 Redis 连接var redis = RedisConnectionHelper.Connection;// 获取 Redis 数据库ISubscriber sub = redis.GetSubscriber();//通过 sub.Subscribe 方法订阅了一个指定的 Redis 频道，//    并且定义了一个回调函数，当该频道收到消息时，回调函数会被触发，执行相应的逻辑或者业务。// 订阅指定频道sub.Subscribe(channel, (redisChannel, message) =>{//redisChannel它代表当前接收到消息的 Redis 频道名称。//redisChannel: 这是自动传入的参数，代表的是消息来自的频道名称。//    这对于订阅多个频道时尤其有用，因为你可以知道具体是哪一个频道发来的消息。// 当收到消息时触发Console.WriteLine($"我是教师管理功能模块，从频道 {redisChannel} 收到消息: {message}");Console.WriteLine("我可以做相关业务了~~~~");});Console.WriteLine($"已订阅频道: {channel}");}}

运行Main方法代码

创建发布者和订阅者对象。
订阅 test-channel 频道，确保订阅者可以接收到发布到该频道的消息。
发布者向 test-channel 发布一条消息，所有订阅者将收到该消息。
延迟 5 秒钟，以便程序不立即退出，从而保证订阅者有足够时间接收消息

 static async Task Main(string[] args){ ///Redis 是一种“广播”式的消息传递系统，任何订阅了该频道的客户端都可以接收到消息。// 创建发布者和订阅者实例var publisher = new RedisPublisher();var subscriber = new RedisSubscriber();// 订阅一个频道subscriber.SubscribeToChannel("test-channel");// 发布者发布消息到频道publisher.PublishMessage("test-channel", "我是学生管理这个功能模块的，我一把所有2025学生的毕业生学生设置为了已经毕业状态了");// 防止应用程序立即退出await Task.Delay(5000);}