Stream Server 上 , 利用 C++ POCO 制作 Gzp + zlib , Deflate 與 Inflate

fiendcly

# 作者 : FIEND
# 文章來源 :  
http://bbs.ecstart.com/forum.php ... id=43305&extra=
或
http://bbs.chinaunix.net/forum.p ... mp;fromuid=20071307
# 轉貼請注明出處 , 以方便討論.

在使用 C++ 做 Socket 的服務端時 , 利用 GZIP 和 ZLIB 做 Deflate 和 Inflate 來做 壓縮的 Stream Server

以下是我利用 POCO 來編寫的.

在使用這個元件時 , 我發現它的 GZIP 的 deflate 和 infalte 不能用 .

所以另外寫了一個獨立的 元件 .

在編寫過程中 , 發現這個 FREE 的 元件庫 問題還蠻多的 , 只好 一 一 解決.


這是我碰到這個問題時的討論主題 :

http://bbs.chinaunix.net/thread-3766361-1-1.html
http://bbs.ecstart.com/thread-43305-1-1.html



不想花錢 : (SUPPORT 是要錢的.)

http://pocoproject.org/download/index.html

使用版本 : 1.4.3p1 , 請先下載編譯.




請服用 .......

1.
zlib.h

1. #ifndef _ZLIB_H
   
2. #define _ZLIB_H
   
3. 
   
4. #pragma once
   
5. #include <string>
   
6. 
   
7. #define ZLIB_HEADER_LENGTH 1
   
8. #define ZLIB_END_LENGTH 4
   
9. 
   
10. //#define ZLIB_HEADER_STR "0x780x9c"
    
11. //#define ZLIB_END_STR "0x0d0xd50x230x55"
    
12. 
    
13. 
    
14. class Zlib
    
15. {
    
16. 
    
17. private:
    
18.         //static int len ;
    
19. public:
    
20. 
    
21.         char zlibHeader[ZLIB_HEADER_LENGTH];
    
22.         char zlibEnd[ZLIB_END_LENGTH] ;
    
23.         static std::string zlibHeaderStr ;
    
24.         static std::string zlibEndStr ;
    
25. 
    
26. 
    
27.         unsigned int i ;
    
28.         unsigned int num ;
    
29. 
    
30.         //const char* zlibHeader ;
    
31.         //const char* zlibEnd ;
    
32.         static std::string inflateStr ;
    
33.         static std::string deflateStr ;
    
34.         static std::string zlibDeflateStr ;
    
35. 
    
36.         static std::string fixHeader ;
    
37. 
    
38.         //std::string inflate (const std::string &source,int level);
    
39.         std::string inflate (const std::string &source);
    
40.         //std::string inflate2 (const std::string &source);
    
41.         std::string deflate (const std::string &source,int level);
    
42. 
    
43. 
    
44.         // convert zlib deflate to gzip deflate
    
45.         std::string gzdeflate (const std::string &source,int level);
    
46. 
    
47. 
    
48. 
    
49.         // convert zlib inflate to gzip inflate
    
50.         std::string gzinflate (const std::string &source);
    
51. 
    
52. 
    
53. 
    
54. };
    
55. 
    
56. #endif
    

复制代码

2. CPP

1. #include <cstdlib>
   
2. #include <iostream>
   
3. #include <string>
   
4. #include <stdio.h>
   
5. #include <math.h>
   
6. #include <sstream>
   
7. 
   
8. // zlib
   
9. #include "Poco/InflatingStream.h"
   
10. #include "Poco/DeflatingStream.h"
    
11. #include "Poco/StreamCopier.h"
    
12. #include <fstream>
    
13. 
    
14. 
    
15. using namespace std;
    
16. 
    
17. using Poco::InflatingInputStream;
    
18. using Poco::InflatingOutputStream;
    
19. using Poco::DeflatingOutputStream;
    
20. using Poco::DeflatingStreamBuf;
    
21. using Poco::StreamCopier;
    
22. 
    
23. 
    
24. #include "wge/zlib.h"
    
25. 
    
26. std::string Zlib::inflateStr ;
    
27. std::string Zlib::deflateStr ;
    
28. 
    
29. std::string Zlib::fixHeader ;
    
30. 
    
31. 
    
32. char zlibHeader[ZLIB_HEADER_LENGTH];
    
33. char zlibEnd[ZLIB_END_LENGTH] ;
    
34. 
    
35. /*
    
36. * zlib deflate 字串壓縮
    
37. */
    
