简单的rabbitmq erlang消息直接队列获取器的奇怪问题

Question

一个带有用户guest/guest的基本RabbitMQ安装。

对于RabbitMQ（erlang client）的以下简单erlang测试代码，我得到了下面的错误。队列TEST_DIRECT_QUEUE已经存在，其中有7条消息，RabbitMQ服务器已经启动并正在运行。

如果我尝试用declare API命令创建一个新的，我也会得到类似的错误。总体而言，该错误将在< >命令期间出现

** exception exit: {shutdown,{gen_server,call,
                                     [<0.50.0>,
                                      {call,{'queue.declare',0,"TEST_DIRECT_QUEUE",false,false,
                                                             false,false,false,[]},
                                            none,<0.31.0>},
                                      infinity]}}
 in function  gen_server:call/3 (gen_server.erl, line 188)
 in call from test:test_message/0 (test.erl, line 12)

-module(test).
-export([test_message/0]).
-include_lib("amqp_client/include/amqp_client.hrl").
-record(state, {channel}).

test_message() ->

    {ok, Connection} = amqp_connection:start(#amqp_params_network{}),
    {ok, Channel} = amqp_connection:open_channel(Connection),
    Get = #'basic.get'{queue = "TEST_DIRECT_QUEUE"},
    {#'basic.get_ok'{}, Content} = amqp_channel:call(Channel, Get),   <=== error here
    #'basic.get_empty'{} = amqp_channel:call(Channel, Get),
    amqp_channel:call(Channel, #'channel.close'{}).

Answer 1

经过几个令人沮丧的小时后，我自己已经确定了这个问题。总的来说，让我承认我对关于RabbitMQ的模糊教程和文档感到不安....不管怎样，问题出在这里：

1）队列名应该是二进制形式的，因此前面要有“<<”，后面要有“>>”。例如:<<“My Queue Name”>>（也包括引号）

2）在另一个场景中，我试图用queue.declare创建队列，队列已经存在的事实不是问题，但是队列是持久的，而queue.declare没有指定这组参数，这导致程序抛出错误并中断执行。这是一个不幸的行为，通常开发人员希望队列匹配只是通过名称完成，然后继续进行。所以为了解决这个问题，我必须指定持久值。

-module(test).
-export([test/0]).
-include_lib("amqp_client/include/amqp_client.hrl").

test() ->
{ok, Connection} = amqp_connection:start(#amqp_params_network{}),
{ok, Channel} = amqp_connection:open_channel(Connection),
Declare = #'queue.declare'{queue = <<"TEST_DIRECT_QUEUE">>, durable = true},
#'queue.declare_ok'{} = amqp_channel:call(Channel, Declare),
Get = #'basic.get'{queue = <<"TEST_DIRECT_QUEUE">>, no_ack = true},
{#'basic.get_ok'{}, Content} = amqp_channel:call(Channel, Get),
#amqp_msg{payload = Payload} = Content.