主页 / 问题 / 901277
Accepted
Rich
Asked:2020-11-02 17:12:50 +0000 UTC2020-11-02 17:12:50 +0000 UTC

与服务器的连接断开时捕获异常

  • 772

当客户端与服务器断开连接时，服务器上会出现一堆错误。

如何将它们包含在异常中？

断开客户端后的错误

客户端.py

# Импорт библиотеки сокетов
import socket
def main():

 while True:
    # Локальный IP
    host = "127.0.0.1"

    # Порт
    port = 25565

    # Создание обьекта сокета
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

    try:
        # Подключение к серверу
        sock.connect((host, port))
    except:
        print("Could not connect")
        break
    print("Connected")

    while True:

        # Отправляемое сообщение
        print("Message: ")
        message = input()

        # Отправка сообщения
        sock.send(message.encode("utf8"))

        # Разбить данные получаемые с сервера на части
        data = sock.recv(1024).decode("utf8")

        # Вывести данные с сервера
        print(str(data))

        if not message:
            ans = input('\nDo you want to exit(y/n): ')
            if ans == 'y':
                break
            else:
                continue

    # Закрыть соединение
    sock.close()

if __name__ == '__main__':
  main()

服务器.py

# Импортируем библиотеку сокетов
import socket

# Импортируем библиотеку потоков
from _thread import *
import threading

print_lock = threading.Lock()

message = "Success!"
file = open("messages.txt", "w")


# Функция потока
def threaded(c):
    # "Общение" с клиентом. Разбить данные на части
    while True:
        data = c.recv(1024).decode("utf8")

        # Если данных больше нет, то метод ничего не возвращает
        if data:
            print(data)
            file.write(data)
            c.send(bytes(message.encode("utf8")))
        if not data:
            break

    # Закрыть подключение
    c.close()


def main():

  # Настройка хоста
  host = ""
  port = 25565

  # Создание обьекта сокета
  sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

  # Хост
  sock.bind((host, port))
  print("Socket binded to post ", port)

  # Максимальное количество подключений в очереди
  sock.listen(5)
  print("Socket is listening")

  # Цикл, пока пользователь не решит выйти
  while True:
    # Принять подключение
    conn, addr = sock.accept()

    print_lock.acquire()
    print("Connected to : ", addr[0], ":", addr[1])

    # Запустить новый поток
    start_new_thread(threaded(conn))
    # Закрыть подключение

    sock.close()


if __name__ == '__main__':
   main()
python-3.x

1 个回答

  1. Best Answer

    任何 Python 包都有用于错误处理的模块、类。

    对于套接字，它看起来像这样：

    import socket
#....
#....

except socket.error as e:
    print("Socket Error: {0}".format(e)
except Exception as e:
    print("Другая ошибка: {0}".format(e))

    或者，如果您想处理此“ConnectionResetError”错误

    就像这样：

    try:
    #...
except ConnectionResetError as e:
    print(e)

    这是您的脚本中的样子：

    # Импортируем библиотеку сокетов
import socket

# Импортируем библиотеку потоков
from _thread import *
import threading

print_lock = threading.Lock()

message = "Success!"
file = open("messages.txt", "w")


# Функция потока
def threaded(c):
    # "Общение" с клиентом. Разбить данные на части
    while True:
        try:
            data = c.recv(1024).decode("utf8")
        except ConnectionResetError as e:
            print(e)

        # Если данных больше нет, то метод ничего не возвращает
        if data:
            print(data)
            file.write(data)
            c.send(bytes(message.encode("utf8")))
        if not data:
            break

    # Закрыть подключение
    c.close()


def main():

  # Настройка хоста
  host = ""
  port = 25565

  # Создание обьекта сокета
  sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

  # Хост
  sock.bind((host, port))
  print("Socket binded to post ", port)

  # Максимальное количество подключений в очереди
  sock.listen(5)
  print("Socket is listening")

  # Цикл, пока пользователь не решит выйти
  while True:
     # Принять подключение
     conn, addr = sock.accept()

     print_lock.acquire()
     print("Connected to : ", addr[0], ":", addr[1])

     # Запустить новый поток
     start_new_thread(threaded(conn))
     # Закрыть подключение

  sock.close()


if __name__ == '__main__':
    main()
    • 0

相关问题