59 lines
1.4 KiB
Python
59 lines
1.4 KiB
Python
import socket
|
|
import threading
|
|
|
|
PORT = 54000
|
|
BROADCAST = "255.255.255.255"
|
|
|
|
udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
|
|
udp_socket.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
|
|
|
|
interfaces = socket.getaddrinfo(host=socket.gethostname(), port=None, family=socket.AF_INET)
|
|
for idx, ip in enumerate(interfaces):
|
|
print(f"{idx}: {ip[-1][0]}")
|
|
|
|
interface = input("Który interfejs: ")
|
|
ip_addr = interface[int(interface)][-1][0]
|
|
udp_socket.bind((ip_addr, PORT))
|
|
|
|
def recive_bradcast():
|
|
print("Nasluchuje....")
|
|
t = threading.currentThread()
|
|
while getattr(t, "do_run", True):
|
|
data, addr = udp_socket.recvfrom(1024)
|
|
print(f"from: {addr}, recive: {data}")
|
|
|
|
print("Przestalem nasluchiwac!")
|
|
|
|
recv_thread = threading.Thread(target=recive_bradcast)
|
|
recv_thread.start()
|
|
|
|
|
|
counter = 0
|
|
while True:
|
|
choice = input("Wyslac dane?[t/n] ")
|
|
if choice.lower() == "n":
|
|
run = False
|
|
break
|
|
elif choice.lower() != "t":
|
|
continue
|
|
|
|
counter = counter + 1
|
|
udp_socket.sendto(f"test connection, counter: {counter}".encode("utf8"), (BROADCAST, PORT))
|
|
|
|
recv_thread.do_run = False
|
|
udp_socket.close()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# print(interfaces[int(interface)][-1][0])
|
|
# allips = [ip[-1][0] for ip in interfaces]
|
|
# print(allips)
|
|
|
|
# print(socket.gethostbyname(socket.gethostname()))
|
|
# print(socket.if_nameindex())
|
|
# print(socket.if_nametoindex(socket.gethostname()))
|
|
# print(interfaces)
|