Форум программистов, компьютерный форум, киберфорум
Python: Сети
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.82/11: Рейтинг темы: голосов - 11, средняя оценка - 4.82
0 / 0 / 0
Регистрация: 18.12.2019
Сообщений: 42

Сокеты в пайтоне и потоки ?

25.12.2019, 07:50. Показов 2063. Ответов 6
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Всем привет ! Если представить что используя сокеты работает чат на пайтоне. То понятно что на сервере у каждого подключения должен быть свой поток(Thread). Но поток будет грузить память итд не плохо. А другого варианта нету ?
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
25.12.2019, 07:50
Ответы с готовыми решениями:

Сокеты в пайтоне или есть ли аналог ?
Всем привет ! Понятно что мессенджеры такие как ватсап или телеграм работают на сокетах. А иначе как отправить клиенту сигнал, о том что у...

Потоки и сокеты
Можно-ли с помощью одного сокета отправлять датаграммы в разных потоках? Имеет ли смысл, например например отправлять направление...

Потоки и сокеты
Сразу к коду: using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using...

6
Просто Лис
Эксперт Python
 Аватар для Рыжий Лис
5973 / 3735 / 1099
Регистрация: 17.05.2012
Сообщений: 10,791
Записей в блоге: 9
25.12.2019, 08:58
Я же тебе (?) объяснял, архитектуру современных приложений. Никто не создаёт отдельный поток (thread) на отдельное соединение. Открытые соединения лежат в пуле и почти не требуют ресурсов системы. Нужно отправить/прочитать данные - берётся соединение и выполняются действия.

There are a bunch of interfaces for different operating systems:
poll, epoll (linux)
kqueue, kevent (BSD)
select (crossplatform)
Вот пример:
Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
import select, socket, sys, Queue
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(0)
server.bind(('localhost', 50000))
server.listen(5)
inputs = [server]
outputs = []
message_queues = {}
 
while inputs:
    readable, writable, exceptional = select.select(inputs, outputs, inputs)
    for s in readable:
        if s is server:
            connection, client_address = s.accept()
            connection.setblocking(0)
            inputs.append(connection)
            message_queues[connection] = Queue.Queue()
        else:
            data = s.recv(1024)
            if data:
                message_queues[s].put(data)
                if s not in outputs:
                    outputs.append(s)
            else:
                if s in outputs:
                    outputs.remove(s)
                inputs.remove(s)
                s.close()
                del message_queues[s]
 
    for s in writable:
        try:
            next_msg = message_queues[s].get_nowait()
        except Queue.Empty:
            outputs.remove(s)
        else:
            s.send(next_msg)
 
    for s in exceptional:
        inputs.remove(s)
        if s in outputs:
            outputs.remove(s)
        s.close()
        del message_queues[s]
1
0 / 0 / 0
Регистрация: 18.12.2019
Сообщений: 42
26.12.2019, 08:44  [ТС]
message_queues[connection] = queue.queue()
AttributeError: module 'queue' has no attribute 'queue'

Добавлено через 2 минуты
Пишет такую ошибку

Добавлено через 5 минут
Ну все разобрался. Вместо Queue.Queue() писать queue.Queue(), а вместо Queue.Empty писать queue.Empty

Добавлено через 34 секунды
да писать import select, socket, sys, queue
0
0 / 0 / 0
Регистрация: 18.12.2019
Сообщений: 42
27.12.2019, 09:00  [ТС]
Глубже копнул. Так как у меня соединении будет несколько десятки тысяч, то select не справиться. По ходу нужно на epoll() надо поднимать. Хотя epoll() только на Linux системах работает. Этого и мне достаточно. Ведь я собираюсь на Centos 7 все это поднимать. Выводы правильные ?
0
Просто Лис
Эксперт Python
 Аватар для Рыжий Лис
5973 / 3735 / 1099
Регистрация: 17.05.2012
Сообщений: 10,791
Записей в блоге: 9
27.12.2019, 09:03
Наверное.

Хотя я до сих пор не понимаю для какой задачи может потребоваться держать постоянно открытыми соединения и писать свой велосипед на серверной стороне. Наверняка есть готовые решения, тот джаббер, например.
0
0 / 0 / 0
Регистрация: 18.12.2019
Сообщений: 42
27.12.2019, 09:38  [ТС]
Ну ватсап, телеграм все они держать открытыми. Интернет магазины итд.
0
153 / 148 / 66
Регистрация: 20.02.2014
Сообщений: 556
31.12.2019, 02:12
Цитата Сообщение от antihacker1981 Посмотреть сообщение
Так как у меня соединении будет несколько десятки тысяч,
asyncio
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
31.12.2019, 02:12
Помогаю со студенческими работами здесь

Потоки и сокеты
TServer *Server; //--------------------------------------------------------------------------- DWORD OpenSrv(){ SOCKET s; char...

Асинхронные сокеты или потоки ?
Ребят qq, что лучше подойдёт: асинхронные сокеты или потоки ? Если, 1) игровой сервер ( менее 10 игроков ) , но с постоянным общением...

TCP сокеты и потоки для клиентов
Как держать клиентов по TCP? Вот к примеру я получаю соединение в 1 потоке и передаю чтение в другой поток. Но при 4 потоках мой комп...

Сокеты, потоки и доступ к элементам формы из дочернего потока
Добрый день. Задача "на человеческом языке" звучит так: при открытии дочерней формы устанавливается соединение с сервером и...

Передача изображения с веб камеры через сокеты, потоки js py
Я дебил сразу признаюсь. У меня есть проблема, мне надо, чтобы код .py создавал определенный поток данных (кадров). На другом конце мой .js...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
7
Ответ Создать тему
Новые блоги и статьи
Символьное дифференцирование
igorrr37 13.02.2026
/ * Логарифм записывается как: (x-2)log(x^2+2) - означает логарифм (x^2+2) по основанию (x-2). Унарный минус обозначается как ! */ #include <iostream> #include <stack> #include <cctype>. . .
Камера Toupcam IUA500KMA
Eddy_Em 12.02.2026
Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу
zbw 12.02.2026
И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.
«Знание-Сила»
zbw 12.02.2026
«Знание-Сила» «Время-Деньги» «Деньги -Пуля»
SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 12.02.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 11.02.2026
Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL3_image
8Observer8 10.02.2026
Содержание блога Библиотека SDL3_image содержит инструменты для расширенной работы с изображениями. Пошагово создадим проект для загрузки изображения формата PNG с альфа-каналом (с прозрачным. . .
Установка Qt-версии Lazarus IDE в Debian Trixie Xfce
volvo 10.02.2026
В общем, достали меня глюки IDE Лазаруса, собранной с использованием набора виджетов Gtk2 (конкретно: если набирать текст в редакторе и вызвать подсказку через Ctrl+Space, то после закрытия окошка. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru