Rafy框架:领域控制器

博客 分享
0 155
张三
张三 2022-03-23 19:57:10
悬赏:0 积分 收藏

Rafy 框架:领域控制器

Rafy

本文简要说明如何使用 Rafy 框架中的领域控制器。

简介

领域控制器是 Rafy 框架中用于封装领域逻辑的主要方式。

在控制器中,开发者可以封装大量的业务逻辑,并向外暴露业务接口。内部的逻辑在实现时,往往调用一个或多个实体仓库的 CDUQ 方法来实现。

示例

以下代码为 Rafy.Accounts 帐户插件 中 AccountController 类型的真实代码。

/// <summary>/// 帐户插件的领域控制器。/// </summary>public class AccountController : DomainController{	/// <summary>	/// 注册指定的用户。	/// </summary>	/// <param name="user"></param>	/// <returns></returns>	[ControllerLogic]	public virtual Result Register(User user)	{		if (user == null) throw new ArgumentNullException("user");		var userNameAsId = _identityMode.HasFlag(UserIdentityMode.UserName);		if (userNameAsId && string.IsNullOrEmpty(user.UserName)) return new Result(ResultCodes.RegisterUserNameInvalid, "用户名不能为空。");		var emailAsId = _identityMode.HasFlag(UserIdentityMode.Email);		if (emailAsId && !TextFormatter.ReEmail.IsMatch(user.Email)) return new Result(ResultCodes.RegisterEmailInvalid, "邮箱格式不正确。");		if (!userNameAsId && !emailAsId) throw new InvalidProgramException("!userNameAsId && !useEmailAsId");		//验证其它属性。		var brokenRules = Validator.Validate(user);		if (brokenRules.Count > 0) return new Result(ResultCodes.RegisterPropertiesInvalid, brokenRules.ToString());		//检查用户名、邮箱的重复性。		var repo = RF.ResolveInstance<UserRepository>();		var criteria = new CommonQueryCriteria();		criteria.Concat = BinaryOperator.Or;		if (userNameAsId)		{			criteria.Add(new PropertyMatch(User.UserNameProperty, user.UserName));		}		if (emailAsId)		{			criteria.Add(new PropertyMatch(User.EmailProperty, user.Email));		}		var exists = repo.GetFirstBy(criteria);		if (exists != null)		{			if (emailAsId && exists.Email == user.Email)			{				return new Result(ResultCodes.RegisterEmailDuplicated, string.Format("注册失败,已经存在邮箱为:{0} 的用户。", user.Email));			}			else			{				return new Result(ResultCodes.RegisterUserNameDuplicated, string.Format("注册失败,已经存在用户名为:{0} 的用户。", user.UserName));			}		}		//保存这个用户		user.PersistenceStatus = PersistenceStatus.New;		repo.Save(user);		this.OnRegisterSuccessed(user);		return true;	}	/// <summary>	/// 注册成功的事件。	/// </summary>	public event EventHandler<AccountEventArgs> RegisterSuccessed;	/// <summary>	/// 注册成功的事件。	/// </summary>	/// <param name="user"></param>	protected virtual void OnRegisterSuccessed(User user)	{		var handler = this.RegisterSuccessed;		if (handler != null) handler(this, new AccountEventArgs(user));	}}

调用方的代码如下:

var controller = DomainControllerFactory.Create<AccountController>();var res = controller.Register(new User{    UserName = "hqf",    RealName = "hqf",    Password = controller.EncodePassword("hqf")});

通过 DomainControllerFactory 来创建一个控制器(也可用简写 DCF),即可调用其中的方法。

特点

  • 支持本地调用,也支持分布式调用

    领域控制器是除了仓库查询以外,提供分布式数据传输的另一机制。控制器的调用,支持本地调用,也支持分布式调用。详见:部署。

  • 无状态

    领域控制器本身应该是无状态的。每次使用工厂创建时,都会创建一个新实例。特殊情况下,如果需要传递状态,需要对属性添加 [ControllerClientSettings] 标记。

  • 支持领域控制器事件及依赖管理

    详见后文。

  • 支持使用接口来定义控制器契约。参见:IDomainControllerContract 接口。

远程调用

DomainController 中,所有可远程调用的方法,都需要满足:一、标记为虚方法;二、添加 [ControllerLogic] 标记。工厂会为在运行时创建控制器的子类,并这些方法实现远程调用。

所以,此类方法需要注意,参数及返回值应该都是要支持序列化的。否则会在远程调用时失败。

领域控制器事件

各业务模块可以分别定义大量的领域控制器,而模块之间的业务,往往需要进行交互。除直接的调用关系以外,领域控制器还提供了事件依赖及管理功能。

例如,我们往往希望在用户注册成功后,各业务模块(例如博客模块)再额外注册一些其它内容。这时,我们又不希望修改用户的注册代码。那么我们可以在博客模块的领域控制器中,指定该控制器依赖 AccountController,这时再监听 RegisterSuccessed 事件添加自己的业务逻辑。

下面示例代码中,基础库存模块与入库管理插件,后者依赖前者。代码展示了,库存业务插件的 StockChanged 事件发生时,入库模块会发生一些特定的逻辑。

//业务插件一:库存模块public class StockController : DomainController{    public event EventHandler StockChanged;    protected virtual void OnStockChanged()    {        var handler = this.StockChanged;        if (handler != null) handler(this, EventArgs.Empty);    }}//业务插件二:入库管理插件public class RecieveController : DomainController{    static RecieveController()    {        Depend<RecieveController>().On<StockController>();    }    protected override void OnAlwaysDependon(DomainController controller)    {        var sc = controller as StockController;        if (sc != null)        {            sc.StockChanged += OnStockChanged;        }    }    private void OnStockChanged(object sender, EventArgs e)    {        //根据库存变化信息,来实现特定功能    }}

PS:该文已经纳入《 Rafy 用户手册》中。

posted @ 2022-03-23 19:11 BloodyAngel 阅读(0) 评论(0) 编辑 收藏 举报
回帖
    张三

    张三 (王者 段位)

    821 积分 (2)粉丝 (41)源码

     

    温馨提示

    亦奇源码

    最新会员