添加 grpc 测试

samples/apis/Backet.Api/Backet.Api.csproj

@@ -16,11 +16,11 @@
   </ItemGroup>
   </ItemGroup>
 
 
   <ItemGroup>
   <ItemGroup>
-    <None Remove="Protos\commonCommandResponse.proto" AdditionalImportDirs="Protos" GrpcServices="Server" />
+    <None Remove="Protos\commonCommandResponse.proto" GrpcServices="Server" />
   </ItemGroup>
   </ItemGroup>
 
 
   <ItemGroup>
   <ItemGroup>
-    <Protobuf Include="Protos\*" GrpcServices="Server" />
+    <Protobuf Include="Protos\*" AdditionalImportDirs="Protos" GrpcServices="Server" />
   </ItemGroup>
   </ItemGroup>
   
   
   <ItemGroup>
   <ItemGroup>

samples/apis/Backet.Api/EventHandlers/ToNoticeBacketCreatedEventHandler.cs

@@ -11,7 +11,7 @@ namespace Backet.Api.EventHandlers
     public class ToNoticeBacketCreatedEventHandler : PoleEventHandler<BacketCreatedEvent>, IToNoticeBacketCreatedEventHandler
     public class ToNoticeBacketCreatedEventHandler : PoleEventHandler<BacketCreatedEvent>, IToNoticeBacketCreatedEventHandler
     {
     {
         public async Task BulkEventsHandle(List<BacketCreatedEvent> @event)
         public async Task BulkEventsHandle(List<BacketCreatedEvent> @event)
-        {
+        {          
             await Task.Delay(1500);
             await Task.Delay(1500);
         }
         }
 
 

samples/apis/Backet.Api/GrpcServices/BacketService.cs

@@ -19,7 +19,7 @@ namespace Backet.Api.GrpcServices
         public override async Task<Pole.Grpc.ExtraType.CommonCommandResponse> AddBacket(AddBacketRequest backetDto, ServerCallContext context)
         public override async Task<Pole.Grpc.ExtraType.CommonCommandResponse> AddBacket(AddBacketRequest backetDto, ServerCallContext context)
         {
         {
             var newId = Guid.NewGuid().ToString("N").ToLower();
             var newId = Guid.NewGuid().ToString("N").ToLower();
-            backetDto.Id = newId;
+            //backetDto.Id = newId;
             var grain = clusterClient.GetGrain<IAddBacketGrain>(newId);
             var grain = clusterClient.GetGrain<IAddBacketGrain>(newId);
             //await  grain.AddBacket(backetDto);
             //await  grain.AddBacket(backetDto);
             return Pole.Grpc.ExtraType.CommonCommandResponse.SuccessResponse;
             return Pole.Grpc.ExtraType.CommonCommandResponse.SuccessResponse;

samples/apis/Backet.Api/Program.cs

@@ -25,14 +25,14 @@ namespace Backet.Api
             Host.CreateDefaultBuilder(args)
             Host.CreateDefaultBuilder(args)
                 .UseOrleans(siloBuilder =>
                 .UseOrleans(siloBuilder =>
                 {
                 {
-                    siloBuilder.ConfigureApplicationParts(parts => parts.AddFromApplicationBaseDirectory());
-                    siloBuilder.UseLocalhostClustering();
-                    siloBuilder.AddEfGrainStorage<BacketDbContext>("ef");
-                    siloBuilder.Configure<GrainCollectionOptions>(options =>
-                    {
-                        options.CollectionAge = TimeSpan.FromMinutes(2);
-                    });
-                    siloBuilder.UseDashboard(options => { });
+                    siloBuilder.ConfigureApplicationParts(parts => parts.AddFromApplicationBaseDirectory())
+                               .UseLocalhostClustering()
+                               .AddEfGrainStorage<BacketDbContext>("ef")
+                               .Configure<GrainCollectionOptions>(options =>
+                                {
+                                    options.CollectionAge = TimeSpan.FromSeconds(65);
+                                })
+                               .UseDashboard(options => { });
                 })
                 })
                 .ConfigureWebHostDefaults(webBuilder =>
                 .ConfigureWebHostDefaults(webBuilder =>
                 {
                 {
@@ -46,6 +46,7 @@ namespace Backet.Api
                         option.ListenAnyIP(82, config =>
                         option.ListenAnyIP(82, config =>
                         {
                         {
                             config.Protocols = Microsoft.AspNetCore.Server.Kestrel.Core.HttpProtocols.Http2;
                             config.Protocols = Microsoft.AspNetCore.Server.Kestrel.Core.HttpProtocols.Http2;
+                            config.UseHttps();
                         });
                         });
                     });
                     });
                 });
                 });

