工厂模式和工厂方法模式是设计模式中较为常见的两种模式,借助于依赖注入可以更好的发挥模式的特性。本文将通过一个业务需求的变化过程来阐述如何更好的使用设计模式与依赖注入。
业务需求 在用户登录之后,需要向用户发送一条短信,通知用户。
代码演练 公共内容 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 namespace Use_Dependency_Injection_With_Factory_Pattern { public interface ISmsSender { void Send (string phone, string message ) ; } public interface IUserBll { bool Login (string phone, string password ) ; } public interface IUserDal { bool Exists (string phone, string password ) ; } public class UserDal : IUserDal { private const string StaticPassword = "newbe" ; private const string StaticPhone = "yueluo" ; public bool Exists (string phone, string password ) { return phone == StaticPhone && password == StaticPassword; } } }
公共内容中包含了业务需求中的主要接口ISmsSender
和IUserBll
,以及演示用的数据存储层接口与实现。
版本1,使用控制台“发送短信” 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 using Autofac;using System;namespace Use_Dependency_Injection_With_Factory_Pattern { public static class Demo1 { public static void Run () { Console.WriteLine($"开始运行{nameof (Demo1)} " ); var cb = new ContainerBuilder(); cb.RegisterType<UserDal>().As<IUserDal>(); cb.RegisterType<UserBll>().As<IUserBll>(); cb.RegisterType<ConsoleSmsSender>().As<ISmsSender>(); var container = cb.Build(); var userBll = container.Resolve<IUserBll>(); var login = userBll.Login("yueluo" , "newbe" ); Console.WriteLine(login); login = userBll.Login("newbe" , "yueluo" ); Console.WriteLine(login); Console.WriteLine($"结束运行{nameof (Demo1)} " ); } public class UserBll : IUserBll { private readonly IUserDal _userDal; private readonly ISmsSender _smsSender; public UserBll ( IUserDal userDal, ISmsSender smsSender ) { _userDal = userDal; _smsSender = smsSender; } public bool Login (string phone, string password ) { var re = _userDal.Exists(phone, password); if (re) { _smsSender.Send(phone, "您已成功登录系统" ); } return re; } } public class ConsoleSmsSender : ISmsSender { public void Send (string phone, string message ) { Console.WriteLine($"已给{phone} 发送消息:{message} " ); } } } }
简要分析。版本1使用构造函数注入实现了代码的解耦,使用Autofac作为容器管理,常规用法,没有问题。
由于没有正常的短信发送调用,所以使用ConsoleSmsSender
在控制台中输出消息进行模拟发送。
版本2,线上版本“真发短信”,开发版本“假发短信” 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 using Autofac;using System;namespace Use_Dependency_Injection_With_Factory_Pattern { public static class Demo2 { public static void Run () { Console.WriteLine($"开始运行{nameof (Demo2)} " ); var cb = new ContainerBuilder(); cb.RegisterType<UserDal>().As<IUserDal>(); cb.RegisterType<UserBll>().As<IUserBll>(); #if DEBUG cb.RegisterType<ConsoleSmsSender>().As<ISmsSender>(); #else cb.RegisterType<HttpApiSmsSender>().As<ISmsSender>(); #endif var container = cb.Build(); var userBll = container.Resolve<IUserBll>(); var login = userBll.Login("yueluo" , "newbe" ); Console.WriteLine(login); login = userBll.Login("newbe" , "yueluo" ); Console.WriteLine(login); Console.WriteLine($"结束运行{nameof (Demo2)} " ); } public class UserBll : IUserBll { private readonly IUserDal _userDal; private readonly ISmsSender _smsSender; public UserBll ( IUserDal userDal, ISmsSender smsSender ) { _userDal = userDal; _smsSender = smsSender; } public bool Login (string phone, string password ) { var re = _userDal.Exists(phone, password); if (re) { _smsSender.Send(phone, "您已成功登录系统" ); } return re; } } public class ConsoleSmsSender : ISmsSender { public void Send (string phone, string message ) { Console.WriteLine($"已给{phone} 发送消息:{message} " ); } } public class HttpApiSmsSender : ISmsSender { public void Send (string phone, string message ) { Console.WriteLine($"已调用API给{phone} 发送消息:{message} " ); } } } }
简要分析。与版本1相比,增加了真实调用短信API的实现类,并且通过预编译的方式,实现了Debug模式和Release模式下发布不同版本的效果。一定程度上已经完成了需求。
版本3,引入工厂模式,实现“短信API选择”逻辑的分类 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 using Autofac;using System;namespace Use_Dependency_Injection_With_Factory_Pattern { public static class Demo3 { public static void Run () { Console.WriteLine($"开始运行{nameof (Demo3)} " ); var cb = new ContainerBuilder(); cb.RegisterType<UserDal>().As<IUserDal>(); cb.RegisterType<UserBll>().As<IUserBll>(); cb.RegisterType<SmsSenderFactory>().As<ISmsSenderFactory>(); cb.RegisterType<ConfigProvider>().As<IConfigProvider>(); var container = cb.Build(); var userBll = container.Resolve<IUserBll>(); var login = userBll.Login("yueluo" , "newbe" ); Console.WriteLine(login); login = userBll.Login("newbe" , "yueluo" ); Console.WriteLine(login); Console.WriteLine($"结束运行{nameof (Demo3)} " ); } public class UserBll : IUserBll { private readonly IUserDal _userDal; private readonly ISmsSenderFactory _smsSenderFactory; public UserBll ( IUserDal userDal, ISmsSenderFactory smsSenderFactory ) { _userDal = userDal; _smsSenderFactory = smsSenderFactory; } public bool Login (string phone, string password ) { var re = _userDal.Exists(phone, password); if (re) { var smsSender = _smsSenderFactory.Create(); smsSender.Send(phone, "您已成功登录系统" ); } return re; } } public class ConsoleSmsSender : ISmsSender { public void Send (string phone, string message ) { Console.WriteLine($"已给{phone} 发送消息:{message} " ); } } public class HttpApiSmsSender : ISmsSender { public void Send (string phone, string message ) { Console.WriteLine($"已调用API给{phone} 发送消息:{message} " ); } } public enum SmsSenderType { Console, HttpAPi } public interface ISmsSenderFactory { ISmsSender Create () ; } public class SmsSenderFactory : ISmsSenderFactory { private readonly IConfigProvider _configProvider; public SmsSenderFactory ( IConfigProvider configProvider ) { _configProvider = configProvider; } public ISmsSender Create () { var smsConfig = _configProvider.GetSmsConfig(); switch (smsConfig.SmsSenderType) { case SmsSenderType.Console: return new ConsoleSmsSender(); case SmsSenderType.HttpAPi: return new HttpApiSmsSender(); default : return new HttpApiSmsSender(); } } } public class SmsConfig { public SmsSenderType SmsSenderType { get ; set ; } } public interface IConfigProvider { SmsConfig GetSmsConfig () ; } public class ConfigProvider : IConfigProvider { private readonly SmsConfig _smsConfig = new SmsConfig { SmsSenderType = SmsSenderType.Console }; public SmsConfig GetSmsConfig () { return _smsConfig; } } } }
简要分析。相较于版本2,引入的工厂模式 ,实现了“短信发送方式选择”逻辑的封装。这样改造之后,便可以不论是在生产环境还是开发环境,都能够通过配置项的修改,实现短信发送方式的切换。
当然,在增加了程序灵活性的同时,也引入了更多的类和配置。
版本4,工厂方法模式 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 using Autofac;using System;using System.Linq;namespace Use_Dependency_Injection_With_Factory_Pattern { public static class Demo4 { public static void Run () { Console.WriteLine($"开始运行{nameof (Demo4)} " ); var cb = new ContainerBuilder(); cb.RegisterType<UserDal>().As<IUserDal>(); cb.RegisterType<UserBll>().As<IUserBll>(); cb.RegisterType<SmsSenderFactory>().As<ISmsSenderFactory>(); cb.RegisterType<ConsoleSmsSenderFactoryHandler>() .As<ISmsSenderFactoryHandler>(); cb.RegisterType<SmsSenderFactoryHandler>() .As<ISmsSenderFactoryHandler>(); cb.RegisterType<ConfigProvider>().As<IConfigProvider>(); var container = cb.Build(); var userBll = container.Resolve<IUserBll>(); var login = userBll.Login("yueluo" , "newbe" ); Console.WriteLine(login); login = userBll.Login("newbe" , "yueluo" ); Console.WriteLine(login); Console.WriteLine($"结束运行{nameof (Demo4)} " ); } public class UserBll : IUserBll { private readonly IUserDal _userDal; private readonly ISmsSenderFactory _smsSenderFactory; public UserBll ( IUserDal userDal, ISmsSenderFactory smsSenderFactory ) { _userDal = userDal; _smsSenderFactory = smsSenderFactory; } public bool Login (string phone, string password ) { var re = _userDal.Exists(phone, password); if (re) { var smsSender = _smsSenderFactory.Create(); smsSender.Send(phone, "您已成功登录系统" ); } return re; } } public enum SmsSenderType { Console, HttpAPi } public interface ISmsSenderFactory { ISmsSender Create () ; } public class SmsSenderFactory : ISmsSenderFactory { private readonly IConfigProvider _configProvider; private readonly ISmsSenderFactoryHandler[] _smsSenderFactoryHandlers; public SmsSenderFactory ( IConfigProvider configProvider, ISmsSenderFactoryHandler[] smsSenderFactoryHandlers ) { _configProvider = configProvider; _smsSenderFactoryHandlers = smsSenderFactoryHandlers; } public ISmsSender Create () { var smsConfig = _configProvider.GetSmsConfig(); var factoryHandler = _smsSenderFactoryHandlers.Single(x => x.SmsSenderType == smsConfig.SmsSenderType); var smsSender = factoryHandler.Create(); return smsSender; } } public interface ISmsSenderFactoryHandler { SmsSenderType SmsSenderType { get ; } ISmsSender Create () ; } #region 控制台发送短信接口实现 public class ConsoleSmsSenderFactoryHandler : ISmsSenderFactoryHandler { public SmsSenderType SmsSenderType { get ; } = SmsSenderType.Console; public ISmsSender Create () { return new ConsoleSmsSender(); } } public class ConsoleSmsSender : ISmsSender { public void Send (string phone, string message ) { Console.WriteLine($"已给{phone} 发送消息:{message} " ); } } #endregion #region API发送短信接口实现 public class SmsSenderFactoryHandler : ISmsSenderFactoryHandler { public SmsSenderType SmsSenderType { get ; } = SmsSenderType.HttpAPi; public ISmsSender Create () { return new HttpApiSmsSender(); } } public class HttpApiSmsSender : ISmsSender { public void Send (string phone, string message ) { Console.WriteLine($"已调用API给{phone} 发送消息:{message} " ); } } #endregion public class SmsConfig { public SmsSenderType SmsSenderType { get ; set ; } } public interface IConfigProvider { SmsConfig GetSmsConfig () ; } public class ConfigProvider : IConfigProvider { private readonly SmsConfig _smsConfig = new SmsConfig { SmsSenderType = SmsSenderType.Console }; public SmsConfig GetSmsConfig () { return _smsConfig; } } } }
简要说明。相对于版本3,采用了工厂方法模式 。本质上,就是将“不同的类型如何创建短信发送API”的逻辑转移到了ISmsSenderFactory
的实现类中。实际项目中,往往可以将ISmsSenderFactory
和ISmsSender
的实现类放在不同的程序集中。而且后续如果要增加新的发送方式,只需要增加对应的实现类并且注册即可,进一步增加了可扩展性。
版本5,结合Autofac的最终版本 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 using Autofac;using Autofac.Features.Indexed;using System;namespace Use_Dependency_Injection_With_Factory_Pattern { public static class Demo5 { public static void Run () { Console.WriteLine($"开始运行{nameof (Demo5)} " ); var cb = new ContainerBuilder(); cb.RegisterModule<CoreModule>(); cb.RegisterModule<SmsCoreModule>(); cb.RegisterModule<ConsoleSmsModule>(); cb.RegisterModule<HttpApiSmsModule>(); var container = cb.Build(); var userBll = container.Resolve<IUserBll>(); var login = userBll.Login("yueluo" , "newbe" ); Console.WriteLine(login); login = userBll.Login("newbe" , "yueluo" ); Console.WriteLine(login); Console.WriteLine($"结束运行{nameof (Demo5)} " ); } public class CoreModule : Module { protected override void Load (ContainerBuilder builder ) { base .Load(builder); builder.RegisterType<UserDal>().As<IUserDal>(); builder.RegisterType<UserBll>().As<IUserBll>(); builder.RegisterType<ConfigProvider>().As<IConfigProvider>(); } } public class SmsCoreModule : Module { protected override void Load (ContainerBuilder builder ) { base .Load(builder); builder.RegisterType<SmsSenderFactory>() .As<ISmsSenderFactory>(); } } public class ConsoleSmsModule : Module { protected override void Load (ContainerBuilder builder ) { base .Load(builder); builder.RegisterType<ConsoleSmsSender>().AsSelf(); builder.RegisterType<ConsoleSmsSenderFactoryHandler>() .Keyed<ISmsSenderFactoryHandler>(SmsSenderType.Console); } } public class HttpApiSmsModule : Module { protected override void Load (ContainerBuilder builder ) { base .Load(builder); builder.RegisterType<HttpApiSmsSender>().AsSelf(); builder.RegisterType<SmsSenderFactoryHandler>() .Keyed<ISmsSenderFactoryHandler>(SmsSenderType.HttpAPi); } } public class UserBll : IUserBll { private readonly IUserDal _userDal; private readonly ISmsSenderFactory _smsSenderFactory; public UserBll ( IUserDal userDal, ISmsSenderFactory smsSenderFactory ) { _userDal = userDal; _smsSenderFactory = smsSenderFactory; } public bool Login (string phone, string password ) { var re = _userDal.Exists(phone, password); if (re) { var smsSender = _smsSenderFactory.Create(); smsSender.Send(phone, "您已成功登录系统" ); } return re; } } public enum SmsSenderType { Console, HttpAPi } public interface ISmsSenderFactory { ISmsSender Create () ; } public class SmsSenderFactory : ISmsSenderFactory { private readonly IConfigProvider _configProvider; private readonly IIndex<SmsSenderType, ISmsSenderFactoryHandler> _smsSenderFactoryHandlers; public SmsSenderFactory ( IConfigProvider configProvider, IIndex<SmsSenderType, ISmsSenderFactoryHandler> smsSenderFactoryHandlers ) { _configProvider = configProvider; _smsSenderFactoryHandlers = smsSenderFactoryHandlers; } public ISmsSender Create () { var smsConfig = _configProvider.GetSmsConfig(); var factoryHandler = _smsSenderFactoryHandlers[smsConfig.SmsSenderType]; var smsSender = factoryHandler.Create(); return smsSender; } } public interface ISmsSenderFactoryHandler { ISmsSender Create () ; } #region 控制台发送短信接口实现 public class ConsoleSmsSenderFactoryHandler : ISmsSenderFactoryHandler { private readonly ConsoleSmsSender.Factory _factory; public ConsoleSmsSenderFactoryHandler ( ConsoleSmsSender.Factory factory ) { _factory = factory; } public ISmsSender Create () { return _factory(); } } public class ConsoleSmsSender : ISmsSender { public delegate ConsoleSmsSender Factory () ; public void Send (string phone, string message ) { Console.WriteLine($"已给{phone} 发送消息:{message} " ); } } #endregion #region API发送短信接口实现 public class SmsSenderFactoryHandler : ISmsSenderFactoryHandler { private readonly HttpApiSmsSender.Factory _factory; public SmsSenderFactoryHandler ( HttpApiSmsSender.Factory factory ) { _factory = factory; } public ISmsSender Create () { return _factory(); } } public class HttpApiSmsSender : ISmsSender { public delegate HttpApiSmsSender Factory () ; public void Send (string phone, string message ) { Console.WriteLine($"已调用API给{phone} 发送消息:{message} " ); } } #endregion public class SmsConfig { public SmsSenderType SmsSenderType { get ; set ; } } public interface IConfigProvider { SmsConfig GetSmsConfig () ; } public class ConfigProvider : IConfigProvider { private readonly SmsConfig _smsConfig = new SmsConfig { SmsSenderType = SmsSenderType.Console }; public SmsConfig GetSmsConfig () { return _smsConfig; } } } }
简要说明。相对于版本4,该版本结合了较多Autofac所提供的特性。
使用了Module
,使得相关的类更加聚合,往往可以通过这种方式将相关的逻辑独立在一个程序集中 使用了Index<,>
的方式进行注册。这是Autofac提供了一种服务注册方式,将相同接口的实现以不同的键进行注册和实例。参考链接 使用了Autofac提供了Delegate Factories
特性。这样在操作ConsoleSmsSender
这样的类时,便也可以使用依赖注入。参考链接 总结 通过上述代码的演变过程,简要介绍了工厂模式和工厂方法模式在项目当中的使用方法,也是对依赖注入方法使用的进一步熟悉。
在使用设计模式和依赖注入的过程当中,不可避免的增加了更多的接口和实现类。读者需要深入理解,各个版本之间的差异,已经后一个版本产生的原因。如果读者能够将每个版本的变化总结为“隔离了什么变化,实现了什么解耦” 这样一句话,那么说明读者已经理解的其中的原因。
实际项目之中也并非始终都要套用最终的复杂模式,开发者需要根据实际项目可能的变化因素自行考评模式使用的力度。
本文示例代码地址
教程链接