【摘要】 介紹Linux下HTTP服務(wù)器搭建，完成網(wǎng)頁(yè)圖片顯示，網(wǎng)頁(yè)視頻顯示。

任務(wù)1: 網(wǎng)頁(yè)視頻監(jiān)控項(xiàng)目

目的: 使用瀏覽器訪(fǎng)問(wèn)開(kāi)發(fā)板的USB攝像頭圖像數(shù)據(jù)，實(shí)時(shí)刷新到達(dá)視頻的效果。

1.?HTTP協(xié)議: 如何傳輸數(shù)據(jù)，讓瀏覽器顯示？

2.?線(xiàn)程的并發(fā)執(zhí)行: 多個(gè)瀏覽器同時(shí)訪(fǎng)問(wèn)攝像頭數(shù)據(jù)。

3.?USB攝像頭編程: 如果獲取攝像頭的數(shù)據(jù)。

1.1 如何顯示一張靜態(tài)的圖片

HTTP協(xié)議: 文本協(xié)議-----報(bào)文: 字符串。

HTTP服務(wù)器基本的交互的步驟:

1.?先創(chuàng)建HTTP服務(wù)器

2.?使用瀏覽器(HTTP客戶(hù)端)訪(fǎng)問(wèn)HTTP服務(wù)器:

(1)?第一次請(qǐng)求的路徑是: / :表示詢(xún)問(wèn): 你需要我做什么?

(2)?HTTP服務(wù)器收到請(qǐng)求之后,先向HTTP客戶(hù)端發(fā)送應(yīng)答報(bào)文。

再發(fā)送需要瀏覽器處理的數(shù)據(jù): 數(shù)據(jù)類(lèi)型、數(shù)據(jù)長(zhǎng)度。 :表示分配給瀏覽器需要做的任務(wù)

如果需要瀏覽器顯示一張圖片，瀏覽器在收到任務(wù)之后，會(huì)解析任務(wù)，再次向服務(wù)器發(fā)送請(qǐng)求:

請(qǐng)求圖片(圖片的資源路徑):

HTTP服務(wù)器收到請(qǐng)求之后,先向HTTP客戶(hù)端發(fā)送應(yīng)答報(bào)文。

再發(fā)送需要瀏覽器處理的數(shù)據(jù): 數(shù)據(jù)類(lèi)型、數(shù)據(jù)長(zhǎng)度。

1.2 采集攝像頭數(shù)據(jù)、顯示動(dòng)態(tài)圖片

1. 采集攝像頭數(shù)據(jù): 開(kāi)一個(gè)新的線(xiàn)程

2. 需要將攝像頭的數(shù)據(jù)編碼為JPG格式—jpglib只能將RGB數(shù)據(jù)壓縮成JPG格式保存到文件。

需要使用改進(jìn)的算法，將JPG圖像壓縮存放到內(nèi)存里。

3.?需要考慮資源共享: 線(xiàn)程互斥鎖+條件變量

(1)?線(xiàn)程1: 負(fù)責(zé)采集攝像頭的數(shù)據(jù),并進(jìn)行編碼壓縮jpg圖像

(2)?線(xiàn)程2(主線(xiàn)程): 負(fù)責(zé)等待HTTP客戶(hù)端連接(瀏覽器),處理與瀏覽器之間的交互過(guò)程。

??云服務(wù)器: 本身就是一個(gè)虛擬電腦。

1.?登錄: 使用ssh遠(yuǎn)程登錄。

2.?買(mǎi)云服務(wù)器: 送一個(gè)公網(wǎng)IP地址。

3.?也可以購(gòu)買(mǎi)一個(gè)域名。www.1234.com

今天的代碼基礎(chǔ)之上實(shí)現(xiàn):

跨網(wǎng)段網(wǎng)頁(yè)視頻監(jiān)控。

1.3 解決TCP服務(wù)器退出時(shí)，產(chǎn)生退出信號(hào)終止進(jìn)程

signal.h中的宏定義SIG_DFL及SIG_IGN

SIG_DFL,SIG_IGN 分別表示無(wú)返回值的函數(shù)指針，指針值分別是0和1，

這兩個(gè)指針值邏輯上講是實(shí)際程序中不可能出現(xiàn)的函數(shù)地址值。

SIG_DFL：默認(rèn)信號(hào)處理程序

SIG_IGN：忽略信號(hào)的處理程序

