RT-Thread-使用RyanW5500连接MQTT时，提示E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0RT-Thread问答社区

使用RyanW5500连接MQTT时，提示E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0

发布于 2023-06-26 10:10:29 浏览：1053 订阅该版

使用RyanW5500连接PahoMQTT，控制台提示如下错误（使用WIZnet软件包初始化可以正常连接MQ，但是上电需要等20秒，提示Socket未关闭，所以才想用RyanW5500）

```
msh [34506] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[34514] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
```
下面是控制台显示完整内容：

```
 \ | /
- RT -     Thread Operating System
 / | \     4.1.1 build Jun 26 2023 09:38:44
 2006 - 2022 Copyright by RT-Thread team
[2] I/sal.skt: Socket Abstraction Layer initialize success.
msh />[1013] E/netdev: netdev name[RyanW5500] length is so long that have been cut into [RyanW550].
[1024] I/RyanW5500: w5500 启动成功
[1049] W/RyanW5500: w5500Static
[3026] I/RyanW5500: w5500 nedev state: 6
[4026] W/TAG: ../packages/RyanW5500-latest/W5500Client/RyanW5500Socket.c:1187 开始获取dns
ifconfig
network interface device: RyanW550 (Default)
MTU: 1460
MAC: 00 08 dc 2f 0c 37 
FLAGS: UP LINK_UP INTERNET_DOWN DHCP_DISABLE
ip address: 192.168.1.10
gw address: 192.168.1.1
net mask  : 255.255.255.0
dns server #0: 0.0.0.0
dns server #1: 0.0.0.0
msh />ping 192.168.1.80
32 bytes from 192.168.1.80 icmp_seq=0 time=3 ms
32 bytes from 192.168.1.80 icmp_seq=1 time=3 ms
32 bytes from 192.168.1.80 icmp_seq=2 time=3 ms
32 bytes from 192.168.1.80 icmp_seq=3 time=3 ms
msh />mqtt_emqx
[34492] D/mqtt: ipv4 address port: 1883
[34496] D/mqtt: HOST = '192.168.1.80'
msh [34506] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[34514] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
/>[39523] D/mqtt: restart!
[39525] D/mqtt: ipv4 address port: 1883
[39529] D/mqtt: HOST = '192.168.1.80'
[39540] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[39548] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
[44557] D/mqtt: restart!
[44559] D/mqtt: ipv4 address port: 1883
[44563] D/mqtt: HOST = '192.168.1.80'
[44574] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[44582] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
[49591] D/mqtt: restart!
[49593] D/mqtt: ipv4 address port: 1883
[49597] D/mqtt: HOST = '192.168.1.80'
[49608] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[49616] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
[54625] D/mqtt: restart!
[54627] D/mqtt: ipv4 address port: 1883
[54631] D/mqtt: HOST = '192.168.1.80'
[54642] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[54650] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
[59659] D/mqtt: restart!
[59661] D/mqtt: ipv4 address port: 1883
[59665] D/mqtt: HOST = '192.168.1.80'
[59676] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[59684] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
```

下面是完整实现步骤：
1、board.h打开 `#define BSP_USING_SPI2`
2、stm32f1xx_hal_conf.h打开 `#define HAL_SPI_MODULE_ENABLED`

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230626/00cbae72c20d017b0497d461088a52fc.png)

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230626/372af95ee70f50f7a90b4f84e96b81e3.png)
3、board.c文件末尾添加初始化spi2代码并自动挂载：

