1.LWIP介紹
lwip是瑞典計算機科學院網絡嵌入式系統小組(SICS)的Adam Dunkels(亞當·鄧克爾) 開發的一個小型開源的TCP/IP協議棧。實現的重點是在保持 TCP 協議主要功能的基礎上減少對RAM的占用。
LwIP是Light Weight(輕型)IP 協議,有無操作系統的支持都可以運行。LwIP 實現的重點是在保持TCP協議 主要功能的基礎上減少對RAM的占用,它只需十幾KB的RAM和 40K左右的ROM就可以運行,這使LwIP協議棧適合在低端的嵌入式系統中使用。
2.連接騰訊物聯網平臺
創建TCP客戶端,接收服務器下發數據
#include "lwip_config.h"
#include "lwip/tcp.h"
/*接收成功回調函數*/
u8 dm9000_rx_buff[1024];
u16 dm9000_rx_len=0;
err_t tcp_recv_func(void *arg, struct tcp_pcb *tpcb,struct pbuf *p, err_t err)
{
memset(dm9000_rx_buff,0,sizeof(dm9000_rx_buff));
dm9000_rx_len=0;
u16 len=0;
if(p==NULL)
{
printf("服務器斷開連接\r\n");
client_connect_stat=0;
}
else
{
if(p->tot_len==p->len)//p->tot_len整包數據長度,p->len當前節點數據長度
{
memcpy(dm9000_rx_buff,p->payload,p->len);
len=p->len;
}
else
{
struct pbuf *temp=p;
len=0;
while(temp!=NULL)
{
memcpy(dm9000_rx_buff+len,temp->payload,temp->len);
len+=temp->len;
temp=temp->next;
}
}
pbuf_free(p);//該釋放函數只需填鏈表頭進來即可
dm9000_rx_len=len;
}
return ERR_OK;
}
struct tcp_pcb *new_tcp;//tcp網絡信息(套接字)
u8 client_addr[4];
u8 client_connect_stat=0;
/*連接服務器成功回調函數*/
err_t tcp_connect_func(void *arg, struct tcp_pcb *tpcb, err_t err)
{
client_addr[0]=tpcb->local_ip.addr>>0;
client_addr[1]=tpcb->local_ip.addr>>8;
client_addr[2]=tpcb->local_ip.addr>>16;
client_addr[3]=tpcb->local_ip.addr>>24;
new_tcp=tpcb;
client_connect_stat=1;
printf("%d.%d.%d.%d連接服務器成功\r\n",client_addr[0],client_addr[1],client_addr[2],client_addr[3]);
tcp_recv(tpcb,tcp_recv_func);
return 0;
}
/**********TCP客戶端創建*****************
**
**形參: addr IP地址
** u16_t port -- 服務器端口號
**返回值:0 --服務器創建成功,其他值--失敗
**
*****************************************/
u8 LWIP_CreateTcpClient(ip_addr_t *addr,u16 port)
{
/*1.創建新的網卡設備*/
new_tcp=tcp_new();
if(new_tcp==NULL)return 1;
/*連接服務器*/
tcp_connect(new_tcp,addr,port,tcp_connect_func);
return 0;
}
3.主函數
? ?在main.c中主要實現DM9000網卡初始化,LWIP網絡協議棧初始化、動態分配IP、DNS域名解析、連接騰訊云登錄物聯網平臺實現數據交互。
#include "lwip_config.h"
#include "aliyun_mqtt.h"
#define SERVER_IP "LA57WTHWL6.iotcloud.tencentdevices.com"http://服務器IP
#define SERVER_PORT 1883 //端口號
//客戶端ID:{產品ID}{設備名}
#define ClientID "LA57WTHWL6Smart_home"
//用戶名和密碼可使用密碼生成工具完成
#define Username "LA57WTHWL6Smart_home;12010126;E4C8Z;1646652494"
#define Password "1ad14baba7986f44444c950d5ee2f1c8a3da601c8471aa284687a64e4809cb3e;hmacsha256"http://密文
//訂閱題:$thing/down/property/{ProductID}/{DeviceName} ---{ProductID}產品ID,{DeviceName}設備名
#define SET_TOPIC "$thing/down/property/LA57WTHWL6/Smart_home"http://訂閱
//發布主題:$thing/up/property/{ProductID}/{DeviceName}
#define POST_TOPIC "$thing/up/property/LA57WTHWL6/Smart_home"http://發布
char mqtt_message[200];//上報數據緩存區
ip_addr_t server_addr;
/*DNS域名解析成功回調函數*/
void dns_callback(const char *name, ip_addr_t *ipaddr, void *callback_arg)
{
server_addr.addr=ipaddr->addr;/*IP地址*/
}
int main()
{
char buff[200];
u8 stat;
u16 time=0,i=0,cnt=0;
float temp=10;
Beep_Init();
Led_Init();
Key_Init();
W25Q64_Init();
Usartx_Init(USART1,115200,72);
TIMx_Init(TIM2,72,20*1000);
IIC_Init();
printf("DM9000連接騰訊云VER1.0\r\n");
NT35310_Init();
LCD_ShowStr(75,5,16,"DM9000連接騰訊云VER1.0");//顯示字符串
AA:
/*DM9000初始化*/
LCD_ShowStr(30,30,16,"DM9000初始化中。。。");//顯示字符串
if(DM9000_Init()==0)
{
printf("DM9000初始化成功\r\n");
LCD_ShowStr(30,30+20,16,"DM9000\t OK!");//顯示字符串
}
else
{
printf("DM9000初始化失敗\r\n");
LCD_ShowStr(30,30+20,16,"DM9000\t ERR!");//顯示字符串
}
/*獲取DM9000工作模式*/
LCD_ShowStr(128,30+20*2,16,"網卡信息");//顯示字符串
stat=DM9000_Get_SpeedAndDuplex();//獲取連接狀態和工作方式
if(stat!=0xff)
{
printf("網卡速度:%d Mbps 模式:%s\r\n",(stat&0x02)?10:100,(stat&0x01)?"全雙工":"半雙工");
snprintf(buff,sizeof(buff),"網卡速度:%d MHZ\t %s",(stat&0x02)?10:100,(stat&0x01)?"全雙工":"半雙工");
LCD_ShowStr(30,30+20*3,16,(u8 *)buff);//網卡速度
}
else
{
printf("DM9000網卡狀態信息獲取失敗!\r\n");
LCD_ShowStr(30,30+20*3,16,(u8 *)"獲取網卡信息失敗!");//網卡速度
}
LWIP_Config_Init();//LWIP協議棧初始化
TIMx_Init(TIM6,72,1000);
TIM6->CR1|=1<<0;
while(!lwip_dhcp_stat);/*等待IP地址分配成功*/
LCD_ShowStr(112,30+20*7,16,"連接云服務器");//顯示字符串
/*域名解析*/
while(1)
{
stat=dns_gethostbyname(SERVER_IP,&server_addr,dns_callback,NULL);
if(stat==0)break;
Delay_Ms(1000);
}
/*連接服務器*/
stat=1;
time=300;
while(!client_connect_stat)
{
if(time>=300)
{
stat=1;
}
if(stat && time>=300)
{
time=0;
stat=LWIP_CreateTcpClient(&server_addr,1883);
}
time++;
Delay_Ms(10);
}
LCD_ShowStr(30,30+20*8,16,(u8 *)"服務器連接成功");
while(1)
{
MQTT_Init();
if(MQTT_Connect(ClientID,Username,Password)==0)
{
printf("騰訊云平臺連接成功\r\n");
break;
}
}
LCD_ShowStr(30,30+20*9,16,(u8 *)"騰訊云連接成功");
stat=MQTT_SubscribeTopic(SET_TOPIC,0,1);
if(stat)printf("訂閱失敗\r\n");
else
{
LCD_ShowStr(30,30+20*10,16,(u8 *)"消息訂閱成功");
}
time=0;
while(1)
{
if(dm9000_rx_len>0)
{
printf("len=%d\r\n",dm9000_rx_len);
for(i=0;i=5000)
{
time=0;
MQTT_SentHeart();//發送心跳包
}
if(cnt>=2000)
{
temp+=1.5;
if(temp>=85)temp=-15;
cnt=0;
sprintf(mqtt_message,"{"method":"report","clientToken":"123","params":{"temp":%.2f,"humi":60}}",temp);//溫度
MQTT_PublishData(POST_TOPIC,mqtt_message,0);
}
if(!client_connect_stat)//服務器斷開連接
{
goto AA;
}
}
}
運行效果:
聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。
舉報投訴
-
物聯網
+關注
關注
2909文章
44634瀏覽量
373317 -
STM32
+關注
關注
2270文章
10900瀏覽量
355985 -
LwIP
+關注
關注
2文章
86瀏覽量
27169 -
STM32F103ZE
+關注
關注
2文章
14瀏覽量
10890 -
騰訊云
+關注
關注
0文章
211瀏覽量
16788
發布評論請先 登錄
相關推薦
STM32F103ZE最小系統版
1.單片機:STM32F103ZE最小系統版6.0?N1RVcKX0SpK?回????/寶或點***擊***鏈節至瑬覽器【STM32F103ZET6小系統板 STM32
發表于 08-06 07:51
嵌入式 STM32F103ZE主要特性
Embest公司的STM32F103ZE ARM Cortex-M3嵌入式評估板采用ST公司的STM32F103ZE處理器,工作頻率72MHz.評估板集成了USB, CAN, SD卡接
發表于 05-08 11:17
?1.5w次閱讀
基于STM32F103ZE的USART2 端口時鐘
STM32F103ZE默認的USART2就是PA03PA02,如果配置映射,USART2端口是PD05PD06了。
發表于 06-04 07:26
?6360次閱讀
評論