会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132358个问题
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 211楼

老师你好,我的问题有两个:

1、我的运行结果和视频中演示的不一样(数据长度那块),为什么最后依然实现了相同的效果(我和老师用的是不同的文件,是否和文件有关?)

2.

if len(recv_data[0]) < 516:
    break

关于这行代码执行的时候,我第截图中显示“数据长度:2”远小于代码中的516,不应该直接执行“break”语句退出吗为什么还能继续往下执行?

# coding=utf-8
from socket import *
import struct
filename = "1.png"
server_ip = "192.168.198.1"  # 服务器
send_data = struct.pack(f"!H{len(filename)}sb5sb",
                        1, filename.encode(), 0, "octet".encode(), 0)
s = socket(AF_INET, SOCK_DGRAM)  # 创建套接字对象
s.sendto(send_data, (server_ip, 69))  # 将数据包发送给服务器69端口
f = open("1.png", "ab")
while True:
    recv_data = s.recvfrom(1024)  # 接收数据
    caozuoma, ack_num = struct.unpack("!HH", recv_data[0][:4])  # 获取数据块编号
    rand_port = recv_data[1][1]  # 获取服务器的随机端口
    if int(caozuoma) == 5:
        print("文件不存在...")
        break
    print(f"操作码:{caozuoma},ACK:{ack_num},"
          f"服务器随机端口:{rand_port},数据长度:{len(recv_data)}")
    f.write(recv_data[0][4:])  # 将数据写入
    if len(recv_data[0]) < 516:
        break
    ack_data = struct.pack("!HH", 4, ack_num)
    s.sendto(ack_data, (server_ip, rand_port))  # 回复确认包

我的截图:

image.png

视屏中:

image.png

我使用的文件:

image.png

Python 全系列/第三阶段:Python 网络与并发编程/网络通信 213楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 214楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 217楼

老师,①为什么要加'f'?(加f的作用是什么?)

          ②要在什么时候加‘f’?



Y)96{XQ}QRTY02V2O[6YJGM.png

@[[{Y~8]}VFCJ8$ELU7V2SM.png

2N0)PUZI3AJ0@RKU4}]$%61.png

代码区:

#join() 的目的是让主线程照顾到子线程
from threading import Thread
from time import sleep,time
import threading
#线程的实现
#方法包装

#创建普通方法
def func1(name):
    print(threading.currentThread())
    print(f'Threading:{name} start')
    sleep(3)
    print(f'Threading:{name} end')

if __name__ == '__main__':
   
    print(threading.currentThread())
    #开始时间
    start = time()
   
    '''
    #打印显示线程
    print(threading.currentThread())
    #创建线程
    t1 = Thread(target=func1, args=('t1',))
    t2 = Thread(target=func1, args=('t2',))
    #开始时间
    start = time()
    #启动线程
    t1.start()#注意:不要再启动线程后就立即jion(),否则就串行了,失去了并发的意义
    t2.start()
    #等待t1线程执行完再往下执行
    t1.join()
    #等待t2线程执行完再往下执行
    t2.join()
    # func1('t1')#对比可以看出而这效率的差别
    # func1('t2')
    '''
    
    thread_list = []
    for i in range(100):
        t = Thread(target=func1, args=(f't{i+1}',))
        t.start()
        thread_list.append(t)
    
    for t in thread_list:
        t.join()
    #结束时间
    end = time()-start
    print(end)


Python 全系列/第三阶段:Python 网络与并发编程/并发编程 219楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 221楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 222楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637