织梦CMS - 轻松建站从此开始！
高级搜索|网站地图|TAG标签RSS订阅[设为首页] [加入收藏]

罗索

搜索

热门标签:

当前位置: 主页>基础技术>高性能服务器>

bencoding编码解析器

落鹤生 发布于 2012-05-30 21:44 点击:次 
BT客户端开始一个下载首先要处理的就是torrent文件.而torrent文件使用bencoding编码.所以实现bencoding编码的解析器,就是第一步工作.
TAG:

BT客户端开始一个下载首先要处理的就是torrent文件.
而torrent文件使用bencoding编码.
所以实现bencoding编码的解析器,就是第一步工作.

Bencoding is done as follows:
Strings are length-prefixed base ten followed by a colon and the string. For example /'4:spam/' corresponds to /'spam/'.
Integers are represented by an /'i/' followed by the number in base 10 followed by an /'e/'. For example /'i3e/' corresponds to 3 and /'i-3e/' corresponds to -3. Integers have no size limitation. /'i-0e/' is invalid. All encodings with a leading zero, such as /'i03e/', are invalid, other than /'i0e/', which of course corresponds to 0.
Lists are encoded as an /'l/' followed by their elements (also bencoded) followed by an /'e/'. For example /'l4:spam4:eggse/' corresponds to [/'spam/', /'eggs/'].
Dictionaries are encoded as a /'d/' followed by a list of alternating keys and their corresponding values followed by an /'e/'. For example, /'d3:cow3:moo4:spam4:eggse/' corresponds to {/'cow/': /'moo/', /'spam/': /'eggs/'} and /'d4:spaml1:a1:bee/' corresponds to {/'spam/': [/'a/', /'b/']} . Keys must be strings and appear in sorted order (sorted as raw strings, not alphanumerics).

