เพิ่มประสิทธิภาพเว็บแบบง่ายๆด้วย HybridCache ใน .NET9

app.MapGet(
    "/posts",
    async () =>
    {
        List<Post> posts =
        [
            new()
            {
                Id = 1,
                Title = "Post 1",
                Content = "Content 1",
            },
            new()
            {
                Id = 2,
                Title = "Post 2",
                Content = "Content 2",
            },
            new()
            {
                Id = 3,
                Title = "Post 3",
                Content = "Content 3",
            },
        ];

        Random random = new();
        int delay = random.Next(1000, 5000);
        await Task.Delay(delay);

        return Results.Ok(posts);
    }
);

builder.Services.AddHybridCache();

app.MapGet(
        // argument แรกเป็นชื่อของ API
        // ตั้งชื่อ posts ใน path รับ id ที่เป็น int
        "/posts/{id:int}",
        // argument ที่สองเป็น function เพื่อคืนค่า
        // มี parameter int id ที่รับมาจาก path แล้วก็ inject HybridCache เข้ามา
        async (int id, HybridCache cache) =>
        {
            // ใช้คำสั่ง GetOrCreateAsync ของ HybridCache เพื่อดึงหรือสร้าง cache
            List<Post>? posts = await cache.GetOrCreateAsync(
                // argument แรกเป็น key ของ cache
                "hybrid:posts",
                // arguemnt ที่สองเป็น function factory ในกรณีที่ถ้ายังไม่มีข้อมูลใน cache function จะถูกเรียกแล้วเก็บข้อมูลที่ได้ไว้ใน cache ต้องใส่ parameter CancellationToken ด้วย ให้ชื่อ cancel
                async (cancel) =>
                {
                    // แล้วก็เรียกใช้ API ที่เตรียมไว้โดยใช้ HttpClient
                    HttpClient client = new();
                    HttpResponseMessage response = await client.GetAsync(
                        "http://localhost:5228/posts",
                        cancel
                    );
                    // ถ้ามี error ก็ให้คืนเป็น array เปล่า
                    if (!response.IsSuccessStatusCode)
                    {
                        return [];
                    }
                    // ไม่มี error คืนค่าที่ได้มาจาก API
                    return await response.Content.ReadFromJsonAsync<List<Post>>(cancel);
                    // จากตรงนี้ข้อมูลจะถูกเก็บลง cache อัตโนมัติโดยที่เราไม่ต้องทำอะไรเพิ่ม
                }
            );
            // ใช้ id จาก path เพื่อหาข้อมูลจาก list
            Post? post = posts?.FirstOrDefault(x => x.Id == id);
            // ไม่เจอก็ NotFound
            if (post == null)
            {
                return Results.NotFound();
            }
            // เจอก็ Ok พร้อมข้อมูล post
            return Results.Ok(post);
        }
    );

@HyBridCacheDemo_HostAddress = http://localhost:8080

GET {{HyBridCacheDemo_HostAddress}}/posts

GET {{HyBridCacheDemo_HostAddress}}/posts/1

// เรียก AddStackExchangeRedisCache เพื่อเชื่อมต่อ Redis
builder.Services.AddStackExchangeRedisCache(options =>
{
    // ใช้ Redis connection ที่อยู่ใน appSettings
    options.Configuration = builder
	    .Configuration.GetConnectionString("RedisConnection");
});

app.MapGet(
    "/dist-posts",
    async (IDistributedCache cache) =>
    {
        string key = $"dist:posts";
        // ทำการเช็คก่อนว่ามี cache เก็บอยู่รึป่าว
        string? json = await cache.GetStringAsync(key);
        List<Post>? posts = [];
        // ถ้าไม่มีก็ให้ดึงข้อมูลเพื่อทำ cache
        if (string.IsNullOrEmpty(json))
        {
            HttpClient client = new();
            HttpResponseMessage response = await client.GetAsync("http://localhost:5228/posts");
            if (response.IsSuccessStatusCode)
            {
                posts = await response.Content.ReadFromJsonAsync<List<Post>>();
                // ได้ข้อมูลเสร็จต้อง serialize แล้วเก็บลอง cache
                json = JsonSerializer.Serialize(posts);
                await cache.SetStringAsync(key, json);
            }
        }
        // ถ้ามีก็ deserialize เป็นค่าที่ต้องการ
        else
        {
            posts = JsonSerializer.Deserialize<List<Post>>(json) ?? [];
        }

        return posts;
    }
);