请问python里使用socket编程时的buf一般怎么实现的？

sjinny

我有在C++里使用socket的经验，但是卡在buf问题上了，简单地讲我需要的就是个典型的buf：
能够在socket.recv的时候把数据放进buf里，然后解析buf里的数据，把用过的数据丢弃掉，尽量减少memcpy/memmove和内存的重新申请……
目前解析收到的数据也很简单：扫描目前为止收到的数据，根据里面花括号对的配对情况来分辨JSON字典的边界，把每个最外层字典作为一个消息拿出去分派。
大家说说该看什么资料呢……谢谢……

Kabie

看标准库。。。

sjinny

恩我就是想问问buf方面要看标准库的哪个部分……recv()得到的似乎是个不可变的字符串

luffy.deng

回复 3# sjinny
用缓冲区我觉得可以这样。

1. 
   
2. import  array
   
3. import struct
   
4. buf=array.array('c',struct.pack('1024s',1024*''))
   
5. buf[0]='s'

复制代码

sjinny

恩我也看到了，我刚刚试着写了一个这个：

1. 
   
2. import array
   
3. 
   
4. class Buffer :
   
5.         def __init__( self, len ) :
   
6.                 self.__array= array.array( 'c', '\0'*len )
   
7.                 self.__databegin= 0
   
8.                 self.__datalen= 0
   
9. 
   
10.         def getFreespace( self, minlen ) :
    
11.                 rightSpace= self.__getRightSpace()
    
12.                 if rightSpace < minlen :
    
13.                         totalSpace= self.__databegin + rightSpace
    
14.                         if totalSpace < minlen :
    
15.                                 dlen= minlen - totalSpace
    
16.                                 self.__array.extend( '\0'*dlen )
    
17.                         self.__array[ 0:self.__datalen ]= self.__array[ self.__databegin:self.__datalen+self.__databegin ]
    
18.                 return buffer( self.__array, self.__databegin + self.__datalen, self.__getRightSpace() )
    
19. 
    
20.         def pushDataLen( self, len ) :
    
21.                 self.__datalen += len
    
22. 
    
23.         def getDataSpace( self ) :
    
24.                 return buffer( self.__array, self.__databegin, self.__datalen )
    
25. 
    
26.         def popDataLen( self, len ) :
    
27.                 len= min( len, self.__datalen )
    
28.                 self.__databegin += len
    
29.                 self.__datalen -= len
    
30.                 if self.__datalen == 0 :
    
31.                         self.__databegin= 0
    
32. 
    
33.         def __getRightSpace( self ) :
    
34.                 return len( self.__array ) - self.__databegin - self.__datalen
    
35. 
    

复制代码

但是发现……原来buffer竟然是只读的……
我知道socket.recv_into可以传入一个array，但是由于不能指定数据从哪个位置开始写入，所以我怀疑每次都是从头部开始，而如果这个array里还有之前的剩余数据，那么这些剩余数据就会被覆盖了……

sjinny

psock.rar (2.4 KB, 下载次数: 61)

2010-07-20 17:49 上传

点击文件名下载附件

基本搞定了buf……目前不够理想的地方就是在从socket recv数据时会多一次拷贝……