下面是实现的bencoding解码器的VC++源代码:

  1. // BEncode.h: interface for the CBEncode class. 
  2. // 
  3. ////////////////////////////////////////////////////////////////////// 
  4.  
  5. #if !defined(AFX_BENCODE_H__4D0BB462_2AE0_45B3_8BE8_19D51B2DBB2E__INCLUDED_) 
  6. #define AFX_BENCODE_H__4D0BB462_2AE0_45B3_8BE8_19D51B2DBB2E__INCLUDED_ 
  7.  
  8. #if _MSC_VER > 1000 
  9. #pragma once 
  10. #endif // _MSC_VER > 1000 
  11. #pragma warning( disable : 4786 ) 
  12. #pragma warning( disable : 4355 ) 
  13. #include <list> 
  14. #include <map> 
  15. #include <string> 
  16. #include <vector> 
  17. using namespace std; 
  18. enum BEncodeParserErrorCode 
  19. { 
  20.     enm_BEncodeErr_noerr = 0,//没有错误  
  21.     enm_BEncodeErr_errString,//错误的字符串 
  22.     enm_BEncodeErr_errInt,//错误的整型数据 
  23.     enm_BEncodeErr_errList,//错误的列表 
  24.     enm_BEncodeErr_errDict,//错误的词典结构 
  25.     enm_BEncodeErr_End,//文本结束 
  26.     enm_BEncodeErr_unknown//未知错误 
  27. }; 
  28. enum BEncodeObjectType 
  29. { 
  30.     enum_BEncodeType_Objectbase = 0,     
  31.     enum_BEncodeType_String, 
  32.     enum_BEncodeType_Int, 
  33.     enum_BEncodeType_List, 
  34.     enum_BEncodeType_Dict, 
  35. }; 
  36. class CBEncodeObjectBase 
  37. { 
  38. public: 
  39.     CBEncodeObjectBase(BEncodeObjectType type
  40.  = enum_BEncodeType_Objectbase){m_type = type;clear();} 
  41.     virtual ~CBEncodeObjectBase(){}; 
  42.     void clear(){szPos = NULL;m_error = enm_BEncodeErr_noerr;} 
  43. public: 
  44.     BEncodeObjectType m_type;   //对象类型 
  45.     char * szPos;   //对象在字符串中的位置 
  46.     int ilen;//对象的数据长度 
  47.     BEncodeParserErrorCode m_error;//错误值     
  48. }; 
  49. class CBEncodeInt : public CBEncodeObjectBase 
  50. { 
  51. public: 
  52.     CBEncodeInt() : CBEncodeObjectBase(enum_BEncodeType_Int) {} 
  53.     virtual ~CBEncodeInt(){}         
  54. public:  
  55.     int m_iValue;//整型对象的值 
  56. }; 
  57. class CBEncodeString : public CBEncodeObjectBase 
  58. { 
  59. public: 
  60.     CBEncodeString() : CBEncodeObjectBase(enum_BEncodeType_String) {m_szData = NULL;} 
  61.     virtual ~CBEncodeString(){}      
  62. public:  
  63.     bool getstring(string & strValue) 
  64.     { 
  65.         if(m_error == enm_BEncodeErr_noerr && m_szData) 
  66.         { 
  67.             strValue.assign(m_szData,m_ilen); 
  68.             return true; 
  69.         } 
  70.         return false; 
  71.     } 
  72.     char * m_szData; 
  73.     int m_ilen; 
  74. }; 
  75. class CBEncodeList : public CBEncodeObjectBase 
  76. { 
  77. public: 
  78.     CBEncodeList() : CBEncodeObjectBase(enum_BEncodeType_List) {} 
  79.     virtual ~CBEncodeList(){clear();} 
  80.     void clear() 
  81.     {            
  82.         list<CBEncodeObjectBase *>::iterator it; 
  83.         for(it = m_listObj.begin();it!=m_listObj.end();++it) 
  84.             delete (*it); 
  85.         m_listObj.clear(); 
  86.     } 
  87. public:  
  88.     list<CBEncodeObjectBase*> m_listObj; 
  89. }; 
  90. class CBEncodeDict : public CBEncodeObjectBase 
  91. { 
  92. public: 
  93.     CBEncodeDict() : CBEncodeObjectBase(enum_BEncodeType_Dict) {} 
  94.     virtual ~CBEncodeDict(){clear();} 
  95.     CBEncodeObjectBase* getvalue(const char * szName) 
  96.     { 
  97.         map<string,CBEncodeObjectBase*>::iterator it = m_mapObj.find(szName); 
  98.         if(it != m_mapObj.end()) 
  99.             return it->second; 
  100.         return NULL; 
  101.     } 
  102.     void clear() 
  103.     {            
  104.         list<CBEncodeObjectBase *>::iterator it; 
  105.         for(it = m_listObj.begin();it!=m_listObj.end();++it) 
  106.             delete (*it); 
  107.         m_listObj.clear(); 
  108.         m_mapObj.clear(); 
  109.     } 
  110. public:  
  111.     map<string,CBEncodeObjectBase*> m_mapObj;// 
  112.     list<CBEncodeObjectBase*> m_listObj;
  113. //真正的对象保存在list中,list是一个name对象一个value对象.map只是一个映射表,引用了指针而已 
  114. }; 
  115. class CBEncode 
  116. { 
  117. public: 
  118.     bool readint(char *szCurPos,int & iendpos,list<CBEncodeObjectBase*> & listObj); 
  119.     bool readstring(char *szCurPos,int & iendpos,list<CBEncodeObjectBase*> & listObj);   
  120.     bool readlist(char *szCurPos,int & iendpos,list<CBEncodeObjectBase*> & listObj);     
  121.     bool readdict(char *szCurPos,int & iendpos,list<CBEncodeObjectBase*> & listObj);     
  122.     bool parse(const char * szData); 
  123.     CBEncode(); 
  124.     virtual ~CBEncode(); 
  125.     void clear() 
  126.     {    
  127.         list<CBEncodeObjectBase *>::iterator it; 
  128.         for(it = m_listObj.begin();it!=m_listObj.end();++it) 
  129.             delete (*it); 
  130.         m_listObj.clear();   
  131.     } 
  132. public: 
  133.     list<CBEncodeObjectBase*> m_listObj; 
  134.     CBEncodeObjectBase* m_plastObj;//解析出来的最后一个对象 
  135.     char * m_szTxt; 
  136. }; 
  137.  
  138. #endif // !defined(AFX_BENCODE_H__4D0BB462_2AE0_45B3_8BE8_19D51B2DBB2E__INCLUDED_) 

