Golang如何实现中介者模式解耦对象交互_Golang 中介者模式应用实践

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

Golang如何实现中介者模式解耦对象交互_Golang 中介者模式应用实践

2025-11-24

浏览次数：次

返回列表

中介者模式通过引入中介者对象集中管理组件交互，实现解耦。在Golang聊天室示例中，用户通过ChatServer发送消息，避免直接引用其他用户，降低耦合，提升可维护性。1. 中介者（ChatMediator）定义通信接口；2. 具体中介者（ChatServer）管理用户并转发消息；3. 同事类（User）通过中介者收发消息，不直接通信。该模式适用于聊天系统、UI联动等场景，但需防中介者过度膨胀。

golang如何实现中介者模式解耦对象交互_golang 中介者模式应用实践

在复杂系统中，多个对象之间直接通信会导致高度耦合，难以维护和扩展。Golang 中通过中介者模式（Mediator Pattern）可以有效解耦对象间的交互逻辑。该模式的核心思想是引入一个“中介者”对象，集中处理对象之间的通信，让各个组件不再相互引用，而是通过中介者进行消息传递。

中介者模式的基本结构

中介者模式包含以下几个关键角色：

Mediator（中介者）：定义统一接口，用于各组件之间的通信协调。
ConcreteMediator（具体中介者）：实现中介者接口，管理多个组件实例，并协调它们的交互。
Colleague（同事类 / 组件）：每个组件持有对中介者的引用，不直接与其他组件通信，而是通过中介者发送和接收消息。

这种结构特别适用于如聊天室、UI组件联动、游戏对象交互等场景。

用 Golang 实现一个聊天室示例

假设我们正在构建一个简单的多人聊天室，用户（User）不能直接向其他用户发送消息，必须通过聊天服务器（ChatServer）中转。这就是典型的中介者应用场景。

package main

// Mediator interface
type ChatMediator interface {
    SendMessage(message string, user User)
}

// ConcreteMediator
type ChatServer struct {
    users []User
}

func (c *ChatServer) AddUser(user User) {
    c.users = append(c.users, user)
}

func (c *ChatServer) SendMessage(message string, sender User) {
    for _, user := range c.users {
        // 不向发送者自己转发消息
        if user.GetName() != sender.GetName() {
            user.Receive(message)
        }
    }
}

// Colleague interface
type User interface {
    GetName() string
    Send(message string)
    Receive(message string)
}

// Concrete colleague
type ChatUser struct {
    name     string
    mediator ChatMediator
}

func NewChatUser(name string, mediator ChatMediator) *ChatUser {
    return &ChatUser{
        name:     name,
        mediator: mediator,
    }
}

func (u *ChatUser) GetName() string {
    return u.name
}

func (u *ChatUser) Send(message string) {
    println(u.name + " 发送消息: " + message)
    u.mediator.SendMessage(message, u)
}

func (u *ChatUser) Receive(message string) {
    println(u.name + " 收到消息: " + message)
}

// 示例使用
func main() {
    server := &ChatServer{}

    alice := NewChatUser("Alice", server)
    bob := NewChatUser("Bob", server)
    charlie := NewChatUser("Charlie", server)

    server.AddUser(alice)
    server.AddUser(bob)
    server.AddUser(charlie)

    alice.Send("大家好，我是 Alice！")
    bob.Send("Hi，我是 Bob。")
}