38. std::string Zlib::deflate (const std::string &source , int level = (-1))        {
    
39. 
    
40.         std::istringstream in(source);
    
41.         std::ostringstream out;
    
42.         Poco::DeflatingOutputStream deflaterOut(out,DeflatingStreamBuf::STREAM_ZLIB,level);
    
43.         deflaterOut << in.str() ;
    
44.         deflaterOut.close() ;
    
45. 
    
46.         //std::cout << " input         : " << in.str() << endl ;
    
47.         //std::cout << " input length  : " << in.str().length() << endl ;
    
48.         //std::cout << " output        : " << out.str() << endl ;
    
49.         //std::cout << " output length : " << out.str().length() << endl ;
    
50.         deflateStr = out.str();
    
51.         return deflateStr ;
    
52. }
    
53. 
    
54. 
    
55. /*
    
56. * zlib inflate 解壓縮
    
57. */
    
58. //std::string Zlib::inflate (const std::string &source , int level = (-1))      {
    
59. std::string Zlib::inflate (const std::string &source)   {
    
60. 
    
61.         std::istringstream in(source);
    
62.         //std::cout << in.str() << endl ;
    
63.         std::ostringstream out;
    
64.         Poco::InflatingInputStream inflaterIn(in,DeflatingStreamBuf::STREAM_ZLIB); // 建立 inflaterIn
    
65.         //Poco::InflatingInputStream inflaterIn(in); // 建立 inflaterIn
    
66.         // 將解壓縮的內容復制到 out stringtream .
    
67.         StreamCopier::copyStream(inflaterIn , out);
    
68.         inflateStr = out.str();
    
69.         return inflateStr ;
    
70. }
    
71. 
    
72. 
    

复制代码

1. 
   
2. /*
   
3. * gzip deflate 字串壓縮
   
4. */
   
5. 
   
6. std::string Zlib::gzdeflate (const std::string &source , int level = (-1))      {
   
7. 
   
8.         std::istringstream in(source);
   
9.         std::ostringstream out;
   
10.         Poco::DeflatingOutputStream deflaterOut(out,DeflatingStreamBuf::STREAM_ZLIB,level);
    
11.         deflaterOut << in.str() ;
    
12.         deflaterOut.close() ;
    
13.         std::string zlibDeflateStr ;
    
14.         zlibDeflateStr = out.str();
    
15.         zlibDeflateStr = zlibDeflateStr.substr(2,zlibDeflateStr.length()-6);
    
16.         deflateStr = zlibDeflateStr ;
    
17.         return deflateStr ;
    
18. }
    
19. 
    

复制代码

1. 
   
2. /*
   
3. * gzip inflate 解壓縮
   
4. */
   
5. std::string Zlib::gzinflate (const std::string &source) {
   
6. 
   
7. 
   
8.         // fix header & end
   
9.         //zlibHeader[ZLIB_HEADER_LENGTH] = ZLIB_HEADER_STR;
   
10.         //zlibEnd[ZLIB_END_LENGTH] = ZLIB_END_STR ;
    
11. 
    
12.         // zlib Header
    
13.         std::string fixsource;
    
14.         //std::string str = source ;
    
15.         zlibHeader[0] = 0x78  ;
    
16.         zlibHeader[1] = 0x9c  ;
    
17.         std::string zlibHeaderStr =  zlibHeader;
    
18.         std::string fixZlibHeaderStr = zlibHeaderStr.substr(0,2);
    
19. 
    
20.         zlibEnd[0] = 0xd ;
    
21.         zlibEnd[1] = 0xd5 ;
    
22.         zlibEnd[2] = 0x23 ;
    
23.         zlibEnd[3] = 0x55 ;
    
24.         std::string zlibEndStr = zlibEnd ;
    
25.         std::string fixZlibEndStr = zlibEndStr.substr(0,2);
    
26. 
    
27.         fixsource = fixZlibHeaderStr + source + fixZlibEndStr ;
    
28. 
    
29.         std::istringstream in(fixsource);
    
30.         //std::cout << in.str() << endl ;
    
31.         std::ostringstream out;
    
32.         Poco::InflatingInputStream inflaterIn(in,DeflatingStreamBuf::STREAM_ZLIB); // 建立 inflaterIn
    
33.         //Poco::InflatingInputStream inflaterIn(in); // 建立 inflaterIn
    
34.         StreamCopier::copyStream(inflaterIn , out);
    
35.         //std::cout << "Inflate  Success  \n" ;
    
36.         //std::cout <<  out.str()  ;
    
37.         inflateStr = out.str();
    
38.         return inflateStr ;
    
39. }
    
40. 
    

复制代码

test.cpp

1. #include <cstdlib>
   
2. #include <iostream>
   
3. #include <string.h>
   
4. #include <string>
   
5. #include <stdio.h>
   
6. 
   
7. #include <ctime>
   
8. //#include <unistd.h>
   
9. #include <sys/time.h>
   
10. 
    
11. #include "zlib.h"
    
12. 
    
13. 
    
14. using namespace std;
    
