Adhesive框架系列文章--WCF 分布式服务模块使用和实现

本文涉及的产品
云数据库 MongoDB,独享型 2核8GB
推荐场景:
构建全方位客户视图
日志服务 SLS,月写入数据量 50GB 1个月
简介: Adhesive框架中的WCF分布式服务模块基于原来写的WCF扩展修改而来,主要的修改如下: 1)原先使用数据库的元数据配置,现在统一改为配置服务,主要是为了统一,不用再去开发一个WCF的配置后台 2)原先直接存储到Mongodb中的各种日志,现在统一使用Monodb数据服务,也是进行了一个统一 3)和信息中心模块中的网站请求状态(统计每一个请求的情况)一样,这里也提供了WCF客户端和服务端的执行状态   这个模块主要实现如下功能: 1)集中化的配置:地址、绑定、契约、端点等等信息都无需在配置文件中配置,直接在统一的配置服务中进行配置。

Adhesive框架中的WCF分布式服务模块基于原来写的WCF扩展修改而来,主要的修改如下:

1)原先使用数据库的元数据配置,现在统一改为配置服务,主要是为了统一,不用再去开发一个WCF的配置后台

2)原先直接存储到Mongodb中的各种日志,现在统一使用Monodb数据服务,也是进行了一个统一

3)和信息中心模块中的网站请求状态(统计每一个请求的情况)一样,这里也提供了WCF客户端和服务端的执行状态

 

这个模块主要实现如下功能:

1)集中化的配置:地址、绑定、契约、端点等等信息都无需在配置文件中配置,直接在统一的配置服务中进行配置。不管是客户端还是服务端都没有配置文件。这么做的好处是可以集中管理,也方便了负载均衡环境多台机器的配置修改。

2)4*2种自动日志的记录:服务端客户端启动(服务端启动WCF服务、或客户端第一次调用WCF服务)日志、服务端客户端异常日志、服务端客户端调用WCF服务日志、服务端客户端发送的消息日志。这8种日志都具有独立的开关,自动记录,无需写一行代码。

3)允许进行调用的请求验证(通过消息头),可以进行请求和响应的双向验证也可以配置为单向,服务端允许开启Unity的依赖注入。

4)允许向.NET Remoting那样直接通过接口进行服务调用,实现了WCF服务的定位器,内部缓存信道工厂并处理调用错误的情况。

 

具体每一个功能的实现就不具体介绍了,有兴趣的可以看以前的WCF扩展的相关文章,其基本原来还是一致的。

现在就来介绍对于一个新的服务要使用的话如何进行配置,首先打开配置服务后台:

image

在配置服务后台的全局配置中可以找到Wcf的配置,点击下一级进入:

image

1、首先需要配置需要的绑定,点击进入绑定配置:

image

这里,我们已经定义了一个叫做UnsecuredTcp的绑定,当然你也可以新建一个自己需要的绑定,我们来看一下绑定里面可以配置哪些东西:

image

1)绑定的类型,可以是NetTcpBinding、BasicHttpBinding、WSHttpBinding、NetNamedPipeBinding、NetMsmqBinding等,默认值是NetTcpBinding。

2)绑定的优先级,数字越小优先级越高,所谓优先级就是优先选择哪一个绑定,客户端在选择服务端的时候会优先选择优先级比较高的绑定

3)绑定行为XML,这个和配置文件中的绑定行为配置是一样的

4)绑定协议,这个需要和绑定类型对应起来,比如http、net.pipe、net.msmq等

 

2、在定义了绑定之后,先可以定义服务的配置,进入服务配置节点:

image

这里可以看到我们有两个服务,我们Mongodb数据服务使用的WCF配置也在这里,点击进入MongodbServer服务看看:

image

1)服务类型名,配置的是服务实现类的完整限定名

2)服务行为XML,这里没有配置,这也是和配置文件中配置的是一样的,比如可以配置:

<behavior name="ServieBehavior"><serviceMetadata httpGetEnabled="false" /><serviceThrottling maxConcurrentCalls="200" maxConcurrentInstances="200" maxConcurrentSessions="200" /></behavior>

3)服务端机器IP,可以针对不同的服务端机器有不同的服务配置,*就是针对所有机器的

4)服务集群名,集群主要用来配置对外的负载均衡地址,这里我们的服务对应LocalFarm

5)服务端设置,点击进入查看详细:

image

这里有核心配置、日志配置和安全配置三类。

1)核心配置:

image

也就是是否开启Unity为服务实现的构造方法进行依赖注入,默认是关闭的。

2)日志配置:

image

这就是之前说的服务端的4种日志的开关,其中无非是开关的配置,对于消息类型的日志,还可以配置记录消息的方向:

image

这是一个枚举:

image

3)安全配置:

image

