1

我使用 reywenderlich http://www.raywenderlich.com/3932/的这个教程成功地创建了一个简单的聊天服务器

代码：

from twisted.internet.protocol import Protocol, Factory
from twisted.internet import reactor


class IphoneChat(Protocol):
    def connectionMade(self):
        #self.transport.write("""connected""")
        self.factory.clients.append(self)
        print "clients are ", self.factory.clients

    def connectionLost(self, reason):
        self.factory.clients.remove(self)

    def dataReceived(self, data):
        #print "data is ", data
        a = data.split(':')
        if len(a) > 1:
            command = a[0]
            content = a[1]

            msg = ""
            if command == "iam":
                self.name = content
                msg = self.name + " has joined"

            elif command == "msg":
                msg = self.name + ": " + content

            print msg

            for c in self.factory.clients:
                c.message(msg)

    def message(self, message):
        self.transport.write(message + '\n')


factory = Factory()
factory.protocol = IphoneChat
factory.clients = []

reactor.listenTCP(79, factory)
print "Iphone Chat server started"
reactor.run()

基本上整个教程展示了一个聊天实现，用户加入一个特定的聊天室并互相实时聊天。但是我的客户想要一个点对点的聊天机制，用户可以选择一个特定的用户与之聊天，所以我真的不知道如何让它成为现实。我将衷心感谢您的帮助。谢谢

4

1 回答 1

1

要创建 p2p 连接，您需要创建一个协议，该协议允许一方知道另一方的 IP 地址和侦听端口，而另一方侦听特定端口。

这可以通过向聊天服务器创建请求以启动 p2p 连接来完成。然后聊天服务器将向另一个客户端发送一条请求许可的消息，并在一个肯定的响应之后，其中应包括侦听端口将该信息连同其对等方的 IP 地址一起传输给发起方。

此时，发起客户端应该创建一个到另一方的 TCP 连接，并且从建立连接的那一刻起，您可以传输您想要的任何数据。

一种简单的方法是允许向聊天服务器发送 ASCII 转义命令，例如/p2p <NICKNAME> ，这会告诉服务器客户端想要启动 p2p 连接。然后，服务器将能够向/p2p-request from <NICKNAME>所请求的聊天发送类似的内容，并且他可以回复类似的内容/p2p-accept <port>或/p2p-reject <reason>。如果响应是/p2p-accept服务器，则可以使用某行返回原始客户端/p2p-accepted <IP> <port>。

随着/p2p-accept客户端将需要创建一个监听套接字：

p2p_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
p2p_socket.bind(('', port))
p2p_socket.listen(1)
p2p_chat, p2p_address = p2p_socket.accpet()

发起方将需要连接到此套接字：

p2p_chat = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
p2p_chat.connect((ip, port))

并且一旦建立连接send()，recv()就可以在客户端之间发送数据。

当然，这可以通过 Twisted 编写，但我并不精通它，所以我宁愿坚持使用低 API。

于 2013-11-02T15:02:24.943 回答