行为模式-责任链模式(The Chain of Responsibility Pattern)

责任链模式(The Chain of ResponsibilityPattern)

在责任链模式里，很多对象由每一个对象对其下家的引用而连接起来形成一条链。请求在这个链上传递，直到链上的某一个对象决定处理此请求。发出这个请求的客户端并不知道链上的哪一个对象最终处理这个请求，这使得系统可以在不影响客户端的情况下动态地重新组织和分配责任。

示例工程

Xcode Command Line Tool 工程：

struct Message {
    let from:String
    let to:String
    let subject:String
}

我们定义了一个结构体Message，接下来我们定义发送Message的Transmitters：

class LocalTransmitter {
    func sendMessage(message: Message) {
        print("Message to \(message.to) sent locally")
    }
}

class RemoteTransmitter {
    func sendMessage(message: Message) {
        print("Message to \(message.to) sent remotely")
    }
}

可以看出我们定义了两个代表发送信息的类，一个本地和一个远程。它们都有一个sendMessage方法，用来模拟发送信息。

let messages = [
    Message(from: "bob@example.com", to: "joe@example.com",subject: "Free for lunch?"),
    Message(from: "joe@example.com", to: "alice@acme.com",subject: "New Contracts"),
    Message(from: "pete@example.com", to: "all@example.com",subject: "Priority: All-Hands Meeting")
]

let localT = LocalTransmitter()
let remoteT = RemoteTransmitter()

for msg in messages {
if let index = msg.from.characters.indexOf("@"){
    if (msg.to.hasSuffix(msg.from[Range<String.Index>(start:
    index, end: msg.from.endIndex)])) {
    localT.sendMessage(msg)
} else {
    remoteT.sendMessage(msg)
    }
} else {
    print("Error: cannot send message to \(msg.from)")
    }
}

可以看到如果from和to如果有相同的后缀，那么就调用本地发送方法；如果后缀不同，则调用远程发送方法。运行程序，得到下面的输出：

Message to joe@example.com sent locally
Message to alice@acme.com sent remotely
Message to all@example.com sent locally

理解责任链模式解决的问题

示例中存在的问题是使用transmitter类来发送消息的组件必须知道应该用哪一个类发送(本地还是远程)。如果要增加新的发送方式，这将变得十分困难。假如我们要增加一个优先发送方式，那么将作如下十分蛋疼的修改：

class LocalTransmitter {
    func sendMessage(message: Message) {
        print("Message to \(message.to) sent locally")
    }
}

class RemoteTransmitter {
    func sendMessage(message: Message) {
        print("Message to \(message.to) sent remotely")
    }
}

class PriorityTransmitter {
    func sendMessage(message: Message) {
        print("Message to \(message.to) sent as priority")
    }
}

let messages = [
    Message(from: "bob@example.com", to: "joe@example.com",
    subject: "Free for lunch?"),
    Message(from: "joe@example.com", to: "alice@acme.com",
    subject: "New Contracts"),
    Message(from: "pete@example.com", to: "all@example.com",
    subject: "Priority: All-Hands Meeting"),
]

let localT = LocalTransmitter()
let remoteT = RemoteTransmitter()
let priorityT = PriorityTransmitter()

for msg in messages {
    if (msg.subject.hasPrefix("Priority")) {
        priorityT.sendMessage(msg)
    }else if let index = msg.from.characters.indexOf("@"){
        if (msg.to.hasSuffix(msg.from[Range<String.Index>(start:
            index, end: msg.from.endIndex)])) {
            localT.sendMessage(msg)
        } else {
            remoteT.sendMessage(msg)
        }
    } else {
        print("Error: cannot send message to \(msg.from)")
    }
}

运行程序：

Message to joe@example.com sent locally
Message to alice@acme.com sent remotely
Message to all@example.com sent as priority

理解责任链模式

责任链模式通过将所有的transmitters 放在一个链里面来解决这个问题。每一个环都在链里并且检查Message对象来决定是否承担责任。如果链里的某一个环能够处理Message对象，那么它处理。如果不能，请求传递到下一个环。这个过程一直持续到有环处理或者到了链中最后一个环。

实现责任链模式

这里我们用定义一个拥有可选类型属性来代表链中下一个环的基类。

class Transmitter {
    var nextLink:Transmitter?
    
    required init() {}
    
    func sendMessage(message:Message) {
        if (nextLink != nil) {
            nextLink!.sendMessage(message);
        } else {
            print("End of chain reached. Message not sent");
        }
    }
    
    private class func matchEmailSuffix(message:Message) -> Bool {
        if let index = message.from.characters.indexOf("@") {
            return message.to.hasSuffix(message.from[Range<String.Index>(start:
                index, end: message.from.endIndex)]);
        }
        return false
    }
}

class LocalTransmitter : Transmitter {
    override func sendMessage(message: Message) {
        if (Transmitter.matchEmailSuffix(message)) {
            print("Message to \(message.to) sent locally")
        } else {
            super.sendMessage(message)
        }
    }
}

