Чтение буфера сокета с использованием asyncore

Question

Я новичок в Python (я программировал в Java уже несколько лет), и я работаю над простым сетевым приложением на основе сокетов (просто для удовольствия). Идея состоит в том, что мой код подключается к удаленной конечной точке TCP, а затем прослушивает любые данные, передаваемые с сервера клиенту, и выполняет некоторые синтаксические разборки по этому вопросу.

Данные, перемещаемые с сервера -> клиент, кодируются в кодировке UTF-8, а каждая строка разделяется CRLF (\x0D\x0A). Вы, наверное, догадались: идея заключается в том, что клиент подключается к серверу (до его отмены пользователем), а затем считывает и анализирует строки по мере их поступления.

Мне удалось заставить это работать, Я не уверен, что я делаю это совершенно правильно. Итак, мои актуальные вопросы (код):

1. Это правильный способ сделать это в Python (то есть это действительно так просто)?
2. Любые советы/рекомендации/полезные ресурсы (кроме справочной документации) относительно буферов/asyncore?

В настоящее время данные считываются и буферном следующим образом:

def handle_read(self): 
    self.ibuffer = b"" 

    while True: 
     self.ibuffer += self.recv(self.buffer_size) 
     if ByteUtils.ends_with_crlf(self.ibuffer): 
      self.logger.debug("Got full line including CRLF") 
      break 
     else: 
      self.logger.debug("Buffer not full yet (%s)", self.ibuffer) 

    self.logger.debug("Filled up the buffer with line") 
    print(str(self.ibuffer, encoding="UTF-8")) 

ByteUtils.ends_with_crlf функция просто проверяет последние два байта буфера для \x0D\x0A. Первый вопрос является основным (на это основан ответ), но любые другие идеи/советы оценены. Благодарю.

Answer 1

TCP - это поток, и вам не гарантируется, что ваш буфер не будет содержать конца одного сообщения и начала следующего. Итак, проверка на \ n \ r в конце буфера не будет работать должным образом во всех ситуациях. Вы должны проверить каждый байт в потоке.

И я настоятельно рекомендую вам использовать Twisted вместо asyncore. Что-то вроде этого (из памяти, может не работать из коробки):

from twisted.internet import reactor, protocol 
from twisted.protocols.basic import LineReceiver 


class MyHandler(LineReceiver): 

    def lineReceived(self, line): 
     print "Got line:", line 


f = protocol.ClientFactory() 
f.protocol = MyHandler 
reactor.connectTCP("127.0.0.1", 4711, f) 
reactor.run() 

Answer 2

Это даже проще - посмотреть на asynchat и его set_terminator метод (и другие полезные лакомые кусочки в этом модуле). Twisted на порядок более богатый и мощный, но для достаточно простых задач асинхронные и асинхронные (которые предназначены для взаимодействия гладко) действительно очень просты в использовании, как вы начали наблюдать.