/*

往一個(gè)已經(jīng)接收到FIN的套接中寫(xiě)是允許的，接收到的FIN僅僅代表對(duì)方不再發(fā)送數(shù)據(jù)。

并不能代表我不能發(fā)送數(shù)據(jù)給對(duì)方。

往一個(gè)FIN結(jié)束的進(jìn)程中寫(xiě)(write)，對(duì)方會(huì)發(fā)送一個(gè)RST字段過(guò)來(lái)，TCP重置。

如果再調(diào)用write就會(huì)產(chǎn)生SIGPIPE信號(hào)

*/

signal(SIGPIPE,SIG_IGN);

1.4 HTTP服務(wù)器搭建_顯示一靜態(tài)JPG圖片

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include  
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#define HTTP_SERVER_PORT 1237  /*HTTP服務(wù)器端口號(hào)*/
int http_server_fd; /*HTTP服務(wù)器套接字*/
/*
函數(shù)功能: 處理退出的信號(hào)
*/
void exit_sighandler(int sig)
{
	/*關(guān)閉服務(wù)器套接字*/
	close(http_server_fd);
	sleep(2);
	
	//退出進(jìn)程
	exit(1);
}

/*
函數(shù)功能: 向HTTP客戶(hù)端發(fā)送文件數(shù)據(jù)
*/
void HTTPClient_SendFileData(int client_fd,char *type,char *file)
{
	int file_fd;
	int read_len;
	struct stat file_buf;
	unsigned char buffer[1024];
	file_fd=open(file,O_RDONLY);
	if(file_fd<0)
	{
		printf("%s文件打開(kāi)失敗!\n",file);
		return;
	}
	
	/*1. 獲取文件的狀態(tài)信息*/
	stat(file,&file_buf);
	//printf("%d\n",file_buf.st_size);
	
	/*2. 構(gòu)造報(bào)文頭*/
	sprintf(buffer,"HTTP/1.1 200 OK\r\n" \
				   "Content-type:%s\r\n" \
				   "Content-Length:%d\r\n" 
				   "Server: wbyq\r\n" \
				   "\r\n",type,file_buf.st_size);
	
	read_len=strlen(buffer);
	
	/*2. 發(fā)送數(shù)據(jù)*/
	do
	{
		if(write(client_fd,buffer,read_len)<=0)break;
	}while((read_len=read(file_fd,buffer,sizeof(buffer)))>0);
}

