web服務(wù)器實(shí)現(xiàn)壓縮數(shù)據(jù)發(fā)送給瀏覽器
web服務(wù)器使用gzip壓縮可以提高網(wǎng)站的響應(yīng)速度，因?yàn)閿?shù)據(jù)壓縮會(huì)消耗一定的cpu及I/O的。但是可以減少通過(guò)網(wǎng)絡(luò)傳輸?shù)臄?shù)據(jù)量。
從而提高網(wǎng)站的瀏覽速度本程序本人自己在ubuntu中編譯成功，在ubuntu中經(jīng)過(guò)Firefox中，window 系統(tǒng)IE 8，F(xiàn)irefox、chrome中測(cè)試成功。
本程序需要用到zlib壓縮類庫(kù)，沒(méi)有裝將無(wú)法成功，本人只提供在ubuntu中的代碼及運(yùn)行方式。希望大家諒解。關(guān)于用到的
zlib庫(kù)中的知識(shí)，稍后會(huì)出新的博客做解釋，關(guān)于gzip壓縮的頭部請(qǐng)看另外一篇博客 gzip頭部格式。
源碼及makefile下載地址：http://pan.baidu.com/share/link?shareid=167795&uk=2181414688
直接給大家上源代碼。下面為源代碼。（如有任何問(wèn)題，希望大家指出來(lái)了）
/* *主要實(shí)現(xiàn)功能，對(duì)傳輸?shù)臄?shù)據(jù)使用gzip進(jìn)行壓縮了*1.實(shí)現(xiàn)綁定本機(jī)機(jī)器的1024端口作為ReageWeb服務(wù)提供網(wǎng)頁(yè)服務(wù)的端口。（避免與機(jī)器上裝有web服務(wù)器產(chǎn)生端口沖突）* 作者：Reage* blog:http://blog.csdn.net/rentiansheng*/#include <stdio.h>#include <stdlib.h>#include <string.h>#include <sys/types.h>#include <sys/socket.h>#include <sys/un.h>#include <netinet/in.h>#include <arpa/inet.h>#include <fcntl.h>#include <string.h>#include <sys/stat.h>#include <signal.h>#include <stdio.h>#include <string.h>#include <assert.h>#include <zlib.h>#define OS_CODE 0x03 /*Unix OS_CODE*/#define DEFAULT_COMPRESSION Z_DEFAULT_COMPRESSION#define DEFAULT_WINDOWSIZE -15#define DEFAULT_MEMLEVEL 9#define DEFAULT_BUFFERSIZE 8096#define MAX 1024#define METHOD 20 //獲取數(shù)據(jù)的方式,使用字符串的長(zhǎng)度#define URI 255 //表示URI的最大長(zhǎng)度#define VERSION 15 //HTTP版本好的最大長(zhǎng)度#define TYPE 20 //表示文件的類型的長(zhǎng)度int res_socket;void app_exit();static const char gzip_header[10] = {37, 213, Z_DEFLATED, 0, 0, 0, 0, 0, 0, OS_CODE};void put_long (unsigned char *string, unsigned long x) { string[0] = (x & 0xff); string[1] = ((x >> 8) & 0xff) ; string[2] = ((x >> 16) & 0xff) ; string[3] = ((x >> 24) & 0xff);}/*@description:將數(shù)據(jù)使用gzip壓縮后發(fā)給瀏覽器@parametersockd:套接字file: 要壓縮的內(nèi)容了*/int gzip_buffer (int sockd, char * msg, int len) { z_stream stream;//zlib使用的。 int ret, flush; char in[MAX];//存放輸入的數(shù)據(jù) char send[MAX + 18 ];//存放壓縮過(guò)后的數(shù)據(jù) unsigned have; memcpy (send, gzip_header, 10); memset (in, 0, len); stream.zalloc = Z_NULL; stream.zfree = Z_NULL; stream.opaque = Z_NULL; stream.avail_in = 0; stream.next_in = Z_NULL; memcpy (in, msg, len); //壓縮初始化。 int tmp_result = deflateInit2(&stream, Z_DEFAULT_COMPRESSION,//壓縮級(jí)別 Z_DEFLATED,//壓縮方式 -MAX_WBITS, 8, Z_DEFAULT_STRATEGY); if (Z_OK != tmp_result) { printf("deflateInit error: %drn", tmp_result); return 0; } stream.avail_in = len; //要壓縮數(shù)據(jù)的長(zhǎng)度 stream.next_in = in; //要壓縮數(shù)據(jù)的首地址 stream.avail_out = MAX; //可存放的最大輸出結(jié)果的長(zhǎng)多。就是壓縮后數(shù)據(jù)的最大長(zhǎng)度 stream.next_out = send + 10; //存放壓縮數(shù)據(jù)的開(kāi)始位置，send前十個(gè)字節(jié)用來(lái)放頭部 ret = deflate (&stream,Z_FINISH); //壓縮 assert (ret != Z_STREAM_ERROR); switch (ret) { case Z_NEED_DICT: ret = Z_DATA_ERROR; case Z_DATA_ERROR: case Z_MEM_ERROR: (void)inflateEnd (&stream); return ret; } have = MAX - stream.avail_out; unsigned crc = crc32(0L, in, len); char * tail = send + 10 + have; put_long (tail, crc); put_long (tail + 4, len); write (sockd, send, have + 18); deflateEnd (&stream); return 1;}/* @description:開(kāi)始服務(wù)端監(jiān)聽(tīng)@parameterip:web服務(wù)器的地址port：web服務(wù)器的端口@result：成功返回創(chuàng)建socket套接字標(biāo)識(shí)，錯(cuò)誤返回-1*/int socket_listen( char *ip, unsigned short int port){ int res_socket; //返回值 int res, on; struct sockaddr_in address; struct in_addr in_ip; res = res_socket = socket(AF_INET, SOCK_STREAM, 0); setsockopt(res_socket, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)); memset(&address, 0, sizeof(address)); address.sin_family = AF_INET ; address.sin_port =htons(port); address.sin_addr.s_addr = htonl(INADDR_ANY); //inet_addr("127.0.0.1"); res = bind( res_socket, (struct sockaddr *) &address, sizeof( address ) ); if(res) { printf( "port is used , not to repeat bindn" ); exit(101); }; res = listen(res_socket,5); if(res) { printf( "listen port is error ;n" ); exit( 102 ); }; return res_socket ;}/*@description:向客戶端發(fā)送網(wǎng)頁(yè)頭文件的信息@parameterconn_socket:套接字描述符。status:http協(xié)議的返回狀態(tài)碼。@s_status:http協(xié)議的狀態(tài)碼的含義@filetype:向客戶端發(fā)送的文件類型*/void send_http_head(int conn_socket){ char buf[MAX]; memset(buf, 0, MAX); sprintf(buf, "HTTP/1.0 %d OKrn", 200); sprintf(buf, "%sServer: Reage Web Serverrn", buf); sprintf(buf, "%sContent-Type: text/htmlrn", buf); sprintf(buf, "%sContent-Encoding: gziprnrn", buf); write(conn_socket, buf, strlen(buf));} int main(int argc, char * argv[] ){ int conn_socket; int tmp ; int line ; struct sockaddr_in client_addr; char buf[MAX]; int len = sizeof(client_addr); char method[METHOD], uri[MAX], version[VERSION], type[TYPE]; char msg[] = "<br><br><h1>Reage Web Server gzip support text!</h1><br/><h1><a href = "http://blog.csdn.net/rentiansheng">Reage blog</a>"; res_socket = socket_listen( "127.0.0.1", 1024) ; //當(dāng)按ctrl+c結(jié)束程序時(shí)調(diào)用，使用app_exit函數(shù)處理退出過(guò)程 signal(SIGINT, app_exit); while(1){ conn_socket = accept( res_socket, (struct sockaddr * )&client_addr, &len ); printf("reagen"); tmp = read (conn_socket, buf, MAX-1); buf [MAX - 1] = 0; send_http_head(conn_socket); gzip_buffer (conn_socket, msg, strlen(msg)); close(conn_socket); } }void app_exit(){ //回復(fù)ctrl+c組合鍵的默認(rèn)行為 signal (SIGINT, SIG_DFL); //關(guān)閉服務(wù)端鏈接、釋放服務(wù)端ip和端口 close(res_socket); printf("n"); exit(0);}新聞熱點(diǎn)
疑難解答
圖片精選
