Redis用作Sub订阅与发布Pub

2024-03-08 17:50
文章标签 redis 发布 订阅 sub 用作 pub

本文主要是介绍Redis用作Sub订阅与发布Pub,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Redis用作Sub订阅与发布Pub

本作者从下载地址:https://download.csdn.net/download/LongtengGensSupreme/12157626下载redis包解压到本地文件目录:E:\Source\redisfile\Redis-x64-3.2.100,如下图所示

 

 

 

 

为了方便启动,我们在该目录下新建一个 startredis.bat 的文件,

然后将以下内容写入文件:redis-server redis.windows.conf

这个命令其实就是在调用 redis-server.exe 命令来读取 redis.window.conf 的内容,

双击刚才创建好的 startredis.bat 文件,就能成功的看到 Redis 启动,如下图所示:

 

redis-server启动之后放着就可以了。可以使用客户端自带工具来测试redis服务器是否可用,

Redis 自带的一个客户端工具,它可以用来连接到我们当前的 Redis 服务器,点击同一个文件夹下的 redis-cli.exe 文件,启动客户端,如下图

 

 

redis-cli客户端启动成功,如下图所示

 

我们做以下测试:在客户端dos界面输入 set key1 value1,回车,可以看到客户端显示:

 

在输入 get key1 回车,客户端显示:

  

 

通过上述工作,我们便在 Windows 的环境下安装好了Redis,我们的准备工作已完成。下面添加简单的使用Redis用作Sub订阅与发布Pub的案例,

以商品购买为案例,下单--》增加积分--》发送购买成功短信通知,如下:

1、新建控制台项目net console 控制台或者net core console控制台都可以,本文使用的是net core console控制台,取名 NetCoreConsoleTest,

在项目下添加积分类Order.cs和短信通知类SMS.cs

积分类Order.cs

using System;namespace NetCoreConsoleTest
{/// <summary>/// 积分处理/// </summary>public class Order{/// <summary>/// 积分订单/// </summary>public void AddOrder(string sn) {System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));Console.WriteLine($"订单 {sn} 处理积分完成");}}
}

短信通知类SMS.cs

using System;namespace NetCoreConsoleTest
{/// <summary>/// 短信处理/// </summary>public class SMS{/// <summary>/// 短信订单/// </summary>public void AddSMS(string sn){System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));Console.WriteLine($"订单 {sn} 处理发送短信完成");}}
}

NetCoreConsoleTest的Program.cs测试

using System;
using System.Diagnostics;namespace NetCoreConsoleTest
{class Program{static void Main(string[] args){Stopwatch stopwatch = new Stopwatch();stopwatch.Start();Console.WriteLine("...........网购处理过程............");string sn = $"WG{DateTime.Now.ToString("yyyMMddHHmmssfffffff")}";Console.WriteLine("...........处理订单............");Console.WriteLine($"订单 {sn} 处理完成");System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));#region 一般使用Console.WriteLine(".......................");Console.WriteLine("...........处理订单积分............");Order order = new Order();order.AddOrder(sn);Console.WriteLine(".......................");Console.WriteLine("...........处理订单发送短息............");SMS sMS = new SMS();sMS.AddSMS(sn);#endregionstopwatch.Stop();Console.WriteLine($"...........网购完成,总共用时{stopwatch.ElapsedMilliseconds}............");Console.ReadKey();}}
}

测试结果:

可以看到整个过程在3秒左右,

下面使用Redis用作Sub订阅与发布Pub

1、项目NetCoreConsoleTest,NuGet程序包管理,添加 StackExchange.Redis,然后添加SubAndPub.cs

using StackExchange.Redis;
using System;
namespace NetCoreConsoleTest
{/// <summary>/// 订阅与发布/// </summary>public class SubAndPub{ConnectionMultiplexer multiplexer;public SubAndPub(){multiplexer = ConnectionMultiplexer.Connect("localhost:6379");}/// <summary>/// 订阅/// </summary>public void Sub(Action<RedisChannel, RedisValue> handler){ISubscriber subscriber = multiplexer.GetSubscriber();subscriber.Subscribe("pub_sub", handler);}/// <summary>/// 发布/// </summary>public void Pub(RedisValue message){ISubscriber subscriber = multiplexer.GetSubscriber();subscriber.Publish("pub_sub", message);}}
}

2、添加控制台项目OrderForm和SMSForm

项目OrderForm

using NetCoreConsoleTest;
using System;namespace OrderForm
{public class Program{static void Main(string[] args){Console.WriteLine("积分");SubAndPub subAndPub = new SubAndPub();subAndPub.Sub((a, b) =>{System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));Console.WriteLine($"订单 {b}, 处理积分完成");});Console.ReadKey();}}
}

项目SMSForm

using NetCoreConsoleTest;
using System;namespace SMSForm
{public class Program{static void Main(string[] args){Console.WriteLine("短信");SubAndPub subAndPub = new SubAndPub();subAndPub.Sub((a, b) =>{System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));Console.WriteLine($"订单 {b} 发送短信完成");});Console.ReadKey();}}
}

NetCoreConsoleTest的Program中修改为如下

