zoukankan      html  css  js  c++  java
  • 反射案例

     private void ResendFailedNotAmountData()
            {
                //要调用方法的对象,该对象实现了ISyncManager接口
                var syncObj = GetSyncManager();
                SelectDatabase(_failureDatabaseId);
                Type type = typeof(ISyncManager);
                string[] hashObj = _redisHelper.HashGetAll(_notAmountDataKey);
                if (hashObj == null || hashObj.Count() <= 0) return;
                string[] keyValue = null;
                try
                {
                    using (var cancelTokenSource = new CancellationTokenSource(_timeOut))
                    {
                        foreach (var item in hashObj)
                        {
                            keyValue = GetItemStringArray(item);
                            var methodAndParams = keyValue[0].Split(new string[] { "_" }, StringSplitOptions.RemoveEmptyEntries);
                            MethodInfo method = type.GetMethod(methodAndParams[0]);
                            NewtonsoftJsonSerializer newtonsoft = new NewtonsoftJsonSerializer();
                            var typClass = Assembly.LoadFrom("Hx.DataSync.Entity.dll").GetExportedTypes().Where(te => te.GetInterface(methodAndParams[1]) != null).FirstOrDefault();
                            if (typClass == null)
                            {
                                Logger.Error("数据解析出问题");
                                return;
                            }
                            Logger.Info("字符串对象为:" + keyValue[1]);
                           //用type类型解析json字符串
                            var obj = newtonsoft.Deserialize(keyValue[1], typClass);
                            try
                            {
                                Task.Run(() =>
                                {
                                   //调用对象syncObj的方法
                                    var o = method.Invoke(syncObj, new object[] { obj });
                                    if ((bool)o)
                                    {
                                        _redisHelper.HashDelete(_notAmountDataKey, keyValue[0]);
                                    }
                                }, cancelTokenSource.Token).Wait();
                            }
                            catch (Exception ex)
                            {
                                Logger.Error($"错误数据提交时失败:{ex}");
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    Logger.Error($"非额度数据重新发送是发生异常:{ex}");
                }                                                                                                                        
  • 相关阅读:
    小技巧
    常用的交互设计软件
    Android studio 使用SVN需要忽略的文件
    android studio 使用SVN 锁定文件,防止别人修改(基于Android studio 1.4 )
    git 和 github 关系?
    Double 数据保留两位小数一:五舍六入
    设计模式
    Java中关于日期类那些方法
    ios 开源免费接口
    华为招聘机试整理5:简单四则运算
  • 原文地址:https://www.cnblogs.com/rengke2002/p/7442444.html
Copyright © 2011-2022 走看看