百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

在 .NET Core 中从 Redis 迁移到本地内存中缓存:分步指南

mhr18 2024-11-09 12:18 24 浏览 0 评论

作为一名全栈开发人员,我最近在 .NET Core 项目中完成了从 Redis 过渡到内存缓存的过程。这种转变的驱动力是需要简化我们的架构并提高特定方案的性能。在本文中,我将指导你完成此迁移的步骤,提供编码做法,并演示在微服务体系结构中使用 .NET Core 后端和 TypeScript 前端的实际方案。

为什么要迁移到内存中缓存?

虽然 Redis 是一种强大的缓存解决方案,但内存中缓存在某些情况下可以提供优势,例如:

  • 单纯: 通过消除对单独缓存服务器的需求,降低了基础架构的复杂性。

  • 性能: 更快的访问时间,因为数据直接存储在应用程序的内存中。

  • 成本: 通过消除维护和扩展 Redis 实例的需要来降低运营成本。

分步迁移

1. 调整架构

我们的架构基本保持不变,只是我们用内存缓存替换了 Redis:

  • 用户服务: 处理与用户相关的操作。

  • 功能服务: 管理新的缓存功能及其逻辑。

  • API网关: 将请求路由到相应的服务。

  • 前端应用: 与后端服务交互。

  • 内存中缓存: 充当缓存层。

2. 在 .NET Core 中设置内存中缓存

添加必要的软件包

请确保 .NET Core 项目中具有所需的包。

dotnet add package Microsoft.Extensions.Caching.Memory

配置 In-Memory 缓存

在文件中配置内存中缓存。Startup.cs

// Startup.cs 
public void ConfigureServices(IServiceCollection services)
{
services.AddMemoryCache();

services.AddScoped<IFeatureService, FeatureService>();
services.AddDbContext<AppDbContext>(options =>
options.UseSqlServer(Configuration.GetConnectionString("DefaultConnection")));
services.AddControllers();
}

在服务中实现缓存

更新服务以使用内存中缓存。

// FeatureService.cs
public class FeatureService : IFeatureService
{
private readonly AppDbContext _context;
private readonly IMemoryCache _cache;

public FeatureService(AppDbContext context, IMemoryCache cache)
{
_context = context;
_cache = cache;
}

public async Task<FeatureResponse> ProcessFeatureAsync(FeatureRequest request)
{
var cacheKey = $"Feature-{request.Input}";
if (_cache.TryGetValue(cacheKey, out FeatureResponse cachedData))
{
return cachedData;
}

// Simulate processing
var result = new FeatureResponse
{
Success = true,
Message = "Feature processed successfully"
};

_cache.Set(cacheKey, result, new MemoryCacheEntryOptions
{
AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(5)
});

return result;
}
}

设置控制器

// FeatureController.cs
[ApiController]
[Route("api/[controller]")]
public class FeatureController : ControllerBase
{
private readonly IFeatureService _featureService;

public FeatureController(IFeatureService featureService)
{
_featureService = featureService;
}

[HttpPost]
public async Task<IActionResult> ProcessFeature([FromBody] FeatureRequest request)
{
var response = await _featureService.ProcessFeatureAsync(request);
return Ok(response);
}
}

3. 开发前端

我们继续使用带有 TypeScript 的 React 作为前端应用程序。

设置 API 服务

// apiService.ts
import axios from 'axios';

export const processFeature = async (data: FeatureRequest) => {
try {
const response = await axios.post<FeatureResponse>('/api/feature', data);
return response.data;
} catch (error) {
throw new Error('Failed to process feature');
}
};

创建 React 组件

// FeatureComponent.tsx
import React, { useState } from 'react';
import { processFeature } from './apiService';

const FeatureComponent: React.FC = () => {
const [input, setInput] = useState('');
const [message, setMessage] = useState('');

const handleSubmit = async (event: React.FormEvent) => {
event.preventDefault();
try {
const response = await processFeature({ input });
setMessage(response.message);
} catch (error) {
setMessage('Error processing feature');
}
};

return (
<div>
<form onSubmit={handleSubmit}>
<input
type="text"
value={input}
onChange={(e) => setInput(e.target.value)}
/>
<button type="submit">Submit</button>
</form>
{message && <p>{message}</p>}
</div>
);
};