15. 
    
16. 
    
17. int main (int argc, char *argv[])
    
18. {
    
19. 
    
20.         std::cout << "Zlib test start ...................\n" ;
    
21.         unsigned int i  ;
    
22.         unsigned int num ;
    
23. 
    
24. 
    
25. 
    
26.         //std::cout << std::endl ;
    
27.         Zlib zlib ; // init Zlib object
    
28.         std::string test2 = "{\"SID\":\"123456789\",\"BID\":\"LD0001\",\"DATA\":{\"args\":{\"name\":\"test1\",\"passwd\":\"test1\",\"item\":[\"itme1\",\"itme2\",\"itme3\",\"itme4\"]}}}" ;
    
29.         std::string inflate ;
    
30.         std::string deflate ;
    
31.         deflate = zlib.deflate(test2,-1);
    
32.         inflate = zlib.inflate(deflate);
    
33.         std::cout << "deflate attribute    : \n" << zlib.deflateStr << std::endl;
    
34.         std::cout << "deflate return       : \n" << deflate << std::endl;
    
35.         std::cout << "PHP deflate HEX : \n" ;
    
36.         for(i=0 ; i< zlib.deflateStr.length(); i++){
    
37.                 num = zlib.deflateStr[i] ;
    
38.                 std::cout << hex << num << " " ;
    
39.         }
    
40.         std::cout << std::endl ;
    
41.         std::cout << "inflate attribute    : \n" << zlib.inflateStr << std::endl;
    
42.         std::cout << "inflate return       : \n" << inflate << std::endl;
    
43.         std::cout << "Test the wrong compression string format : " << endl ;
    
44.         std::string wrongStr = "Input the wrong compression string........."  ;
    
45.         inflate = zlib.inflate(wrongStr);
    
46.         if(inflate == ""){
    
47.                 std::cout << ".........................The compression string is wrong!!" << endl;
    
48.         }
    
49.         std::cout << std::endl ;
    
50.         std::cout << std::endl ;
    
51. 
    
52. 
    
53.         /*
    
54.          *  BASE64 是我另外寫的一個元件庫....懶得貼 , 這裡不用測試 請淦掉.....
    
55. 
    
56.         std::cout << "gzip test start ...................\n" ;
    
57.         std::string test3 = "q1YK9nRRslIyNDI2MTUzt7BU0lFyAov4uBgYGBgCuS6OIY5KVtVKiUXpxSA6LzE3FShfklpcApIuSCwuLk9BEsgsSc1VsooG0rmpEH5uqhGUNobSJkqxtbW1AA==" ;
    
58.         std::cout << "PHP gzInflate & Base64Decode string is : \n" ;
    
59.         std::cout << test3 << std::endl ;
    
60.         std::cout << std::endl ;
    
61.         decode = base64.decode(test3);
    
62.         std::cout << "Base64 Decode attribute    : \n" << base64.decodeStr << std::endl;
    
63.         std::cout << std::endl ;
    
64. 
    
65.         std::cout << "PHP deflate HEX : \n" ;
    
66.         for(i=0 ; i< base64.decodeStr.length(); i++){
    
67.                 num = base64.decodeStr[i] ;
    
68.                 std::cout << hex << num << " " ;
    
69.         }
    
70.         std::cout << std::endl ;
    
71. 
    
72. 
    
73.         std::cout << std::endl ;
    
74.         inflate = zlib.gzinflate(decode);
    
75.         std::cout << "Gzip Inflate String : \n" << inflate << std::endl; ;
    
76.         std::cout << std::endl ;
    
77.           */
    
78. 
    
79. 
    
80.         std::cout << std::endl ;
    
81.         std::cout << std::endl ;
    
82.         std::cout << "zlib deflate : \n" ;
    
83.         deflate = zlib.gzdeflate(test2,-1);
    
84.         std::cout << "gzdeflate attribute    : \n" << zlib.deflateStr << std::endl;
    
85.         std::cout << std::endl ;
    
86.         std::cout << "GZIP deflate HEX : \n" ;
    
87.         for(i=0 ; i< zlib.deflateStr.length(); i++){
    
88.                 num = zlib.deflateStr[i] ;
    
89.                 std::cout << hex << num << " " ;
    
90.         }
    
91.         std::cout << std::endl ;
    
92. 
    
93.         std::cout << "Gzip indeflate : \n" ;
    
94. 
    
95.         inflate = zlib.gzinflate(deflate);
    
96.         std::cout << "Gzip Inflate String : \n" << inflate << std::endl; ;
    
97. 
    
98. }

复制代码

fiendcly

這是我碰到這個問題時的討論主題 :

http://bbs.chinaunix.net/thread-3766361-1-1.html
http://bbs.ecstart.com/thread-43305-1-1.html