可扩展通信机制

我需要在代码中实现一个可扩展的通信机制，如何实现观察者模式？