[参考译文] CC3220SF-LAUNCHXL：调用 MQTTClient_connect()会阻止所有任务(已编辑)；警告(如&quot)；#48-D 不兼容宏&quot 的重新定义；O_creat&quot；(在&quot 的第59行声明；C：/ti/ccsv8/tools/compiler/ti-cgt-arm_18.12.0.LTS/include/file.h &quot；

SlNetIf 初始化(0)；
SlNetIf_add (SLNETIF_ID_1、"CC32xx"、
(const SlNetIf _Config_t *) SlNetIfConfigWifi、
SLNET_IF_WIFI_PRIO)；
SlNetSock_init (0)；
SlNetUtil_init (0)；

pthread_attr_init (&pAttrs_spawn)；
priParam.sched_priority = sawn_task_priority；
retc = pthread_attr_setschedparam (&pAttrs_spawn、&priParam)；
retc |= pthread_attr_setstacksize (&pAttrs_sprawn、TASKSTACKSIZE)；
retc |= pthread_attr_setdetachstate (&pAttrs_sprawn、pthread_create_detachstate)；
retc = pthread_create (&spawn_thread、&pAttrs_spawn、sl_Task、NULL)
gAppConnectionState = MQTT_IF_Connect ()；
if (gApConnectionState<0)｛
System_printf ("连接到 AP\r\n 时出现问题")；
｝
if (！MQTT_START())｛
System_printf ("消息队列已固定\r\n)；
｝
retc=MQTT_CLIENT_CONNECT()；
if (！retc)
｛
System_printf ("MQTT 连接失败\r\n)；
｝

while (1)｛
UART_READ (uart0、&INPUT、1)；
UART_READ (uart1、&input1、1)；
system_flush()；
} 

int32_t MQTT_IF_Connect ()
｛
int32_t lRetVal；
char SSID_Remote_Name[32]；
INT8_t Str_Length；

memset (SSID_Remote_Name、'\0'、sizeof (SSID_Remote_Name))；
STR_Length = strlen (SSID_NAME)；

IF (StR_Length)
｛
/*将默认 SSID 复制到局部变量 *
strncpy (SSID_Remote_Name、SSID_NAME、Str_Length)；
｝

/*显示应用程序横幅 //
//显示横幅(application_name)；

/*重置机器的状态 *
network_if_ResetMCUStateMachine()；

/*启动驱动程序 *
lRetVal = Network_IF_InitDriver (Role_STA)；
if (lRetVal < 0)
｛
System_printf ("无法启动 SimpleLink 器件\n\r"、lRetVal)；
return(-1)；
}

/*打开 Board_GPIO_LED2以指示 Simplelink 已正确启动。 //
GPIO_write (Board_GPIO_LED2、Board_GPIO_LED_ON)；

/*启动计时器使 Board_GPIO_LED0闪烁，直至接入点连接 //
// LedTimerConfigNStart()；

/*初始化 AP 安全参数 *
SecurityParams.Key =(signed char *) security_key；
SecurityParams.KeyLen = strlen (security_key)；
SecurityParams.Type = SECURITY_TYPE；

/*连接到接入点 *
lRetVal = Network_IF_ConnectAP (SSID_Remote_Name、SecurityParams)；
if (lRetVal < 0)
｛
System_printf ("连接到 AP 失败\n\r\n)；
return(-1)；
}

睡眠(2)；

返回(0)；
}

bool MQTT_START()｛
mq_attr 属性；
无符号模式= 0；

/*sync 对象，用于线程间通信 *
ATTR.MQ_maxmsg = 10；
attr.mq_msgsize = sizeof (struct msgQueue)；
G_PBQueue = MQ_open ("g_PBQueue"、O_creat、mode、&attr)；

if (g_PBQueue ==空)
｛
System_printf ("MQTT 消息队列创建失败\n\r\n)；
//gInitState &=~MQTT_INIT_STATE；
返回 false；
｝


返回 true；
｝

int32_t MQTT_CLIENT_CONNECT ()｛
int32_t lRetVal =-1；
int32_t iCount = 0；
MqttClientExample_params.clientId = ClientID；
MqttClientExample_params.connParams =&MQTT_ClientCtx；
MqttClientExample_params.mqttMode31 = MQTT_3_1；
MqttClientExample_params.blockingSend = true；
gMqttClient = MQTTClient_create (MqttClientCallback、
&MqttClientExample_params)；
if (gMqttClient =NULL)
｛

System_printf ("MQTT 连接失败\r\n)；
return(-1)；
}
MQTTClient_set (gMqttClient、MQTTClient_Will 参数、will _param、&will _param、
sizeof (will _param))；
system_flush()；
lRetVal = MQTTClient_connect (gMqttClient)；
UART_PRINT ("lRetVal =%d"、lRetVal)；
if (0 > lRetVal)
｛
/*lib 初始化失败 *
UART_PRINT ("连接到代理失败、错误代码：%d\n\r\n、
lRetVal)；

gUiConnFlag = 0；
｝
其他
｛
gUiConnFlag = 1；
｝
/*在服务器未存储会话时订阅主题 *
if ((gUiConnFlag = 1)&&(0 = lRetVal))
｛
uint8_t 子索引；
MQTTClient_SubscribeParams 下标信息[
subscription_topic_count]；

for (子索引= 0；子索引< subIndex_topic_count；子索引++)
｛
subscriptionInfo[subIndex].topic = topic[subIndex]；
subscriptionInfo[subIndex].QoS = QOS[subIndex]；
｝

if (MQTTClient_subscribe (gMqttClient、下标信息、
subscription_topic_count)< 0)
｛
UART_PRINT ("\n\r 订阅错误\n\r")；
MQTTClient_DISCONNECT (gMqttClient)；
gUiConnFlag = 0；
｝
其他
｛
for (iCount = 0；iCount < subscription_topic_count；iCount++)
｛
UART_PRINT ("已在%s\n\r 上订阅客户端"、Topic[iCount])；
｝
}

返回0;
｝