追加demo示例

Author: liguoliang

demo/Test.Client/Program.cs

@@ -9,6 +9,7 @@
 using System.Threading.Tasks;
 using Microsoft.Extensions.Configuration;
 using Nacos.V2.DependencyInjection;
+using System.Collections.Generic;
 
 namespace Test.Client
 {
@@ -127,6 +128,49 @@ static async Task Main(string[] args)
             persons = await personService.GetPersons();
             Console.WriteLine($"最后获取Persons,persons=[{persons.ToJson()}]");
 
+            Stopwatch stopwatch = Stopwatch.StartNew();
+            for (int i = 0; i < 100; i++)
+            {
+                await personService.GetPersons();
+            }
+            stopwatch.Stop();
+            Console.WriteLine($"await:{stopwatch.Elapsed.TotalMilliseconds}");
+
+            stopwatch.Reset();
+            stopwatch.Start();
+            List<Task> tasks = new List<Task>();
+            for (int i = 0; i < 100; i++)
+            {
+                tasks.Add(personService.GetPersons());
+            }
+            await Task.WhenAll(tasks);
+            stopwatch.Stop();
+            Console.WriteLine($"tasks await:{stopwatch.Elapsed.TotalMilliseconds}");
+
+            IProductService productService = rpcClient.CreateClient<IProductService>(TestServerName);
+            ProductDto product = new ProductDto
+            {
+                Id = 1000,
+                Name="抗原",
+                Price = 158.22M
+            };
+            int productAddResult = await productService.Add(product);
+            Console.WriteLine($"添加Product1:{productAddResult==1}");
+            product = productService.Get(1000);
+            Console.WriteLine($"获取添加Product1,id=1000,person=[{product.ToJson()}]");
+            product = new ProductDto
+            {
+                Id = 2000,
+                Name = "N95口罩",
+                Price = 35.5M
+            };
+            productAddResult = await productService.Add(product);
+            Console.WriteLine($"添加Product2:{productAddResult == 1}");
+            product = productService.Get(2000);
+            Console.WriteLine($"获取添加Product2,id=2000,person=[{product.ToJson()}]");
+            var products = await productService.GetProducts();
+            Console.WriteLine($"products=[{products.ToJson()}]");
+
             //BenchmarkRunner.Run<RpcClientBenchTest>();
 
             Console.ReadLine();

demo/Test.Client/Test.Client.csproj

@@ -23,4 +23,7 @@
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
     </None>
   </ItemGroup>
+  <ItemGroup>
+    <Folder Include="Properties\" />
+  </ItemGroup>
 </Project>

demo/Test.DAL/ProductDal.cs

@@ -0,0 +1,42 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Test.IDAL;
+using Test.Model;
+
+namespace Test.DAL
+{
+    public class ProductDal : IProductDal
+    {
+        private List<ProductDto> products = new List<ProductDto>();
+
+        public bool Add(ProductDto product)
+        {
+            if (products.Any(i => i.Id == product.Id))
+            {
+                return false;
+            }
+            products.Add(product);
+            return true;
+        }
+
+        public void Delete(int id)
+        {
+            var person = products.FirstOrDefault(i => i.Id == id);
+            if (person != null)
+            {
+                products.Remove(person);
+            }
+        }
+
+        public ProductDto Get(int id)
+        {
+            return products.FirstOrDefault(i => i.Id == id);
+        }
+
+        public List<ProductDto> GetProducts()
+        {
+            return products;
+        }
+    }
+}

demo/Test.IDAL/IProductDal.cs

@@ -0,0 +1,13 @@
+using System.Collections.Generic;
+using Test.Model;
+
+namespace Test.IDAL
+{
+    public interface IProductDal
+    {
+        ProductDto Get(int id);
+        List<ProductDto> GetProducts();
+        bool Add(ProductDto product);
+        void Delete(int id);
+    }
+}

demo/Test.IService/IProductService.cs

@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Test.Model;
+
+namespace Test.IService
+{
+    public interface IProductService
+    {
+        ProductDto Get(int id);
+        Task<List<ProductDto>> GetProducts();
+        ValueTask<int> Add(ProductDto person);
+        void Delete(int id);
+        Task Edit(int id);
+    }
+}

demo/Test.Model/ProductDto.cs

@@ -0,0 +1,10 @@
+using System;
+namespace Test.Model
+{
+    public class ProductDto
+    {
+        public long Id { get; set; }
+        public string Name { get; set; }
+        public decimal Price { get; set; }
+    }
+}

demo/Test.Server/Startup.cs

@@ -31,6 +31,8 @@ public void ConfigureServices(IServiceCollection services)
         {
             services.AddSingleton<IPersonDal, PersonDal>()
                 .AddSingleton<IPersonService,PersonService>()
+                .AddSingleton<IProductDal, ProductDal>()
+                .AddSingleton<IProductService, ProductService>()
                 .AddSingleton(new RedisConfig { Address="127.0.0.1:6379",db=10 })
                 .AddSingleton(new ElasticSearchConfig { Address = "127.0.0.1:9200" })
                 .AddDotNetCoreRpcServer(options => {

demo/Test.Server6/Program.cs

@@ -10,6 +10,8 @@
 
 builder.Services.AddSingleton<IPersonDal, PersonDal>()
                .AddSingleton<IPersonService, PersonService>()
+               .AddSingleton<IProductDal, ProductDal>()
+               .AddSingleton<IProductService, ProductService>()
                .AddSingleton(new RedisConfig { Address = "127.0.0.1:6379", db = 10 })
                .AddSingleton(new ElasticSearchConfig { Address = "127.0.0.1:9200" })
                .AddDotNetCoreRpcServer(options => {

demo/Test.Service/ProductService.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Test.IDAL;
+using Test.IService;
+using Test.Model;
+using Test.Service.Filters;
+
+namespace Test.Service
+{
+    public class ProductService:IProductService
+    {
+        private readonly IProductDal _productDal;
+        public ProductService(IProductDal productDal)
+        {
+            _productDal = productDal;
+        }
+
+        [LoggerFilter]
+        public ValueTask<int> Add(ProductDto person)
+        {
+            bool result =_productDal.Add(person);
+            return new ValueTask<int>(result?1:0);
+        }
+
+        public void Delete(int id)
+        {
+            _productDal.Delete(id);
+        }
+
+        public Task Edit(int id)
+        {
+            return Task.CompletedTask;
+        }
+
+        [LoggerFilter]
+        public ProductDto Get(int id)
+        {
+            return _productDal.Get(id);
+        }
+
+        public async Task<List<ProductDto>> GetProducts()
+        {
+            return await Task.FromResult(_productDal.GetProducts());
+        }
+    }
+}