Socket close handler and proxy

Question

im, выполняющий некоторые базовые программирование сокетов в python. Но у меня возникли проблемы с выяснением того, как мой echoserver мог заметить, что эхоклиент закрыл его соединение, без постоянного пинга/понга или таймаута.

echoclient.py

#echoclient 
import sys 
import socket 
import os 
import datetime 

def log(s): 
    return datetime.datetime.now().strftime('%H:%M:%S') + ' - ' + s 

s = socket.socket(
    socket.AF_INET, socket.SOCK_STREAM) 

s.connect(('127.0.0.1', 9000)) 

while 1: 
    try: 
     foo = raw_input('what do you want to send?: ') 
     if len(foo) > 0: 
      s.send(foo) 
    except KeyboardInterrupt: 
     print 'shutting down connection' 
     s.close() 
     break 
    data = s.recv(1024) 
    if data: 
     print log('Recieved'), repr(data) 

echoserver.py

#echoserver 
import sys 
import socket 
import os 
import datetime 

def log(s): 
    return datetime.datetime.now().strftime('%H:%M:%S') + ' - ' + s 

port = 9000 

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
s.bind(('127.0.0.1', port)) 
s.listen(5) 

while 1: 
    conn, addr = s.accept() 
    conn.settimeout(10) 
    print 'Connected by', addr 
    while 1: 
     try: 
      data = conn.recv(1024) 
      if data: 
       print log(repr(data)) 
       conn.send(data) 
     except KeyboardInterrupt: 
      print 'Closing connection ', addr 
      conn.close() 
      sys.exit(1) 
     except: 
      print 'Exception caught! closing connection ', addr 
      conn.close() 
      break   

Теперь единственный способ сервер знает, что клиент умер находится в conn.settimeout (10)

1. Как я могу получить исключение для своего сервера, когда клиент отключается предпочтительно без сообщения pt/pong-сообщения betw их или установление.

2. Мой следующий шаг - создать эхопрокси между эхоклиентом и echoserver, мне нужно будет использовать потоки/многопроцессорность, чтобы достичь этого? Любые советы или указатели?

3. Что еще вы должны комментировать плохие/хорошие практики приветствуются

Спасибо!

Answer 1

Это было мое понимание библиотеки сокетов уже получает сообщение, когда clients disconnect.

Строго говоря, вы должны использовать выключение на розетке, прежде чем закрыть его. Выключение - это рекомендация к разъему на другом конце. В зависимости от аргумента, который вы передаете, это может означать, что «я больше не буду отправлять, но я все равно буду слушать», или «Я не слушаю, хорошее избавление!». Однако большинство библиотек сокетов используются для программистов, пренебрегая использованием этой этикетки, которая обычно близка к тому же, что и shutdown(); Закрыть(). Поэтому в большинстве ситуаций явное закрытие не требуется.

Сервер может обнаруживать «EOF» посредством приема 0 байтов. Он может предположить, что у него есть полный запрос. Сервер отправляет ответ. Если отправка завершена успешно, действительно, клиент все еще получает.

Когда другие концы разъединяются внезапно (например, сетевая ошибка или сбой), когда таймаут вступает в игру.

В вашем сервере кода выше, вы должны быть в состоянии немедленно обнаружить клиент отсоединяется с помощью:

if data: 
    # process data 
else: 
    # client disconnected 

Answer 2

Библиотека сокетов Python представляет собой реализацию на низком уровне, поэтому ее сложно использовать. Я бы рекомендовал использовать что-то более высокое, например Twisted. Вы можете выполнить именно то, что вы ищете, в Twisted с помощью метода connectLost.

from twisted.internet.protocol import Protocol 

class Echo(Protocol): 
    def connectLost(self, reason): 
     pass 

См. http://twistedmatrix.com/documents/current/core/howto/servers.html для получения дополнительной информации.

(Twisted также может сделать прокси проще реализовать, а также.)

Answer 3

Использование socket.shutdown() перед вызовом socket.close().Прочтите примечание для socket.close()here