自定义消息头：amqp 与 paho

如何解决自定义消息头：amqp 与 paho

mqttv5 paho 和 amqp 中用于自定义消息头的数据结构之间的区别是由于协议，还是仅仅是实现决定？

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

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

slice := message.Headers["key"]

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

// 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
}

选择这种实现方式有什么原因吗？

解决方法

根据贡献者的说法，以该格式返回 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