samples/apis/Backet.Api/Protos/backet.proto

@@ -2,7 +2,7 @@ syntax = "proto3";
 
 
 option csharp_namespace = "Backet.Grpc";
 option csharp_namespace = "Backet.Grpc";
 
 
-import "Protos/Common/commonCommandResponse.proto";
+import "Common/commonCommandResponse.proto";
 package greet;
 package greet;
 
 
 // The greeting service definition.
 // The greeting service definition.
@@ -14,13 +14,13 @@ service Backet {
 // The request message containing the user's name.
 // The request message containing the user's name.
 message AddBacketRequest {
 message AddBacketRequest {
   string name = 1;
   string name = 1;
-  string id = 2;
-  string userId = 3;
-  repeated AddBacketItemRequest Items = 4;
-  message AddBacketItemRequest{
-    string productId = 1;
-    string productName = 2;
-    int64 price = 3;
-  }
+  //string id = 2;
+  //string userId = 3;
+  //repeated AddBacketItemRequest Items = 4;
+  //message AddBacketItemRequest{
+  //  string productId = 1;
+  //  string productName = 2;
+  //  int64 price = 3;
+  //}
 }
 }
 
 

samples/apis/Backet.Api/Startup.cs

@@ -32,7 +32,13 @@ namespace Backet.Api
             services.AddGrpcValidation();
             services.AddGrpcValidation();
             services.AddGrpcRequestValidator();
             services.AddGrpcRequestValidator();
             services.AddGrpcWeb(o => o.GrpcWebEnabled = true);
             services.AddGrpcWeb(o => o.GrpcWebEnabled = true);
-
+            services.AddCors(o => o.AddPolicy("AllowAll", builder =>
+            {
+                builder.AllowAnyOrigin()
+                       .AllowAnyMethod()
+                       .AllowAnyHeader()
+                       .WithExposedHeaders("Grpc-Status", "Grpc-Message");
+            }));
             services.AddPole(config =>
             services.AddPole(config =>
             {
             {
                 config.AddRabbitMQ(option =>
                 config.AddRabbitMQ(option =>
@@ -66,11 +72,12 @@ namespace Backet.Api
             app.UseRouting();
             app.UseRouting();
 
 
             app.UseGrpcWeb();
             app.UseGrpcWeb();
+            app.UseCors("AllowAll");
 
 
             app.UseEndpoints(endpoints =>
             app.UseEndpoints(endpoints =>
             {
             {
                 endpoints.MapDefaultControllerRoute();
                 endpoints.MapDefaultControllerRoute();
-                endpoints.MapGrpcService<BacketService>();
+                endpoints.MapGrpcService<BacketService>().EnableGrpcWeb();
             });
             });
         }
         }
     }
     }

samples/apis/Backet.Api/appsettings.json

@@ -4,7 +4,8 @@
       "Default": "Information",
       "Default": "Information",
       "Microsoft": "Warning",
       "Microsoft": "Warning",
       "Microsoft.Hosting.Lifetime": "Information",
       "Microsoft.Hosting.Lifetime": "Information",
-      "Grpc": "Information"
+      "Grpc": "Information",
+      "Microsoft.AspNetCore.Server.Kestrel": "Debug"
     }
     }
   },
   },
   "postgres": {
   "postgres": {