使用接口的方式調用遠程服務 ------ 利用動態調用服務，實現.net下類似Dubbo的玩法。

     分布式微服務現在成為了很多公司架構首先項，據我了解，很多java公司架構都是 Maven+Dubbo+Zookeeper基礎上擴展的。

     Dubbo是Alibaba開源的分布式服務框架，它最大的特點是按照分層的方式來架構，使用這種方式可以使各個層之間解耦合（或者最大限度地松耦合）。從服務模型的角度來看，Dubbo采用的是一種非常簡單的模型，要么是提供方提供服務，要么是消費方消費服務，所以基於這一點可以抽象出服務提供方（Provider）和服務消費方（Consumer）兩個角色。

     關於更多Dubbo更多資料，可以查看Dubbo官方文檔。值得一提的是，Dubbo官方文檔也是一份非常好的分布式學習資料。

     那么.net下能不能類似dubbo那樣玩呢？目前好像沒有找到.net下類似的實現。感覺很多公司應該有自己類似實現，但是沒有開源出來吧。

     我這里先做一個類似的基於接口的遠程調用的實現，項目的服務實現使用WCF，IOC注入使用Autofac。

     一，解決方案整體設計

     

      （一）Cn.Code.Demo 

       如上圖，Cn.Code.Demo 解決方案包含了所有的項目。

       

    如上圖：1 Cn.Code.Common 是項目一些公共方法的實現。

               2 Cn.Code.Core 是項目所有的對外接口，此項目只包含接口。

               3 Cn.Code.Demo 是一個MVC項目，用於測試我們的接口調用。

               4 Cn.Code.FirstService 第一個服務實現，實現了Cn.Code.Core 部分接口。

               5 Cn.Code.SecondService 第二個服務實現，實現了Cn.Code.Core 部分接口。

        （二）Cn.Code.FirstService

          

 

          此解決方案只包含 Cn.Code.Core 和Cn.Code.FirstService 。

         （三）Cn.Code.SecondService

          

 

         此解決方案只包含 Cn.Code.Core 和Cn.Code.SecondService 。

 

        二，接口層 --Cn.Code.Core 

        

        接口層只包含如下2個接口，這里我使用WCF進行測試，所以需要添加System.ServiceModel 模塊引用。

        IFirstService 接口如下：

    [ServiceContract]
    public interface IFirstService
    {
        [OperationContract]
        string GetData();
    }

         ISecondService接口如下：

    [ServiceContract]
    public interface ISecondService
    {
        [OperationContract]
        string GetData();
    }

        三，服務實現 --Cn.Code.FirstService 和Cn.Code.SecondService

        為了方便測試，這里的服務實現都非常簡單。

    public class FirstService :IFirstService
    {
        public string GetData()
        {
            return string.Format("您調用了 FirstService ！");
        }

    }

    public class SecondService :ISecondService
    {
        public string GetData()
        {
            return string.Format("您調用了 SecondService ！");
        }
    }

         四，公共方法實現 --Cn.Code.Common

         首先是WCF動態調用的構建工廠。

   /// <summary>
    /// Wcf動態調用構建
    /// </summary>
    public class WcfInvokeFactory
    {
        #region WCF服務工廠
        public static T GetService<T>(string url)
        {
            return GetService<T>(url, "basicHttpBinding");
        }


        public static T GetService<T>(string url, string bing)
        {
            try
            {
                if (string.IsNullOrEmpty(url)) throw new NotSupportedException("This url is not Null or Empty!");
                EndpointAddress address = new EndpointAddress(url);
                Binding binding = CreateBinding(bing);
                ChannelFactory<T> factory = new ChannelFactory<T>(binding, address);
                return factory.CreateChannel();
            }
            catch (Exception ex)
            {
                throw new Exception("創建服務工廠出現異常.");
            }
        }
        #endregion

        #region 創建傳輸協議
        /// <summary>
        /// 創建傳輸協議
        /// </summary>
        /// <param name="binding">傳輸協議名稱</param>
        /// <returns></returns>
        private static Binding CreateBinding(string binding)
        {
            Binding bindinginstance = null;
            if (binding.ToLower() == "basichttpbinding")
            {
                BasicHttpBinding ws = new BasicHttpBinding();
                ws.MaxBufferSize = 2147483647;
                ws.MaxBufferPoolSize = 2147483647;
                ws.MaxReceivedMessageSize = 2147483647;
                ws.ReaderQuotas.MaxStringContentLength = 2147483647;
                ws.CloseTimeout = new TimeSpan(0, 30, 0);
                ws.OpenTimeout = new TimeSpan(0, 30, 0);
                ws.ReceiveTimeout = new TimeSpan(0, 30, 0);
                ws.SendTimeout = new TimeSpan(0, 30, 0);

                bindinginstance = ws;
            }
            else if (binding.ToLower() == "nettcpbinding")
            {
                NetTcpBinding ws = new NetTcpBinding();
                ws.MaxReceivedMessageSize = 65535000;
                ws.Security.Mode = SecurityMode.None;
                bindinginstance = ws;
            }
            else if (binding.ToLower() == "wshttpbinding")
            {
                WSHttpBinding ws = new WSHttpBinding(SecurityMode.None);
                ws.MaxReceivedMessageSize = 65535000;
                ws.Security.Message.ClientCredentialType = System.ServiceModel.MessageCredentialType.Windows;
                ws.Security.Transport.ClientCredentialType = System.ServiceModel.HttpClientCredentialType.Windows;
                bindinginstance = ws;
            }
            return bindinginstance;

        }
        #endregion
    }

         其次是擴展Autofac一個注冊接口的方法。

    /// <summary>
    /// Autofac 擴展注入方法
    /// </summary>
    public static class RegistExtensions
    {
        /// <summary>
        /// 
        /// </summary>
        /// <typeparam name="T">需要注入的接口類型</typeparam>
        /// <param name="builder"></param>
        /// <param name="url">接口服務調用URL</param>
        /// <returns></returns>
        public static IRegistrationBuilder<T, SimpleActivatorData, SingleRegistrationStyle> RegisterService<T>(this ContainerBuilder builder, string url)
        {
            return builder.Register(c => WcfInvokeFactory.GetService<T>(url)).As<T>();
        }
    }

 

         五，MVC項目測試 --Cn.Code.Demo

         首先運行2個解決方案Cn.Code.FirstService與Cn.Code.SecondService，得到2個服務地址，將地址配置到項目的web.config中。

    <add key="FirstService" value="http://localhost:9970/FirstService.svc"/>
    <add key="SecondService" value="http://localhost:10014/SecondService.svc"/>

         其次在全局文件Global.asax中，利用自定義Autofac注冊擴展，分別注入不同的服務地址。

