0

我只能将数据发送到连接，我可以这样做吗？

服务器：

import asyncore, socket, threading

class EchoHandler(asyncore.dispatcher_with_send):
    def __init__(self,sock):
        asyncore.dispatcher.__init__(self,sock=sock);
        self.out_buffer = ''

    def handle_read(self):
        datos = self.recv(1024);
        if datos:
            print(datos);
            self.sock[0].send("signal");

class Server(asyncore.dispatcher):

    def __init__(self,host='',port=6666):
        asyncore.dispatcher.__init__(self);
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM);
        self.set_reuse_addr();
        self.bind((host,port));
        self.listen(1);

    def handle_accept(self):
        self.sock,self.addr = self.accept();
        if self.addr:
            print self.addr[0];
        handler = EchoHandler(self.sock);

    def handle_close(self):
        self.close();     

cliente = Server();
asyncore.loop()

这一行是一个失败的例子，但我想将数据发送到零袜子：

self.sock[0].send("probando");

例如，如果我有 5 个套接字，请选择向谁发送数据

4

1 回答 1

5

解释

您试图从列表中获取 sock 并执行其发送方法。这会导致错误，因为EchoHandler既没有 sock 属性也不是套接字列表。正确的方法是获取EchoHandler您想要的实例（例如，基于 IP 地址或某些用户定义协议分配的插槽），然后使用其发送方法 - 在这里（使用dispatcher_with_send）它也比使用特殊缓冲区更好发送。

EchoHandler在每次接受连接时都会创建实例 - 从那时起，它是与给定主机通信的已建立通道。Server侦听任何未建立的连接，而EchoHandlers 使用袜子（由Serverin给出handle_accept）来建立连接，因此EchoHandler实例与连接一样多。

解决方案

您需要制作一些连接列表（EchoHandler实例；我们将使用缓冲区，而不是send()直接使用套接字）并让他们有机会在关闭时删除他们的条目：

class Server(asyncore.dispatcher):
    def __init__(self, host='', port=6666):
        ...
        self.connections = []

    def handle_accept(self):
        ...
        handler = EchoHandler(self.sock, self);
        self.connections.append(self.sock)

    ...

    def remove_channel(self, sock):
        if sock in self.connections:
            self.connections.remove(sock)

class EchoHandler(asyncore.dispatcher_with_send):
    def __init__(self, sock, server):
        ...
        self.server = server

    def handle_read(self):
        datos = self.recv(1024);
        if datos:
            print(datos);
            self.out_buffer += 'I echo you: ' + datos

    def handle_close(self):
        self.server.remove_channel(self)
        self.close()

EchoHandler现在知道服务器实例并且可以从列表中删除它的套接字。这个回显示例现在功能齐全，并且使用有效的套接字列表，我们可以继续进行异步发送。

但是，此时您可以根据需要使用此列表 -cliente.connections[0].out_buffer += 'I am data'将完成工作，但您可能希望更好地控制它。如果是，请继续。

“为谁，由我”

为了异步发送数据，我们需要将 asyncore 从控制线程中分离出来，我们将在其中输入要发送的内容和发送给谁。

class ServerThread(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        self.daemon = True # if thread is a daemon, it'll be killed when main program exits
        self.cliente = Server()
        self.start()

    def run(self):
        print 'Starting server thread...'
        asyncore.loop()

thread = ServerThread()

while True:
    msg = raw_input('Enter IP and message divided by semicolon: ')

    if msg == 'exit':
        break

    ip, data = msg.split('; ')
    for sock in thread.cliente.connections:
        if sock.addr[0] == ip:
            sock.out_buffer += data
            break

这将起作用并等待目标 IP 和数据。记住要连接客户端。

正如我所说，您可以使用任何东西来指示哪个套接字是哪个。它可以是一个带有字段的类，例如。IP 和用户名，因此您只能向用户名以“D”开头的对等方发送数据。

但...

这个解决方案有点粗糙，如果你想很好地发送数据（这里它由于select()工作原理而有一些延迟）并充分利用这个socket包装器，则需要更好地了解 asyncore 模块。 这里和这里有一些资源。

语法说明

尽管您的代码现在可以工作，但您的代码有一些不好的地方。指令末尾的分号不会导致错误，但几乎每个类属性的变量都会导致错误。例如这里：

def handle_accept(self):
    self.sock,self.addr = self.accept();
    if self.addr:
        print self.addr[0];
    handler = EchoHandler(self.sock);

self.sock并且self.addr可能在该类中用于其他事物（例如，与套接字相关的事物；地址）并覆盖它们可能会造成麻烦。用于请求的方法不应该保存先前操作的状态。

我希望 Python 足够好，让你继续使用它！

编辑： sock.addr[0]可以用来代替，sock.socket.getpeername()[0]但不需要self.addr修改，所以handle_accept()应该是这样的：

def handle_accept(self):
    sock, addr = self.accept()
    if addr:
        print addr[0]
    handler = EchoHandler(sock, self)
    self.connections.append(handler)
于 2013-08-02T22:12:18.757 回答