/*
函數(shù)功能: 處理HTTP客戶(hù)端的線(xiàn)程
*/
void *pthread_Handler_HTTP_Client(void *dev)
{
	int Clientfd;
	unsigned char buffer[1024];
	unsigned char *p=buffer;
	struct pollfd fds;
	int poll_state; /*poll函數(shù)的狀態(tài)值*/
	int recv_len;   /*接收的數(shù)據(jù)長(zhǎng)度*/
	if(dev==NULL)
	{
		pthread_exit(NULL); /*終止線(xiàn)程*/
	}
	Clientfd=*(int*)dev; /*保存客戶(hù)端套接字描述符*/
	free(dev); /*釋放空間*/
	
	/*1. 接收客戶(hù)端的請(qǐng)求報(bào)文*/
	fds.fd=Clientfd;
	fds.events=POLLIN;
	while(1)
	{
		/*等待數(shù)據(jù)*/
		poll_state=poll(&fds,1,100);
		if(poll_state<=0)break; /*數(shù)據(jù)接收完畢就退出*/
		recv_len=read(Clientfd,p,1024);
		p+=recv_len;
		if(p-buffer>1024)break;
	}
	
	//printf("buffer=%s\n",buffer);
	
	/*1. 判斷請(qǐng)求的路徑*/
	if(strstr(buffer,"GET / HTTP/1.1"))
	{
		HTTPClient_SendFileData(Clientfd,"text/html","index.html");
	}
	else if(strstr(buffer,"GET /image.jpg HTTP/1.1"))
	{
		HTTPClient_SendFileData(Clientfd,"image/jpeg","123.jpg");
	}
	else if(strstr(buffer,"GET /favicon.ico HTTP/1.1"))
	{
		HTTPClient_SendFileData(Clientfd,"image/x-icon","123.ico");
	}
	
	close(Clientfd);
}
/*
HTTP服務(wù)器創(chuàng)建:
1. 創(chuàng)建socket套接字
2. 綁定端口號(hào): 服務(wù)器創(chuàng)建
3. 設(shè)置監(jiān)聽(tīng)端口的數(shù)量: 服務(wù)器最大等待連接的客戶(hù)端總數(shù)量
4. 等待客戶(hù)端連接
*/
int main(int argc,char **argv)
{
	/*1. 綁定將要捕獲的信號(hào)*/
	signal(SIGINT,exit_sighandler);
	signal(SIGSEGV,exit_sighandler);
	
	/*2. 創(chuàng)建套接字*/
	http_server_fd=socket(AF_INET,SOCK_STREAM,0);
	if(http_server_fd<0)
	{
		printf("HTTP服務(wù)器:創(chuàng)建套接字創(chuàng)建失敗!\n");
		return -1;
	}
	
	/*3. 綁定端口號(hào)*/
	struct sockaddr_in server_addr;
	memset(&server_addr,0,sizeof(struct sockaddr_in));
	server_addr.sin_family=AF_INET; //IPV4
	server_addr.sin_port=htons(HTTP_SERVER_PORT); //需要填大端格式的端口號(hào)數(shù)據(jù)
	server_addr.sin_addr.s_addr=0;//inet_addr("192.168.18.3");
	/*0=inet_addr("0.0.0.0") ---表示本地所有IP地址*/
	if(bind(http_server_fd,(struct sockaddr *)&server_addr,sizeof(struct sockaddr_in))!=0)
	{
		printf("HTTP服務(wù)器:綁定端口號(hào)失敗!\n");
		return -2;
	}
	
	/*4. 設(shè)置監(jiān)聽(tīng)客戶(hù)端連接的數(shù)量*/
	listen(http_server_fd,50);
	
	/*5. 等待客戶(hù)端連接:阻塞*/
	struct sockaddr_in client_addr;
	int addrlen=sizeof(struct sockaddr_in);
	pthread_t thread_id; /*線(xiàn)程的ID*/
	int *client_fd=NULL; /*保存客戶(hù)端的套接字描述符*/
	while(1)
	{
		client_fd=(int*)malloc(sizeof(int));
		if(client_fd==NULL)
		{
			printf("存放客戶(hù)端的套接字描述符,空間申請(qǐng)失敗!\n");
			break;
		}
		*client_fd=accept(http_server_fd,(struct sockaddr *)&client_addr,&addrlen);
		if(*client_fd<0)
		{
			break;
		}
		
		/*6. 創(chuàng)建新的線(xiàn)程*/
		if(pthread_create(&thread_id,NULL,pthread_Handler_HTTP_Client,(void*)client_fd)!=0)
		{
			printf("創(chuàng)建處理HTTP客戶(hù)端線(xiàn)程失敗!\n");
			break;
		}
	}
	
	/*7. 關(guān)閉服務(wù)器套接字*/
	close(http_server_fd);
	return 0;
}

1.5 網(wǎng)頁(yè)視頻監(jiān)控的項(xiàng)目代碼_多線(xiàn)程處理

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include  
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include "yuv_to_jpeg.h"

#define UVC_VIDEO_DEVICE "/dev/video15"  /*UVC攝像頭設(shè)備節(jié)點(diǎn)*/
int uvc_video_fd; /*存放攝像頭設(shè)備節(jié)點(diǎn)的文件描述符*/
int video_stop_stat=1; /*視頻停止?fàn)顟B(tài): 1表示正常執(zhí)行,0表示退出*/

unsigned char *video_memaddr_buffer[4]; /*存放的是攝像頭映射出來(lái)的緩沖區(qū)首地址*/
int Image_Width;  /*圖像的寬度*/
int Image_Height; /*圖像的高度*/
unsigned char *jpg_video_buffer=NULL; /*轉(zhuǎn)換之后的JPG數(shù)據(jù)緩沖區(qū)首地址*/
unsigned int jpg_video_size; /*存放當(dāng)前JPG數(shù)據(jù)緩沖區(qū)的大小*/
pthread_mutex_t mutex; /*互斥鎖*/
pthread_cond_t cond;  /*條件變量*/

#define HTTP_SERVER_PORT 1235  /*HTTP服務(wù)器端口號(hào)*/
int http_server_fd; /*HTTP服務(wù)器套接字*/

/*
函數(shù)功能: 處理退出的信號(hào)
*/
void exit_sighandler(int sig)
{
	video_stop_stat=0; //讓攝像頭采集線(xiàn)程自動(dòng)退出
	sleep(2);
	
	/*關(guān)閉服務(wù)器套接字*/
	close(http_server_fd);
	
	//退出進(jìn)程
	exit(1);
}