这里主要配置的是是否启用调用的密码验证:

image

当然,也可以配置验证的方向:

image

是在请求的时候验证还是在回复的时候验证,还是都需要验证。

 

3、在完成了服务的配置之后,需要进行服务端点的配置:

image

在这里,我们之前配置的每一个服务都有配置一个端点,还是进入Mongodb服务的端点看看,注意到这里名称是契约名而不是服务实现的类型名了:

image

1)服务类型名,这是和服务配置中对应的,也就是需要配置契约的实现类型的完整限定名

2)契约类型名,也就是接口名

3)契约版本,在这里可以针对不同的接口程序集的版本配置不同的端点

4)服务器IP,在这里可以针对不同的服务端的IP地址配置不同的端点

5)服务端点行为的XML,在这里没有特殊的配置,格式按照配置文件,比如可以这么配置:

<behavior name="ServiceEndpointBehavior"><dataContractSerializer maxItemsInObjectGraph="10000" /></behavior>

6)服务端点绑定名,也就是需要对应绑定配置中的绑定名

7)端口,通讯端口

8)端点名,这是作为通讯地址的一部分,通常可以使用契约名

 

4、服务端的配置部分差不多结束了,接下去可以配置服务集群对外的地址,进入集群配置:

image

还记得吗,我们之前配置的Mongodb数据服务是用的是LocalFarm,在这里我们看到定义了两个集群。分别来看一下每一个集群:

image

image

可以发现这两个集群的友好名字和集群名都是LocalFarm,也就是说Mongodb的数据服务对应这两个集群,那么客户端在选择的时候怎么判断是哪个集群呢?

这里通过客户端机器IP来决定的,*的优先级是比较低的,如果遇到客户端IP是192.168.136.202的话,选择127.0.0.1作为集群地址,这个IP地址是我机器的IP,也就是说我希望在本机开发的时候使用本地的服务端,方便调试。而对于其它客户端IP使用192.168.129.143,这是开发测试服务器的IP地址,也就是希望开发服务器环境上的其它客户端在使用服务的时候定位到开发测试服务器。

 

5、然后我们就需要配置客户端部分了,首先是客户端端点:

image

还是进入IMongodbServer:

image

1)契约类型名,接口类型的完整限定名

2)客户端机器IP,可以根据不同的客户端机器IP配置不同的客户端端点

3)客户端端点行为XML,这个和XML中配置的客户端行为配置节点的内容是一样的

4)客户端设置:

image

这里的配置其实和服务端的配置是差不多的,只不要需要注意,WcfCoreSetting中没有内容,因为客户端没有Unity的选项。而WcfSecuritySetting是不需要配置的,客户端是否进行调用密码验证根据服务端的配置来的,客户端的配置是不会使用到的。

 

6、为了安全,我们还要进行客户端允许和客户端禁止的配置,在这里我们配置了刚才配置的那个集群需要允许所有的客户端访问:

image

必要的话,还可以进行Deny的配置,这里没有进行配置。

 

在完成了配置之后现在就可以写服务端和客户端的代码了,服务端:

            AdhesiveFramework.Start();
            var host = WcfServiceHostFactory.CreateServiceHost<MongodbServer>();
            host.Open();
            Console.WriteLine("Adhesive.Mongodb.Server started...");
            Console.ReadLine();
            host.Close();
            AdhesiveFramework.End();

当然,服务端还需要添加如下程序集的引用:

image

其中TestService就是服务端实现的程序集,也就是FuckService所在的程序集。

在服务端运行后,需要修改本地Config文件夹下的配置文件来进行最基础的配置:

<?xml version="1.0" encoding="utf-8"?>
<AdhesiveConfig xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema">
  <ApplicationName>AdhesiveMongodbServerConsoleHost</ApplicationName>
  <LocalLoggingServiceLevel>Debug</LocalLoggingServiceLevel>
  <WcfConfigServiceAddress>192.168.129.143:18888/WcfConfigService</WcfConfigServiceAddress>
  <ConfigServiceAddress>192.168.129.143:18989/ConfigService</ConfigServiceAddress>
  <StateServiceDefaultReportStateIntervalMilliSeconds>10000</StateServiceDefaultReportStateIntervalMilliSeconds>
</AdhesiveConfig>

这也是所有用到Adhesive的程序都需要进行的配置,Adhesive除了这些最最基础的配置之外,其它配置都在配置服务中。

1)应用程序名

2)本地日志服务的记录等级

3)配置服务服务端地址

4)Wcf配置服务服务端地址

5)状态服务默认的汇报时间间隔

 

最后一步就是编写客户端的代码了,对于客户端程序来说首先需要引用框架必要的程序集,然后就是需要引用服务的客户端程序集(当然对于测试项目你也可以把客户端和服务端放在一个程序集中)。调用方式如下:

