Anno微服务引擎与传统应用相融合

1、Anno是什么？

　　Anno是一个微服务引擎。在此之前我们通过 Viper项目对Anno有一个基本的认识，并且Viper也受到的很多朋友的喜欢，截止发稿前Viper在GitHub收获了300多个星。并且Anno也在昨天（2020年11月24日）开源。今天我们就聊一聊Anno如何与传统的项目相结合。

github   :https://github.com/duyanming/Anno.Core  

gitee      :https://gitee.com/duyanming/anno.core

体验地址：http://140.143.207.244/Home/Login

2、Anno和传统项目相结合

　　我们新建一个asp.net framework WebApi 项目。然后我们通过客户端代理（Install-Package Anno.Rpc.Client.DynamicProxy）生成服务接口代理类，并注入到Autofac容器中去。服务提供方可以是.netcore服务、.netframework服务、java服务以及其他语言提供的服务（期待大佬的加入扩展出更多）。

　　Demo地址：https://github.com/duyanming/Viper/tree/master/Samples

　　以下Demo我们用.netcore提供服务。

 创建一个传统的ASP.NET WEB API项目，结构如下：

第一步 引入Nuget包 :

Install-Package Anno.Rpc.Client.DynamicProxy -Version 1.0.2.8

Install-Package Autofac.WebApi2 -Version 4.3.1

第二步：

　　新增文件:IocManager.cs　　

 public static class IocManager
    {
        public static IContainer IoContainer;
        private static readonly ContainerBuilder Builder = new ContainerBuilder();

        public static ContainerBuilder GetContainerBuilder()
        {
            return Builder;
        }

        public static void Build(params Assembly[] assemblies)
        {
            if (assemblies != null)
            {
                assemblies.ToList().ForEach(assembly =>
                {
                    assembly.GetTypes().Where(x => x.GetTypeInfo().IsClass && !x.GetTypeInfo().IsAbstract && !x.GetTypeInfo().IsInterface).ToList().ForEach(
                        t =>
                        {
                            var interfaces = t.GetInterfaces();
                            if (interfaces.Length <= 0)
                            {
                                Builder.RegisterType(t);
                            }
                            else
                            {
                                Builder.RegisterType(t).As(t.GetInterfaces());
                            }
                        });
                });

            }
            IoContainer = Builder.Build();
        }
    }

　　新增文件:AutoFacConfig.cs　　

public class AutoFacConfig
    {
        public static void Register()
        {
            var builder = IocManager.GetContainerBuilder();
            var config = GlobalConfiguration.Configuration;

            builder.RegisterApiControllers(Assembly.GetCallingAssembly())
               .PropertiesAutowired();
            builder.RegisterWebApiFilterProvider(config);
            builder.RegisterWebApiModelBinderProvider();
            /*
             * Anno服务接口通过代理注册到IOC容器中去
             */
            builder.RegisterInstance<IHelloWorldViperService>(AnnoProxyBuilder.GetService<IHelloWorldViperService>());

            IocManager.Build(typeof(IocManager).Assembly);
            config.DependencyResolver = new AutofacWebApiDependencyResolver(IocManager.IoContainer);


        }
    }

　　修改文件：WebApiConfig.cs　　

public static class WebApiConfig
    {
        public static void Register(HttpConfiguration config)
        { 
            //1、将默认的xml格式化程序清除
            GlobalConfiguration.Configuration.Formatters.XmlFormatter.SupportedMediaTypes.Clear();

            // Web API 配置和服务

            // Web API 路由
            config.MapHttpAttributeRoutes();

            config.Routes.MapHttpRoute(
                name: "DefaultApi",
                routeTemplate: "api/{controller}/{id}",
                defaults: new { id = RouteParameter.Optional }
            );
            config.Formatters.JsonFormatter.SerializerSettings.DateFormatString = "MM/dd/yyy HH:mm:ss";
        }
    }