class RemoteTransmitter : Transmitter {
    override func sendMessage(message: Message) {
        if (!Transmitter.matchEmailSuffix(message)) {
            print("Message to \(message.to) sent remotely")
        } else {
            super.sendMessage(message)
        }
    }
}

class PriorityTransmitter : Transmitter {
    override func sendMessage(message: Message) {
        if (message.subject.hasPrefix("Priority")) {
            print("Message to \(message.to) sent as priority")
        } else {
            super.sendMessage(message)
        }
    }
}

Transmitter 类定义了发送器的基本行为，包括了提交请求到链中下一个环。初始化方法前面的required关键字使得我们可以用类型来创建 transmitter实例。

创建和提供责任链

下一步我们将创建责任链：

......
class Transmitter {
    var nextLink:Transmitter?
    
    required init() {}
    
    func sendMessage(message:Message) {
        if (nextLink != nil) {
            nextLink!.sendMessage(message);
        } else {
            print("End of chain reached. Message not sent");
        }
    }
    
    private class func matchEmailSuffix(message:Message) -> Bool {
        if let index = message.from.characters.indexOf("@") {
            return message.to.hasSuffix(message.from[Range<String.Index>(start:
                index, end: message.from.endIndex)]);
        }
        return false
    }
    
    class func createChain() -> Transmitter? {
        let transmitterClasses:[Transmitter.Type] = [
            PriorityTransmitter.self,
            LocalTransmitter.self,
            RemoteTransmitter.self
        ]
        
        var link:Transmitter?
        
        for tClass in transmitterClasses.reverse() {
            let existingLink = link
            link = tClass.init()
            link?.nextLink = existingLink
        }
        return link
    }
}
......

应用责任链模式

let messages = [
    Message(from: "bob@example.com", to: "joe@example.com",
    subject: "Free for lunch?"),
    Message(from: "joe@example.com", to: "alice@acme.com",
    subject: "New Contracts"),
    Message(from: "pete@example.com", to: "all@example.com",
    subject: "Priority: All-Hands Meeting"),
]

if let chain = Transmitter.createChain() {
        for msg in messages {
            chain.sendMessage(msg)
        }
}

运行程序：

Message to joe@example.com sent locally
Message to alice@acme.com sent remotely
Message to all@example.com sent as priority

责任链模式的变形

这里有几种比较常用的变形，我们一一介绍。

应用工厂方法模式

我们可以将责任链模式和工厂方法模式或者抽象工厂方法模式结合起来，可以满足不同的请求。

.....
    class func createChain(localOnly:Bool) -> Transmitter? {
        let transmitterClasses:[Transmitter.Type] = localOnly ? [PriorityTransmitter.self, LocalTransmitter.self]
        : [PriorityTransmitter.self, LocalTransmitter.self, RemoteTransmitter.self]
        
        var link:Transmitter?
        
        for tClass in transmitterClasses.reverse() {
            let existingLink = link
            link = tClass.init()
            link?.nextLink = existingLink
        }
        return link
    }
......

可以看出我们增加了一个只有本地发送的链。

let messages = [
    Message(from: "bob@example.com", to: "joe@example.com",
    subject: "Free for lunch?"),
    Message(from: "joe@example.com", to: "alice@acme.com",
    subject: "New Contracts"),
    Message(from: "pete@example.com", to: "all@example.com",
    subject: "Priority: All-Hands Meeting"),
]

if let chain = Transmitter.createChain(true) {
        for msg in messages {
            chain.sendMessage(msg)
        }
}

运行程序,可以看出远程发送的情况有所不同：

Message to joe@example.com sent locally
End of chain reached. Message not sent
Message to all@example.com sent as priority

表面请求是否被接受

现在，请求组件并不清楚请求是否被接受，我们将对此做修改。

class Transmitter {
    var nextLink:Transmitter?
    
    required init() {}
    
    func sendMessage(message:Message) -> Bool{
        if (nextLink != nil) {
           return nextLink!.sendMessage(message)
        
        } else {
            print("End of chain reached. Message not sent")
            return false
        }
    }
    
    private class func matchEmailSuffix(message:Message) -> Bool {
        if let index = message.from.characters.indexOf("@") {
            return message.to.hasSuffix(message.from[Range<String.Index>(start:
                index, end: message.from.endIndex)])
        }
        return false
    }
    
    class func createChain(localOnly:Bool) -> Transmitter? {
        let transmitterClasses:[Transmitter.Type] = localOnly ? [PriorityTransmitter.self, LocalTransmitter.self]
        : [PriorityTransmitter.self, LocalTransmitter.self, RemoteTransmitter.self]
        
        var link:Transmitter?
        
        for tClass in transmitterClasses.reverse() {
            let existingLink = link
            link = tClass.init()
            link?.nextLink = existingLink
        }
        return link
    }
}

class LocalTransmitter : Transmitter {
    override func sendMessage(message: Message) ->Bool{
        if (Transmitter.matchEmailSuffix(message)) {
            print("Message to \(message.to) sent locally")
            return true
        } else {
            return super.sendMessage(message)
        }
    }
}

