如何在Golang中实现中介者模式协调对象交互_Golang中介者模式对象交互协调方法汇总-Golang-PHP中文网

如何在Golang中实现中介者模式协调对象交互_Golang中介者模式对象交互协调方法汇总

P粉602998670

发布： 2025-11-16 18:03:22

原创

448人浏览过

中介者模式通过引入中介者对象封装多个对象间的交互，降低直接耦合。在Go中利用接口和结构体实现，如聊天室示例中用户通过中介者发送消息，实现广播与私聊，提升系统可维护性与扩展性。

如何在golang中实现中介者模式协调对象交互_golang中介者模式对象交互协调方法汇总

在Go语言中，中介者模式是一种行为设计模式，用来降低多个对象之间复杂的直接耦合。通过引入一个中介者对象来封装一系列对象之间的交互，使得对象不必显式地相互引用，从而提高系统的可维护性和可扩展性。

中介者模式的核心思想

当多个对象之间存在频繁的通信时，如果每个对象都直接调用其他对象的方法，会导致系统结构混乱、难以修改和测试。中介者模式通过将这些交互逻辑集中到一个“中介者”中，让各个对象只与中介者通信，彼此解耦。

在Go中没有类和继承，但可以通过接口和结构体组合实现类似效果。关键在于定义清晰的参与者接口和中介者接口。

基本结构与接口定义

以下是实现中介者模式的基本组件：

Mediator（中介者接口）：定义协调交互的方法，通常包含通知或事件分发机制。
Colleague（同事对象）：各个参与交互的对象，持有对中介者的引用，通过中介者发送和接收消息。
ConcreteMediator（具体中介者）：实现中介者接口，管理所有同事对象，并定义它们之间的交互规则。

示例代码：

立即学习“go语言免费学习笔记（深入）”；

type Mediator interface {
    Notify(sender Colleague, event string)
}

type Colleague interface {
    Send(event string)
    Receive(event string)
}

登录后复制

实现一个聊天室场景

以多人聊天室为例，用户（User）作为同事对象，ChatRoom 作为中介者统一处理消息转发。

北极象沉浸式AI翻译

免费的北极象沉浸式AI翻译 - 带您走进沉浸式AI的双语对照体验

查看详情

type ChatRoom struct {
    users map[string]*User
}

func NewChatRoom() *ChatRoom {
    return &ChatRoom{users: make(map[string]*User)}
}

func (c *ChatRoom) Register(user *User) {
    user.SetMediator(c)
    c.users[user.name] = user
}

func (c *ChatRoom) Notify(sender Colleague, event string) {
    // 假设 event 格式为 "from:to:message"
    parts := strings.SplitN(event, ":", 3)
    if len(parts) != 3 {
        return
    }
    from, to, msg := parts[0], parts[1], parts[2]

    if to == "all" {
        for _, u := range c.users {
            if u.name != from {
                u.Receive(from + ": " + msg)
            }
        }
    } else {
        if user, ok := c.users[to]; ok {
            user.Receive(from + " whispers: " + msg)
        }
    }
}

登录后复制

用户结构体：

type User struct {
    name      string
    mediator  Mediator
}

func NewUser(name string) *User {
    return &User{name: name}
}

func (u *User) SetMediator(m Mediator) {
    u.mediator = m
}

func (u *User) Send(event string) {
    u.mediator.Notify(u, event)
}

func (u *User) Receive(msg string) {
    fmt.Printf("[%s received] %s\n", u.name, msg)
}

登录后复制

使用示例：

room := NewChatRoom()
alice := NewUser("Alice")
bob := NewUser("Bob")
charlie := NewUser("Charlie")

room.Register(alice)
room.Register(bob)
room.Register(charlie)

alice.Send("Alice:all:Hello everyone!")     // 广播
bob.Send("Bob:Alice:Hi, can we talk?")       // 私聊

登录后复制