export default FeatureComponent;

创建 React 组件

// FeatureComponent.tsx
import React, { useState } from 'react';
import { processFeature } from './apiService';

const FeatureComponent: React.FC = () => {
const [input, setInput] = useState('');
const [message, setMessage] = useState('');

const handleSubmit = async (event: React.FormEvent) => {
event.preventDefault();
try {
const response = await processFeature({ input });
setMessage(response.message);
} catch (error) {
setMessage('Error processing feature');
}
};

return (
<div>
<form onSubmit={handleSubmit}>
<input
type="text"
value={input}
onChange={(e) => setInput(e.target.value)}
/>
<button type="submit">Submit</button>
</form>
{message && <p>{message}</p>}
</div>
);
};

export default FeatureComponent;

4. 测试和部署

在实现内存中缓存后,我们进行了彻底的测试:

  • 单元测试: 确保各个组件按预期工作。

  • 集成测试: 验证服务之间的交互。

  • 性能测试: 衡量内存中缓存对响应时间的影响。

  • 用户验收测试 (UAT): 让真实用户参与验证解决方案。

最后,我们分阶段部署了新的缓存机制,从有限的 beta 版本开始。

编码实践和真实世界场景

以下是一些基于我们的迁移经验的编码实践和示例:

在 .NET Core 中使用依赖项注入Using Dependency Injection in .NET Core

依赖关系注入 (DI) 有助于管理依赖关系并促进干净的架构。

public void ConfigureServices(IServiceCollection services) 
{
services.AddMemoryCache();

services.AddScoped<IFeatureService, FeatureService>();
services.AddDbContext<AppDbContext>(options =>
options.UseSqlServer(Configuration.GetConnectionString("DefaultConnection")));
services.AddControllers();
}

在 TypeScript 中处理 API 请求

使用 Axios 处理 API 请求提供了一种干净简单的方法来处理 HTTP 请求。

import axios from 'axios'; 

interface FeatureRequest {
input: string;
}

interface FeatureResponse {
success: boolean;
message: string;
}

export const processFeature = async (data: FeatureRequest): Promise<FeatureResponse> => {
try {
const response = await axios.post<FeatureResponse>('/api/feature', data);
return response.data;
} catch (error) {
throw new Error('Failed to process feature');
}
};

React 中的状态管理

使用钩子管理功能组件中的状态。

const FeatureComponent: React.FC = () => {
const [input, setInput] = useState('');
const [message, setMessage] = useState('');

const handleSubmit = async (event: React.FormEvent) => {
event.preventDefault();
try {
const response = await processFeature({ input });
setMessage(response.message);
} catch (error) {
setMessage('Error processing feature');
}
};

return (
<div>
<form onSubmit={handleSubmit}>
<input
type="text"
value={input}
onChange={(e) => setInput(e.target.value)}
/>
<button type="submit">Submit</button>
</form>
{message && <p>{message}</p>}
</div>
);
};

在我们的 .NET Core 项目中从 Redis 迁移到内存中缓存简化了我们的架构,并提高了特定用例的性能。这一旅程强化了结构良好的开发方法和现代编码实践的重要性。通过将 .NET Core 用于后端,将 TypeScript 用于前端,我们创建了一个可靠且可缩放的解决方案,可有效满足用户的需求。

如果你喜欢我的文章,请给我一个赞!谢谢

相关推荐

Java面试宝典之问答系列(java面试回答)

以下内容,由兆隆IT云学院就业部根据多年成功就业服务经验提供:1.写出从数据库表Custom中查询No、Name、Num1、Num2并将Name以姓名显示、计算出的和以总和显示的SQL。SELECT...

ADG (Active Data Guard) 数据容灾架构下,如何配置 Druid 连接池?

