Contiki os MQTT

Question

嗨，我尝试将 cooja simluator 中的 mqtt mote 连接到桌面上的 mosquitto 服务器。但它一直无法连接，我能够 ping rpl 路由器，但不能 ping 我的 mqtt 客户端节点。我正在使用 https://github.com/esar/contiki-mqtt 中的示例.

有人可以告诉我我所犯的错误吗？谢谢

这是我使用的代码

#include "stdio.h"
#include "contiki.h"
#include "contiki-net.h"
#include "mqtt-service.h"
PROCESS(mqtt_publisher_process, "MQTT Publisher");
PROCESS_NAME(mqtt_process);
AUTOSTART_PROCESSES(&mqtt_process, &mqtt_publisher_process);

PROCESS_THREAD(mqtt_publisher_process, ev, data)
{

    static uip_ip6addr_t server_address;

    // printf("address %d\n",server_address);
    // Allocate buffer space for the MQTT client
    static uint8_t in_buffer[64];
    static uint8_t out_buffer[64];

    // Setup an mqtt_connect_info_t structure to describe
    // how the connection should behave
    static mqtt_connect_info_t connect_info =
    {
        .client_id = "contiki",
        .username = "user",
        .password = "user",
        .will_topic = "dev/text",
        .will_message = NULL,
        .keepalive = 60,
        .will_qos = 0,
        .will_retain = 0,
        .clean_session = 1
    };

    // The list of topics that we want to subscribe to
    static const char* topics[] =
    {
      "0", "1", "2", "3", "4", "5", NULL
    };
     PROCESS_BEGIN();
        // Set the server address
    uip_ip6addr(&server_address,0,0,0,0,0,0,0,1);

    // Initialise the MQTT client
    mqtt_init(in_buffer, sizeof(in_buffer),
              out_buffer, sizeof(out_buffer));

    // Ask the client to connect to the server
    // and wait for it to complete.
    mqtt_connect(&server_address, UIP_HTONS(33065),1, &connect_info);
    // mqtt_connect(&server_address, 1883,1, &connect_info);
    PROCESS_WAIT_EVENT_UNTIL(ev == mqtt_event);
    if(mqtt_connected())
    {
        static int i;

        for(i = 0; topics[i] != NULL; ++i)
        {
            // Ask the client to subscribe to the topic
            // and wait for it to complete
            mqtt_subscribe(topics[i]);
            PROCESS_WAIT_EVENT_UNTIL(ev == mqtt_event);
        }

        // Loop waiting for events from the MQTT client
        while(1)
        {
            PROCESS_WAIT_EVENT_UNTIL(ev == mqtt_event);

            // If we've received a publish event then print
            // out the topic and message
            if(mqtt_event_is_publish(data))
            {
                const char* topic = mqtt_event_get_topic(data);
                const char* message = mqtt_event_get_data(data);
                int level = 0;

                printf("%s = %s\n", topic, message);

                // Relay the received message to a new topic
                mqtt_publish("new_topic", message, 0, 1);
            }else{

            }
        }
    } else
        printf("mqtt service connect failed\n");
     PROCESS_END();
}

Answer 1

我怀疑您所说的在桌面上运行的 MQTT 服务器是否具有 IPv6 地址::1，对吗？

而不是:

uip_ip6addr(&server_address,0,0,0,0,0,0,0,1);

您可能想输入运行 Mosquitto 的台式计算机的地址？