基于stm32cubef4的httpserver-socket（freertos lwip）在407上调试成功...

[复制链接]

stm32_beginner 发布时间：2015-1-6 12:38

技术贴
文章封面:	-
文章简介:	-

本帖最后由 stm32_beginner 于 2015-1-8 14:58 编辑

基于stm32cubef4(HAL驱动，非固件库)的httpserver-socket（freertos lwip）在407上调试成功（RMII模式）

Lwip.part01.rar (9 MB, 下载次数: 2409)

2015-1-6 12:36 上传

点击文件名下载附件

Lwip.part02.rar (9 MB, 下载次数: 2385)

2015-1-6 12:37 上传

点击文件名下载附件

Lwip.part03.rar (9 MB, 下载次数: 2362)

2015-1-6 12:37 上传

点击文件名下载附件

Lwip.part04.rar (9 MB, 下载次数: 2264)

2015-1-6 12:37 上传

点击文件名下载附件

Lwip.part05.rar (1.66 MB, 下载次数: 1950)

2015-1-6 12:37 上传

点击文件名下载附件

收发实例：将里面http_server_socket_thread（httpserver）那句替换为http_server_socket_thread4（收发通信）
void http_server_socket_thread4( void *pvParameters )
{
int sockfd,newsockfd,is_connected[MAX],fd;
struct sockaddr_in addr;
int addr_len = sizeof(struct sockaddr_in);
fd_set myreadfds;
char msgbuffer[256];
char msg[] = "This is the message from server.Connected.\n";
if( (sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0 )
{
return;
}

memset(&addr,0,sizeof(addr));    //Çå¿ÕËùÔÚµÄÄÚ´æ

addr.sin_family = AF_INET;
addr.sin_port = htons(1234);
addr.sin_addr.s_addr = INADDR_ANY;

if(bind(sockfd,(struct sockaddr *)&addr,sizeof(addr)) < 0) //°ó¶¨¶Ë¿Ú
{
return;
}

if(listen(sockfd,3) < 0) //¿ªÊ¼¼àÌý
{
return;
}

for(fd=0;fd<MAX;fd++)
{
is_connected[fd] = 0; //ÉèÖÃËùÓÐµÄÁ¬½Ó±ê¼ÇÎª0
}

while(1)
{
FD_ZERO(&myreadfds); //Çå¿ÕÒ»¸ö±êÖ¾
FD_SET(sockfd,&myreadfds);  //ÉèÖÃ±êÖ¾

for(fd=0;fd<MAX;fd++)
{
if(is_connected[fd]) //ÅÐ¶ÏÓÐÃ»ÓÐÁ¬½Ó
{
FD_SET(fd,&myreadfds); //ÉèÖÃ±êÖ¾
}
}

if(!select(MAX,&myreadfds,NULL,NULL,NULL))  //Èç¹ûµ½´ïÁË×î´óÁ¬½ÓÊýÔò½øÈëÏÂ´ÎÑ»·¡£
{
continue;
}

for(fd=0;fd<MAX;fd++)
{
if(FD_ISSET(fd,&myreadfds))  //ÅÐ¶Ï±êÖ¾
{
if(sockfd == fd) //Èç¹ûÐÂ½¨µÄsocketºÍfdÏàÍ¬
{
if((newsockfd = accept(sockfd,(struct sockaddr *)&addr,(socklen_t *)&addr_len)) < 0)
{
return;
}
write(newsockfd,msg,sizeof(msg)); //¸ø¿Í»§¶Ë·¢ËÍÒ»¶ÎÐÅÏ¢
is_connected[newsockfd] = 1; //ÉèÖÃ±êÖ¾
}
else
{
memset(msgbuffer,0,sizeof(msgbuffer)); //Çå¿Õ×Ö·û´®
if(read(fd,msgbuffer,sizeof(msgbuffer)) <= 0) //¶ÁÈ¡½á¹û
{
is_connected[fd] = 0;    //ÉèÖÃ±êÖ¾
close(fd); //¹Ø±ÕÒ»¸ösocket
}
else
{
write(fd,msgbuffer,sizeof(msgbuffer));  //·¢ËÍ½ÓÊÕµ½µÄÏûÏ¢

}
}
}
}

}
}