電子工程網(wǎng)

關(guān)鍵代碼：

     系統(ucos_ii)中建立了兩個(gè)任務(wù)，task1用來(lái)處理服務(wù)器的一些周期性任務(wù)，task2用來(lái)發(fā)送JPEG數據流。

/**
  * @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;             //接收數據netbuf指針        
        struct pbuf *bufptr;         //pbuf數據緩沖區指針
        
        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)入監聽(tīng)模式
        server_coon->recv_timeout = 10;                         //禁止阻塞線(xiàn)程 等待10ms
         
        while (1)   
        {
                  err = netconn_accept(server_coon,&client_conn);        //接收連接請求
                  //printf("\r\nerr=0x%x\r\n",err);
                if (err == ERR_OK)                                     //正確說(shuō)明有客戶(hù)端聯(lián)入
                  {                                                
                          while(1)
                                {                                
                                        if((recv_err = netconn_recv(client_conn,&recvbuf)) == ERR_OK)          //接收到數據且正確
                                        {               
                                                bufptr=recvbuf->p;                                  //得到數據指針
                                                memcpy(Data_buff,bufptr->payload,bufptr->tot_len);  //拷貝數據                                       
                                                Data_buff[bufptr->tot_len]='\0';                        //加入結束符
                                                
                                                if(!memcmp(Data_buff,Video_Start,9))               //開(kāi)始采集
                                                {                     
                                                        Video_flag=1;                                   //標志位值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;                                     //標志位值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;
                                        }
                                }
                                
                  }
        }
}

/*********************分割線(xiàn)*************************/

/**
  * @brief  發(fā)送數據任務(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))      //找數據尾
                                {
                                        ptr[i+2]='\r';
                                        ptr[i+3]='\n';
                                        temp=i+4;                               //有效數據長(cháng)度
                                        flag=1;
                                        break;
                                }
                        }
                        if(flag)
                        {        
                                netconn_write(client_conn ,ptr,temp,NETCONN_COPY);  //發(fā)送數據
                                CamFrame++;                                       //幀率+1
                        }
                        
                          Buf_DoutPtr+=BUFF_SIZE;                        
                          if(Buf_DoutPtr==Buf_EndPtr)  Buf_DoutPtr=Buf_StartPtr;  //到最后一個(gè)了
                                                          //回到開(kāi)頭                        
            }

                OSTimeDly(1);
        }
}

UC截圖20161209153253.png

UC截圖20161027163031.png

【】紅龍429_網(wǎng)絡(luò )攝像頭TCP.rar (1.64 MB)

2016-12-14 14:19 上傳

點(diǎn)擊文件名下載附件
下載積分: 積分 -1

http://player.youku.com/player.php/sid/XMTg2MTMzNTIyOA==/v.swf