danilko09/udp_over_ws
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

central.py from prod

Browse Source
This commit is contained in:
Danil Kolesnikov
2026-03-10 00:51:23 +04:00
parent e251fcd8f1
commit b11ef28829
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
central.py
View File

@@ -1,11 +1,13 @@
import os
import asyncio import asyncio
import websockets import os
import asyncudp import asyncudp
import websockets
UDP_IP = os.getenv("UDP_IP", "127.0.0.1") UDP_IP = os.getenv("UDP_IP", "127.0.0.1")
UDP_PORT = int(os.getenv("UDP_PORT", 12345)) UDP_PORT = int(os.getenv("UDP_PORT", 12345))
async def websocket_handler(websocket): async def websocket_handler(websocket):
udp_socket = await asyncudp.create_socket(remote_addr=(UDP_IP, UDP_PORT)) udp_socket = await asyncudp.create_socket(remote_addr=(UDP_IP, UDP_PORT))
print("Received new connection from", websocket.remote_address) print("Received new connection from", websocket.remote_address)
@@ -27,10 +29,13 @@ async def websocket_handler(websocket):
task1.cancel() task1.cancel()
udp_socket.close() udp_socket.close()
async def main(): async def main():
print("Starting websockets server with target", UDP_IP, UDP_PORT)
async with websockets.serve(websocket_handler, "0.0.0.0", 80): async with websockets.serve(websocket_handler, "0.0.0.0", 80):
print("WebSocket server started") print("WebSocket server started")
while True: while True:
await asyncio.sleep(3600) await asyncio.sleep(3600)
asyncio.run(main()) asyncio.run(main())