文件名称：传递：使用标准接口发布和订阅消息
文件大小：11KB
文件格式：ZIP
更新时间：2024-02-26 16:39:59
kafka publisher publishing consumer message-queue
交付 go get -u github.com/tomwright/deliver 通过标准接口发布+使用消息。 快速开始 此快速入门假定您已经创建了Subscriber或Producer 。 有关创建这些对象的信息，。 信息 以下是创建用户后可能发布的示例消息。 type UserCreated struct { Username string `json:"username"` } func (m *UserCreated) Type() string { return "user.created" } func (m *UserCreated) Payload() ([]byte
【文件预览】：
deliver-master
----.gitignore(34B)
----go.mod(154B)
----subscribe_test.go(2KB)
----kafka.go(5KB)
----LICENSE.md(1KB)
----.travis.yml(207B)
----publish_observed.go(1KB)
----publish_observed_test.go(2KB)
----publish.go(279B)
----examples()
--------kafka_publisher()
--------messages()
--------kafka_subscriber()
----README.md(1KB)
----subscribe.go(3KB)
----message.go(335B)