实现了 Publish-Subscribe 模式和 Parallel Pipeline 模式