Python Перенаправление портов сокетов - PullRequest
0 голосов
/ 18 июня 2020

Итак, я перенаправил свой IP-адрес, чтобы мои друзья могли проверить, работает ли мой материал enter image description here

И у меня есть простой сервер, который размещен на внутреннем IP-адресе

import socket
import threading



class Server:
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    connections = []
    def __init__(self, ip="0.0.0.0", port=5555):
        self.sock.bind((ip, port))
        self.sock.listen(1)

    def handler(self, c, a):
        while True:
            data = c.recv(4096)
            for connection in self.connections:
                connection.send(data)
            if not data:
                print(str(a[0]) + ":" + str(a[1]), "disconnected")
                self.connections.remove(c)
                c.close()
                break

    def run(self):
        while True:
            c, a = self.sock.accept()
            rThread = threading.Thread(target=self.handler, args=(c, a))
            rThread.daemon = True
            rThread.start()
            self.connections.append(c)
            print(str(a[0]) + ":" + str(a[1]), "connected")


host = Server("192.168.x.xxx", 6667)
print("Server status: Running")
host.run()

И простой клиентский модуль, который я пытался передать publi c ip на

import socket
import pickle
import threading
import pyaudio
import numpy as np

class Client():
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    def __init__(self, address):
        threading.Thread.__init__(self)

        self.sock.connect((address, 6667))

    def run(self, id):
        RATE = 16000
        CHUNK = 256

        self.id = id

        p = pyaudio.PyAudio()
        player = p.open(format=pyaudio.paInt16, channels=1, rate=RATE, output=True, frames_per_buffer=CHUNK)
        while True:
            data = self.sock.recv(4096)
            data = pickle.loads(data)
            if data[0] != self.id:
                if not data:
                    break
                player.write(np.fromstring(data[1],dtype=np.int16),CHUNK)

    def sendMsg(self, data, id):
        data1 = [id, data]
        self.sock.send(pickle.dumps(data1))

Клиент не подключается к серверу, когда я пытаюсь передать ему publi c адрес

print("Connecting to server")
cli = Client("91.242.xxx.xxx")
rThread = threading.Thread(target=cli.run, args=(id,))
rThread.daemon = True
rThread.start()
print("Connected to server")

Единственное, что выводит: Connecting to server

Я не уверен, что я делаю не так или что делать, чтобы исправить это

1 Ответ

0 голосов
/ 22 июня 2020

Мой интернет-провайдер использует CGNat, и мне просто нужно было позвонить им, чтобы сказать им, что мне нужен publi c IP, и они с радостью сделали это за меня.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...