基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

import socket
import threading


tLock = threading.Lock()
shutdown = False


def receiving(sock):
    while not shutdown:
        try:
            tLock.acquire()
            while True:
                data = sock.recvfrom(1024)[0]
                data = data.decode()
                print(str(data))
        except (BlockingIOError, RuntimeError):
            pass
        finally:
            tLock.release()


host = "127.0.0.1"
port = 0

server = (host, 2001)
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.bind((host, port))
s.setblocking(0)

rT = threading.Thread(target=receiving, kwargs={'sock': s})
rT.start()

alias = input("Name: ")
s.sendto(str("connect " alias).encode(), server)
message = alias

while message != 'q':
    if message != '':
        message = input()
        s.sendto(str(message).encode(), server)

s.sendto(str('q').encode(), server)
shutdown = True
s.close()
rT.join()