如何在 RabbitMQ 的 Erlang 客户端中使用消息头？

Question

我正在尝试通过 Erlang 客户端发送带有元数据的消息，但我不明白应该如何在消息的基本属性记录中设置自定义应用程序标头。我已经尝试了所有这些选项，但没有成功：

#'P_basic'{headers = [{<<"key">>, <<"value">>}]}
#'P_basic'{headers = [{"key", <<"value">>}]}
#'P_basic'{headers = [{key, <<"value">>}]}

似乎标题使用了一些特殊的数据结构，一个 AMQP 表 - 但我找不到关于这个问题的任何文档或示例。

发送带有标头的消息的正确方法是什么？

更新：堆栈跟踪（实际上，它无关紧要 - 该错误的原因是静默关闭的通道）和源代码。

Answer 1

尝试发送带有标头的消息时是否遇到任何错误？

您是否尝试对键和值都使用字符串类型？

#'P_basic'{headers = [{"key", "value"}]}

更新：我调查了包rabbit_common的源代码，发现了一些关于标头类型的信息。在 rabbit_basic.erl 中有一个类型headers（）：

-type(headers() :: rabbit_framing:amqp_table() | 'undefined').

模块 rabbit_framing_amqp 中定义了类型：

-type(amqp_field_type() ::
      'longstr' | 'signedint' | 'decimal' | 'timestamp' |
      'table' | 'byte' | 'double' | 'float' | 'long' |
      'short' | 'bool' | 'binary' | 'void' | 'array').
-type(amqp_property_type() ::
      'shortstr' | 'longstr' | 'octet' | 'shortint' | 'longint' |
      'longlongint' | 'timestamp' | 'bit' | 'table').
-type(amqp_table() :: [{binary(), amqp_field_type(), amqp_value()}]).
-type(amqp_array() :: [{amqp_field_type(), amqp_value()}]).
-type(amqp_value() :: binary() |    % longstr
                      integer() |   % signedint
                      {non_neg_integer(), non_neg_integer()} | % decimal
                      amqp_table() |
                      amqp_array() |
                      byte() |      % byte
                      float() |     % double
                      integer() |   % long
                      integer() |   % short
                      boolean() |   % bool
                      binary() |    % binary
                      'undefined' | % void
                      non_neg_integer() % timestamp
     ).

所以标题是一个由三个项目（不是两个）组成的元组，它们是二进制的，值的类型，值。所以你必须像这样定义每个标头：

BooleanHeader = {<<"my-boolean">>, bool, true}.
StringHeader = {<<"my-string">>, longstr, <<"value">>}.
IntHeader = {<<"my-int">>, long, 1000}.