pubsub:一个发布和订阅库,带有用于Golang的可插入提供程序和中间件
PubSub提供了一个简单的帮助程序库,用于在Go(通常在Web或微服务)中执行发布和订阅样式的异步任务。 PubSub允许您编写完全键入的发布者和订阅者,并根据需要交换提供者(Google Cloud PubSub,AWS SQS等)。
PubSub还抽象化了队列及其订阅者的创建,因此您不必编写任何特定于云的代码,但仍可以设置并发性,期限,错误处理等。
还包括,包括日志记录,跟踪和错误处理!
目录
例
这是使用和打印问候的基本订阅者功能的基本示例。
要发布消息,可以调用Publish ,也可以发布或JSON可序列化的对象(即大多数Go对象)。
默认情况下,发布是Protobuf。
发行人
pubsub . Publish ( ctx , "topic-name" , & User { Id : "usr_0001" })
发布JSON对象
pubsub . PublishJSON ( ctx , "topic-name" , & User { Id : "usr_0001" })
例如,如果应用程序订阅不适用于Protobuf或在您的公司外部,则这很有用。 但是,建议Pr