多层分布式设计模式

    原来就想写一些关于分布式的设计。正好目前开发的GIX4项目中,需要对客户端的许多操作进行记录。这个功能的设计或多或少能说明,一般情况下,多层的分布式系统应该如何设计。现在我就对这个功能进行描述。

功能描述

GIX4项目中有个审核日志记录功能,它需要以下功能:

    需要把客户的所有操作记录下来,以便支持审计。如,当用户进行:登录、打开模块、查看数据、点击按钮……等操作时,把相关的数据全部在服务器的数据库中记录下来,这些数据有:操作类型、操作时间、操作内容、操作者、客户端机器名等。

    在服务端对某些特定的事件进行记录,如:计算出错。

设计目标

    这个模块需要支持以下目标:

    *为客户端代码、服务器端代码都提供简单统一的接口。

    *需要异步记录。

    *如果扩展为多级物理层时,也需要使用相同的接口。

设计

    先把设计完成的图贴出来,然后再逐一描述:

图1 全部类图

通用部分

    首先,API设计之初,先根据需求,定出使用的接口。它们包含两个类:一个是贫血数据类AuditLogItem,一个是对AuditLogItem进行操作的静态类AuditLogService。AuditLogService暂时公布两个静态方法,一个记录日志方法Log(),另一个方法是异步记录LogAsync()。如下:

    由于各物理层都使用AuditLogService的方法,而实现不同。这里把使用了Provider模式,提取接口IAuditLogProvider,这里就不再需要异步方法了:

/// <summary>
/// 审计功能提供程序
/// </summary>
public interface IAuditLogProvider
{
    /// <summary>
    /// 记录指定的日志
    /// </summary>
    /// <param name="log"></param>
    void Log(AuditLogItem log);
}

    除了最终与数据库通信的服务器外,其它节点都默认使用ClientAuditLogProvider作为提供程序。此提供程序使用了ICommunication,而ICommunication则是负责向“下一节点”通信并提交日志记录功能。

GIX4实现部分

    这部分主要是两个类:ServerAuditLogProvider 和 CSLACommandCommunication。

    ServerAuditLogProvider 使用CSLA的类库把AuditLogItem转换为相应的数据库模型存入数据库中:

public class ServerAuditLogProvider : IAuditLogProvider
{
    public void Log(AuditLogItem log)
    {
        var dbItem = AuditItem.New();

        dbItem.Title = log.Title;
        dbItem.Content = log.Content;
        dbItem.User = log.User;
        dbItem.MachineName = log.MachineName;
        dbItem.Type = log.Type;
        dbItem.LogTime = log.LogTime;

        dbItem.Save();
    }
}

    CSLACommandCommunication 则是使用WCF和CSLA命令模式作为基础框架,让当前节点把请求发送给下一节点,下一节点接到请求后,使用本节点的提供程序Provider来处理请求。其中重要的代码在内部类AuditServerCommand中,如下:

[Serializable]
public class AuditServerCommand : Csla.CommandBase
{
    private AuditLogItem _logItem;

    public AuditServerCommand(AuditLogItem logItem)
    {
        if (logItem == null) throw new ArgumentNullException("logItem");

        this._logItem = logItem;
    }

    protected override void DataPortal_Execute()
    {
        //server log
        AuditLogService.Log(this._logItem);
    }
}

整个过程

    整个过程其实很简单,一图胜千言:

后记

    其实本次设计过程的思路很简单:分析要提供的API(场景驱动)、分析分布式实现的差异、编写基础部分、编码与重构。

    其实熟悉CSLA的人应该知道,它里面的通信机制也是采用了类似的方式实现的。所以这应该算是一种分布式的设计模式吧。 :)

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏北京马哥教育

如何判断目标站点是否为Django开发

老文一篇,几个月以前发在【代码审计】小密圈里的文章,当时是写一个系列(Django安全漫谈),抽出其中的一部分,分享一下。 在黑盒测试的情况下,如何判断一个站是...

33780
来自专栏分布式系统进阶

Kafka的消息是如何被消费的?Kafka源码分析-汇总

21230
来自专栏编程

Linux常用网络工具总结(一)

本文整理了在实践过程中使用的Linux网络工具,这些工具提供的功能非常强大,我们平时使用的只是冰山一角,比如、、、等。 本文不会深入研究这些命令的强大用法,因为...

35470
来自专栏闵开慧

hadoop集群调优分两个方面,map和reduce

hadoop集群调优分两个方面,map和reduce map调优:         map 任务执行会产生中间数据,但这些中间结果并没有直接IO到磁盘上,而...

37750
来自专栏公众号_薛勤的博客

Java性能调优工具(Linux、Windows篇)

top命令的输出可以分为两部分:前半部分是系统统计信息,后半部分是进程信息。在统计信息中,

51220
来自专栏美团技术团队

美团技术团队博客:Kafka文件存储机制那些事

Kafka是什么 Kafka最初由Linkedin公司开发,是一个分区、多副本、多订阅者、且基于zookeeper协调的分布式日志系统(也可以当做MQ系统),常...

1.2K110
来自专栏黑白安全

PHP安全编码规范之安全配置篇

因为配置不当引发的安全问题是屡见不鲜的,通过一系列的安全配置,可以很好的解决一些安全隐患,从而为系统增加安全系数。但是在开发过程中,因为需求的改变和编程的习惯可...

33820
来自专栏jeremy的技术点滴

现代Web开发教程系列_02

30970
来自专栏landv

robocopy的用法,数据库局域网备份

27150
来自专栏木头编程 - moTzxx

小程序 发送模板消息的功能实现

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/u011415782/article/de...

3.8K20

扫码关注云+社区

领取腾讯云代金券