Непрерывная потоковая передача пользовательского TCP / IP до завершения

Question

tl; dr: Как разработать программу сокетов TCP / IP, в которой клиент многократно принимает строку ввода пользователя и записывает ее в поток, а сервер повторно читает из потока, пока пользователь не прервет поток данных.

Как я могу изменить приведенный ниже программный код Клиент / Сервер для повторной отправки и получения данных между собой. На данный момент я могу отправить любую длину данных, но как только я нажму клавишу Return , данные прекратятся. Я хочу использовать исключение KeyboardInterrupt , чтобы пользователь мог непрерывно отправлять данные на сервер, а сервер выплевывал одни и те же данные обратно клиенту, пока пользователь не нажмет Ctrl + C . Кажется, это не работает, возможно, моя логика где-то не так.

Пожалуйста, посмотрите:

клиентская программа:

# TCP Client

import socket
import sys

# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# Connect the socket to the port where the server is listening
server_address = ('localhost', 10000)
print >> sys.stderr, 'connecting to %s port %s' % server_address
sock.connect(server_address)

try:
    # Send data
    message = raw_input()  # obtain user input

    print >> sys.stderr, 'sending "%s"' % message
    sock.sendall(message)

    # Look for the response
    amount_received = 0
    amount_expected = len(message)

    while amount_received < amount_expected:
        data = sock.recv(16)
        amount_received += len(data)
        print >> sys.stderr, 'received "%s"' % data
except KeyboardInterrupt:  # Ctrl+C causes KeyboardInterrupt to occur
    print >> sys.stderr, 'closing socket'
    sock.close()

Серверная программа:

# TCP Server

import socket
import sys

# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# Bind the socket to the port
server_address = ('localhost', 10000)
print >> sys.stderr, 'starting up on %s port %s' % server_address
sock.bind(server_address)

# Listen for incoming connections
sock.listen(1)

while True:
    # Wait for a connection
    print >> sys.stderr, 'waiting for a connection'
    connection, client_address = sock.accept()

    try:
        print >> sys.stderr, 'connection from', client_address

        # Receive the data in small chunks and retransmit it
        while True:
            data = connection.recv(16)
            print >> sys.stderr, 'received "%s"' % data
            if data:
                print >> sys.stderr, 'sending data back to the client'
                connection.sendall(data)
            else:
                print >> sys.stderr, 'no more data from', client_address
                break

    finally:
        # Clean up the connection
        connection.close()