UDP打孔不工作

Question

我试图创建一个聊天程序，通过UDP打孔和直接连接到一个由代理提供的节点。在

我现在的脚本在本地运行得很好。当我试图使用外部地址连接时，问题就来了。我自己也搞不清楚，所以我希望有人能帮我！在

import socket
import json
import landerdb
import threading

class PeerChat:

    address = None

    def __init__(self):
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        self.db = landerdb.Connect("nodes")
        self.brok_ip = ""
        self.brok_port = 5000
        self.nick = "Test"
        self.friends = []

    def listen(self):
        self.command = {

            "HERE":self.here,
            "MSG":self.msg,
            } 

        global address
        self.sock.bind(address)
        while True:
            msg, addr = self.sock.recvfrom(1024)
            try:
                data = json.loads(msg)
            except:
                continue
            if data[u'cmd'] in self.command:
                threading.Thread(target=self.command[data[u'cmd']], args=(addr, data)).start()

    def main(self):
        while True:
            msg = raw_input("> ")
            msg = msg.split()
            try:
                msg = json.dumps({"cmd":msg[0], "data":' '.join(msg[2:]), "nick":self.nick, "to":msg[1]})
            except:
                continue
            for x in self.db.find("nodes", "all"):
                self.sock.sendto(msg, tuple(x['addr']))

    def here(self, addr, data):
        if not self.db.find("nodes", {"addr":addr}):
            self.db.insert("nodes", {"addr":addr})
        if data['nick'] in self.friends:
            print data['nick'] + " has come online."
    def msg(self, addr, data):
        if data['to'] == self.nick:
            print data['nick']+": "+data['data']

    def GetNodes(self):
        self.sock.sendto("", (self.brok_ip, self.brok_port))
        with open("nodes", 'wb') as file:
            while True:
                msg, addr = self.sock.recvfrom(1024)
                if msg == "\n":
                    break
                file.write(msg)
        msg, addr = self.sock.recvfrom(1024)
        global address 
        address = ("0.0.0.0", int(msg))   
        for x in self.db.find("nodes", "all"):
            addr = tuple(x['addr'])
            self.sock.sendto(json.dumps({"cmd":"HERE", "nick":self.nick}),addr)

if __name__ == "__main__":
    PeerChat().GetNodes()
    threading.Thread(target=PeerChat().listen).start()
    PeerChat().main()

Answer 1

我还没有在外部测试这段代码，因为我在uni，但是我使用稍微不同的线路来建立UDP连接。在

他们可能会给你一些想法。。。在

#!/usr/bin/python
import socket
import struct

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
sock.bind(('239.255.60.60', 4876)) 
mreq = struct.pack("=4sl", socket.inet_aton("239.255.60.60"), socket.INADDR_ANY)
sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)
packet_number = 0

while True:

    packet_number += 1
    print packet_number
    raw_data = sock.recv(1024)
    print raw_data
    print

我不完全明白，但这对我有用。 它改编自here。你应该把整页读几遍，以了解他们在说什么。在页面中搜索您需要设置socket.IP_MULTICAST_TTL, 33的“IP多点广播”页面插座固定支架，其中数字是任何数字>；32。请记住，在这个阶段我几乎和你一样不确定。。。在