class RemoteTransmitter : Transmitter {
    override func sendMessage(message: Message) ->Bool{
        if (!Transmitter.matchEmailSuffix(message)) {
            print("Message to \(message.to) sent remotely")
            return true
        } else {
            return super.sendMessage(message)
        }
    }
}

class PriorityTransmitter : Transmitter {
    override func sendMessage(message: Message) ->Bool{
        if (message.subject.hasPrefix("Priority")) {
            print("Message to \(message.to) sent as priority")
            return true
        } else {
            return super.sendMessage(message)
        }
    }
}

接下来修改main.swift：

let messages = [
    Message(from: "bob@example.com", to: "joe@example.com",
    subject: "Free for lunch?"),
    Message(from: "joe@example.com", to: "alice@acme.com",
    subject: "New Contracts"),
    Message(from: "pete@example.com", to: "all@example.com",
    subject: "Priority: All-Hands Meeting"),
]

if let chain = Transmitter.createChain(true) {
    for msg in messages {
        let handled = chain.sendMessage(msg)
        print("Message sent: \(handled)")
    }
}

运行程序：

Message to joe@example.com sent locally
Message sent: true
End of chain reached. Message not sent
Message sent: false
Message to all@example.com sent as priority
Message sent: true

通知链中所有的环

在标准的责任链模式中，责任环前面所有的环都被请求过，责任环后面的环则不会被请求。这里我们将请求所有的环，无论责任环是否已经被执行。

class Transmitter {
    var nextLink:Transmitter?
    
    required init() {}
    
    func sendMessage(message:Message,handled: Bool = false) -> Bool{
        if (nextLink != nil) {
           return nextLink!.sendMessage(message,handled: handled)
        
        } else if(!handled) {
            print("End of chain reached. Message not sent")
        }
        return handled
    }
    
    private class func matchEmailSuffix(message:Message) -> Bool {
        if let index = message.from.characters.indexOf("@") {
            return message.to.hasSuffix(message.from[Range<String.Index>(start:
                index, end: message.from.endIndex)])
        }
        return false
    }
    
    class func createChain(localOnly:Bool) -> Transmitter? {
        let transmitterClasses:[Transmitter.Type] = localOnly ? [PriorityTransmitter.self, LocalTransmitter.self]
        : [PriorityTransmitter.self, LocalTransmitter.self, RemoteTransmitter.self]
        
        var link:Transmitter?
        
        for tClass in transmitterClasses.reverse() {
            let existingLink = link
            link = tClass.init()
            link?.nextLink = existingLink
        }
        return link
    }
}

class LocalTransmitter : Transmitter {
    override func sendMessage(message: Message, var handled:Bool) ->Bool{
        if (!handled && Transmitter.matchEmailSuffix(message)) {
            print("Message to \(message.to) sent locally")
            handled = true
        }
        return super.sendMessage(message, handled: handled)
    }
}

class RemoteTransmitter : Transmitter {
    override func sendMessage(message: Message, var handled:Bool) ->Bool{
        if (!handled && !Transmitter.matchEmailSuffix(message)) {
            print("Message to \(message.to) sent remotely")
            handled = true
        }
        return super.sendMessage(message, handled: handled)
    }
}

class PriorityTransmitter : Transmitter {
    var totalMessages = 0
    var handledMessages = 0
    
    override func sendMessage(message: Message, var handled:Bool) -> Bool {
        totalMessages++
        if (!handled && message.subject.hasPrefix("Priority")) {
            handledMessages++
            print("Message to \(message.to) sent as priority")
            print("Stats: Handled \(handledMessages) of \(totalMessages)")
            handled = true
        }
        return super.sendMessage(message, handled: handled)
    }
}

运行程序：

Message to joe@example.com sent locallyMessage 
sent: trueEnd of chain reached. 
Message not sentMessage 
sent: false
Message to all@example.com sent as priority
Stats: Handled 1 of 3
Message sent: true

最后编辑于：2017.12.03 05:18:20

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 199,902评论 5赞 468
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 84,037评论 2赞 377
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 146,978评论 0赞 332
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 53,867评论 1赞 272
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 62,763评论 5赞 360
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,104评论 1赞 277
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,565评论 3赞 390
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,236评论 0赞 254
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,379评论 1赞 294
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,313评论 2赞 317
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,363评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,034评论 3赞 315
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,637评论 3赞 303
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,719评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 30,952评论 1赞 255
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,371评论 2赞 346
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 41,948评论 2赞 341

行为模式-责任链模式(The Chain of Responsibility Pattern)

责任链模式(The Chain of ResponsibilityPattern)

示例工程

理解责任链模式解决的问题

理解责任链模式

实现责任链模式

创建和提供责任链

应用责任链模式

责任链模式的变形

应用工厂方法模式

表面请求是否被接受

通知链中所有的环

推荐阅读更多精彩内容