python網絡編程socket實現服務端、客戶端操作詳解

更新時間：2020年03月24日 09:02:22 作者：隨風行云

這篇文章主要介紹了python網絡編程socket實現服務端、客戶端操作,結合實例形式分析了python基于socket實現服務端、客戶端相關操作技巧與使用注意事項,需要的朋友可以參考下

本文實例講述了python網絡編程socket實現服務端、客戶端操作。分享給大家供大家參考，具體如下：

本文內容：

socket介紹
TCP:
- 服務端
- 客戶端
UDP:
- 服務端
- 客戶端

首發(fā)時間：2018-02-08 01:14

修改：

2018-03-20 ：重置了布局，增加了UDP

什么是socket:

socket又稱"套接字"，應用程序通常通過"套接字"向網絡發(fā)出請求或者應答網絡請求。
網絡上的兩個程序通過一個雙向的通信連接實現數據的交換，這個連接的一端稱為一個socket。
socket就像電話線插口，只有電話線插上了，才能通信。
python中使用socket來進行網絡連接傳輸

TCP:
- 如果使用socket模塊來創(chuàng)建TCP客戶端和服務端：
  - 首發(fā)需要導入模塊：import socket
  - 然后創(chuàng)建過程在下面
服務端：

TCP服務端一般需要下面幾個操作：建立，綁定IP地址和端口，監(jiān)聽端口，等待連接,接收數據,傳輸數據 ,關閉連接
- 建立：server=socket.socket(socket.AF_INET, socket.SOCK_STREAM) 【參數默認就是socket.AF_INET, socket.SOCK_STREAM】
- 綁定端口：server.bind(('IP地址',端口))，【地址和端口號是一個 tuple 】
- 監(jiān)聽：server.listen()
- 接受連接: conn,addr=server.accept()，返回值是一個連接實例和一個地址，地址是連接過來的客戶端地址，而數據操作要利用這個連接實例
- 傳輸數據：conn.send(data)，【傳輸的數據必須是字節(jié)流，所以對字符串數據需要使用encode() 】
- 接收數據read：conn.recv(size)，【傳輸的數據必須是字節(jié)流,size是接收的字節(jié)數,如果需要轉成Unicode，需要使用decode() 】
- 關閉連接close:close()
```
import socket
server=socket.socket()#建立socket
server.bind(('localhost',1234))#綁定
server.listen()#監(jiān)聽
print("開始等待。。。")
conn,addr=server.accept()#接收連接
print("連接成功")
data=conn.recv(1024)#接收數據
print(data.decode())
conn.send(data)#發(fā)送數據
server.close()#關閉連接
print("--------------------")
```
- 上述代碼存在一個問題：只能接受一次連接，連接結束后，服務端socket將關閉，更改成不立即關閉能等待下一個連接的：
```
#服務器端
import socket
server = socket.socket()
server.bind(('localhost',1234)) #綁定ip和端口
server.listen(5) #監(jiān)聽
while True:
  print("開始等待")
  conn, addr = server.accept()
  print(conn, addr)
  print("客戶端連接")
  while True:
    data = conn.recv(1024)
    print("recv:",data)
    if not data: #當data=0時為真
      print("連接斷開...")
      break
    conn.send(data)
server.close()
```
注：上述代碼中在linux中正常運行，在windows中會報錯！

如果要在windows中運行，需要捕獲異常：
```
#服務器端
import socket
server = socket.socket()
server.bind(('localhost',1234)) #綁定ip和端口
server.listen(5) #監(jiān)聽
while True:
  print("開始等待")
  conn, addr = server.accept()
  print(conn, addr)
  print("客戶端連接")
  while True:
    try:
      data = conn.recv(1024)
      print("recv:",data)
      if not data: #當data=0時為真
        print("連接斷開...")
        break
      conn.send(data)
    except ConnectionResetError as e:
      print(e)
      break
server.close()
```
客戶端：

TCP客戶端一般需要下面幾個操作：建立socket,連接遠程socket，傳輸數據，接收數據,關閉連接
- 建立：client=socket.socket()
- 連接：client.connect(('IP地址',端口))，其中地址和端口號是一個 tuple
- 傳輸數據：client.send(data)，傳輸的數據必須是字節(jié)流,所以對字符串數據需要使用encode()
- 接收數據recv：client.recv(size)，傳輸的數據是字節(jié)流,如果需要轉成Unicode，需要使用decode()
- 關閉連接close:close()
```
import socket
client=socket.socket()#建立socket
client.connect(('localhost',1234))#連接
client.send("你好".encode())#發(fā)送數據
data=client.recv(1024)#接收數據
print(data.decode())
client.close()#關閉連接
```
- 上述代碼存在一個問題：只能發(fā)送一次數據，發(fā)生完數據就會斷開連接，改成可以多次發(fā)送數據，不自動斷開的【前提是服務端能接收多次】：
```
import socket
client=socket.socket()
client.connect(('localhost',1234))
while True:
  cmd=input(">>")
  if len(cmd)==0:
    continue
  client.send(cmd.encode())
  cmd_res=client.recv(1024)
  print(cmd_res.decode())
client.close()
```
UDP:

服務端：

UDP服務端通常有以下幾個操作：創(chuàng)建socket,綁定端口，傳輸數據，接收數據
- 創(chuàng)建socket:server=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
- 綁定端口：server.bind(addr),【addr是一個元組，內容為(地址,端口)】
- 接收數據：data,client_addr=server.recvfrom(1024)
- 傳輸數據：server.sendto(data,client_addr)
```
import socket
import time
server=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
server.bind(("localhost",1234))
start_time=time.time()
while True:
  data,addr=server.recvfrom(1024)
  print(data,addr)
  server.sendto("hello".encode(),addr)
  time.sleep(1)
  if time.time()-start_time>30:
    break
server.close()
```
客戶端：

UDP客戶端通常有以下幾個操作：創(chuàng)建socket,傳輸數據，接收數據
- 創(chuàng)建socket:client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
- 傳輸數據：server.sendto(data,addr),【addr是一個元組，內容為(地址,端口)】
- 接收數據：data,server_addr=client.recvfrom(1024)
```
import socket,time
client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
addr=("localhost",1234)
start_time=time.time()
while True:
  client.sendto(time.ctime().encode(),addr)
  data,addr= client.recvfrom(1024)
  print(data)
  time.sleep(1)
  if time.time()-start_time>30:
    break
client.close()
```