private static IMongodbServer service = WcfServiceLocator.GetSafeService<IMongodbServer>();

只需要使用WcfServiceLocator就可以获得服务的实例:

   public class WcfServiceLocator
    {
        public static T GetService<T>() where T : class
        {
            return (T)(new ServiceRealProxy<T>().GetTransparentProxy());
        }

        public static T GetSafeService<T>() where T : class
        {
            return (T)(new ServiceRealProxy<T>(true).GetTransparentProxy());
        }
    }

WcfServiceLocator提供了两个获得服务的方法,安全的和非安全的。所谓安全就是即使服务端访问不到,服务不存在也不会出现异常,只会没有结果,客户端不用进行异常捕获。对于非安全的方式,在服务端连不上或服务端调用服务出现异常的时候会出现异常,需要进行异常处理。需要注意的是,对于非安全方式的调用,如果服务在执行过程中出错,那么客户端收到异常的HelpLink中会给出服务端异常的ID,异常ID是通过从服务端传过来的上下文获得的,代码片段:

                        var exceptionID = ClientApplicationContext.Current.ServerExceptionID ?? "";
                        exception.HelpLink = "服务端异常Id:" + exceptionID;
作者: lovecindywang
本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。
相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识,包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用(唯一索引、地理索引、过期索引、全文索引等)、MapReduce操作实现、用户管理、Java对MongoDB的操作支持(基于2.x驱动与3.x驱动的完全讲解)。 通过学习此课程,读者将具备MongoDB数据库的开发能力,并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品:云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构,具备安全审计,时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版(ApsaraDB for MongoDB)完全兼容MongoDB协议,基于飞天分布式系统和高可靠存储引擎,提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
相关文章
|
2月前
|
存储 缓存 算法
分布式锁服务深度解析:以Apache Flink的Checkpointing机制为例
【10月更文挑战第7天】在分布式系统中,多个进程或节点可能需要同时访问和操作共享资源。为了确保数据的一致性和系统的稳定性,我们需要一种机制来协调这些进程或节点的访问,避免并发冲突和竞态条件。分布式锁服务正是为此而生的一种解决方案。它通过在网络环境中实现锁机制,确保同一时间只有一个进程或节点能够访问和操作共享资源。
78 3
|
25天前
|
机器学习/深度学习 自然语言处理 并行计算
DeepSpeed分布式训练框架深度学习指南
【11月更文挑战第6天】随着深度学习模型规模的日益增大,训练这些模型所需的计算资源和时间成本也随之增加。传统的单机训练方式已难以应对大规模模型的训练需求。
80 3
|
29天前
|
机器学习/深度学习 并行计算 Java
谈谈分布式训练框架DeepSpeed与Megatron
【11月更文挑战第3天】随着深度学习技术的不断发展,大规模模型的训练需求日益增长。为了应对这种需求,分布式训练框架应运而生,其中DeepSpeed和Megatron是两个备受瞩目的框架。本文将深入探讨这两个框架的背景、业务场景、优缺点、主要功能及底层实现逻辑,并提供一个基于Java语言的简单demo例子,帮助读者更好地理解这些技术。
59 2
|
2月前
|
分布式计算 Hadoop
Hadoop-27 ZooKeeper集群 集群配置启动 3台云服务器 myid集群 zoo.cfg多节点配置 分布式协调框架 Leader Follower Observer
Hadoop-27 ZooKeeper集群 集群配置启动 3台云服务器 myid集群 zoo.cfg多节点配置 分布式协调框架 Leader Follower Observer
50 1
|
3月前
|
数据采集 分布式计算 MaxCompute
MaxCompute 分布式计算框架 MaxFrame 服务正式商业化公告
MaxCompute 分布式计算框架 MaxFrame 服务于北京时间2024年09月27日正式商业化!
93 3
|
3月前
|
负载均衡 监控 Dubbo
分布式框架-dubbo
分布式框架-dubbo
|
2月前
|
存储 SQL 消息中间件
Hadoop-26 ZooKeeper集群 3台云服务器 基础概念简介与环境的配置使用 架构组成 分布式协调框架 Leader Follower Observer
Hadoop-26 ZooKeeper集群 3台云服务器 基础概念简介与环境的配置使用 架构组成 分布式协调框架 Leader Follower Observer
49 0
|
3月前
|
XML 负载均衡 监控
分布式-dubbo-简易版的RPC框架
分布式-dubbo-简易版的RPC框架
|
前端开发
WCF更新服务引用报错的原因之一
WCF更新服务引用报错的原因之一
|
C# 数据安全/隐私保护
c#如何创建WCF服务到发布(SqlServer版已经验证)
c#如何创建WCF服务到发布(SqlServer版已经验证)
73 0