.NetCore使用Redis，StackExchange.Redis队列，发布与订阅，分布式锁的简单使用-程序员宅基地
https://www.cnblogs.com/Fengge518/p/13556182.html
环境：之前一直是使用serverStack.Redis的客服端，
今天来使用一下StackExchange.Redis(个人感觉更加的人性化一些，也是免费的，性能也不会差太多)，
版本为StackExchange.Redis V2.1.58 ,Core3.1
简单的说明(专业的术语参考资料网络和官网)：官网地址：https://www.redis.net.cn/
Redis（Remote Dictionary Server )，即远程字典服务是一个开源的 ，由C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。
Redis 是一个高性能的key-value数据库。Redis的出现，很大程度补偿了memcached这类key/value存储的不足，
提供了Java，C/C++，C#，PHP，JavaScript，Perl，Object-C，Python，Ruby，Erlang等客户端，使用很方便。
优点：
1 Redis读写性能优异，从内存当中进行IO读写速度快，支持超过100K+每秒的读写频率。
2 Redis支持Strings,
Lists, Hashes, Sets,Ordered Sets等数据类型操作。
3 Redis支持数据持久化，支持AOF和RDB两种持久化方式
4 Redis支持主从复制，主机会自动将数据同步到从机，可以进行读写分离。
5 Redis的所有操作都是原子性的，同时Redis还支持对几个操作全并后的原子性执行。
6 Redis是单线程多CPU，不需要考虑加锁释放锁，也就没有死锁的问题，效率高。
1：redis队列值入队出队,截图效果：
优化之前入队1000条数据，测试结果将近50秒，这实在太慢，不可忍受！
优化后的效果：为5.55s的样子
2：redis发布与订阅截图效果：(一个发布者，四个订阅者) 订阅者都会收到相同的信息
3：redis秒杀，截图如下：单个进程秒杀ok
开多个进程时，会有超卖的现象：（那我加lock锁呢？结果也是会有超卖的现象，此时下面的分布式锁可以解决）
4：加上redis分布式锁的测试效果截图：
但是这样会比较耗资源，库存已经没有了，就应该不要再去执行下去了
分布式锁ok库存为零就不在请求直接抛异常即可
上面通过测试的截图，简单的介绍了，Redis的队列(入队和出队)，Redis发布与订阅，Redis分布式锁的使用，现在直接上代码 ：
出队入队的WebApi Core3.1
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace WebApp.Controllers
{
using Microsoft.AspNetCore.Mvc;
using RedisPublishAndSubHelper;
[Route("api/[Controller]")]
[ApiController]
public class RedisTestController
{
[HttpGet("EnqueueMsg")]
public async Task<ApiResultObject> EnqueueMsgAsync(string rediskey, string redisValue)
{
ApiResultObject obj = new ApiResultObject();
try
{
long enqueueLong = default;
for (int i = 0; i < 1000; i++)
{
enqueueLong = await MyRedisSubPublishHelper.EnqueueListLeftPushAsync(rediskey, redisValue + i);
}
obj.Code = ResultCode.Success;
obj.Data = "入队的数据长度：" + enqueueLong;
obj.Msg = "入队成功！";
}
catch (Exception ex)
{
obj.Msg = $"入队异常，原因：{ex.Message}";
}
return obj;
}
[HttpGet("DequeueMsg")]
public async Task<ApiResultObject> DequeueMsgAsync(string rediskey)
{
ApiResultObject obj = new ApiResultObject();
try
{
string dequeueMsg = await MyRedisSubPublishHelper.DequeueListPopRightAsync(rediskey);
obj.Code = ResultCode.Success;
obj.Data = $"出队的数据是：{dequeueMsg}";
obj.Msg = "入队成功！";
}
catch (Exception ex)
{
obj.Msg = $"入队异常，原因：{ex.Message}";
}
return obj;
}
}
}
出队入队的后端code WebApi：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace WebApp.Controllers
{
using Microsoft.AspNetCore.Mvc;
using RedisPublishAndSubHelper;
[Route("api/[Controller]")]
[ApiController]
public class RedisTestController
{
[HttpGet("EnqueueMsg")]
public async Task<ApiResultObject> EnqueueMsgAsync(string rediskey, string redisValue)
{
ApiResultObject obj = new ApiResultObject();
try
{
long enqueueLong = default;
for (int i = 0; i < 1000; i++)
{
enqueueLong = await MyRedisSubPublishHelper.EnqueueListLeftPushAsync(rediskey, redisValue + i);
}
obj.Code = ResultCode.Success;
obj.Data = "入队的数据长度：" + enqueueLong;
obj.Msg = "入队成功！";
}
catch (Exception ex)
{
obj.Msg = $"入队异常，原因：{ex.Message}";
}
return obj;
}
[HttpGet("DequeueMsg")]
public async Task<ApiResultObject> DequeueMsgAsync(string rediskey)
{
ApiResultObject obj = new ApiResultObject();
try
{
string dequeueMsg = await MyRedisSubPublishHelper.DequeueListPopRightAsync(rediskey);
obj.Code = ResultCode.Success;
obj.Data = $"出队的数据是：{dequeueMsg}";
obj.Msg = "入队成功！";
}
catch (Exception ex)
{
obj.Msg = $"入队异常，原因：{ex.Message}";
}
return obj;
}
}
}
入队以及秒杀分布式锁的客服端的Code：
using System;
using System.Threading;
using System.Threading.Tasks;
namespace RedisPublishService
{
using RedisPublishAndSubHelper;
class Program
{
static void Main(string[] args)
{
#region 入队的code
{
int Index = 100000;
while (Index > 0)
{
//string msg = Console.ReadLine();
new MyRedisSubPublishHelper().PublishMessage("nihaofengge", $"你好风哥：Guid值是：{DateTime.Now}{Guid.NewGuid().ToString()}");
Console.WriteLine("发布成功！");
Index -= 1;
}
Console.ReadKey();
}
#endregion
#region 秒杀的code
{
try
{
Console.WriteLine("秒杀开始。。。。。");
for (int i = 0; i < 200; i++)
{
Task.Run(() =>
{
MyRedisSubPublishHelper.LockByRedis("mstest");
string productCount = MyRedisHelper.StringGet("productcount");
int pcount = int.Parse(productCount);
if (pcount > 0)
{
long dlong = MyRedisHelper.StringDec("productcount");
Console.WriteLine($"秒杀成功，商品库存:{dlong}");
pcount -= 1;
System.Threading.Thread.Sleep(30);
}
else
{
Console.WriteLine($"秒杀失败，商品库存为零了！");
throw new Exception("产品秒杀数量为零！");//加载这里会比较保险
}
MyRedisSubPublishHelper.UnLockByRedis("mstest");
}).Wait();
}
}
catch (Exception ex)
{
Console.WriteLine($"产品已经秒杀完毕，原因：{ex.Message}");
}
Console.ReadKey();
}
#endregion
}
}
}
完整的code RedisHelper帮助类(测试并使用了部分方法的封装)，
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace RedisPublishAndSubHelper
{
using StackExchange.Redis;
using StackExchange;
using System.Threading;
public class MyRedisHelper
{
private static readonly string connectionRedisStr = string.Empty;
static MyRedisHelper()
{
//在这里来初始化一些配置信息
connectionRedisStr = "12.23.45.12:6379,connectTimeout=1000,connectRetry=3,syncTimeout=10000";
}
#region Redis string简单的常见同步方法操作
public static bool StringSet(string key, string stringValue, double senconds = 60)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
IDatabase db = conn.GetDatabase();
return db.StringSet(key, stringValue, TimeSpan.FromSeconds(senconds));
}
}
public static string StringGet(string key)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
IDatabase db = conn.GetDatabase();
return db.StringGet(key);
}
}
public static long StringInc(string key)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
IDatabase db = conn.GetDatabase();
return db.StringIncrement(key);
}
}
public static long StringDec(string key)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
IDatabase db = conn.GetDatabase();
return db.StringDecrement(key);
}
}
public static bool KeyExists(string key)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
IDatabase db = conn.GetDatabase();
return db.KeyExists(key);
}
}
#endregion
#region List Hash, Set,Zset 大同小异的使用，比较简单,后续有时间再补上
#endregion
#region 入队出队
#region 入队
/// <summary>
/// 入队right
/// </summary>
/// <param name="queueName"></param>
/// <param name="redisValue"></param>
/// <returns></returns>
public static long EnqueueListRightPush(RedisKey queueName, RedisValue redisValue)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
return conn.GetDatabase().ListRightPush(queueName, redisValue);
}
}
/// <summary>
/// 入队left
/// </summary>
/// <param name="queueName"></param>
/// <param name="redisvalue"></param>
/// <returns></returns>
public static long EnqueueListLeftPush(RedisKey queueName, RedisValue redisvalue)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
return conn.GetDatabase().ListLeftPush(queueName, redisvalue);
}
}
/// <summary>
/// 入队left异步
/// </summary>
/// <param name="queueName"></param>
/// <param name="redisvalue"></param>
/// <returns></returns>
public static async Task<long> EnqueueListLeftPushAsync(RedisKey queueName, RedisValue redisvalue)
{
using (var conn = await ConnectionMultiplexer.ConnectAsync(connectionRedisStr))
{
return await conn.GetDatabase().ListLeftPushAsync(queueName, redisvalue);
}
}
/// <summary>
/// 获取队列的长度
/// </summary>
/// <param name="queueName"></param>
/// <returns></returns>
public static long EnqueueListLength(RedisKey queueName)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
return conn.GetDatabase().ListLength(queueName);
}
}
#endregion
#region 出队
public static string DequeueListPopLeft(RedisKey queueName)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
IDatabase database = conn.GetDatabase();
int count = database.ListRange(queueName).Length;
if (count <= 0)
{
throw new Exception($"队列{queueName}数据为零");
}
string redisValue = database.ListLeftPop(queueName);
if (!string.IsNullOrEmpty(redisValue))
return redisValue;
else
return string.Empty;
}
}
public static string DequeueListPopRight(RedisKey queueName)
{
using (var conn = ConnectionMultiplexer.Connect(connectionRedisStr))
{
IDatabase database = conn.GetDatabase();
int count = database.ListRange(queueName).Length;
if (count <= 0)
{
throw new Exception($"队列{queueName}数据为零");
}
string redisValue = conn.GetDatabase().ListRightPop(queueName);
if (!string.IsNullOrEmpty(redisValue))
return redisValue;
else
return string.Empty;
}
}
public static async Task<string> DequeueListPopRightAsync(RedisKey queueName)
{
using (var conn = await ConnectionMultiplexer.ConnectAsync(connectionRedisStr))
{
IDatabase database = conn.GetDatabase();
int count = (await database.ListRangeAsync(queueName)).Length;
if (count <= 0)
{
throw new Exception($"队列{queueName}数据为零");
}
string redisValue = await conn.GetDatabase().ListRightPopAsync(queueName);
if (!string.IsNullOrEmpty(redisValue))
return redisValue;
else
return string.Empty;
}
}
#endregion
#endregion
#region 分布式锁
public static void LockByRedis(string key, int expireTimeSeconds = 10)
{
try
{
IDatabase database1 = ConnectionMultiplexer.Connect(connectionRedisStr).GetDatabase();
while (true)
{
expireTimeSeconds = expireTimeSeconds > 20 ? 10 : expireTimeSeconds;
bool lockflag = database1.LockTake(key, Thread.CurrentThread.ManagedThreadId, TimeSpan.FromSeconds(expireTimeSeconds));
if (lockflag)
{
break;
}
}
}
catch (Exception ex)
{
throw new Exception($"Redis加锁异常:原因{ex.Message}");
}
}
public static bool UnLockByRedis(string key)
{
ConnectionMultiplexer conn = ConnectionMultiplexer.Connect(connectionRedisStr);
try
{
IDatabase database1 = conn.GetDatabase();
return database1.LockRelease(key, Thread.CurrentThread.ManagedThreadId);
}
catch (Exception ex)
{
throw new Exception($"Redis加锁异常:原因{ex.Message}");
}
finally
{
if (conn != null)
{
conn.Close();
conn.Dispose();
}
}
}
#endregion
}
}
using System;
using System.Collections.Generic;
using System.Text;
namespace RedisPublishAndSubHelper
{
using StackExchange.Redis;
using System.Net.Http;
using System.Threading;
using System.Threading.Channels;
using System.Threading.Tasks;
public class MyRedisSubPublishHelper
{
private static readonly string redisConnectionStr = "12.32.12.54:6379,connectTimeout=10000,connectRetry=3,syncTimeout=10000";
private static readonly ConnectionMultiplexer connectionMultiplexer = null;
static MyRedisSubPublishHelper()
{
connectionMultiplexer = ConnectionMultiplexer.Connect(redisConnectionStr);
}
#region 发布订阅
public void SubScriper(string topticName, Action<RedisChannel, RedisValue> handler = null)
{
ISubscriber subscriber = connectionMultiplexer.GetSubscriber();
ChannelMessageQueue channelMessageQueue = subscriber.Subscribe(topticName);
channelMessageQueue.OnMessage(channelMessage =>
{
if (handler != null)
{
string redisChannel = channelMessage.Channel;
string msg = channelMessage.Message;
handler.Invoke(redisChannel, msg);
}
else
{
string msg = channelMessage.Message;
Console.WriteLine($"订阅到消息: { msg},Channel={channelMessage.Channel}");
}
});
}
public void PublishMessage(string topticName, string message)
{
ISubscriber subscriber = connectionMultiplexer.GetSubscriber();
long publishLong = subscriber.Publish(topticName, message);
Console.WriteLine($"发布消息成功：{publishLong}");
}
#endregion
#region 入队出队
public static async Task<long> EnqueueListLeftPushAsync(RedisKey queueName, RedisValue redisvalue)
{
return await connectionMultiplexer.GetDatabase().ListLeftPushAsync(queueName, redisvalue);
}
public static async Task<string> DequeueListPopRightAsync(RedisKey queueName)
{
IDatabase database = connectionMultiplexer.GetDatabase();
int count = (await database.ListRangeAsync(queueName)).Length;
if (count <= 0)
{
throw new Exception($"队列{queueName}数据为零");
}
string redisValue = await database.ListRightPopAsync(queueName);
if (!string.IsNullOrEmpty(redisValue))
return redisValue;
else
return string.Empty;
}
#endregion
#region 分布式锁
public static void LockByRedis(string key, int expireTimeSeconds = 10)
{
try
{
IDatabase database = connectionMultiplexer.GetDatabase();
while (true)
{
expireTimeSeconds = expireTimeSeconds > 20 ? 10 : expireTimeSeconds;
bool lockflag = database.LockTake(key, Thread.CurrentThread.ManagedThreadId, TimeSpan.FromSeconds(expireTimeSeconds));
if (lockflag)
{
break;
}
}
}
catch (Exception ex)
{
throw new Exception($"Redis加锁异常:原因{ex.Message}");
}
}
public static bool UnLockByRedis(string key)
{
try
{
IDatabase database = connectionMultiplexer.GetDatabase();
return database.LockRelease(key, Thread.CurrentThread.ManagedThreadId);
}
catch (Exception ex)
{
throw new Exception($"Redis加锁异常:原因{ex.Message}");
}
}
#endregion
}
}
智能推荐
使用nginx解决浏览器跨域问题_nginx不停的xhr-程序员宅基地
文章浏览阅读1k次。通过使用ajax方法跨域请求是浏览器所不允许的，浏览器出于安全考虑是禁止的。警告信息如下：不过jQuery对跨域问题也有解决方案，使用jsonp的方式解决，方法如下：$.ajax({ async:false, url: 'http://www.mysite.com/demo.do', // 跨域URL ty..._nginx不停的xhr
在 Oracle 中配置 extproc 以访问 ST_Geometry-程序员宅基地
文章浏览阅读2k次。关于在 Oracle 中配置 extproc 以访问 ST_Geometry，也就是我们所说的 使用空间SQL 的方法，官方文档链接如下。http://desktop.arcgis.com/zh-cn/arcmap/latest/manage-data/gdbs-in-oracle/configure-oracle-extproc.htm其实简单总结一下，主要就分为以下几个步骤。..._extproc
Linux C++ gbk转为utf-8_linux c++ gbk->utf8-程序员宅基地
文章浏览阅读1.5w次。linux下没有上面的两个函数，需要使用函数 mbstowcs和wcstombsmbstowcs将多字节编码转换为宽字节编码wcstombs将宽字节编码转换为多字节编码这两个函数，转换过程中受到系统编码类型的影响，需要通过设置来设定转换前和转换后的编码类型。通过函数setlocale进行系统编码的设置。linux下输入命名locale -a查看系统支持的编码_linux c++ gbk->utf8
IMP-00009: 导出文件异常结束-程序员宅基地
文章浏览阅读750次。今天准备从生产库向测试库进行数据导入，结果在imp导入的时候遇到“ IMP-00009:导出文件异常结束” 错误，google一下，发现可能有如下原因导致imp的数据太大，没有写buffer和commit两个数据库字符集不同从低版本exp的dmp文件，向高版本imp导出的dmp文件出错传输dmp文件时，文件损坏解决办法：imp时指定..._imp-00009导出文件异常结束
python程序员需要深入掌握的技能_Python用数据说明程序员需要掌握的技能-程序员宅基地
文章浏览阅读143次。当下是一个大数据的时代，各个行业都离不开数据的支持。因此，网络爬虫就应运而生。网络爬虫当下最为火热的是Python，Python开发爬虫相对简单，而且功能库相当完善，力压众多开发语言。本次教程我们爬取前程无忧的招聘信息来分析Python程序员需要掌握那些编程技术。首先在谷歌浏览器打开前程无忧的首页，按F12打开浏览器的开发者工具。浏览器开发者工具是用于捕捉网站的请求信息，通过分析请求信息可以了解请..._初级python程序员能力要求
Spring @Service生成bean名称的规则（当类的名字是以两个或以上的大写字母开头的话，bean的名字会与类名保持一致）_@service beanname-程序员宅基地
文章浏览阅读7.6k次，点赞2次，收藏6次。@Service标注的bean，类名：ABDemoService查看源码后发现，原来是经过一个特殊处理：当类的名字是以两个或以上的大写字母开头的话，bean的名字会与类名保持一致public class AnnotationBeanNameGenerator implements BeanNameGenerator { private static final String C..._@service beanname
随便推点
二叉树的各种创建方法_二叉树的建立-程序员宅基地
文章浏览阅读6.9w次，点赞73次，收藏463次。1.前序创建#include<stdio.h>#include<string.h>#include<stdlib.h>#include<malloc.h>#include<iostream>#include<stack>#include<queue>using namespace std;typed_二叉树的建立
解决asp.net导出excel时中文文件名乱码_asp.net utf8 导出中文字符乱码-程序员宅基地
文章浏览阅读7.1k次。在Asp.net上使用Excel导出功能，如果文件名出现中文，便会以乱码视之。 解决方法： fileName = HttpUtility.UrlEncode(fileName, System.Text.Encoding.UTF8);_asp.net utf8 导出中文字符乱码
笔记-编译原理-实验一-词法分析器设计_对pl/0作以下修改扩充。增加单词-程序员宅基地
文章浏览阅读2.1k次，点赞4次，收藏23次。第一次实验 词法分析实验报告设计思想词法分析的主要任务是根据文法的词汇表以及对应约定的编码进行一定的识别，找出文件中所有的合法的单词，并给出一定的信息作为最后的结果，用于后续语法分析程序的使用；本实验针对 PL/0 语言 的文法、词汇表编写一个词法分析程序，对于每个单词根据词汇表输出： (单词种类, 单词的值) 二元对。词汇表：种别编码单词符号助记符0beginb..._对pl/0作以下修改扩充。增加单词
android adb shell 权限,android adb shell权限被拒绝-程序员宅基地
文章浏览阅读773次。我在使用adb.exe时遇到了麻烦.我想使用与bash相同的adb.exe shell提示符,所以我决定更改默认的bash二进制文件(当然二进制文件是交叉编译的,一切都很完美)更改bash二进制文件遵循以下顺序> adb remount> adb push bash / system / bin /> adb shell> cd / system / bin> chm..._adb shell mv 权限
投影仪-相机标定_相机-投影仪标定-程序员宅基地
文章浏览阅读6.8k次，点赞12次，收藏125次。1. 单目相机标定引言相机标定已经研究多年，标定的算法可以分为基于摄影测量的标定和自标定。其中，应用最为广泛的还是张正友标定法。这是一种简单灵活、高鲁棒性、低成本的相机标定算法。仅需要一台相机和一块平面标定板构建相机标定系统，在标定过程中，相机拍摄多个角度下（至少两个角度，推荐10~20个角度）的标定板图像（相机和标定板都可以移动），即可对相机的内外参数进行标定。下面介绍张氏标定法（以下也这么称呼）的原理。原理相机模型和单应矩阵相机标定，就是对相机的内外参数进行计算的过程，从而得到物体到图像的投影_相机-投影仪标定
Wayland架构、渲染、硬件支持-程序员宅基地
文章浏览阅读2.2k次。文章目录Wayland 架构Wayland 渲染Wayland的 硬件支持简 述： 翻译一篇关于和 wayland 有关的技术文章, 其英文标题为Wayland Architecture .Wayland 架构若是想要更好的理解 Wayland 架构及其与 X (X11 or X Window System) 结构；一种很好的方法是将事件从输入设备就开始跟踪, 查看期间所有的屏幕上出现的变化。这就是我们现在对 X 的理解。 内核是从一个输入设备中获取一个事件，并通过 evdev 输入_wayland