.NET Core对接GridDB REST API数据获取异常问题排查

已完成的操作 #

• 搭建GridDB服务器
• 本地安装并配置GridDB
• 验证GridDB正常运行且可访问
• 使用Java（Spring Boot）创建REST API，用于暴露GridDB数据，可通过指定容器和键获取数据

Java REST API端点代码 #

@RestController
@RequestMapping("/griddb")
public class GridDBController 
{
    private static final String GRIDDB_CLUSTER_NAME = "myCluster";
    private static final String GRIDDB_NOTIFICATION_MEMBER = "***.0.0.1";
    private static final String GRIDDB_USERNAME = "***";
    private static final String GRIDDB_PASSWORD = "****";

    @GetMapping("/get/{container}/{key}")
    public ResponseEntity<String> getData(@PathVariable String container, @PathVariable String key) 
    {
        try 
        {
            GridStore store = GridStoreFactory.getInstance().getGridStore(
                new Properties() {{
                    setProperty("notificationMember", GRIDDB_NOTIFICATION_MEMBER);
                    setProperty("clusterName", GRIDDB_CLUSTER_NAME);
                    setProperty("user", GRIDDB_USERNAME);
                    setProperty("password", GRIDDB_PASSWORD);
                }});

            Container<String, Row> col = store.getContainer(container);
            Row row = col.get(key);

            return ResponseEntity.ok(row.toString());
        } 
        catch (Exception e) 
        {
            return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body("Error: " + e.getMessage());
        }
    }
}

使用Postman测试该API可正常返回预期数据

.NET Core调用代码 #

using System;
using System.Net.Http;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        string baseUrl = "http://localhost:8080/griddb";  // Java API URL
        string container = "sensorData";
        string key = "device***";

        using HttpClient client = new HttpClient();
        HttpResponseMessage response = await client.GetAsync($"{baseUrl}/get/{container}/{key}");

        if (response.IsSuccessStatusCode)
        {
            string data = await response.Content.ReadAsStringAsync();
            Console.WriteLine("Received Data: " + data);
        }
        else
        {
            Console.WriteLine("Failed to retrieve data. Status: " + response.StatusCode);
        }
    }
}

遇到的问题 #

• Postman调用API可正常返回数据
• 使用.NET Core的HttpClient调用时，出现**[请填写实际错误信息，如超时、404、500等]**
• 已确认API URL正确

已尝试的操作 #

• Postman测试正常
• 尝试为HttpClient配置不同的请求头和设置
• 验证Java API是否运行且可通过浏览器访问
• 尝试增加超时设置

疑问 #

1. 为何Postman可正常调用，但.NET Core服务无法从GridDB REST API获取响应？
2. 是否需要处理特定的CORS、防火墙或网络问题？
3. 有没有更优的.NET Core与GridDB连接方式？

问题解答 #

1. Postman正常但.NET Core调用失败的可能原因

• 请求头差异：Postman会自动添加默认请求头（如User-Agent、Accept），而.NET Core的HttpClient默认请求头可能不全。可手动补充：

  client.DefaultRequestHeaders.Add("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36");
  client.DefaultRequestHeaders.Accept.Add(new System.Net.Http.Headers.MediaTypeWithQualityHeaderValue("application/json"));
  

• URL编码问题：如果container或key包含特殊字符，Postman会自动编码，但.NET Core字符串拼接不会处理。建议对参数编码：

  string encodedContainer = Uri.EscapeDataString(container);
  string encodedKey = Uri.EscapeDataString(key);
  HttpResponseMessage response = await client.GetAsync($"{baseUrl}/get/{encodedContainer}/{encodedKey}");
  

• 异步调用阻塞：若在非异步环境中调用async Main，可能导致死锁，确保项目支持.NET Core 3.0+的异步入口。

2. CORS、防火墙或网络问题排查

• CORS配置：若Java API与.NET Core服务不在同一域，需在Spring Boot中配置CORS。可在控制器添加@CrossOrigin注解，或全局配置：

  @Configuration
  public class CorsConfig implements WebMvcConfigurer {
      @Override
      public void addCorsMappings(CorsRegistry registry) {
          registry.addMapping("/**")
                  .allowedOrigins("*")
                  .allowedMethods("GET", "POST", "PUT", "DELETE")
                  .allowedHeaders("*");
      }
  }
  

• 防火墙/端口检查：确认本地防火墙未拦截.NET Core的网络请求，Java API的8080端口未被占用。
• 网络连通性：跨机器调用时，用telnet或Test-NetConnection测试.NET Core机器能否访问Java API的8080端口。

3. 更优的.NET Core与GridDB连接方式

直接使用GridDB官方.NET驱动，无需Java API中转，性能更高且减少中间层依赖：

1. 安装NuGet包：Install-Package GridDB.Net
2. 示例代码：

using GridDB;
using System;

class Program
{
    static void Main(string[] args)
    {
        var properties = new Properties
        {
            ["notificationMember"] = "***.0.0.1:10001",
            ["clusterName"] = "myCluster",
            ["user"] = "***",
            ["password"] = "****"
        };

        try
        {
            using var store = GridStoreFactory.GetInstance().GetGridStore(properties);
            store.Open();

            var container = store.GetContainer<String, Row>("sensorData");
            var row = container.Get("device***");
            
            Console.WriteLine("Received Data: " + row.ToString());
            store.Close();
        }
        catch (Exception e)
        {
            Console.WriteLine("Error: " + e.Message);
        }
    }
}

注意：需确保GridDB服务器开启对应连接模式，且驱动版本与服务器版本兼容。

内容的提问来源于stack exchange，提问作者Taseeb Saeed