Apache Ignite瘦客户端异常处理

Question

我使用Apache Ignite 2.7.5作为.NET核心中服务器和瘦客户机。当我做与缓存相关的操作时，put、get和load等.net核心应用程序会自动崩溃。

因此，我想处理for循环内部的异常，例如IgniteCheckedException、BinaryInvalidTypeException、ClassNotFoundException等，然后从catch块抛出for循环，否则如果只有异常块，则继续循环迭代。

public async void loadData(string configPath,List<JObject> dataList)
    {

        using (var ldr = _ignite.GetDataStreamer<string, Employee>(cacheName))
        {             

            foreach (var item in parsedObjectList)
            {
                try
                {
                    JObject keyObj = new JObject();
                    foreach (var keyName in keyArray)
                    {
                        keyObj[keyName.ToString()] = item[keyName.ToString()];
                    }

                    var serializerSettings = new JsonSerializerSettings { NullValueHandling = NullValueHandling.Ignore };

                    JsonConvert.PopulateObject(item.ToString(), emp, serializerSettings);

                    string json = JsonConvert.SerializeObject(keyObj, Formatting.None);

                    string base64EncodedKey = Convert.ToBase64String(Encoding.UTF8.GetBytes(json));

                    await ldr.AddData(base64EncodedKey, emp);                   

                }
                catch (IgniteCheckedException ex)//how to handle here
                {
                    throw;
                }
                catch (BinaryInvalidTypeException ex)//how to handle here
                {
                    throw;
                }
                catch (ClassNotFoundException ex)//how to handle here
                {
                    throw;
                }
                catch (Exception ex)
                {
                //continue for loop if data parsing ,some normal exception
                    Console.WriteLine(ex);
                }
            }

        }
    }

Answer 1

当您从瘦.NET客户端捕获异常时，与任何此类客户端一样，最好的操作过程是重试，如果再次失败，则等待一段时间，关闭连接，打开新连接，再试一次。如果也失败，则重新抛出（写入日志，失败当前操作）。