.net使用cap實現(xiàn)消息異步處理
更新時間：2024年05月17日 10:05:15 作者：假裝我不帥
CAP 是一個基于 .NET Standard 的 C# 庫,它是一種處理分布式事務的解決方案,同樣具有 EventBus 的功能,它具有輕量級、易使用、高性能等特點,本文給大家介紹了.net下使用cap實現(xiàn)消息異步處理,需要的朋友可以參考下
介紹
CAP 是一個基于 .NET Standard 的 C# 庫，它是一種處理分布式事務的解決方案，同樣具有 EventBus 的功能，它具有輕量級、易使用、高性能等特點。
新建項目
新建.net7web項目
安裝依賴包
安裝軟件
安裝redis和Sql Server
修改代碼
新建RedisConfigModel
namespace CAPStu01.Models;
public class RedisConfigModel
{
/// <summary>
/// 服務器地址
/// </summary>
public string Host { get; set; }
/// <summary>
/// 端口號
/// </summary>
public int Port { get; set; }
/// <summary>
/// 密碼
/// </summary>
public string Pwd { get; set; }
}
修改appsettings.json
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"ConnectionStrings": {
"SQlServer": "server=127.0.0.1;User ID=sa;Password=xxxx;database=capstu;Encrypt=True;TrustServerCertificate=True;connection timeout=600;"
},
"RedisConfig": {
"Host": "127.0.0.1",
"Port": 6379,
"Pwd": ""
}
}
修改Program.cs
using CAPStu01.Models;
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddControllers();
var redisConfig = builder.Configuration.GetSection("RedisConfig").Get<RedisConfigModel>();
var connectionStr = builder.Configuration.GetConnectionString("SQlServer") ?? "";
builder.Services.AddCap(x =>
{
x.UseRedis(options =>
{
if (options.Configuration != null && redisConfig != null)
{
options.Configuration.EndPoints.Add(redisConfig.Host, redisConfig.Port);
options.Configuration.DefaultDatabase = 0;
options.Configuration.Password = redisConfig?.Pwd ?? "";
}
});
x.UseSqlServer(sqlServerOptions =>
{
sqlServerOptions.Schema = "dbo";
sqlServerOptions.ConnectionString = connectionStr;
});
//開啟面板
x.UseDashboard(d =>
{
//允許匿名訪問
d.AllowAnonymousExplicit = true;
});
});
var app = builder.Build();
app.UseRouting();
app.MapControllers();
app.Run();
新建HomeController
using DotNetCore.CAP;
using Microsoft.AspNetCore.Mvc;
namespace CAPStu01.Controllers;
[ApiController]
public class HomeController:ControllerBase
{
public HomeController()
{
}
/// <summary>
/// 發(fā)送消息
/// </summary>
/// <returns></returns>
[HttpGet("/")]
public IActionResult Index([FromServices]ICapPublisher capBus)
{
capBus.Publish("test.show.time","你好,CAP");
return Content("發(fā)送消息成功");
}
/// <summary>
/// 接受消息
/// </summary>
/// <param name="data"></param>
[NonAction]
[CapSubscribe("test.show.time")]
public void ReceiveMessage(string data)
{
Console.WriteLine("message data is:" + data);
}
}
結果
如果使用redis需要定期清理streams內容
安裝freeredis，修改Program.cs
builder.Services.AddSingleton<IRedisClient>(new RedisClient($"{redisConfig.Host}:{redisConfig.Port},password={redisConfig.Pwd},defaultDatabase=0"));
新增清除方法
private readonly IRedisClient _redisClient;
public HomeController(IRedisClient redisClient)
{
_redisClient = redisClient;
}
/// <summary>
/// 清除已處理的redis數(shù)據(jù)
/// </summary>
/// <returns></returns>
[HttpGet("/clear")]
public IActionResult ClearAckStream()
{
var groups = _redisClient.XInfoGroups("test.show.time");
var unreandMsgs = new List<string>();
//獲取所有的未讀消息
foreach (var group in groups)
{
if (group.pending > 0)
{
//有未讀消息
var unReadList = _redisClient.XPending("test.show.time", group.name);
if (unReadList.count > 0)
{
var groupInfo = _redisClient.XPending("test.show.time", group.name);
var unreandList = _redisClient.XPending("test.show.time", group.name, groupInfo.minId, groupInfo.maxId,
groupInfo.count);
foreach (var unre in unreandList)
{
unreandMsgs.Add(unre.id);
}
}
}
}
//獲取全部的消息
var allMsgs = _redisClient.XRange("test.show.time", "-", "+");
foreach (var msg in allMsgs)
{
if (unreandMsgs.Contains(msg.id))
{
//這個消息未讀則跳過
continue;
}
//刪除已處理的消息
_redisClient.XDel("test.show.time", msg.id);
}
return Content($"共處理未讀消息:{unreandMsgs.Count}個，已讀消息{allMsgs.Length}個");
}
以上就是.net使用cap實現(xiàn)消息異步處理的詳細內容，更多關于.net cap消息處理的資料請關注腳本之家其它相關文章！
相關文章
完成OSS.Http底層HttpClient重構封裝 支持標準庫
OSS.Http項目對于.Net Standard標準庫的支持已經(jīng)遷移完畢，OSS開源系列兩個最底層的類庫已經(jīng)具備跨運行時支持的能力。本篇文章主要包含 1. HttpClient的介紹，2. 重構的思路， 3. 容易遇到的問題。具有很好的參考價值，下面跟著小編一起來看下吧2017-02-02
這篇文章主要介紹了C#隊列Queue多線程用法,實例分析了隊列的相關使用技巧,需要的朋友可以參考下2015-05-05
這篇文章主要介紹了C#中如何使用Chart圖表問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-11-11
這篇文章主要介紹了c#自帶緩存使用方法,包括獲取數(shù)據(jù)緩存、設置數(shù)據(jù)緩存、移除指定數(shù)據(jù)緩存等方法，需要的朋友可以參考下2014-02-02
這篇文章主要為大家詳細介紹了C#遍歷文件夾獲取指定后綴名文件，具有一定的參考價值，感興趣的小伙伴們可以參考一下2019-03-03
C#使用CefSharp實現(xiàn)內嵌網(wǎng)頁詳解
這篇文章主要介紹了C# WPF里怎么使用CefSharp嵌入一個網(wǎng)頁，并給出一個簡單示例演示C#和網(wǎng)頁（JS）的交互實現(xiàn)，感興趣的小伙伴可以了解一下2023-04-04
本文主要介紹了C#?執(zhí)行Javascript腳本的方法步驟，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-01-01
C#調用Win32的API函數(shù)--User32.dll
這篇文章主要介紹了C#調用Win32_的API函數(shù)--User32.dll，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-01-01
最近在排查項目OTA的一個問題,觸發(fā)了一毫秒或者2毫秒執(zhí)行一次進程間通信的,導致通信阻塞的問題,這樣就需要用到模擬觸發(fā)1ms或者2ms觸發(fā)事件,所以本文給大家介紹了C#?定時器?Timer?如何精確到?1-2?毫秒以內,需要的朋友可以參考下2024-12-12
C#實現(xiàn)啟用與禁用本地網(wǎng)絡的方式小結【3種方式】
這篇文章主要介紹了C#實現(xiàn)啟用與禁用本地網(wǎng)絡的方式,結合實例形式總結分析了使用Hnetcfg.dll、Shell32.dll及setupapi.dll三種啟用與禁用本地網(wǎng)絡的操作方法,需要的朋友可以參考下2016-07-07