using StackExchange.Redis;
using System;
using System.Diagnostics;namespace NetCoreConsoleTest
{class Program{static void Main(string[] args){Stopwatch stopwatch = new Stopwatch();stopwatch.Start();#region pub sub 订阅发布string sn = null;SubAndPub subAndPub = new SubAndPub();for (int i = 0; i < 20; i++){sn = $"WG{DateTime.Now.ToString("yyyMMddHHmmssfffffff")}";Console.WriteLine($"生成第 {i} 个订单,订单号:{sn}");Console.WriteLine("...........处理订单............");Console.WriteLine($"订单 {sn} 处理完成");System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));//发布subAndPub.Pub(sn);System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));}#endregionstopwatch.Stop();Console.WriteLine($"...........网购完成,总共用时{stopwatch.ElapsedMilliseconds}............");Console.ReadKey();}}
}

生成上述NetCoreConsoleTest,OrderForm和SMSForm三个项目,然后启动redis服务器,先启动OrderForm和SMSForm项目,然后启动 NetCoreConsoleTest项目,运行结果

完整代码:https://download.csdn.net/download/LongtengGensSupreme/12254559

这篇关于Redis用作Sub订阅与发布Pub的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/787909

相关文章

微信公众号脚本-获取热搜自动新建草稿并发布文章

《微信公众号脚本-获取热搜自动新建草稿并发布文章》本来想写一个自动化发布微信公众号的小绿书的脚本,但是微信公众号官网没有小绿书的接口,那就写一个获取热搜微信普通文章的脚本吧,:本文主要介绍微信公众... 目录介绍思路前期准备环境要求获取接口token获取热搜获取热搜数据下载热搜图片给图片加上标题文字上传图片

SpringKafka消息发布之KafkaTemplate与事务支持功能

《SpringKafka消息发布之KafkaTemplate与事务支持功能》通过本文介绍的基本用法、序列化选项、事务支持、错误处理和性能优化技术,开发者可以构建高效可靠的Kafka消息发布系统,事务支... 目录引言一、KafkaTemplate基础二、消息序列化三、事务支持机制四、错误处理与重试五、性能优

新特性抢先看! Ubuntu 25.04 Beta 发布:Linux 6.14 内核

《新特性抢先看!Ubuntu25.04Beta发布:Linux6.14内核》Canonical公司近日发布了Ubuntu25.04Beta版,这一版本被赋予了一个活泼的代号——“Plu... Canonical 昨日(3 月 27 日)放出了 Beta 版 Ubuntu 25.04 系统镜像,代号“Pluc

Redis 中的热点键和数据倾斜示例详解

《Redis中的热点键和数据倾斜示例详解》热点键是指在Redis中被频繁访问的特定键,这些键由于其高访问频率,可能导致Redis服务器的性能问题,尤其是在高并发场景下,本文给大家介绍Redis中的热... 目录Redis 中的热点键和数据倾斜热点键(Hot Key)定义特点应对策略示例数据倾斜(Data S

redis+lua实现分布式限流的示例

《redis+lua实现分布式限流的示例》本文主要介绍了redis+lua实现分布式限流的示例,可以实现复杂的限流逻辑,如滑动窗口限流,并且避免了多步操作导致的并发问题,具有一定的参考价值,感兴趣的可... 目录为什么使用Redis+Lua实现分布式限流使用ZSET也可以实现限流,为什么选择lua的方式实现

Redis中管道操作pipeline的实现

《Redis中管道操作pipeline的实现》RedisPipeline是一种优化客户端与服务器通信的技术,通过批量发送和接收命令减少网络往返次数,提高命令执行效率,本文就来介绍一下Redis中管道操... 目录什么是pipeline场景一:我要向Redis新增大批量的数据分批处理事务( MULTI/EXE

Redis中高并发读写性能的深度解析与优化

《Redis中高并发读写性能的深度解析与优化》Redis作为一款高性能的内存数据库,广泛应用于缓存、消息队列、实时统计等场景,本文将深入探讨Redis的读写并发能力,感兴趣的小伙伴可以了解下... 目录引言一、Redis 并发能力概述1.1 Redis 的读写性能1.2 影响 Redis 并发能力的因素二、

Redis中的常用的五种数据类型详解

《Redis中的常用的五种数据类型详解》:本文主要介绍Redis中的常用的五种数据类型详解,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Redis常用的五种数据类型一、字符串(String)简介常用命令应用场景二、哈希(Hash)简介常用命令应用场景三、列表(L

Redis解决缓存击穿问题的两种方法

《Redis解决缓存击穿问题的两种方法》缓存击穿问题也叫热点Key问题,就是⼀个被高并发访问并且缓存重建业务较复杂的key突然失效了,无数的请求访问会在瞬间给数据库带来巨大的冲击,本文给大家介绍了Re... 目录引言解决办法互斥锁(强一致,性能差)逻辑过期(高可用,性能优)设计逻辑过期时间引言缓存击穿:给

Redis中如何实现商品秒杀

《Redis中如何实现商品秒杀》:本文主要介绍Redis中如何实现商品秒杀问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录技术栈功能实现步骤步骤一:准备商品库存数据步骤二:实现商品秒杀步骤三:优化Redis性能技术讲解Redis的List类型Redis的Set