Python: эхо-сервер UDP asyncore; закрытие сокета после отправки

Я пытаюсь написать UDP-сервер, который возвращает данные обратно, используя asyncore.dispatcher_with_send.

У меня проблема в том, что когда я устанавливаю буфер и вызываю self.send(self.buffer), кажется, что он вызывает handle_close и закрывает сокет.

import asyncore, socket,

class Server(asyncore.dispatcher_with_send): 

def __init__(self):
    asyncore.dispatcher.__init__(self)
    self.create_socket(socket.AF_INET, socket.SOCK_DGRAM)
    self.bind(('192.168.0.10', 1452))
    self.buffer = ''
    self.recvData = ''


def handle_close(self):
    self.close()

def handle_read(self):
    print self.recv(8192)
    self.buffer ='a'

def handle_write(self):
    if self.buffer != '':
        sent = self.send(self.buffer)
        self.buffer = self.buffer[sent:]


if __name__ == '__main__':

The_Server = Server()
asyncore.loop()

Любые идеи?

Спасибо


python sockets asyncore
person moonraker    schedule 26.05.2017    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Решение состояло в том, чтобы использовать sendto и убедиться, что адрес sendto был явным.

import asyncore, socket,

class Server(asyncore.dispatcher_with_send): 

def __init__(self):
    asyncore.dispatcher.__init__(self)
    self.create_socket(socket.AF_INET, socket.SOCK_DGRAM)
    self.bind(('192.168.0.10', 1452))
    self.buffer = ''
    self.recvData = ''


def handle_close(self):
    self.close()

def handle_read(self):
    print self.recv(8192)
    self.buffer ='a'

def handle_write(self):
    if self.buffer != '':
        sent = self.sendto(self.buffer,('192.168.0.9',1452))
        self.buffer = self.buffer[sent:]


if __name__ == '__main__':

The_Server = Server()
asyncore.loop()
person moonraker    schedule 26.05.2017
comment
Вы также могли бы вызвать self.connect(('192.168.0.9',1452)) в __init__ и продолжить использовать .send(). - person jasonharper; 26.05.2017