src/Library/NetPro.StackExchange.Redis/StackExchange.Redis.Extensions.AspNetCore/Midllewares/RedisInformationMiddleware.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using StackExchange.Redis.Extensions.Core.Abstractions;
using System.Linq;
using System.Text.Json;
using System.Threading.Tasks;

namespace StackExchange.Redis.Extensions.AspNetCore.Midllewares
{
    internal class RedisInformationMiddleware
    {
        private readonly ILogger<RedisInformationMiddleware> logger;
        private readonly RequestDelegate next;
        private readonly IRedisCacheConnectionPoolManager connectionPoolManager;
        private readonly IRedisDatabase redisDatabase;
        private readonly RedisMiddlewareAccessOptions options;

        public RedisInformationMiddleware(
            RequestDelegate next,
            RedisMiddlewareAccessOptions options,
            ILogger<RedisInformationMiddleware> logger,
            IRedisCacheConnectionPoolManager connectionPoolManager,
            IRedisDatabase redisDatabase)
        {
            this.next = next;
            this.options = options;
            this.logger = logger;
            this.connectionPoolManager = connectionPoolManager;
            this.redisDatabase = redisDatabase;
        }

        public async Task Invoke(HttpContext context)
        {
            logger.LogTrace("{0} --> Handling request: {1}", nameof(RedisInformationMiddleware), context.Request.Path);

            if (context.Request.Method == "GET" && context.Request.Path == "/redis/connectionInfo")
            {
                if (!IsClientAllowed(context))
                {
                    await next.Invoke(context);
                    return;
                }

                var data = connectionPoolManager.GetConnectionInformations();

                await JsonSerializer.SerializeAsync(context.Response.Body, data);

                return;
            }

            if (context.Request.Method == "GET" && context.Request.Path == "/redis/info")
            {
                if (!IsClientAllowed(context))
                {
                    await next.Invoke(context);
                    return;
                }

                var data = await redisDatabase.GetInfoAsync();