關(guān)鍵代碼： 系統(tǒng)(ucos_ii)中建立了兩個(gè)任務(wù)，task1用來(lái)處理服務(wù)器的一些周期性任務(wù)，task2用來(lái)發(fā)送JPEG數(shù)據(jù)流。 /** * @brief TCP服務(wù)器任務(wù) * @param * @retval None */ void TCP_Server_task(void *arg) { err_t err=0; err_t recv_err; struct netconn *server_coon; //服務(wù)器連接 struct netbuf *recvbuf; //接收數(shù)據(jù)netbuf指針 struct pbuf *bufptr; //pbuf數(shù)據(jù)緩沖區(qū)指針 server_coon = netconn_new(NETCONN_TCP); //創(chuàng)建一個(gè)TCP鏈接 netconn_bind(server_coon,IP_ADDR_ANY,TCP_SERVER_PORT); //綁定端口 netconn_listen(server_coon); //進(jìn)入監(jiān)聽(tīng)模式 server_coon->recv_timeout = 10; //禁止阻塞線程 等待10ms while (1) { err = netconn_accept(server_coon,&client_conn); //接收連接請(qǐng)求 //printf("\r\nerr=0x%x\r\n",err); if (err == ERR_OK) //正確說(shuō)明有客戶端聯(lián)入 { while(1) { if((recv_err = netconn_recv(client_conn,&recvbuf)) == ERR_OK) //接收到數(shù)據(jù)且正確 { bufptr=recvbuf->p; //得到數(shù)據(jù)指針 memcpy(Data_buff,bufptr->payload,bufptr->tot_len); //拷貝數(shù)據(jù) Data_buff[bufptr->tot_len]='\0'; //加入結(jié)束符 if(!memcmp(Data_buff,Video_Start,9)) //開(kāi)始采集 { Video_flag=1; //標(biāo)志位值1 CamFrame=0; //幀率清零 cam_start(); //開(kāi)始采集 RTC_ITConfig(RTC_IT_WUT,ENABLE); } else if(!memcmp(Data_buff,Video_Stop,8)) //關(guān)閉采集 { Video_flag=0; //標(biāo)志位值0，自動(dòng)采集完最后一幀，自動(dòng)停止 RTC_ITConfig(RTC_IT_WUT,DISABLE); } netbuf_delete(recvbuf); //清除緩沖netbuf } else if(recv_err == ERR_CLSD) //關(guān)閉連接 { netconn_close(client_conn); //關(guān)閉連接 netconn_delete(client_conn); //刪除連接 break; } } } } } /*********************分割線*************************/ /** * @brief 發(fā)送數(shù)據(jù)任務(wù) * @param * @retval None */ void CAM_Send_task(void *arg) { u16 len,i,temp; u8 *ptr; u8 flag; while(1) { if(Buf_DoutPtr!=Buf_DinPtr) { len=(*Buf_DoutPtr); ptr=(u8 *)(Buf_DoutPtr+1); //指向CAMbuf flag=0; for(i=0;i if((ptr==0xFF)&&(ptr[i+1]==0xD9)) //找數(shù)據(jù)尾 { ptr[i+2]='\r'; ptr[i+3]='\n'; temp=i+4; //有效數(shù)據(jù)長(zhǎng)度 flag=1; break; } } if(flag) { netconn_write(client_conn ,ptr,temp,NETCONN_COPY); //發(fā)送數(shù)據(jù) CamFrame++; //幀率+1 } Buf_DoutPtr+=BUFF_SIZE; if(Buf_DoutPtr==Buf_EndPtr) Buf_DoutPtr=Buf_StartPtr; //到最后一個(gè)了 //回到開(kāi)頭 } OSTimeDly(1); } } 現(xiàn)象：
如果關(guān)注的人多的話，我就收拾收拾上位機(jī)的代碼，發(fā)給你們玩玩[PS:用的是labview，其實(shí)也沒(méi)什么好玩的]。 |
| 歡迎光臨 電子工程網(wǎng) (http://m.qingdxww.cn/) | Powered by Discuz! X3.4 |