using Autofac;
using Autofac.Integration.Mvc;

using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Web;
using System.Web.Http;
using System.Web.Mvc;
using System.Web.Optimization;
using System.Web.Routing;
using System.Web.Security;
using System.Web.SessionState;
using System.Configuration;

using Cn.Code.Core;
using Cn.Code.Common;


namespace Cn.Code.Demo
{
    public class MvcApplication : System.Web.HttpApplication
    {
        protected void Application_Start()
        {
            var builder = new ContainerBuilder();
            SetupResolveRules(builder);
            builder.RegisterControllers(Assembly.GetExecutingAssembly()).PropertiesAutowired();
            builder.RegisterAssemblyTypes(Assembly.GetExecutingAssembly()).AsImplementedInterfaces();
            var container = builder.Build();
            DependencyResolver.SetResolver(new AutofacDependencyResolver(container));



            AreaRegistration.RegisterAllAreas();
            GlobalConfiguration.Configure(WebApiConfig.Register);
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);


        }

        private void SetupResolveRules(ContainerBuilder builder)
        {
            //利用自定義注冊擴展，分別注入不同的服務地址
            builder.RegisterService<IFirstService>(ConfigurationManager.AppSettings["FirstService"]);
            builder.RegisterService<ISecondService>(ConfigurationManager.AppSettings["SecondService"]);
        }  
    }
}

         接下來就是調用我們的接口了。

using Cn.Code.Core;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Mvc;

namespace Cn.Code.Demo.Controllers
{
    public class HomeController : Controller
    {
        private IFirstService _iFirstService;
        private ISecondService _iSecondService;
        public HomeController() { }
        public HomeController(IFirstService iFirstService, ISecondService iSecondService)
        {
            this._iFirstService = iFirstService;
            this._iSecondService = iSecondService;
        }
        public ActionResult Index()
        {
            //第一個接口
            ViewBag.FirstText = _iFirstService.GetData();
            //第二個接口
            ViewBag.SecondText = _iSecondService.GetData();
            return View();
        }
    }
}

         視圖頁面輸出結果。

@{
    ViewBag.Title = "Home Page";
}
<div class="row">
    @ViewBag.FirstText
    <br />
    @ViewBag.SecondText
</div>

 

 

       調用成功。

       五，總結

       這樣的話，我們的遠程調用服務接口就和平時正常調用使用項目內接口方法一樣了。同時這樣拆分，可以將不同的服務注冊到不同的節點。這個節點也可以是一個集群。

       當然，這里只是個測試小demo，后續應該結合Zookeeper或者其他的分布式服務框架，實現均衡負載的管理。

       

       注：代碼比較low，望見諒。代碼下載地址Cn.Code.Demo.zip