ADO.NET+Redis 实现缓存

using System;

using System.Data;

using System.Data.SqlClient;

using StackExchange.Redis;

class Program

{

static void Main(string[] args)

{

// Redis 连接配置

var redisConnectionString = "localhost";

var redis = ConnectionMultiplexer.Connect(redisConnectionString);

var db = redis.GetDatabase();

// 数据库连接配置

var sqlConnectionString = "Data Source=(local);Initial Catalog=YourDatabase;Integrated Security=True";

using (var sqlConnection = new SqlConnection(sqlConnectionString))

{

sqlConnection.Open();

// 执行 SQL 查询

using (var command = new SqlCommand("SELECT * FROM YourTable", sqlConnection))

using (var reader = command.ExecuteReader())

{

while (reader.Read())

{

// 假设我们有一个唯一标识符，例如 "id"

var id = reader["id"].ToString();

// 从 Redis 尝试获取数据

string cachedData = db.StringGet(id);

if (cachedData == null)

{

// 如果 Redis 中没有数据，则从数据库读取

var data = reader["data"].ToString();

// 将数据存入 Redis，并设置过期时间（例如，30分钟）

db.StringSet(id, data, expiry: TimeSpan.FromMinutes(30));

cachedData = data; // 现在 Redis 中有数据了，使用它

}

// 使用缓存数据

Console.WriteLine($"ID: {id}, Data: {cachedData}");

}

}

}

}

}