美文网首页RabbitMQRabbitMQ
记录:rabbitmq对ipv6地址通讯的支持方式

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

作者: 戴宏鹏 | 来源:发表于2018-06-06 15:24 被阅读4次

    一般情况下,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

    相关文章

      网友评论

        本文标题:记录:rabbitmq对ipv6地址通讯的支持方式

        本文链接:https://www.haomeiwen.com/subject/kdibsftx.html