```c
void HAL_SPI_MspInit(SPI_HandleTypeDef *spiHandle)
{
    GPIO_InitTypeDef GPIO_InitStruct;

RT_ASSERT(spiHandle != RT_NULL);

#ifdef BSP_USING_SPI1
    if (spiHandle->Instance == SPI1)
    {
        /* SPI1 clock enable */
        __HAL_RCC_SPI1_CLK_ENABLE();
        __HAL_RCC_GPIOA_CLK_ENABLE();

/**SPI1 GPIO Configuration
        PA5     ------> SPI1_SCK
        PA6     ------> SPI1_MISO
        PA7     ------> SPI1_MOSI
        */
        GPIO_InitStruct.Pin = GPIO_PIN_5 | GPIO_PIN_6 | GPIO_PIN_7;
        GPIO_InitStruct.Mode = GPIO_MODE_AF_PP;
        GPIO_InitStruct.Pull = GPIO_NOPULL;
        GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_VERY_HIGH;
        GPIO_InitStruct.Alternate = GPIO_AF5_SPI1;
        HAL_GPIO_Init(GPIOA, &GPIO_InitStruct);
    }
    else
#endif
#ifdef BSP_USING_SPI2
    if (spiHandle->Instance == SPI2)
    {
        /* SPI2 clock enable */
        __HAL_RCC_SPI2_CLK_ENABLE();
        __HAL_RCC_GPIOB_CLK_ENABLE();

/**SPI2 GPIO Configuration
        PB13     ------> SPI2_SCK
        PB14     ------> SPI2_MISO
        PB15     ------> SPI2_MOSI
        */
        GPIO_InitStruct.Pin = GPIO_PIN_13|GPIO_PIN_15;
        GPIO_InitStruct.Mode = GPIO_MODE_AF_PP;
        GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_HIGH;
        HAL_GPIO_Init(GPIOB, &GPIO_InitStruct);

GPIO_InitStruct.Pin = GPIO_PIN_14;
        GPIO_InitStruct.Mode = GPIO_MODE_INPUT;
        GPIO_InitStruct.Pull = GPIO_NOPULL;
        HAL_GPIO_Init(GPIOB, &GPIO_InitStruct);
    }
    else
#endif
#ifdef BSP_USING_SPI3
    if (spiHandle->Instance == SPI3)
    {
        /* SPI3 clock enable */
        __HAL_RCC_SPI3_CLK_ENABLE();
        __HAL_RCC_GPIOB_CLK_ENABLE();

/**SPI3 GPIO Configuration
        PB3 (JTDO-TRACESWO)     ------> SPI3_SCK
        PB4 (NJTRST)            ------> SPI3_MISO
        PB5                     ------> SPI3_MOSI
        */
        GPIO_InitStruct.Pin = GPIO_PIN_3 /* | GPIO_PIN_4 */ | GPIO_PIN_5;
        GPIO_InitStruct.Mode = GPIO_MODE_AF_PP;
        GPIO_InitStruct.Pull = GPIO_NOPULL;
        GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_VERY_HIGH;
        GPIO_InitStruct.Alternate = GPIO_AF6_SPI3;
        HAL_GPIO_Init(GPIOB, &GPIO_InitStruct);
    }
    else
#endif
    {
        RT_ASSERT(0);
    }
}
//自动初始化 rt_hw_spi_flash_init 函数，将spi20 挂载到spi2总线上

static int rt_hw_spi_flash_init(void)
{
    __HAL_RCC_GPIOB_CLK_ENABLE();
    rt_hw_spi_device_attach("spi2", "spi20", GPIOB, GPIO_PIN_12);

return RT_EOK;
}
/* 导 出 到 自 动 初 始 化 */
INIT_COMPONENT_EXPORT(rt_hw_spi_flash_init);
```
4、下载RyanW5500软件包，并修改IP为192.168.1.10，不启用DHCP，使用静态IP，如下：

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230626/7c025918671a8f81996ef9d4a155357e.png)

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230626/2a329326709b174b9b3b5c28b172597a.png.webp)
启动代码：

