2

Сервер:

import socket
import threading
import sys

sock = socket.socket()
sock.bind(('192.168.0.100', 1080))
sock.listen(3)
conn = []

def Reciver():
    while 1:
        for i in range(len(conn)):
            try:
                data = conn[i].recv(1024)
                if data:
                    print(data.decode())
            except socket.error as e:
                if e.errno == 10053:
                    conn.pop(i)
                    print("Подключено пользователй:", len(conn))
                else:
                    raise

def Sender():
    while 1:
        global conn
        message = input()
        if message:
            for i in range(len(conn)):
                conn[i].send(message.encode())

def Accepter():
    while 1:
        global conn
        conn.append(sock.accept()[0])
        print("Подключено пользователй:", len(conn))


# init threads
t1 = threading.Thread(target=Reciver)
t2 = threading.Thread(target=Sender)
t3 = threading.Thread(target=Accepter)

# start threads
t1.start()
t2.start()
t3.start()

Код клиента:

import socket
import threading
import sys

host = "192.168.0.100"
port = 1080
sock = socket.socket()
sock.connect((host, port))

def Reciver():
    while 1:
        data = sock.recv(1024)
        if data:
            print(data.decode())

def Sender():
    while 1:
        message = input()
        if message == "exit":
            sock.close()
            sys.exit()
        else:
            sock.send(message.encode())

# init threads
t1 = threading.Thread(target=Reciver)
t2 = threading.Thread(target=Sender)

# start threads
t1.start()
t2.start()

Проблемы: При подключении 2 клиентов получается что нормально писать может только сервер, а от клиентов приходят багнутые сообщения. А еще при отключении клиентов, сервер долго это понимает из-за чего при отключении 2 сразу происходит баг и отключается только 1, и выдается ошибка, после которой не работает отправка сообщений ни на сервере ни на клиенте..

6
  • 1
    В Интернете так же полно инструкций по многопоточности. Если вы действительно поймёте инструкции по обеим темам, то для вас не составит труда их объединить. 23 июн 2017 в 6:01
  • Можете объяснить как принимать все входящие соединения и потом посылать сообщения сразу всем подключенным? 23 июн 2017 в 6:05
  • Добавлять каждое новое подключение в список. Потом обходить список в цикле и отправлять сообщение в каждый сокет. 23 июн 2017 в 6:18
  • Код добавил. Почему мне ошибку кидает, и как удалять при отключении из списка? 23 июн 2017 в 6:28
  • Добавьте ещё полный текст ошибки. 23 июн 2017 в 6:30

1 ответ 1

3

socket.accept() возвращает кортеж из сокета и адреса. Поэтому вам надо либо код conn.append(sock.accept()) поменять на conn.append(sock.accept()[0]), либо код conn[i].send(message.encode()) на conn[i][0].send(message.encode()).

У вас в коде есть ещё немало мест, которые стоило бы изменить, но конкретно к этой ошибке они не относятся.

UPDATE:

try:
    conn[i].send(message.encode())
except socket.error as e:
    if e.errno == errno.ECONNRESET:
        # Сокет закрыт
        # обрабатываем этот факт каким-либо образом
    else:
        # Какая-то другая ошибка
        # пробрасываем её дальше
        raise
19
  • Хорошо, сообщения с сервера клиенту доходят, теперь осталось вот что сделать: Удалять из списка при отключении и наладить отправку с клиента к серверу сообщения, я попробую наладить отправку с клиента,а вы расскажите как понять что человек отключился) 23 июн 2017 в 6:49
  • Отправка клиент - сервер починил) 23 июн 2017 в 6:55
  • Правильный вариант - отправка клиентом сообщения об отключении. Проверяйте его так же, как сообщение exit проверяете. А вот нештатное отключение можно обнаружить только попытавшись прочитать из закрытого сокета и нарвавшись на ошибку. Самый простой способ - завернуть операции чтения\записи в try-catch и в обработчике socket.error удалять сбойные сокеты. 23 июн 2017 в 7:03
  • А как это реализовать? Можно пример хотя бы? 23 июн 2017 в 7:06
  • Дополнил ответ. Только не пытайтесь удалить сокет из списка, который обходите в цикле. Это само по себе может привести к приключениям, а в многопоточной среде - это натурально выстрел в ногу™. 23 июн 2017 в 7:17

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.