Golang—–发布订阅

package main import ( fmt math/rand sync time ) /** 发布者 事件驱动架构是计算机科学家中一种高度可扩展年的范例,它允许我们可以多方系统异步处理事件 事件总线是 发布/ 订阅模式的实现,其中发布者发布数据,并且感兴趣的订阅者可以监听这些数据并基于 这些数据作出处理,是发布者与订阅者松耦合,发布者将数据事件发布到事件总线,总线负责将他们发送给订阅者 传统的实现事件总线的方法会涉及到使用回调,订阅者通常实现接口,然后事件总线通过接口传播数据 使用Go的并发模型,大多数地方可以使用channel来代替回调,在本文中,我们将重点