Skip to content

Redis Streams

Redis 是一个开源(BSD许可)的,内存中的数据结构存储系统,它可以用作数据库、缓存和消息中间件。

Redis Stream 是 Redis 5.0 引入的一种新数据类型,它用一种仅附加的数据结构以更抽象的方式模拟日志数据结构。

Redis Streams 可以在 CAP 中用作消息传输器。

配置

要使用 Redis Streams 传输器,您需要从 NuGet 安装以下包:

PM> Install-Package DotNetCore.CAP.RedisStreams

然后,您可以在 Startup.csConfigureServices 方法中添加基于 Redis Stream 的配置项。

public void ConfigureServices(IServiceCollection services)
{
    services.AddCap(capOptions =>
    {
        capOptions.UseRedis(redisOptions=>{
            //redisOptions
        });
    });
}

Redis Streams Options

CAP 直接对外提供的 Redis Stream 配置参数如下:

NAME DESCRIPTION TYPE DEFAULT
Configuration redis连接配置 (StackExchange.Redis) ConfigurationOptions ConfigurationOptions
StreamEntriesCount 读取时从 stream 返回的条目数 uint 10
ConnectionPoolSize 连接池数 uint 10

Redis ConfigurationOptions

如果需要**更多**原生Redis相关配置选项,您可以在 Configuration 选项中进行设置 :

services.AddCap(capOptions => 
{
    capOptions.UseRedis(redisOptions=>
    {
        // redis options.
        redisOptions.Configuration.EndPoints.Add(IPAddress.Loopback, 0);
    });
});

Configuration 是 StackExchange.Redis ConfigurationOptions ,您可以通过此链接找到更多详细信息。