本文實例講述了Python3 socket同步通信。分享給大家供大家參考，具體如下：
本文比較簡單，適合入門用，作個筆記，方便日后抄寫
一個服務(wù)端，一個客戶端，而且是阻塞方式，一次只能接受一個客戶端連接并通信噢。
客戶端發(fā)送‘bye', 結(jié)束與服務(wù)端的通信，如果發(fā)送'shutdown'，服務(wù)端將會關(guān)閉自己！
服務(wù)端代碼:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
from socket import *from time import ctimeHOST = ''PORT = 21567BUFSIZE = 1024ADDR = (HOST, PORT)tcpSerSock = socket(AF_INET, SOCK_STREAM)tcpSerSock.bind(ADDR)tcpSerSock.listen(5)quit = Falseshutdown = Falsewhile True: print('waiting for connection...') tcpCliSock, addr = tcpSerSock.accept() print('...connected from: ', addr) while True: data = tcpCliSock.recv(BUFSIZE) data = data.decode('utf8') if not data: break ss = '[%s] %s' %(ctime(), data) tcpCliSock.send(ss.encode('utf8')) print(ss) if data == 'bye': quit = True break elif data == 'shutdown': shutdown = True break print('Bye-bye: [%s: %d]' %(addr[0], addr[1])) tcpCliSock.close() if shutdown: breaktcpSerSock.close()print('Server has been |
客戶端代碼:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
from socket import *HOST = 'localhost'PORT = 21567BUFSIZE = 1024ADDR = (HOST, PORT)tcpCliSock = socket(AF_INET, SOCK_STREAM)tcpCliSock.connect(ADDR)while True: data = input('>') if not data: continue print('input data: [%s]' %data) tcpCliSock.send(data.encode('utf8')) rdata = tcpCliSock.recv(BUFSIZE) if not rdata: break print(rdata.decode('utf8')) if data == 'bye' or data == 'shutdown': breaktcpCliSock.close() |
希望本文所述對大家Python程序設(shè)計有所幫助。
