一、前言

　　上一篇中我們已經(jīng)知道了客戶端通過socket來連接服務(wù)端，進行了一次數(shù)據(jù)傳輸，那如何實現(xiàn)客戶端多次發(fā)生數(shù)據(jù)？而服務(wù)端接受多個客戶端呢？

二、發(fā)送中文信息

　　在python3中，socket只能發(fā)送bytes類型的數(shù)據(jù)，bytes類型只能表示0-225的ASCII碼的值，并不能表示中文，所以當(dāng)我們需要發(fā)送中文時，需要使用到編碼和解碼。

客戶端：

import socket# 客戶端# 聲明協(xié)議類型,同時生成socket對象client = socket.socket()#client.connect(('localhost', 8888))# python3 接收字節(jié)流數(shù)據(jù)msg = input('>>:').strip()client.send(msg.encode('utf-8')) # 先編碼成utf-8格式data = client.recv(1024) # 1024字節(jié)的數(shù)據(jù)print(data)print(data.decode())

服務(wù)端：

import socket# 聲明協(xié)議類型server = socket.socket()# 綁定本地網(wǎng)卡（多網(wǎng)卡選擇），端口server.bind(('localhost', 8888))# 監(jiān)聽端口server.listen() # 監(jiān)聽# conn 就是客戶端連接后，在服務(wù)器端為其生成的一個連接實例# address 是客戶端的 hostaddr,portconn, address = server.accept()print("進入等待時間....")# 等待# print(conn, address)print("收到連接....")# 接收數(shù)據(jù)data_server = conn.recv(1024)print('receive:', data_server.decode()) # 解碼# 返回一個值conn.send(data_server)

三、Socket實現(xiàn)多個連接

　　這個事例需要在Linux環(huán)境下測試，在windows中測試時，多個客戶端同時連接(也就是同時運行多個socket_client.py程序)，其中一個斷開，服務(wù)端會報錯。Linux環(huán)境python版本為3.5。

　　事例代碼：

客戶端：

import socket# 客戶端# 聲明協(xié)議類型,同時生成socket對象client = socket.socket()#client.connect(('localhost', 8888))# python3 接收字節(jié)流數(shù)據(jù)while True:  msg = input('>>:').strip()  if len(msg) == 0:   # 輸入不能為空    continue  client.send(msg.encode('utf-8'))  data = client.recv(1024) # 1024字節(jié)的數(shù)據(jù)  print(data)  print(data.decode())

　　事例中輸入為空（即len(msg==0)）是不可以的，如果不輸入任何東西，socket程序默認(rèn)等待你的輸入，所以程序會卡掉。

服務(wù)端：

# -*- coding: UTF-8 -*-import socket# 聲明協(xié)議類型server = socket.socket()# 綁定本地網(wǎng)卡（多網(wǎng)卡選擇），端口server.bind(('localhost', 8888))# 監(jiān)聽端口server.listen(5) # 監(jiān)聽while True:  conn, address = server.accept()  print("進入等待時間....")  while True:    print("收到連接....")    # 接收數(shù)據(jù)    data_server = conn.recv(1024)    if not data_server:  # 這里判斷客戶端斷開的情況，不控制會無限循環(huán)      print('client is lost...')      break    print('receive:', data_server.decode())    # 返回一個值    conn.send(data_server)