展開全部

import?timeimport?threadingimport?queueimport?socket#?三個(gè)線程：e5a48de588b662616964757a686964616f31333337396165#?線程1：產(chǎn)生遞增的數(shù)字，轉(zhuǎn)成字符串放到隊(duì)列中#?線程2：監(jiān)聽端口，將產(chǎn)生的連接放到列表中#?線程3：從隊(duì)列中取出數(shù)字，遍歷連接列表，發(fā)送到所有客戶端#?線程1：產(chǎn)生遞增的數(shù)字，轉(zhuǎn)成字符串放到隊(duì)列中class?Producer(threading.Thread):

def?__init__(self,?work_queue):

super().__init__()?#?必須調(diào)用

self.work_queue?=?work_queue

def?run(self):

#print("Begin?produce...")

num?=?1

while?True:

self.work_queue.put(str(num))

num?=?num+1

time.sleep(1)?#?暫停1秒#?線程2：監(jiān)聽端口，將產(chǎn)生的連接放到列表中class?SocketServer(threading.Thread):

def?__init__(self,?socket_list):

super().__init__()

self.socket_list?=?socket_list

def?run(self):

sock?=?socket.socket()

sock.bind(('',?9090))

sock.listen(5)

print("Start?listen...")

while?True:

conn,?addr?=?sock.accept()

print("Connect?by",?addr)

self.socket_list.append((conn,?addr))#?線程3：從隊(duì)列中取出數(shù)字，遍歷連接列表，發(fā)送到所有客戶端class?Printer(threading.Thread):

def?__init__(self,?work_queue,?socket_list):

super().__init__()?#?必須調(diào)用

self.work_queue?=?work_queue

self.socket_list?=?socket_list

def?run(self):

while?True:

num?=?self.work_queue.get()?#?當(dāng)隊(duì)列為空時(shí)，會(huì)阻塞，直到有數(shù)據(jù)

for?sock,?addr?in?self.socket_list:?#?遍歷保存連接的列表

print("Send",?num,?"To",?addr)

try:

sock.sendall(bytes(num?+?'\r\n',?'utf-8'))?#?把字符串轉(zhuǎn)換成字節(jié)數(shù)組發(fā)送

except:

print("Disconnect?by",?addr)?#?如果連接斷開，發(fā)送會(huì)失敗

self.socket_list.remove((sock,?addr))?#?從列表中刪除斷開的連接def?main():

work_queue?=?queue.Queue()

socket_list?=?[]?#?為了更安全可靠，從多線程訪問列表時(shí)應(yīng)該加鎖，

#?這里做了簡化，因?yàn)榱斜淼脑黾觿h除操作基本上可以認(rèn)為是線程安全的

socket_server?=?SocketServer(socket_list)

socket_server.daemon?=?True

socket_server.start()

printer?=?Printer(work_queue,?socket_list)

printer.daemon?=?True?#?當(dāng)主線程退出時(shí)子線程也退出

printer.start()

producer?=?Producer(work_queue)

producer.daemon?=?True?#?當(dāng)主線程退出時(shí)子線程也退出

producer.start()

time.sleep(1)?#?這里要暫停一下，否則執(zhí)行下一條語句時(shí)，會(huì)因隊(duì)列為空而直接返回

work_queue.join()?#?主線程會(huì)停在這里，直到所有數(shù)字被get()，并且task_done()，因?yàn)闆]有調(diào)用task_done()，所在這里會(huì)一直阻塞，直到用戶按^Cif?__name__?==?'__main__':

main()

總結(jié)

以上是生活随笔為你收集整理的python socket发送组播数据_Python socket 如何实现广播单播切换的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。