простой сервер с несколькими клиентами

Question

Я пытаюсь реализовать простой сервер с несколькими клиентами. Он должен получать данные из необходимого сокета, обрабатывать и затем отправлять данные другим клиентам. Я использую модуль select из стандартной библиотеки Python. Вот сервер:

class ProcessingServer:
    def __init__(self, bindaddress="localhost", portname=50001, maxqueue=5):
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.socket.bind((bindaddress, portname))
        self.socket.listen(maxqueue)
        self.inputsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.data = ""

    def connect_to_output(self, address, port):
        self.inputsocket.connect((address, port))

    def start(self):
        rsocks = []
        wsocks = []
        rsocks.append(self.socket)
        wsocks.append(self.inputsocket)
        self.socket.accept()

        while True:
            try:
                reads, writes, errs = select.select(rsocks, wsocks, [])
            except:
                return
            for sock in reads:
                if sock == self.socket:
                    client, address  = sock.accept()
                    rsocks.append(client)
                else:
                    self.socket.send(self.data)
                    rsocks.remove(sock) 
            for sock in writes:
               if sock == self.inputsocket:
                    self.data = sock.recv(512)
                    wsocks.remove(sock)
                    print repr(self.data)

Вот простой клиент:

import socket
mysocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
mysocket.connect(("localhost", 50001))
while True:
    data = mysocket.recv(512)
    print repr(data)
mysocket.close()

Приемная часть сервера работает нормально, но сервер не производит никакого вывода. У меня совсем нет опыта сетевого программирования, и мне кажется, что я что-то упустил.

Answer 1

В вашем скрипте есть несколько вещей, которые кажутся странными.

Стандартное использование модуля select таково: у вас есть один сокет для прослушивания соединений и один сокет на соединение с клиентами.

Сначала только этот сокет добавляется в ваш список потенциальных читателей, а ваш список потенциальных читателей пуст.

Вызов select.select (потенциальные читатели, потенциальные_пользователи, потенциальные_отказы) вернет 3 списка: -Сокеты, готовые к чтению - Сокеты, готовые к записи - Сокеты с ошибкой

В списке сокетов, готовых к чтению, если сокет прослушивает соединение, он должен принять его и поместить новый сокет впотенциальные чтения, потенциальные записи и потенциальные ошибки.

Если сокет другой, то есть данные для чтения из этого сокета.Вы должны позвонить в sock.recv (длина)

Если вы хотите отправить данные, вы должны отправить их из списка wlist, возвращаемого select.select.

Список ошибок используется не оченьчасто.

---

Теперь, для решения вашей проблемы, способа, которым вы описываете свой протокол (если я правильно понял), это может выглядеть так:

import socket, select

sock_producer = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock_producer.bind(('localhost', 5000))
sock_producer.listen(5)
producers = []    

clients = []
sock_consumer_listener = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# Note: different port to differentiate the clients who receive data from the one who sends messages
sock_consumer_listener.bind(('localhost', 5001))

rlist = [sock_producer, sock_listener]
wlist = []
errlist = []

out_buffer = []

while True:
    r, w, err = select.select(rlist, wlist, errlist)
    for sock in r:
        if sock == sock_producer:
            prod, addr = sock.accept()
            producers.append(prod)
            rlist.append(prod)
         elif sock == sock_consumer_listener:
            cons, addr = sock.accept()
            clients.append(cons)
            wlist.append(cons)
         else:
            out_buffer.append(sock.recv(1024))

     out_string = ''.join(out_buffer)
     out_buffer = []

     for sock in w:
         if sock in clients:
             sock.send(out_string)

У меня естьне тестировал этот код, поэтому может быть несколько ошибок, но это близко к тому, как я это сделаю.

Answer 2

Да ... используйте zeromq вместо:

server.py

import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://127.0.0.1:50001")

while True:
    msg = socket.recv()
    print "Got", msg
    socket.send(msg)

client.py

import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://127.0.0.1:50001")

for i in range(100):
    msg = "msg %s" % i
    socket.send(msg)
    print "Sending", msg
    msg_in = socket.recv()