　　修改文件：Global.asax　　

 using Anno.Rpc.Client;
    public class WebApiApplication : System.Web.HttpApplication
    {
        protected void Application_Start()
        {
            /*
             * 配置注册中心地址
             * 客户端名称：MvcCallAnno
             * 注册中心IP：127.0.0.1
             * 注册中心端口：7010
             * 调用链追踪：false（true开启，false关闭）
             */
            DefaultConfigManager.SetDefaultConfiguration("MvcCallAnno", "127.0.0.1", 7010, true);
            /*
             * Autofac Ioc 初始化
             */
            AutoFacConfig.Register();
            GlobalConfiguration.Configure(WebApiConfig.Register);
        }
    }

　　增加服务接口：IHelloWorldViperService.cs　　

namespace MvcCallAnno.Service
{
    using Anno.Rpc.Client.DynamicProxy;

    /// <summary>
    /// 对应Anno.Plugs.HelloWorldService 插件的 HelloWorldViperModule 模块
    /// 接口名称和接口方法和 AnnoService端的 名称不一样的时候使用AnnoProxy 指定别名
    /// </summary>
    [AnnoProxy(Channel = "Anno.Plugs.HelloWorld", Router = "HelloWorldViper")]
    public interface IHelloWorldViperService
    {
        /// <summary>
        /// 名称不一致
        /// </summary>
        /// <param name="name"></param>
        /// <param name="age"></param>
        /// <returns></returns>
        [AnnoProxy(Method = "SayHello")]
        dynamic SayHello(string name, int age);
        /// <summary>
        /// 名称一致
        /// </summary>
        /// <param name="x"></param>
        /// <param name="y"></param>
        /// <returns></returns>
        int Subtraction(int x, int y);

        ProductDto BuyProduct(string productName, int number);
    }


    public class ProductDto
    {
        public string Name { get; set; }
        public int Number { get; set; }
        public double Price { get; set; }
        public double Amount { get { return Price * Number; } }
        public string CountryOfOrigin { get; set; }
    }
}

　　增加控制器：ValuesController.cs 　　

  public class ValuesController : ApiController
    {
        private readonly IHelloWorldViperService helloWorldViperService;
        public ValuesController(IHelloWorldViperService helloWorldViperService) {
            this.helloWorldViperService = helloWorldViperService;
        }
        [HttpGet]
        public dynamic SayHello(string name, int age) {
            var rlt= helloWorldViperService.SayHello(name,age);
            return Json(rlt);
        }
        [HttpGet]
        public int Subtraction(int x, int y) {
            return helloWorldViperService.Subtraction(x,y);
        }
        [HttpGet]
        public dynamic BuyProduct(string productName, int number) {
            return helloWorldViperService.BuyProduct(productName, number);
        }

 主要步骤：

安装Nuget包---》初始化Anno注册中心配置----》代理注入AutoFac容器---》控制器通过构造函数注入服务接口

2.1、开始演示

1、启动注册中心

 2、启动HelloWorldService服务

  再来看下注册中心输出的信息

 注册中心已经收到HelloWorldService服务的注册

3、启动我们的Asp.net Web API

　　调用控制器接口：SayHello　　

[HttpGet]
        public dynamic SayHello(string name, int age) {
            var rlt= helloWorldViperService.SayHello(name,age);
            return Json(rlt);
        }

 看到了输出结果，第一个接口调用成功。

　　第二个接口：Subtraction　　

 [HttpGet]
        public int Subtraction(int x, int y) {
            return helloWorldViperService.Subtraction(x,y);
        }

  看到了输出结果75，也是我们预期的结果。调用成功。

　　第三个接口：BuyProduct

　　

[HttpGet]
        public dynamic BuyProduct(string productName, int number) {
            return helloWorldViperService.BuyProduct(productName, number);
        }

  也是我们预期的结果。调用成功。

学习交流 QQ群：478399354 ，到这里我们互为师长相互学习。

Anno核心源码:https://github.com/duyanming/Anno.Core  

Viper示例项目:https://github.com/duyanming/Viper  

体验地址：http://140.143.207.244/Home/Login

文档地址：https://duyanming.github.io/

关于Anno的更多内容，随后更新。敬请关注。开源不易，感谢Star。