本文阅读时长大约为7分钟。

今日内容概述：

TCP 文件下载、线程

今日思维导图

TCP 文件下载代码

tcp客户端

import socket

def main（）：

＃ 创建套接字　

client＿socket ＝ socket．socket（socket．AF＿INET， socket．SOCK＿STREAM）

＃ 链接服务器

client＿socket．connect（（＂192．168．xxx．xxx＂， 8080））

＃ 发送要下载的文件名

file＿name ＝ input（＂请输入要下载的文件名：＂）

client＿socket．send（file＿name．encode（＂utf－8＂））

＃ 接收数据并保存

recv＿data ＝ client＿socket．recv（1024 ＊ 1024）

＃ 判断是否有数据，如果有就进行保存，没有就就进行提示

＃ ＂wb＂ 是以字节模式进行写入，软件会对字节进行解码

if recv＿data：
       with open（＂new＿％s＂ ％ file＿name， ＂wb＂） as f：

f．write（recv＿data）

print（＂文件下载成功＂）

else：
       print（＂文件下载失败＂）

＃ 关闭套接字

client＿socket．close（

if ＿＿name＿＿ ＝＝ ＂＿＿main＿＿＂：

main（）

tcp服务器

import socket

def send＿file＿content（client＿socket， client＿addr）：

＃ 接收服务器发送过来的文件，

＃ 进行判断有没有这个文件，如果有就打开文件并读取

recv＿file＿name ＝ client＿socket．recv（1024）．decode（＂utf－8＂）

print（＂客户端 ％s 要下载的文件是　％s＂ ％ （client＿addr， recv＿file＿name））

file＿content ＝ None

＃ 把文件的内容发送给客户端

＃ 进行异常判断，出现异常就进行提示

try：
       f ＝ open（recv＿file＿name， ＂rb＂）
       file＿content ＝ f．read（）
       f．close（）

except Exception as result：
       ＃ print（result）
       print（＂没有要下载的　％s 这个文件＂ ％ recv＿file＿name）

＃ 判断是否有数据，如果有数据，就进行发送

if file＿content：
       client＿socket．send（file＿content）
       print（＂文件传输成功＂

def main（）：

＃ 创建套接字

server＿socket ＝ socket．socket（socket．AF＿INET， socket．SOCK＿STREAM）

＃ 绑定本地信息

server＿socket．bind（（＂＂， 8080））

＃ 监听

server＿socket．listen（128）

while True：
       ＃ 等待链接
       client＿socket， client＿addr ＝ server＿socket．accept（）
       ＃ 调用发送文件数据的函数
       send＿file＿content（client＿socket， client＿addr）
       ＃ 关闭两个套接字
       client＿socket．close（）

server＿socket．close（）

if ＿＿name＿＿ ＝＝ ＂＿＿main＿＿＂：

main（）

执行结果

在这里碰见一个问题：

Linux 中客户端的代码可以和别人 Windows 中服务器的代码可以链接，但是无法下载， 不知道是因为系统是原因还是什么其他原因。

线程练习代码

简单的多任务线程

import threading

import time

def sing（）：

＂＂＂唱歌＂＂＂

for i in range（5）：

print（＂－－－正在唱歌－－－－＂）
       time．sleep（1）

def dance（）：

＂＂＂跳舞＂＂＂

for i in range（5）：
       print（＂－－－正在跳舞－－－＂）
       time．sleep（1）

def main（）：

＃ 创建对象

t1 ＝ threading．Thread（target＝sing）

t2 ＝ threading．Thread（target＝dance）

＃ 启动子线程

t1．start（）

t2．start（）

if ＿＿name＿＿ ＝＝ ＇＿＿main＿＿＇：

main（）

多任务——继承

import threading

＂＂＂由继承来实现多任务＂＂＂

class MyThread（threading．Thread）：

def ＿＿init＿＿（self， num）：  ＃ 重写父类方法

super（）．＿＿init＿＿（）

self．num ＝ num

def run（self）：   ＃ 重写父类方法

for i in range（self．num）：

print（i）

if ＿＿name＿＿ ＝＝ ＇＿＿main＿＿＇：

t1 ＝ MyThread（10）

t1．start（）  ＃ 调用父类中的start方法会创建一个子线程， 子线程会自动调用子类中的run方法

互斥锁解决资源竞争问题

import threading

import time

＃ 新建全局变量

gl＿nums ＝ 0

＃ 新建锁

＃ 使用锁来解决资源竞争问题

mutex ＝ threading．Lock（）

def test1（num）：

global gl＿nums

for i in range（num）：
       ＃ 上锁
       mutex．acquire（）
       gl＿nums ＋＝ 1
       ＃ 解锁
       mutex．release（）

print（＂－－－－test1  ％d－－－－＂ ％ gl＿nums）

def test2（num）：

global gl＿nums

for i in range（num）：
       ＃ 上锁
       mutex．acquire（）
       gl＿nums ＋＝ 1
       ＃ 解锁
       mutex．release（）

print（＂－－－－test2  ％d－－－－＂ ％ gl＿nums）

def main（）：

t1 ＝ threading．Thread（target＝test1， args＝（1000000，））

t2 ＝ threading．Thread（target＝test2， args＝（1000000，））

t1．start（）

t2．start（）

time．sleep（2）

print（＂－－－main  ％d－－－－＂ ％ gl＿nums）

if ＿＿name＿＿ ＝＝ ＇＿＿main＿＿＇：

main（）

线程听了个迷迷糊糊，把代码多敲几遍吧。。。

刚才吃完饭回来抽空研究了一下如何翻墙，嗯，折腾了一会，成功翻了出去，一直听说墙外的世界很精彩，终于可以一睹真面目了。。。

对于如何翻墙感兴趣的可以联系我。

最近的进度有点快，有点跟不上，需要加倍努力！

加油！！！

END