```c
int w5500Start()
{

if (NULL != RyanNetdev)
    {
        ulog_w(TAG, "w5500已经启动,不要重复选择");
        return -1;
    }

wiz_NetInfo netInfo = {0};

// mac地址有48bit
    // mac地址高24bit表示网卡制造商，由IEEE分配，称为OUI（组织唯一标识符）, 低24bit为网卡制造商分配的唯一编号
    // mac地址首位偶数单播，首位奇数为多播地址,多播作为设备地址是无效(第48bit 0 单播， 1 多播)
    // 广播mac地址:FF-FF-FF-FF-FF-FF
    // 第一个字节一般为00
    uint8_t myMac[6] = {0x00, 0x08, 0xdc, 0x2f, 0x0c, 0x37};

// stm32可以使用唯一96Bit芯片序列号
    // myMac[3] = *(uint8_t *)(UID_BASE + 0);
    // myMac[4] = *(uint8_t *)(UID_BASE + 4);
    // myMac[5] = *(uint8_t *)(UID_BASE + 8);

memcpy(netInfo.mac, myMac, sizeof(netInfo.mac));

// 用户也使用随机数来，需要支持rand函数才行
    // ?但操作系统启动时间几乎时恒定的，ms时钟，可能造成随机数种子相同，随机数也一样的可能性
    // srand(rt_tick_get()); // 设立随机数种子
    // myMac[3] = rand() % 254 + 0;// 生成0~254的随机数
    // srand(rt_tick_get()); // 设立随机数种子
    // myMac[4] = rand() % 254 + 0;// 生成0~254的随机数
    // srand(rt_tick_get()); // 设立随机数种子
    // myMac[5] = rand() % 254 + 0;// 生成0~254的随机数

uint8_t ipStrArr[4] = {0};
    inet_pton(AF_INET, "192.168.1.10", &ipStrArr);
    memcpy(netInfo.ip, ipStrArr, 4);

inet_pton(AF_INET, "255.255.255.0", &ipStrArr);
    memcpy(netInfo.sn, ipStrArr, 4);

inet_pton(AF_INET, "192.168.1.1", &ipStrArr);
    memcpy(netInfo.gw, ipStrArr, 4);

inet_pton(AF_INET, "0.0.0.0", &ipStrArr);
    memcpy(netInfo.dns, ipStrArr, 4);

netInfo.dhcp = NETINFO_STATIC; // 使能dhcp

if (0 != RyanW5500Init(&netInfo)) // 初始化w5500并启动
    {
        ulog_e(TAG, "初始化w5500错误");
        return -1;
    }

RyanNetdev = netdev_get_by_name("RyanW5500"); // netdev
    if (NULL == RyanNetdev)
    {
        ulog_e(TAG, "No device found");
        return -1;
    }

netdev_set_default(RyanNetdev);
    netdev_set_status_callback(RyanNetdev, neDevStatusChangeCallback);

ulog_i(TAG, "w5500 启动成功");

// while (!netdev_is_link_up(RyanNetdev))
    // {
    //     delay(200);
    // }

return 0;
}
```
staric代码：

```c
int w5500Static()
{
    // 测试netDev
    netdev_dhcp_enabled(RyanNetdev, RT_FALSE);

//  设置网卡 IP 地址
    uint32_t addr = inet_addr("192.168.1.10");
    netdev_set_ipaddr(RyanNetdev, (const ip_addr_t *)&addr);

addr = inet_addr("192.168.1.1");
    //  设置网卡网关地址
    netdev_set_gw(RyanNetdev, (const ip_addr_t *)&addr);

addr = inet_addr("255.255.255.0");
    //  设置网卡子网掩码地址
    netdev_set_netmask(RyanNetdev, (const ip_addr_t *)&addr);

addr = inet_addr("0.0.0.0");
    //  设置网卡子网掩码地址
    netdev_set_dns_server(RyanNetdev, 0, (const ip_addr_t *)&addr);
    ulog_w(TAG, "w5500Static");
    return 0;
}

```

然后在RyanW5500Store.h头文件内声明
int w5500Start();
int w5500Static();

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230626/de5f2801f733b8d68c06877b0c990b91.png)

然后主函数内添加头文件，并调用启动W5500函数和static函数

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230626/de41b1b57c4dba31694b549c7caa61c9.png)
启动后连接MQ使用MSH控制台调用mqtt_emqx示例提示：
```
msh />mqtt_emqx
[34492] D/mqtt: ipv4 address port: 1883
[34496] D/mqtt: HOST = '192.168.1.80'
msh [34506] E/mqtt: MQTTConnect wait resp fail, res:-1 errno:0
[34514] E/mqtt: MQTT connect error(-1): UNKNOWN_ERROR.
/>[39523] D/mqtt: restart!
```