记录：rabbitmq对ipv6地址通讯的支持方式

一般情况下，RabbitMQ的默认配置就足够了。如果希望特殊设置的话，有两个途径：
一个是环境变量的配置文件 rabbitmq-env.conf ；
一个是配置信息的配置文件 rabbitmq.config；
注意，这两个文件默认是没有的，如果需要必须自己创建。

根据需要支持的ip协议配置 rabbitmq.config,不同版本略有差异，参考：rabbitmq网络配置
示例：

[
  {rabbit, [
    {tcp_listeners, [{"0.0.0.0", 8989},
                     {"::",      5672}]}
  ]}
].

验证配置是否被读取应用：

查看/var/log/rabbitmq/下的rabbit@*.log文件，是否成功加载了rabbitmq.config

=INFO REPORT==== 5-Jun-2018::21:48:06 ===
node           : rabbit@ubuntu
home dir       : /root
config file(s) : /etc/rabbitmq/rabbitmq.config   #找不到则是not found 或 none
cookie hash    : TFJHdEY4Q8wuZDZLdM/OEg==
log            : /var/log/rabbitmq/rabbit@ubuntu.log
sasl log       : /var/log/rabbitmq/rabbit@ubuntu-sasl.log
database dir   : /var/lib/rabbitmq/mnesia/rabbit@ubuntu

使用rabbitmq-c下的amqp_listen和amqp_sendstring两个程序通信

./examples/amqp_listen 2001:0:53aa:64c:341f:f9d6:730c:e4a9 5672 amq.direct test
./examples/amqp_sendstring 2001:0:53aa:64c:341f:f9d6:730c:e4a9 5672 amq.direct test "hello world"

使用SimpleAmqpClient库验证channel是否成功创建

#include <SimpleAmqpClient/SimpleAmqpClient.h>
#include <iostream>
#include <string>
using namespace std;
using namespace AmqpClient;

int main()
{
    char* szBroker = getenv("AMQP_BROKER");
    Channel::ptr_t channel;
    if (szBroker != NULL)
    {
        channel = Channel::Create(szBroker);
    }
    else
    {
        //channel = Channel::Create("fe80::20c:29ff:fe13:6f4", 5672);
        channel = Channel::Create("2001:0:53aa:64c:341f:f9d6:730c:e4a9", 5672);
        //channel = Channel::Create("::1",5672);
        //channel = Channel::Create("127.0.0.1",8989);
    }


    BasicMessage::ptr_t the_message = BasicMessage::Create("Body content");
    try
    {
        channel->DeclareQueue("BasicReturnTestQueue");
        channel->BasicConsume("BasicReturnTestQueue", "consumer_tag1");

        channel->BasicPublish("", "BasicReturnTestQueue", the_message, true, false);
        channel->BasicPublish("", "ThisDoesntExist", the_message, true, false);
    }
    catch (MessageReturnedException& e)
    {
        cout << "Message got returned: " << e.what();
        cout << "\nMessage body: " << e.message()->Body();
    }


    return 0;
}

可以确认在C/C++中rabbitmq对ipv6的支持方式可以是以上步骤。

以下关于ipv6地址的小坑记录：

背景：
两台可以互相ping6通ipv6地址的虚拟机(CentOS、Ubuntu)，地址分别为

fe80::20c:29ff:fe33:3dd4

和

fe80::20c:29ff:fe13:6f4

调用SimleAmqpClient，

hannel = Channel::Create("ip or hostname", "port");

根据是否抛出异常以及后续输出判定rabbitmq对ipv6的支持

配置ipv6的支持后,代码执行环境Ubuntu：
    参数为::1(ipv6环回地址)结果：ok
    参数为fe80::20c:29ff:fe13:6f4 结果：faield
    参数为fe80::20c:29ff:fe33:3dd4 结果：faield   
后面往ubuntu添加了一个teredo隧道，得到一个ipv6的地址：2001:0:53aa:64c:341f:f9d6:730c:e4a9，参数为此地址，ok

对于本地测试，发现可以不用双栈、隧道等过度策略。
参考：https://blog.csdn.net/liuyu60305002/article/details/7821882

最后编辑于：2018.06.07 15:18:17