专栏首页.NET开发那点事检测WCF服务是否在线(动态执行WCF服务)

检测WCF服务是否在线(动态执行WCF服务)

  在我们的系统里有多个wcf支撑。但是有的时候会莫名的停止,于是今天写了一个服务,定时去检测其他wcf服务是否在线。那么最简单的办法自然是引用其他wcf服务让vs给我们自动生成clientProxy然后一个个去调用是否正常。但是这种办法显然不是我要的。我要弄一个通用的服务检测。

  方案1:

  对于httpbinding的wcf服务有个最简单的检测方法:就是用httpClient去请求一下服务地址看有没有服务描述xml返回。如果有就是live不然就是服务异常关闭了。这个方法对于net.tcp绑定等不适用。

  方案2:

  使用反射动态生成channelProxy然后去尝试执行一个方法。当然这个方法最好不是Update等会影响到业务数据的方法,最好是query级别的方法。

  正常使用ChannelFactory<T>调用wcf服务:

var channelFactory = new ChannelFactory<T>(endpoint);
var proxy = this._channelFactory.CreateChannel();proxy.Add(1,2);

   很简单,我们只需要把T接口协定,endpoint节点名称,调用的方法名称,以及程序集名称或者路径提取到配置文件里就行了。然后把上面的代码转换成反射代码就行。

看一下最主要的方法吧,废话不多了。

private bool IsLive(string assemblyName, string apiServiceFullName, string endpointName, string testMethodName)
        {
            var basePath = AppDomain.CurrentDomain.BaseDirectory;
            Type apiType = null;

            var asm = Assembly.LoadFrom(basePath + "/services/" + assemblyPath);
            apiType = asm.GetType(apiServiceFullName);
            var channelType = typeof(ChannelFactory<>).MakeGenericType(apiType);

            try
            {
                FuncExtension.TryDo(() =>
                {
                    var channel = Activator.CreateInstance(channelType, endpointName);
                    Type[] types = new Type[0];
                    var createChannelMethod = channelType.GetMethod("CreateChannel", types);
                    var proxy = createChannelMethod.Invoke(channel, null);
                    try
                    {
                        var testMethod = apiType.GetMethod(testMethodName);
                        var patameterInfos = testMethod.GetParameters();
                        List<object> parameters = new List<object>();
                        foreach (var patameterInfo in patameterInfos)
                        {
                            var defaultValue = patameterInfo.ParameterType.IsValueType
                                ? Activator.CreateInstance(patameterInfo.ParameterType)
                                : null;
                            parameters.Add(defaultValue);
                        }
                        testMethod.Invoke(proxy, parameters.ToArray());
                    }
                    catch (Exception exc)
                    {
                        Logger.Error(
                            string.Format("Try to connect wcf service error:{0}, ExceptionType:{1}", endpointName,
                                exc.GetType()), GetType(), exc);
                        throw;
                    }
                    finally
                    {
                        try
                        {
                            (proxy as ICommunicationObject).Close();
                        }
                        catch
                        {
                            (proxy as ICommunicationObject).Abort();
                        }
                    }

                }, 3);

                return true;
            }
            catch (Exception exc)
            {
                PrintWholeException(exc);
                return !IsHttpOrSocketException(exc);
            }

        }

        private void PrintWholeException(Exception exc)
        {
            Logger.Error(exc.GetType().ToString(), GetType(), exc);
            if (exc.InnerException != null)
            {
                PrintWholeException(exc.InnerException);
            }
        }

        private bool IsHttpOrSocketException(Exception exc)
        {
            if (exc is EndpointNotFoundException || exc is SocketException)
            {
                return true;
            }
            else
            {
                if (exc.InnerException != null)
                {
                    return IsHttpOrSocketException(exc.InnerException);
                }
            }

            return false;
        }

  其中FuncExtension.TryDo是自动尝试一个Actoin的封装,不影响理解反射的代码。

  我们的目的是判断wcf是否还live,所以不要在意返回值。我们只要判断这次调用的异常是否是SocketException或者EndpointNotFindException即可。

  这样,当需要监控新的wcf服务的时候只要在配置文件里添加一行协定,程序集,调用方法,endpoint的配置即可,当然协定所在的dll要复制到程序的跟目录下或者指定的文件下。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 检测WCF服务是否在线第二版

    上一版在这里https://cloud.tencent.com/developer/article/1013406 上一版主要是解决了监控服务不需要手动添加服务...

    kklldog
  • ASP.NET Core 对Controller进行单元测试

    单元测试对我们的代码质量非常重要。很多同学都会对业务逻辑或者工具方法写测试用例,但是往往忽略了对Controller层写单元测试。我所在的公司没见过一个对Con...

    kklldog
  • .NET Core 基于Websocket的在线聊天室

    我们在传统的客户端程序要实现实时双工通讯第一想到的技术就是socket通讯,但是在web体系是用不了socket通讯技术的,因为http被设计成无状态,每次跟服...

    kklldog
  • MVVM框架的搭建(一)——背景

    好久没有对于自己的知识进行总结了,趁着最近不忙,会写一系列关于MVVM框架的文章和构想,有兴趣的同学我们一起探讨,一起成长,一起进步。

    Demo_Yang
  • @Resource和@Autowire的区别

    DencyCheng
  • Date对象和Math对象

        1.  var  date=new Date()    //无参数的情况下返回值为当前时间

    用户3159471
  • 《数学之美》拾遗——TF-IDF

        在学习机器学习的过程中,我写了简单易学的机器学习算法的专题,依然还有很多的算法会陆续写出来。网上已经有很多人分享过类似的材料,我只是通过自己的理解,想尽...

    zhaozhiyong
  • CVE-2019-3398:Confluence 路径穿越

    2019年4月17日Confluence官方发布安全公告,Confluence Server和Data Center产品在downloadallattachme...

    周俊辉
  • 人工智能珠宝设计师 1

    人工智能珠宝设计师是怎么一种存在? 人工智能可以在珠宝设计里起到什么作用? 珠宝被赋予智能,已经不算新闻了,在时尚界已有多种尝试,这里有2个智能珠宝(首饰)的案...

    mixlab
  • HTML5的Histroy API

    比较典型的是GitHub,在点击代码文件夹和文件时,会发现它的url地址栏变换了、标题栏变化了、前进后退按钮也变化了(跟新开了一个新页面感觉一样),但体验起来很...

    meteoric

扫码关注云+社区

领取腾讯云代金券