/*
函數(shù)功能: 向HTTP客戶(hù)端發(fā)送文件數(shù)據(jù)
*/
void HTTPClient_SendFileData(int client_fd,char *type,char *file)
{
	int file_fd;
	int read_len;
	struct stat file_buf;
	unsigned char buffer[1024];
	file_fd=open(file,O_RDONLY);
	if(file_fd<0)
	{
		printf("%s文件打開(kāi)失敗!\n",file);
		return;
	}
	
	/*1. 獲取文件的狀態(tài)信息*/
	stat(file,&file_buf);
	//printf("%d\n",file_buf.st_size);
	
	/*2. 構(gòu)造報(bào)文頭*/
	sprintf(buffer,"HTTP/1.1 200 OK\r\n" \
				   "Content-type:%s\r\n" \
				   "Content-Length:%d\r\n" 
				   "Server: wbyq\r\n" \
				   "\r\n",type,file_buf.st_size);
	
	read_len=strlen(buffer);
	
	/*2. 發(fā)送數(shù)據(jù)*/
	do
	{
		if(write(client_fd,buffer,read_len)<=0)break;
	}while((read_len=read(file_fd,buffer,sizeof(buffer)))>0);
}
/*
函數(shù)功能: 發(fā)送數(shù)據(jù)流
*/
void SendVideoData(int Clientfd)
{
	int image_size;
	unsigned char *image_data; 
	unsigned char buffer[1024];
	
	/*1. 構(gòu)造報(bào)文頭: 回應(yīng)瀏覽器請(qǐng)求,并告訴瀏覽器接下來(lái)需要使用長(zhǎng)連接*/
	sprintf(buffer, "HTTP/1.0 200 OK\r\n" \
					"Server: wbyq\r\n" \
					"Content-Type: multipart/x-mixed-replace;boundary=" "boundarydonotcross" "\r\n" \
					"\r\n" \
					"--" "boundarydonotcross" "\r\n");
	if(write(Clientfd,buffer,strlen(buffer))<0)
	{
		return;
	}
	
	/*2. 循環(huán)發(fā)送數(shù)據(jù)流: JPG圖片*/
	image_data=malloc(Image_Width*Image_Height*3);
	if(image_data==NULL)
	{
		printf("循環(huán)發(fā)送數(shù)據(jù)流緩沖區(qū)申請(qǐng)失敗!\n");
		return;
	}
	while(video_stop_stat)
	{
		//阻塞方式等待條件變量,等待成功并上鎖
		pthread_cond_wait(&cond,&mutex);
		
		image_size=jpg_video_size; //保存圖片的大小
		memcpy(image_data,jpg_video_buffer,image_size);
		
		//互斥鎖解鎖
		pthread_mutex_unlock(&mutex);
		
		/*2.1 構(gòu)造報(bào)文頭: 告訴瀏覽器發(fā)送數(shù)據(jù)類(lèi)型和數(shù)據(jù)的長(zhǎng)度*/
		sprintf(buffer,"Content-type:%s\r\n" \
					   "Content-Length:%d\r\n"\
					   "\r\n","image/jpeg",image_size);
		if(write(Clientfd,buffer,strlen(buffer))<0)
		{
			break;
		}
		
		/*2.2 發(fā)送實(shí)際的數(shù)據(jù)*/
		if(write(Clientfd,image_data,image_size)<0)break;
		
		/*2.3 發(fā)送間隔符號(hào)*/
		sprintf(buffer,"\r\n--" "boundarydonotcross" "\r\n"); //間隔符號(hào)
		if(write(Clientfd,buffer,strlen(buffer))<0)
		{
			break;
		}
	}
	free(image_data); //釋放空間
}
/*
函數(shù)功能: 處理HTTP客戶(hù)端的線(xiàn)程
*/
void *pthread_Handler_HTTP_Client(void *dev)
{
	int Clientfd;
	unsigned char buffer[1024];
	unsigned char *p=buffer;
	struct pollfd fds;
	int poll_state; /*poll函數(shù)的狀態(tài)值*/
	int recv_len;   /*接收的數(shù)據(jù)長(zhǎng)度*/
	if(dev==NULL)
	{
		pthread_exit(NULL); /*終止線(xiàn)程*/
	}
	Clientfd=*(int*)dev; /*保存客戶(hù)端套接字描述符*/
	free(dev); /*釋放空間*/
	
	/*1. 接收客戶(hù)端的請(qǐng)求報(bào)文*/
	fds.fd=Clientfd;
	fds.events=POLLIN;
	while(1)
	{
		/*等待數(shù)據(jù)*/
		poll_state=poll(&fds,1,100);
		if(poll_state<=0)break; /*數(shù)據(jù)接收完畢就退出*/
		recv_len=read(Clientfd,p,1024);
		p+=recv_len;
		if(p-buffer>1024)break;
	}
	
	//printf("buffer=%s\n",buffer);
	
	/*1. 判斷請(qǐng)求的路徑*/
	if(strstr(buffer,"GET / HTTP/1.1"))
	{
		HTTPClient_SendFileData(Clientfd,"text/html","index.html");
	}
	else if(strstr(buffer,"GET /?action=stream HTTP/1.1"))
	{
		SendVideoData(Clientfd); //發(fā)送視頻流數(shù)據(jù)
	}
	else if(strstr(buffer,"GET /favicon.ico HTTP/1.1"))
	{
		HTTPClient_SendFileData(Clientfd,"image/x-icon","123.ico");
	}
	
	close(Clientfd);
}
/*
函數(shù)功能: UVC攝像頭初始化
返回值: 0表示成功
*/
int UVCvideoInit(void)
{
	/*1. 打開(kāi)攝像頭設(shè)備*/
	uvc_video_fd=open(UVC_VIDEO_DEVICE,O_RDWR);
	if(uvc_video_fd<0)
	{
		printf("%s 攝像頭設(shè)備打開(kāi)失敗!\n",UVC_VIDEO_DEVICE);
		return -1;
	}
	
	/*2. 設(shè)置攝像頭的屬性*/
	struct v4l2_format format;
	memset(&format,0,sizeof(struct v4l2_format));
	format.type=V4L2_BUF_TYPE_VIDEO_CAPTURE; /*表示視頻捕獲設(shè)備*/
	format.fmt.pix.width=320;  /*預(yù)設(shè)的寬度*/
	format.fmt.pix.height=240; /*預(yù)設(shè)的高度*/
	format.fmt.pix.pixelformat=V4L2_PIX_FMT_YUYV; /*預(yù)設(shè)的格式*/
	format.fmt.pix.field=V4L2_FIELD_ANY; /*系統(tǒng)自動(dòng)設(shè)置: 幀屬性*/
	if(ioctl(uvc_video_fd,VIDIOC_S_FMT,&format)) /*設(shè)置攝像頭的屬性*/
	{
		printf("攝像頭格式設(shè)置失敗!\n");
		return -2;
	}
	
	Image_Width=format.fmt.pix.width;
	Image_Height=format.fmt.pix.height;
		
	printf("攝像頭實(shí)際輸出的圖像尺寸:x=%d,y=%d\n",format.fmt.pix.width,format.fmt.pix.height);
	if(format.fmt.pix.pixelformat==V4L2_PIX_FMT_YUYV)
	{
		printf("當(dāng)前攝像頭支持YUV格式圖像輸出!\n");
	}
	else
	{
		printf("當(dāng)前攝像頭不支持YUV格式圖像輸出!\n");
		return -3;
	}

	/*3. 請(qǐng)求緩沖區(qū): 申請(qǐng)攝像頭數(shù)據(jù)采集的緩沖區(qū)*/
	struct v4l2_requestbuffers req_buff;
	memset(&req_buff,0,sizeof(struct v4l2_requestbuffers));
	req_buff.count=4; /*預(yù)設(shè)要申請(qǐng)4個(gè)緩沖區(qū)*/
	req_buff.type=V4L2_BUF_TYPE_VIDEO_CAPTURE; /*視頻捕獲設(shè)備*/
	req_buff.memory=V4L2_MEMORY_MMAP; /*支持mmap內(nèi)存映射*/
	if(ioctl(uvc_video_fd,VIDIOC_REQBUFS,&req_buff)) /*申請(qǐng)緩沖區(qū)*/
	{
		printf("申請(qǐng)攝像頭數(shù)據(jù)采集的緩沖區(qū)失敗!\n");
		return -4;
	}
	printf("攝像頭緩沖區(qū)申請(qǐng)的數(shù)量: %d\n",req_buff.count);

	/*4. 獲取緩沖區(qū)的詳細(xì)信息: 地址,編號(hào)*/
	struct v4l2_buffer buff_info;
	memset(&buff_info,0,sizeof(struct v4l2_buffer));
	int i;
	for(i=0;i
                        聲明：本文內(nèi)容及配圖由入駐作者撰寫(xiě)或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀(guān)點(diǎn)僅代表作者本人，不代表電子發(fā)燒友網(wǎng)立場(chǎng)。文章及其配圖僅供工程師學(xué)習(xí)之用，如有內(nèi)容侵權(quán)或者其他違規(guī)問(wèn)題，請(qǐng)聯(lián)系本站處理。
                        舉報(bào)投訴