使用Apworks开发基于CQRS架构的应用程序【创建.NET WCF服务】

2022-02-18 02:38:47

在本节，我们将介绍.NET WCF服务的创建过程。

在Solution Explorer中，右键单击TinyLibraryCQRS，然后选择Add | New Project…菜单，这将打开Add New Project对话框
在Installed Templates 选项卡下，选择Visual C# | WCF，然后选择WCF Service Application，确保所选.NET版本为.NET Framework 4，在Name文本框中输入TinyLibrary.Services，然后单击OK按钮
右键单击TinyLibrary.Services的References节点，然后选择Add Reference…菜单，这将打开Add Reference对话框
在.NET选项卡下，选择Apworks，Apworks.Bus.DirectBus以及Apworks.ObjectContainers.Unity，然后单击OK按钮
右键单击TinyLibrary.Services的References节点，然后选择Add Reference…菜单，这将打开Add Reference对话框
在Projects选项卡下，选择TinyLibrary.Events，TinyLibrary.EventHandlers，TinyLibrary.Commands，TinyLibrary.CommandHandlers，TinyLibrary.Domain以及TinyLibrary.QueryObjects，然后单击OK按钮
将自动生成的Service1.svc文件删掉
右键单击TinyLibrary.Services项目，然后单击Add | New Item…菜单，这将打开Add New Item对话框
在Installed Templates选项卡下，选择Visual C# | Web，然后选择WCF Service，在Name文本框中，输入CommandService然后单击Add按钮

编辑CommandService.svc.cs文件，输入如下代码

using System;
using Apworks;
using Apworks.Bus;
using Apworks.Generators;
using TinyLibrary.Commands;
  
namespace TinyLibrary.Services
{
    public class CommandService : ICommandService
    {
        private readonly ICommandBus bus = ObjectContainer.Instance.GetService<ICommandBus>();
  
        public long CreateReader(string loginName, string name)
        {
            long id = (long)IdentityGenerator.Instance.Generate();
            RegisterReaderCommand command = new RegisterReaderCommand(id, loginName, name);
            bus.Publish(command);
            bus.Commit();
            return id;
        }
  
        public long CreateBook(string title, string publisher, DateTime pubDate, string isbn, int pages)
        {
            long id = (long)IdentityGenerator.Instance.Generate();
            CreateBookCommand createBookCommand = new CreateBookCommand(id, 
                title, publisher, pubDate, isbn, pages, false);
            bus.Publish(createBookCommand);
            bus.Commit();
            return id;
        }
  
        public void BorrowBook(long readerId, long bookId)
        {
            BorrowBookCommand borrowBookCommand = new BorrowBookCommand(readerId, bookId);
            bus.Publish(borrowBookCommand);
            bus.Commit();
        }
  
        public void ReturnBook(long readerId, long bookId)
        {
            ReturnBookCommand returnBookCommand = new ReturnBookCommand(readerId, bookId);
            bus.Publish(returnBookCommand);
            bus.Commit();
        }
    }
}

用上面相同的方法创建一个QueryService.svc，然后编辑QueryService.svc.cs文件，输入如下代码

using System;
using System.Collections.Generic;
using Apworks;
using Apworks.Queries.Storage;
using Apworks.Storage;
using TinyLibrary.QueryObjects;
  
namespace TinyLibrary.Services
{
    public class QueryService : IQueryService
    {
        private IQueryObjectStorage GetQueryStorage()
        {
            return ObjectContainer.Instance.GetService<IQueryObjectStorage>();
        }
  
        public BookObject GetBook(long id)
        {
            using (IQueryObjectStorage queryObjectStorage = this.GetQueryStorage())
            {
                var pb = new PropertyBag();
                pb.Add("AggregateRootId", id);
                return queryObjectStorage.SelectFirstOnly<BookObject>(pb);
            }
        }
  
        public ReaderObject GetReader(long id)
        {
            using (IQueryObjectStorage queryObjectStorage = this.GetQueryStorage())
            {
                var pb = new PropertyBag();
                pb.Add("AggregateRootId", id);
                return queryObjectStorage.SelectFirstOnly<ReaderObject>(pb);
            }
        }
  
        public ReaderObject GetReaderByLogin(string loginName)
        {
            using (IQueryObjectStorage queryObjectStorage = this.GetQueryStorage())
            {
                var pb = new PropertyBag();
                pb.Add("LoginName", loginName);
                return queryObjectStorage.SelectFirstOnly<ReaderObject>(pb);
            }
        }
  
        public IEnumerable<BookObject> GetAllBooks()
        {
            using (IQueryObjectStorage queryObjectStorage = this.GetQueryStorage())
            {
                return queryObjectStorage.Select<BookObject>();
            }
        }
  
        public IEnumerable<RegistrationObject> GetBookRegistrationHistory(long bookId)
        {
            using (IQueryObjectStorage qos = this.GetQueryStorage())
            {
                PropertyBag pbCriteria = new PropertyBag();
                pbCriteria.Add("BookAggregateRootId", bookId);
  
                PropertyBag pbSort = new PropertyBag();
                pbSort.AddSort<DateTime>("RegistrationDate");
                return qos.Select<RegistrationObject>(pbCriteria, pbSort, Apworks.Storage.SortOrder.Descending);
            }
        }
  
  
        public IEnumerable<RegistrationObject> GetReaderRegistrationHistory(long readerId)
        {
            using (IQueryObjectStorage qos = this.GetQueryStorage())
            {
                PropertyBag pbCriteria = new PropertyBag();
                pbCriteria.Add("ReaderAggregateRootId", readerId);
  
                PropertyBag pbSort = new PropertyBag();
                pbSort.AddSort<DateTime>("RegistrationDate");
                return qos.Select<RegistrationObject>(pbCriteria, pbSort, Apworks.Storage.SortOrder.Descending);
            }
        }
    }
}

右键单击TinyLibrary.Services项目，然后选择Add | New Item…菜单，这将打开Add New Item对话框
在Installed Templates选项卡下，选择Visual C# | Web，然后选择Global Application Class，然后单击Add按钮

修改Global.asax.cs文件如下

using System;
using Apworks.Application;
  
namespace TinyLibrary.Services
{
    public class Global : System.Web.HttpApplication
    {
        private readonly IBootStrapper bootStrapper = BootStrapperFactory.Create();
  
        protected void Application_Start(object sender, EventArgs e)
        {
            bootStrapper.BootStrap();
        }
  
        // ... other methods omitted here.
    }
}

Global.asax文件中定义了，当应用程序启动时，同时会启动Apworks系统。首先，Apworks.Application.BootStrapperFactory类创建了启动实例，然后使用BootStrap方法来初始化应用程序。这个过程是在Apworks的配置文件中定义的，将在后续文章中讨论。

使用Apworks开发基于CQRS架构的应用程序【创建.NET WCF服务】

码农公寓

相关文章