asyncore.md

1> **Источник:** https://python-all.ru/3.0/library/asyncore.html2>3> «Документация Python на русском» – неофициальный перевод официальной документации Python: версии от 2.6 до 3.16, полнотекстовый поиск, английский оригинал рядом с переводом. Эта Markdown-версия страницы предназначена для работы с LLM: вставьте её в ChatGPT, Claude или Cursor.45---67# `asyncore` – Асинхронный обработчик сокетов89Этот модуль предоставляет базовую инфраструктуру для написания клиентов и серверов асинхронных сокетных служб.1011Есть только два способа заставить программу на одном процессоре делать «более одного дела одновременно». Многопоточное программирование – самый простой и популярный способ, но есть и другой, совершенно иной метод, который даёт почти все преимущества многопоточности без использования нескольких потоков. Он действительно практичен только в том случае, если программа в основном связана с вводом-выводом. Если программа загружает процессор, то, вероятно, на самом деле требуются вытесняющие потоки с планированием. Однако сетевые серверы редко бывают привязаны к процессору.1213Если ваша операционная система поддерживает системный вызов `select` в своей библиотеке ввода-вывода (а так делают почти все), вы можете использовать его для одновременной работы с несколькими каналами связи; выполняя другую работу, пока ваш ввод-вывод происходит в «фоне». Хотя такая стратегия может показаться странной и сложной, особенно поначалу, во многих отношениях она проще для понимания и управления, чем многопоточное программирование. Модуль `asyncore` решает многие сложные проблемы, превращая задачу построения сложных высокопроизводительных сетевых серверов и клиентов в простую задачу. Для «диалоговых» приложений и протоколов незаменим модуль-компаньон [`asynchat`](https://python-all.ru/3.0/library/asynchat.html#module-asynchat) модуль.1415Основная идея обоих модулей – создать один или несколько сетевых *каналов*, экземпляров классов [`asyncore.dispatcher`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher) и [`asynchat.async_chat`](https://python-all.ru/3.0/library/asynchat.html#asynchat.async_chat). Создание каналов добавляет их в глобальную карту, используемую функцией [`loop()`](https://python-all.ru/3.0/library/asyncore.html#asyncore.loop), если вы не предоставите ей собственную *карту*.1617После создания начального канала (или каналов) вызов функции [`loop()`](https://python-all.ru/3.0/library/asyncore.html#asyncore.loop) активирует обслуживание каналов, которое продолжается до тех пор, пока последний канал (включая те, что были добавлены в карту во время асинхронного обслуживания) не будет закрыт.1819#### `[asyncore.loop]asyncore.loop([timeout[, use_poll[, map[, count]]]])`2021Enter a polling loop that terminates after count passes or all open channels have been closed. All arguments are optional. The *count* parameter defaults to None, resulting in the loop terminating only when all channels have been closed. The *timeout* argument sets the timeout parameter for the appropriate `select()` or `poll()` call, measured in seconds; the default is 30 seconds. The *use\_poll* parameter, if true, indicates that `poll()` should be used in preference to `select()` (the default is `False`).2223The *map* parameter is a dictionary whose items are the channels to watch. As channels are closed they are deleted from their map. If *map* is omitted, a global map is used. Channels (instances of [`asyncore.dispatcher`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher), [`asynchat.async_chat`](https://python-all.ru/3.0/library/asynchat.html#asynchat.async_chat) and subclasses thereof) can freely be mixed in the map.2425#### `[asyncore.dispatcher]class asyncore.dispatcher`2627Класс [`dispatcher`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher) – это тонкая обёртка вокруг низкоуровневого сокетного объекта. Чтобы сделать его более полезным, у него есть несколько методов для обработки событий, которые вызываются из асинхронного цикла. В остальном его можно рассматривать как обычный неблокирующий сокетный объект.2829Возникновение низкоуровневых событий в определённые моменты или в определённых состояниях соединения сообщает асинхронному циклу, что произошли некоторые высокоуровневые события. Например, если мы запросили подключение сокета к другому хосту, мы знаем, что соединение установлено, когда сокет впервые становится доступным для записи (в этот момент можно писать в него, рассчитывая на успех). Подразумеваемые высокоуровневые события:3031| Событие | Описание |32| --- | --- |33| `handle_connect()` | Подразумевается первым событием записи |34| `handle_close()` | Подразумевается событием чтения, когда данные недоступны |35| `handle_accept()` | Подразумевается событием чтения на слушающем сокете |3637В процессе асинхронной обработки методы [`readable()`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher.readable) и [`writable()`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher.writable) каждого сопоставленного канала используются для определения, нужно ли добавить сокет канала в список каналов для опроса `select` или `poll` на предмет событий чтения и записи.3839Таким образом, набор событий канала шире, чем базовые события сокета. Полный набор методов, которые можно переопределить в вашем подклассе, приведён ниже:4041#### `[asyncore.dispatcher.handle_read]handle_read()`4243Вызывается, когда асинхронный цикл обнаруживает, что вызов4445`read()`4647на сокете канала завершится успешно.4849#### `[asyncore.dispatcher.handle_write]handle_write()`5051Вызывается, когда асинхронный цикл обнаруживает, что сокет, доступный для записи, можно записать. Часто этот метод реализует необходимую буферизацию для производительности. Например:5253```python54def handle_write(self):55    sent = self.send(self.buffer)56    self.buffer = self.buffer[sent:]57```5859#### `[asyncore.dispatcher.handle_expt]handle_expt()`6061Вызывается при наличии внеполосных данных (OOB) для сокетного соединения. Это почти никогда не происходит, так как OOB поддерживается слабо и редко используется.6263#### `[asyncore.dispatcher.handle_connect]handle_connect()`6465Вызывается, когда сокет активного инициатора действительно устанавливает соединение. Может, например, отправить приветственный баннер или инициировать согласование протокола с удалённой конечной точкой.6667#### `[asyncore.dispatcher.handle_close]handle_close()`6869Вызывается при закрытии сокета.7071#### `[asyncore.dispatcher.handle_error]handle_error()`7273Вызывается, когда возникает исключение, которое иначе не обрабатывается. Версия по умолчанию выводит сокращённую трассировку.7475#### `[asyncore.dispatcher.handle_accept]handle_accept()`7677Вызывается на прослушивающих каналах (пассивных открывателях), когда можно установить соединение с новой удалённой конечной точкой, которая выполнила вызов7879[`connect()`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher.connect)8081для данной локальной конечной точки.8283#### `[asyncore.dispatcher.readable]readable()`8485Вызывается на каждом проходе асинхронного цикла, чтобы определить, нужно ли добавить сокет канала в список, на котором могут происходить события чтения. Метод по умолчанию просто возвращает8687`True`8889, указывая, что по умолчанию все каналы заинтересованы в событиях чтения.9091#### `[asyncore.dispatcher.writable]writable()`9293Вызывается на каждом проходе асинхронного цикла, чтобы определить, нужно ли добавить сокет канала в список, на котором могут происходить события записи. Метод по умолчанию просто возвращает9495`True`9697, указывая, что по умолчанию все каналы заинтересованы в событиях записи.9899Кроме того, каждый канал делегирует или расширяет многие методы сокета. Большинство из них почти идентичны своим сокетным аналогам.100101#### `[asyncore.dispatcher.create_socket]create_socket(family, type)`102103Это идентично созданию обычного сокета и использует те же параметры создания. Обратитесь к документации104105[`socket`](https://python-all.ru/3.0/library/socket.html#module-socket)106107за информацией о создании сокетов.108109#### `[asyncore.dispatcher.connect]connect(address)`110111Как и для обычного объекта сокета,112113*address*114115– это кортеж, первый элемент которого – хост для подключения, а второй – номер порта.116117#### `[asyncore.dispatcher.send]send(data)`118119Отправляет120121*data*122123на удалённый узел сокета.124125#### `[asyncore.dispatcher.recv]recv(buffer_size)`126127Читает не более128129*buffer\_size*130131байт из удалённой конечной точки сокета. Пустая строка означает, что канал был закрыт с другого конца.132133#### `[asyncore.dispatcher.listen]listen(backlog)`134135Ожидает входящие соединения на сокете. Аргумент136137*backlog*138139задаёт максимальное количество соединений в очереди и должен быть не менее 1; максимальное значение зависит от системы (обычно 5).140141#### `[asyncore.dispatcher.bind]bind(address)`142143Привязывает сокет к адресу144145*address*146147. Сокет не должен быть уже привязан. (Формат148149*address*150151зависит от семейства адресов – см. выше.) Чтобы пометить сокет как повторно используемый (установив опцию152153`SO_REUSEADDR`154155), вызовите у объекта156157[`dispatcher`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher)158159метод160161`set_reuse_addr()`162163.164165#### `[asyncore.dispatcher.accept]accept()`166167Принимает соединение. Сокет должен быть привязан к адресу и находиться в состоянии ожидания соединений. Возвращаемое значение – пара168169`(conn, address)`170171, где172173*conn*174175– это176177*новый*178179объект сокета, который можно использовать для отправки и получения данных по соединению, а180181*address*182183– это адрес, привязанный к сокету на другом конце соединения.184185#### `[asyncore.dispatcher.close]close()`186187Закрывает сокет. Все последующие операции с объектом сокета будут завершаться ошибкой. Удалённый узел больше не будет получать данные (после отправки данных из очереди). Сокеты автоматически закрываются при сборке мусора.188189#### `[asyncore.file_dispatcher]class asyncore.file_dispatcher`190191file\_dispatcher принимает файловый дескриптор или файловый объект вместе с необязательным аргументом map и оборачивает его для использования с функциями192193`poll`194195или196197`loop`198199. Если передан файловый объект или что-либо с методом200201`fileno`202203, этот метод будет вызван и передан в конструктор204205[`file_wrapper`](https://python-all.ru/3.0/library/asyncore.html#asyncore.file_wrapper)206207. Доступность: UNIX.208209#### `[asyncore.file_wrapper]class asyncore.file_wrapper`210211file\_wrapper принимает целочисленный файловый дескриптор и вызывает212213[`os.dup()`](https://python-all.ru/3.0/library/os.html#os.dup)214215для дублирования дескриптора, чтобы исходный дескриптор можно было закрыть независимо от file\_wrapper. Этот класс реализует достаточное количество методов для эмуляции сокета для использования классом216217[`file_dispatcher`](https://python-all.ru/3.0/library/asyncore.html#asyncore.file_dispatcher)218219. Доступно: UNIX.220221## asyncore Пример базового HTTP-клиента222223Вот очень простой HTTP-клиент, который использует класс [`dispatcher`](https://python-all.ru/3.0/library/asyncore.html#asyncore.dispatcher) для реализации обработки сокетов:224225```python226import asyncore, socket227228class http_client(asyncore.dispatcher):229230    def __init__(self, host, path):231        asyncore.dispatcher.__init__(self)232        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)233        self.connect( (host, 80) )234        self.buffer = bytes('GET %s HTTP/1.0\r\n\r\n' % path, 'ascii')235236    def handle_connect(self):237        pass238239    def handle_close(self):240        self.close()241242    def handle_read(self):243        print(self.recv(8192))244245    def writable(self):246        return (len(self.buffer) > 0)247248    def handle_write(self):249        sent = self.send(self.buffer)250        self.buffer = self.buffer[sent:]251252c = http_client('www.python.org', '/')253254asyncore.loop()255```256