python socket

@VasR228 · Регистрация: 07.02.2021

Author24 — интернет-сервис помощи студентам

good afternoon, could you help me with socket. when connecting the user, it outputs "Enable trace malloc to get the object allocation traceback", and no data is transmitted between users . program code

добрый день, не могли бы вы помочь мне с socket. при подключении пользователя он выводит "Enable trace malloc to get the object allocation traceback", и данные между пользователями не передаются . код программы

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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
    import socket
    
    import asyncio
    
    class Socket: 
        def __init__(self):
            self.socket=socket.socket(
                socket.AF_INET,  
                socket.SOCK_STREAM,  
            )
            self.main_loop = asyncio.get_event_loop() 
    
    
        async def send_data(self, data):
            raise NotImplementedError()
    
    
        async def listen_socket(self, listen_socket=None):
            raise NotImplementedError()
    
        async def main(self):
            raise NotImplementedError()
    
        def start(self):
            self.main_loop.run_until_complete(self.main())
    
        async def set_up(self):
            raise NotImplementedError()
    
    
    
    -------------
    from Socket import Socket
    
    import asyncio
    
    
    
    
    class Server(Socket):
        def __init__(self):
            super(Server, self).__init__()
            #self.socket.listen(5)
            self.users = []  
    
        def set_up(self):
            self.socket.bind(("127.0.0.1", 1234))
            print("Сервер запусщин")
            self.socket.listen(5)
            self.socket.setblocking(False)
    
    
        async def send_data(self, data):
            for user in self.users:
                await self.main_loop.sock_sendall(user, data)  
    
    
        async def listen_socket(self, listen_socket=None):
            while True:
                data = self.main_loop.sock_recv(listen_socket ,2048)
                print(f"user sent {data}")
    
                await self.send_data(data) 
    
    
        async def accept_socket(self):
    
            while True:
                user_socket, address = await self.main_loop.sock_accept(self.socket)
                print(f"подключение пользователя >>>{address[0]}")
    
                self.users.append(user_socket)
    
    
                self.main_loop.create_task(self.listen_socket(user_socket))
    
    
    
    
        async def main(self):
            await self.main_loop.create_task(self.accept_socket())
    
    
    if __name__ == '__main__':
        server = Server()
        server.set_up()
        server.start()
    
    
    --------------------
    from Socket import Socket
    
    from datetime import datetime
    import asyncio
    import os
    
    
    
    
    class Client(Socket):
    
        def __init__(self):
            super(Client, self).__init__()
            self.messages = "" 
    
    
        def set_up(self):
            self.socket.connect(("127.0.0.1", 1234))
            self.socket.setblocking(False)
    
    
        async def listen_socket(self, listen_socket=None):
            while True:
                data=await self.main_loop.sock_recv(self.socket, 2048)
                self.messages += f"{datetime.now()} - {data.decode()} \n"
    
                os.system("cls")
                print(self.messages)
    
    
        async def send_data(self, data=None):
            while True:
                data = await  self.main_loop.run_in_executor(None, input, ":::")
                await self.main_loop.sock_sendall(self.socket, data.encode("utf-8"))
    
    
        async def main(self):
            await asyncio.gather(
                self.main_loop.create_task(self.listen_socket()),
                self.main_loop.create_task(self.send_data())
            )
    
    
    
    if __name__=="__main__":
        client=Client()
        client.set_up()
    
        client.start()

Новые блоги и статьи Все статьи Все блоги /
Реализация многопоточных сетевых серверов на Python py-thonny 16.05.2025 Когда сталкиваешься с необходимостью писать высоконагруженные сетевые сервисы, выбор технологии имеет критическое значение. Python, со своей элегантностью и высоким уровнем абстракции, может. . .	C# и IoT: разработка Edge приложений с .NET и Azure IoT UnmanagedCoder 16.05.2025 Мир меняется прямо на наших глазах, и интернет вещей (IoT) — один из главных катализаторов этих перемен. Если всего десять лет назад концепция "умных" устройств вызывала скептические улыбки, то. . .	Гибридные квантово-классические вычисления: Примеры оптимизации EggHead 16.05.2025 Гибридные квантово-классические вычисления — это настоящий прорыв в подходах к решению сложнейших вычислительных задач. Представьте себе союз двух разных миров: классические компьютеры, с их. . .	Использование вебсокетов в приложениях Java с Netty Javaican 16.05.2025 HTTP, краеугольный камень интернета, изначально был спроектирован для передачи гипертекста с минимальной интерактивностью. Его главный недостаток в контексте современных приложений — это. . .	Реализация операторов Kubernetes Mr. Docker 16.05.2025 Концепция операторов Kubernetes зародилась в недрах компании CoreOS (позже купленной Red Hat), когда команда инженеров искала способ автоматизировать управление распределёнными базами данных в. . .
Отражение в C# и динамическое управление типами stackOverflow 16.05.2025 Reflection API в . NET — это набор классов и интерфейсов в пространстве имён System. Reflection, который позволяет исследовать и манипулировать типами, методами, свойствами и другими элементами. . .	Настройка гиперпараметров с помощью Grid Search и Random Search в Python AI_Generated 15.05.2025 В машинном обучении существует фундаментальное разделение между параметрами и гиперпараметрами моделей. Если параметры – это те величины, которые алгоритм "изучает" непосредственно из данных (веса. . .	Сериализация и десериализация данных на Python py-thonny 15.05.2025 Сериализация — это своего рода "замораживание" объектов. Вы берёте живой, динамический объект из памяти и превращаете его в статичную строку или поток байтов. А десериализация выполняет обратный. . .	Чем асинхронная логика (схемотехника) лучше тактируемой, как я думаю, что помимо энергоэффективности - ещё и безопасность. Hrethgir 14.05.2025 Помимо огромного плюса в энергоэффективности, асинхронная логика - тотальный контроль над каждым совершённым тактом, а значит - безусловная безопасность, где безконтрольно не совершится ни одного. . .	Многопоточные приложения на C++ bytestream 14.05.2025 C++ всегда был языком, тесно работающим с железом, и потому особеннно эффективным для многопоточного программирования. Стандарт C++11 произвёл революцию, добавив в язык нативную поддержку потоков,. . .

Опции темы