高级会员

- 积分
- 624
- 金钱
- 624
- 注册时间
- 2014-11-11
- 在线时间
- 161 小时
|

楼主 |
发表于 2016-11-21 13:59:28
|
显示全部楼层
代码如下:
[mw_shl_code=applescript,true]#include "tcp_server_demo.h"
#include "lwip/opt.h"
#include "lwip_comm.h"
#include "led.h"
#include "lwip/lwip_sys.h"
#include "lwip/api.h"
//////////////////////////////////////////////////////////////////////////////////
//本程序只供学习使用,未经作者许可,不得用于其它任何用途
//ALIENTEK STM32F407开发板
//NETCONN API编程方式的TCP服务器测试代码
//正点原子@ALIENTEK
//技术论坛:www.openedv.com
//创建日期:2014/8/15
//版本:V1.0
//版权所有,盗版必究。
//Copyright(C) 广州市星翼电子科技有限公司 2009-2019
//All rights reserved
//*******************************************************************************
//修改信息
//无
//////////////////////////////////////////////////////////////////////////////////
u8 tcp_server_recvbuf[TCP_SERVER_RX_BUFSIZE]; //TCP客户端接收数据缓冲区
u8 tcp_server_sendbuf[TCP_SERVER_TX_BUFSIZE];
u8 tcp_server_flag; //TCP服务器数据发送标志位
//TCP客户端任务
#define TCPSERVER_PRIO 6
//任务堆栈大小
#define TCPSERVER_STK_SIZE 300
//任务堆栈
OS_STK TCPSERVER_TASK_STK[TCPSERVER_STK_SIZE];
//tcp服务器任务
static void tcp_server_thread(void *arg)
{
OS_CPU_SR cpu_sr;
u32 data_len = 0;
struct pbuf *q;
err_t err,recv_err;
u8 remot_addr[4];
struct netconn *conn, *newconn;
static ip_addr_t ipaddr;
static u16_t port;
u8 Recv_Tcp_Flag = 0x80;
LWIP_UNUSED_ARG(arg);
conn = netconn_new(NETCONN_TCP); //创建一个TCP链接
netconn_bind(conn,IP_ADDR_ANY,TCP_SERVER_PORT); //绑定端口 8号端口
netconn_listen(conn); //进入监听模式
while (1)
{
err = netconn_accept(conn,&newconn); //接收连接请求
if (err == ERR_OK) //处理新连接的数据
{
struct netbuf *recvbuf;
netconn_getaddr(newconn,&ipaddr,&port,0); //获取远端IP地址和端口号
remot_addr[3] = (uint8_t)(ipaddr.addr >> 24);
remot_addr[2] = (uint8_t)(ipaddr.addr>> 16);
remot_addr[1] = (uint8_t)(ipaddr.addr >> 8);
remot_addr[0] = (uint8_t)(ipaddr.addr);
printf("主机%d.%d.%d.%d连接上服务器,主机端口号为:%d\r\n",remot_addr[0], remot_addr[1],remot_addr[2],remot_addr[3],port);
while(1)
{
if((Recv_Tcp_Flag & LWIP_SEND_DATA) == LWIP_SEND_DATA) //有数据要发送
{
err = netconn_write(newconn ,tcp_server_sendbuf,8192,NETCONN_COPY); //发送tcp_server_sendbuf中的数据
if((err == ERR_CLSD)||(err==ERR_RST)) //关闭连接或者重启网络
{
netconn_close(newconn);
netconn_delete(newconn);
printf("主机:%d.%d.%d.%d断开与视频服务器的连接\r\n",\
remot_addr[0], remot_addr[1],remot_addr[2],remot_addr[3]);
break;
}
else
{
OSTimeDlyHMSM(0,0,0,2);//延时2ms
}
}
}
}
}
}
//创建TCP服务器线程
//返回值:0 TCP服务器创建成功
// 其他 TCP服务器创建失败
INT8U tcp_server_init(void)
{
INT8U res;
OS_CPU_SR cpu_sr;
u16 i;
for(i=0;i<8192;i++)
{
tcp_server_sendbuf = i;
}
OS_ENTER_CRITICAL(); //关中断
res = OSTaskCreate(tcp_server_thread,(void*)0,(OS_STK*)&TCPSERVER_TASK_STK[TCPSERVER_STK_SIZE-1],TCPSERVER_PRIO); //创建TCP服务器线程
OS_EXIT_CRITICAL(); //开中断
return res;
}
[/mw_shl_code]
|
|