.NET使用Graphql的演示

 // 添加GraphQL服务
 builder.Services
     .AddGraphQLServer()
     .AddQueryType<TestQuery>()
     .AddMutationType<TestMutation>()
     .AddSubscriptionType<TestSub>()
     .AddInMemorySubscriptions(); // 默认消息持久化(生产情况建议更换)

 var app = builder.Build();

 app.UseWebSockets();

 // 映射GraphQL端点
 app.MapGraphQL();

 var option = new GraphQLHttpClientOptions
 {
     EndPoint = new Uri("http://localhost:5264/graphql"),
     // 设置 WebSocket 端点以支持订阅
     WebSocketEndPoint = new Uri("ws://localhost:5264/graphql")
 };

 using var client = new GraphQLHttpClient(/*"http://localhost:5264/graphql"*/ option , new NewtonsoftJsonSerializer());
 //            var request = new GraphQLRequest
 //            {
 //                Query = @"mutation{
 //  otherOperation(info:{address:""龙岗区宝龙街道"",city:""大大大深圳"",phone:""10100011""})
 //}"
 //            };

 //            var response = await client.SendQueryAsync<object>(request);
 //            Console.WriteLine(response.Data);

 // 定义订阅请求
 var subscriptionRequest = new GraphQLRequest
 {
     Query = @"
     subscription {
         onTestPublish
     }"
 };

 // 创建订阅流
 var subscriptionStream = client.CreateSubscriptionStream<OnTestPublishResponse>(subscriptionRequest);

 // 订阅消息流
 var subscription = subscriptionStream.Subscribe(
     response =>
     {
         if (response.Errors != null)
         {
             Console.WriteLine("Error occurred: " + response.Errors);
         }
         else
         {
             Console.WriteLine($"Received message: {response.Data.OnTestPublish}");
         }
     },
     error => Console.WriteLine($"Subscription error: {error.Message}"),
     () => Console.WriteLine("Subscription completed."));

 // 模拟其他逻辑（例如，在某个时刻取消订阅,这儿通过输入任意按键触发取消和释放）
 Console.WriteLine("Press any key to exit...");
 Console.ReadKey();

 // 取消订阅并关闭 WebSocket 连接
 subscription.Dispose();
 client.Dispose();