自定义消息 Headers：amqp 与 paho

Question

mqttv5 paho 和 amqp 中用于自定义消息 header 的数据结构之间的差异是由于协议造成的，还是仅仅是实施决定？

背景：我注意到 mqttv5 的最新 paho 库将 map[string]string 中 Publish.PublishProperties.User 的类型替换为 []UserProperty。我假设更改的原因是需要多个值共享一个键的用例很普遍，但是使用 amqp 样式客户消息 header 不是更有效吗？ amqp 使用 amqp.Table 其中 Table 是 map[string]interface{}，这似乎起到相同的作用（只需使用 []string 作为接口实现）。

在 amqp 中检索共享自定义消息 header 的值片段需要一行代码：

slice := message.Headers["key"]

在 paho 中检索共享自定义消息 header 的值片段需要一个字符串比较循环：

// GetAll returns a slice of all entries in the UserProperties
// that match key, or a nil slice if none were found.
func (u UserProperties) GetAll(key string) []string {
    var ret []string
    for _, v := range u {
        if v.Key == key {
            ret = append(ret, v.Value)
        }
    }

    return ret
}

选择这种实施方式是否有原因？

Answer 1

根据贡献者的说法，以该格式返回 UserProperty 的性能要低得多。

在此处查看 github 讨论：https://github.com/eclipse/paho.golang/issues/47

从那次讨论中，当前的实现是第二个性能运行：

With 10 k/v in the user properties and 5 being the same key

pkg: github.com/eclipse/paho.golang/paho
BenchmarkUserProperties-8         703861              1476 ns/op             784 B/op         15 allocs/op
BenchmarkUserProperty-8          6933013               158 ns/op             320 B/op          1 allocs/op

自定义消息 Headers：amqp 与 paho

Custom Message Headers: amqp vs. paho

amqp

go

mqtt

paho