如上图的数据容灾架构下,上层应用如果使用Druid连接池,应该如何配置,才能在数据库集群节点切换甚至主备数据中心站点切换的情况下,上层应用不需要变动(无需修改配置也无需重启);即数据库节点宕机/...

SpringBoot多数据源dynamic-datasource快速入门

一、简介dynamic-datasourc是一个基于SpringBoot的快速集成多数据源的启动器,其主要特性如下:支持数据源分组,适用于多种场景纯粹多库读写分离一主多从混合模式。支持...

SpringBoot项目快速开发框架JeecgBoot——项目简介及系统架构!

项目简介及系统架构JeecgBoot是一款基于SpringBoot的开发平台,它采用前后端分离架构,集成的框架有SpringBoot2.x、SpringCloud、AntDesignof...

常见文件系统格式有哪些(文件系统类型有哪几种)

PART.01常见文件系统格式有哪些常见的文件系统格式有很多,通常根据使用场景(Windows、Linux、macOS、移动设备、U盘、硬盘等)有所不同。以下是一些主流和常见的文件系统格式及其特点:一...

Oracle MySQL Operator部署集群(oracle mysql group by)

以下是使用OracleMySQLOperator部署MySQL集群的完整流程及关键注意事项:一、部署前准备安装MySQLOperator通过Helm安装Operator到Ku...

LibreOffice加入&#34;转向Linux&#34;运动

LibreOffice项目正准备削减部分Windows支持,并鼓励用户切换到Linux系统。自Oracle放弃OpenOffice后,支持和指导LibreOffice开发的文档基金会对未来有着明确的观...

Oracle Linux 10发布:UEK 8.1、后量子加密、增强开发工具等

IT之家6月28日消息,科技媒体linuxiac昨日(6月27日)发布博文,报道称OracleLinux10正式发布,完全二进制兼容(binarycompatibility...

【mykit-data】 数据库同步工具(数据库同步工具 开源)

项目介绍支持插件化、可视化的数据异构中间件,支持的数据异构方式如下MySQL<——>MySQL(增量、全量)MySQL<——>Oracle(增量、全量)Oracle...

oracle关于xml的解析(oracle读取xml节点的属性值)

有时需要在存储过程中处理xml,oracle提供了相应的函数来进行处理,xmltype以及相关的函数。废话少说,上代码:selectxmltype(SIConfirmOutput).extract...

如何利用DBSync实现数据库同步(通过dblink同步数据库)

DBSync是一款通用型的数据库同步软件,能侦测数据表之间的差异,能实时同步差异数据,从而使双方始终保持一致。支持各种数据库,支持异构同步、增量同步,且提供永久免费版。本文介绍其功能特点及大致用法,供...

MYSQL存储引擎InnoDB(八十):InnoDB静态数据加密

InnoDB支持独立表空间、通用表空间、mysql系统表空间、重做日志和撤消日志的静态数据加密。从MySQL8.0.16开始,还支持为模式和通用表空间设置加密默认值,这允许DBA控制在这些模...

JDK高版本特性总结与ZGC实践(jdk高版本兼容低版本吗)

美团信息安全技术团队核心服务升级JDK17后,性能与稳定性大幅提升,机器成本降低了10%。高版本JDK与ZGC技术令人惊艳,且JavaAISDK最低支持JDK17。本文总结了JDK17的主要...

4 种 MySQL 同步 ES 方案,yyds!(两个mysql数据库自动同步的方法)

本文会先讲述数据同步的4种方案,并给出常用数据迁移工具,干货满满!不BB,上文章目录:1.前言在实际项目开发中,我们经常将MySQL作为业务数据库,ES作为查询数据库,用来实现读写分离,...

计算机Java培训课程包含哪些内容?其实就这六大块

不知不觉秋天已至,如果你还处于就业迷茫期,不如来学习Java。对于非科班小白来说,Java培训会更适合你。提前了解下计算机Java培训课程内容,会有助于你后续学习。下面,我就从六个部分为大家详细介绍...

取消回复欢迎 发表评论: