Added redis example (#599)

* Added redis example

* added missed config

Author: OlenaKostash

examples/CSharpProd/CSharpProd.csproj

@@ -10,19 +10,23 @@
         <PackageReference Include="Bogus" Version="34.0.2" />
         <PackageReference Include="Dapper.Contrib" Version="2.0.78" />
         <PackageReference Include="LiteDB" Version="5.0.15" />
-        <PackageReference Include="NBomber" Version="5.0.1" />
+        <PackageReference Include="NBomber" Version="5.1.0" />
         <PackageReference Include="NBomber.Data" Version="5.0.0" />
         <PackageReference Include="NBomber.Http" Version="5.0.0" />
         <PackageReference Include="NBomber.Sinks.InfluxDB" Version="5.0.0" />
         <PackageReference Include="MQTTnet" Version="3.1.2" />
         <PackageReference Include="Serilog.Sinks.Elasticsearch" Version="9.0.0" />
+        <PackageReference Include="StackExchange.Redis" Version="2.6.116" />
         <PackageReference Include="System.Data.SQLite.Core" Version="1.0.117" />
     </ItemGroup>
 
     <ItemGroup>
         <None Update="Db\LiteDB\config.json">
           <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
         </None>
+        <None Update="DB\Redis\config.json">
+          <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+        </None>
         <None Update="DB\SQLiteDB\config.json">
           <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
         </None>
@@ -46,4 +50,8 @@
         </None>
     </ItemGroup>
 
+    <ItemGroup>
+      <Folder Include="DB\Redis\" />
+    </ItemGroup>
+
 </Project>

examples/CSharpProd/DB/Redis/RedisExample.cs

@@ -0,0 +1,17 @@
+using NBomber.CSharp;
+
+namespace CSharpProd.DB.Redis;
+
+public class RedisExample
+{
+    public void Run()
+    {
+        NBomberRunner.RegisterScenarios(
+            new RedisInitScenario().Create(),
+            new RedisReadScenario().Create(),
+            new RedisWriteScenario().Create()
+        )
+        .LoadConfig("./DB/Redis/config.json")
+        .Run();
+    }
+}

examples/CSharpProd/DB/Redis/RedisInitScenario.cs

@@ -0,0 +1,37 @@
+using Microsoft.Extensions.Configuration;
+using NBomber.Contracts;
+using NBomber.CSharp;
+using NBomber.Data;
+using StackExchange.Redis;
+
+namespace CSharpProd.DB.Redis;
+
+public class RedisDbConfig
+{
+    public string ConnectionString { get; set; }
+    public int RecordsCount { get; set; }
+    public int RecordSize { get; set; }
+}
+
+public class RedisInitScenario
+{
+    public ScenarioProps Create()
+    {
+        return Scenario.Empty("redis_init")
+            .WithInit(context =>
+            {
+                var dbConfig = context.GlobalCustomSettings.Get<RedisDbConfig>();
+
+                var redis = ConnectionMultiplexer.Connect(dbConfig.ConnectionString);
+                var db = redis.GetDatabase();
+                var payload = Data.GenerateRandomBytes(dbConfig.RecordSize);
+
+                foreach (var i in Enumerable.Range(0, dbConfig.RecordsCount))
+                {
+                    db.StringSet($"user-{i}", payload);
+                }
+
+                return Task.CompletedTask;
+            });
+    }
+}

examples/CSharpProd/DB/Redis/RedisReadScenario.cs

@@ -0,0 +1,33 @@
+using Microsoft.Extensions.Configuration;
+using NBomber.Contracts;
+using NBomber.CSharp;
+using StackExchange.Redis;
+
+namespace CSharpProd.DB.Redis;
+
+public class RedisReadScenario
+{
+    private RedisDbConfig _dbConfig;
+    private ConnectionMultiplexer _redis;
+    private IDatabase _db;
+    private readonly Random _random = new();
+
+    public ScenarioProps Create()
+    {
+        return Scenario
+            .Create("redis_read", async context =>
+            {
+                var randomId = _random.Next(_dbConfig.RecordsCount);
+                byte[] data = await _db.StringGetAsync($"user-{randomId}");
+                return Response.Ok(sizeBytes: data.Length);
+            })
+            .WithInit(context =>
+            {
+                _dbConfig = context.GlobalCustomSettings.Get<RedisDbConfig>();
+                _redis = ConnectionMultiplexer.Connect(_dbConfig.ConnectionString);
+                _db = _redis.GetDatabase();
+
+                return Task.CompletedTask;
+            });
+    }
+}

examples/CSharpProd/DB/Redis/RedisWriteScenario.cs

@@ -0,0 +1,36 @@
+using Microsoft.Extensions.Configuration;
+using NBomber.Contracts;
+using NBomber.CSharp;
+using NBomber.Data;
+using StackExchange.Redis;
+
+namespace CSharpProd.DB.Redis;
+
+public class RedisWriteScenario
+{
+    private RedisDbConfig _dbConfig;
+    private ConnectionMultiplexer _redis;
+    private IDatabase _db;
+    private readonly Random _random = new();
+    private byte[] _payload;
+
+    public ScenarioProps Create()
+    {
+        return Scenario
+            .Create("redis_write", async context =>
+            {
+                var randomId = _random.Next(_dbConfig.RecordsCount);
+                await _db.StringSetAsync($"user-{randomId}", _payload);
+                return Response.Ok(sizeBytes: _payload.Length);
+            })
+            .WithInit(context =>
+            {
+                _dbConfig = context.GlobalCustomSettings.Get<RedisDbConfig>();
+                _redis = ConnectionMultiplexer.Connect(_dbConfig.ConnectionString);
+                _db = _redis.GetDatabase();
+                _payload = Data.GenerateRandomBytes(_dbConfig.RecordSize);
+
+                return Task.CompletedTask;
+            });
+    }
+}

examples/CSharpProd/DB/Redis/config.json

@@ -0,0 +1,34 @@
+{
+    "TargetScenarios": ["redis_init", "redis_read", "redis_write"],
+
+    "GlobalSettings": {
+
+        "ScenariosSettings": [
+            {
+                "ScenarioName": "redis_read",
+
+                "WarmUpDuration": "00:00:05",
+
+                "LoadSimulationsSettings": [
+                    { "KeepConstant": [200, "00:03:30"] }
+                ]
+            },
+
+            {
+                "ScenarioName": "redis_write",
+
+                "WarmUpDuration": "00:00:05",
+
+                "LoadSimulationsSettings": [
+                    { "KeepConstant": [200, "00:03:30"] }
+                ]
+            }
+        ],
+
+        "GlobalCustomSettings": {
+            "ConnectionString": "localhost:6379",
+            "RecordsCount": 100000,
+            "RecordSize": 2000
+        }
+    }
+}

examples/CSharpProd/DB/Redis/docker-compose.yaml

@@ -0,0 +1,18 @@
+version: '3.4'
+services:
+
+    redis:
+        image: 'redis:7.0.2'
+#        command: 'redis-server --save "30 1000" --appendonly yes --requirepass "" '
+        command: 'redis-server --save "" --appendonly no --requirepass "" '
+#        command: 'redis-server /usr/local/etc/redis/redis.conf'
+        volumes:
+            - './redis-data:/data'
+#            - './redis-config/redis.conf:/usr/local/etc/redis/redis.conf'
+        ports:
+            - '6379:6379'
+
+# to fix redis.conf you should set:
+# bind 0.0.0.0
+# protected-mode no
+# redis.conf should have ASCII encoding