BEncode.cpp

  1. // BEncode.cpp: implementation of the CBEncode class. 
  2. // 
  3. ////////////////////////////////////////////////////////////////////// 
  4.  
  5. #include "stdafx.h" 
  6. #include "BEncode.h" 
  7.  
  8. ////////////////////////////////////////////////////////////////////// 
  9. // Construction/Destruction 
  10. ////////////////////////////////////////////////////////////////////// 
  11.  
  12. CBEncode::CBEncode() 
  13. { 
  14.     m_plastObj = NULL; 
  15.     m_szTxt = NULL; 
  16. } 
  17.  
  18. CBEncode::~CBEncode() 
  19. { 
  20.     clear(); 
  21. } 
  22.  
  23. bool CBEncode::parse(const char *szData) 
  24. { 
  25.     if(szData == NULL||*szData==NULL) 
  26.         return false; 
  27.     clear(); 
  28.     m_szTxt = (char*)szData; 
  29.     char * szCurPos = (char*)szData; 
  30.     int iendpos; 
  31.     while(*szCurPos) 
  32.     {    
  33.         if(*szCurPos== 'i') 
  34.         { 
  35.             if(!readint(szCurPos,iendpos,m_listObj)) 
  36.                 break;//遇到任何错误都终止整个解析 
  37.             szCurPos+=iendpos; 
  38.         } 
  39.         else if(*szCurPos== 'l') 
  40.         { 
  41.             if(!readlist(szCurPos,iendpos,m_listObj)) 
  42.                 break; 
  43.             szCurPos+=iendpos; 
  44.         } 
  45.         else if(*szCurPos== 'd') 
  46.         { 
  47.             if(!readdict(szCurPos,iendpos,m_listObj)) 
  48.                 break; 
  49.             szCurPos+=iendpos; 
  50.         } 
  51.         else             
  52.         { 
  53.             if(!readstring(szCurPos,iendpos,m_listObj)) 
  54.                 break; 
  55.             szCurPos+=iendpos; 
  56.         } 
  57.     } 
  58.     if(*szCurPos==0&&m_plastObj->m_error == enm_BEncodeErr_noerr) 
  59.         return true; 
  60.     return false; 
  61. } 
  62. //从当前位置读取一个字符串 
  63. bool CBEncode::readstring(char *szCurPos,int & iendpos
  64. ,list<CBEncodeObjectBase*> & listObj) 
  65. {    
  66.     char * szTmp = szCurPos; 
  67.     CBEncodeString * pNewString = new CBEncodeString;    
  68.     pNewString->szPos = szCurPos; 
  69.  
  70.     char szLen[20]; 
  71.     int i = 0; 
  72.     while(*szTmp>='0'&&*szTmp<='9') 
  73.         szLen[i++]=*(szTmp++); 
  74.     szLen[i]=0; 
  75.     if(*szTmp==':') 
  76.     { 
  77.         int ilen = atoi(szLen); 
  78.         if(ilen>0) 
  79.         {    
  80.             pNewString->m_szData = ++szTmp; 
  81.             pNewString->m_ilen = ilen; 
  82.             szTmp+=ilen; 
  83.         } 
  84.         else 
  85.             pNewString->m_error = enm_BEncodeErr_errString; 
  86.     } 
  87.     else 
  88.         pNewString->m_error = enm_BEncodeErr_errString; 
  89.     listObj.push_back(pNewString); 
  90.     iendpos = szTmp-szCurPos;            
  91.     m_plastObj = pNewString; 
  92.     m_plastObj->ilen = iendpos; 
  93.     return pNewString->m_error == enm_BEncodeErr_noerr?true:false; 
  94. } 
  95. //读取一个整型数据 
  96. bool CBEncode::readint(char *szCurPos,int & iendpos
  97. ,list<CBEncodeObjectBase*> & listObj) 
  98. { 
  99.     char * szTmp = szCurPos; 
  100.     CBEncodeInt * pNewInt= new CBEncodeInt;  
  101.     pNewInt->szPos = szCurPos; 
  102.  
  103.     if(*szTmp == 'i') 
  104.     {    
  105.         szTmp++; 
  106.         char szLen[20]; 
  107.         int i = 0; 
  108.         while(*szTmp>='0'&&*szTmp<='9') 
  109.             szLen[i++]=*(szTmp++); 
  110.         szLen[i]=0; 
  111.         if(*szTmp=='e') 
  112.         { 
  113.             pNewInt->m_iValue = atoi(szLen);             
  114.             ++szTmp; 
  115.         } 
  116.         else 
  117.             pNewInt->m_error = enm_BEncodeErr_errInt; 
  118.     } 
  119.     else 
  120.         pNewInt->m_error = enm_BEncodeErr_errInt; 
  121.     listObj.push_back(pNewInt); 
  122.     iendpos = szTmp-szCurPos;    
  123.     m_plastObj = pNewInt; 
  124.     m_plastObj->ilen = iendpos; 
  125.     return pNewInt->m_error == enm_BEncodeErr_noerr?true:false; 
  126. } 
  127. //读取一个列表 
  128. bool CBEncode::readlist(char *szCurPos,int & iendpos
  129. ,list<CBEncodeObjectBase*> & listObj) 
  130. { 
  131.     char * szTmp = szCurPos; 
  132.     CBEncodeList * pNewList= new CBEncodeList; 
  133.     pNewList->szPos = szCurPos; 
  134.     if(*szTmp == 'l') 
  135.     { 
  136.         szTmp++; 
  137.         int ilistendpos; 
  138.         while(*szTmp!='e') 
  139.         { 
  140.             if(*szTmp== 'i') 
  141.             { 
  142.                 if(!readint(szTmp,ilistendpos,pNewList->m_listObj)) 
  143.                     break;//遇到任何错误都终止整个解析 
  144.                 szTmp+=ilistendpos; 
  145.             } 
  146.             else if(*szTmp== 'l') 
  147.             { 
  148.                 if(!readlist(szTmp,ilistendpos,pNewList->m_listObj)) 
  149.                     break; 
  150.                 szTmp+=ilistendpos; 
  151.             } 
  152.             else if(*szTmp== 'd') 
  153.             { 
  154.                 if(!readdict(szTmp,ilistendpos,pNewList->m_listObj)) 
  155.                     break; 
  156.                 szTmp+=ilistendpos; 
  157.             } 
  158.             else             
  159.             { 
  160.                 if(!readstring(szTmp,ilistendpos,pNewList->m_listObj)) 
  161.                     break; 
  162.                 szTmp+=ilistendpos; 
  163.             } 
  164.         }    
  165.         if(*szTmp!='e'||m_plastObj->m_error != enm_BEncodeErr_noerr) 
  166.             pNewList->m_error = enm_BEncodeErr_errList; 
  167.         else 
  168.             szTmp++; 
  169.     } 
  170.     else 
  171.         pNewList->m_error = enm_BEncodeErr_errList; 
  172.     listObj.push_back(pNewList); 
  173.     iendpos = szTmp-szCurPos; 
  174.     m_plastObj = pNewList; 
  175.     m_plastObj->ilen = iendpos; 
  176.     return pNewList->m_error == enm_BEncodeErr_noerr?true:false; 
  177. } 
  178. //读取一个字典 
  179. bool CBEncode::readdict(char *szCurPos,int & iendpos
  180. ,list<CBEncodeObjectBase*> & listObj) 
  181. { 
  182.     char * szTmp = szCurPos; 
  183.     CBEncodeDict * pNewDict= new CBEncodeDict; 
  184.     pNewDict->szPos = szCurPos;  
  185.     if(*szTmp == 'd') 
  186.     {        
  187.         szTmp++; 
  188.         int ilistendpos; 
  189.         string strname; 
  190.         while(*szTmp!='e') 
  191.         { 
  192.             if(!readstring(szTmp,ilistendpos,pNewDict->m_listObj)) 
  193.                 break; 
  194.             if(m_plastObj->m_type !=enum_BEncodeType_String) 
  195.                 break;           
  196.             strname.assign(((CBEncodeString *)m_plastObj)->m_szData
  197. ,((CBEncodeString *)m_plastObj)->m_ilen); 
  198.             szTmp+=ilistendpos; 
  199.             if(*szTmp== 'i') 
  200.             { 
  201.                 if(!readint(szTmp,ilistendpos,pNewDict->m_listObj)) 
  202.                     break;//遇到任何错误都终止整个解析 
  203.                 szTmp+=ilistendpos; 
  204.             } 
  205.             else if(*szTmp== 'l') 
  206.             { 
  207.                 if(!readlist(szTmp,ilistendpos,pNewDict->m_listObj)) 
  208.                     break; 
  209.                 szTmp+=ilistendpos; 
  210.             } 
  211.             else if(*szTmp== 'd') 
  212.             { 
  213.                 if(!readdict(szTmp,ilistendpos,pNewDict->m_listObj)) 
  214.                     break; 
  215.                 szTmp+=ilistendpos; 
  216.             } 
  217.             else             
  218.             { 
  219.                 if(!readstring(szTmp,ilistendpos,pNewDict->m_listObj)) 
  220.                     break; 
  221.                 szTmp+=ilistendpos; 
  222.             } 
  223.             pNewDict->m_mapObj.insert(pair<string
  224. ,CBEncodeObjectBase*>(strname,m_plastObj));             
  225.         }    
  226.         if(*szTmp!='e'||m_plastObj->m_error != enm_BEncodeErr_noerr) 
  227.             pNewDict->m_error = enm_BEncodeErr_errDict; 
  228.         else 
  229.             szTmp++; 
  230.     } 
  231.     else 
  232.         pNewDict->m_error = enm_BEncodeErr_errDict; 
  233.     listObj.push_back(pNewDict); 
  234.     iendpos = szTmp-szCurPos; 
  235.     m_plastObj = pNewDict;   
  236.     m_plastObj->ilen = iendpos; 
  237.     return pNewDict->m_error == enm_BEncodeErr_noerr?true:false; 
  238. } 

 


(lightest)
本站文章除注明转载外，均为本站原创或编译欢迎任何形式的转载，但请务必注明出处，尊重他人劳动，同学习共成长。转载请注明：文章转载自：罗索实验室 [http://www.rosoo.net/a/201205/16046.html]
本文出处：CSDN博客　作者：lightest 原文
顶一下
(2)
100%
踩一下
(0)
0%
------分隔线----------------------------
相关文章
发表评论
请自觉遵守互联网相关的政策法规，严禁发布色情、暴力、反动的言论。
评价:
表情:
用户名: 验证码:点击我更换图片
最新评论 进入详细评论页>>
栏目列表
将本文分享到微信
织梦二维码生成器
推荐内容
热点内容