[refactor] Adding data to PublishAsync method for synchronize other instances

Author: farhadzm

RedisPubSub.Common/Models/MemoryCacheDataDto.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace RedisPubSub.Common.Models
+{
+    public class MemoryCacheDataDto
+    {
+        public string CacheKey { get; set; }
+        public object Data { get; set; }
+    }
+}

RedisPubSub.Publisher/Services/RedisPublisher.cs

@@ -1,4 +1,5 @@
 using RedisPubSub.Common.Constants;
+using RedisPubSub.Common.Models;
 using StackExchange.Redis;
 using System.Threading.Tasks;
 
@@ -18,7 +19,13 @@ public RedisPublisher(IConnectionMultiplexer redisCachingProvider)
         }
         public async Task PublishMessage()
         {
-            await _databaseAsync.PublishAsync(RedisChannelConstant.MemoryCache, "keyForDelete");
+            var updatedData = new MemoryCacheDataDto
+            {
+                CacheKey = "user_information",
+                Data = 20
+            };
+            var redisChannelData = System.Text.Json.JsonSerializer.Serialize(updatedData);
+            await _databaseAsync.PublishAsync(RedisChannelConstant.MemoryCache, redisChannelData);
         }
     }
 }

RedisPubSub.Publisher/Startup.cs

@@ -31,9 +31,7 @@ public void ConfigureServices(IServiceCollection services)
 
         public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
         {
-
             app.UseRouting();
-
             app.UseEndpoints(endpoints =>
             {
                 endpoints.MapDefaultControllerRoute();

RedisPubSub.Subscriber/HostedServices/RedisSubscriberHostedService.cs

@@ -2,6 +2,7 @@
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 using RedisPubSub.Common.Constants;
+using RedisPubSub.Common.Models;
 using StackExchange.Redis;
 using System;
 using System.Threading;
@@ -23,10 +24,12 @@ public RedisSubscriberHostedService(IConnectionMultiplexer connectionMultiplexer
 
         protected override async Task ExecuteAsync(CancellationToken stoppingToken)
         {
-            await _subscriber.SubscribeAsync(RedisChannelConstant.MemoryCache, (a, cacheKey) =>
+            await _subscriber.SubscribeAsync(RedisChannelConstant.MemoryCache, (a, updatedData) =>
              {
-                 _memoryCache.Remove(cacheKey);
-                 _logger.LogInformation($"Cache deleted. Key:{cacheKey}");
+                 var data = System.Text.Json.JsonSerializer.Deserialize<MemoryCacheDataDto>(updatedData);
+                 _memoryCache.Remove(data.CacheKey);
+                 _memoryCache.Set(data.CacheKey, data.Data);
+                 _logger.LogInformation($"MemoryCache update. Key:{data.CacheKey}");
              });
         }
         public override async Task StopAsync(CancellationToken cancellationToken)