from socket import *
import struct
file_name = "go.jpg"
sever_ip = "192.168.2.120"
send_data = struct.pack("!H%dsb5sb"%len(file_name), 1, file_name.encode(), 0, "ocete".encode(), 0)
s = socket(AF_INET,SOCK_DGRAM)
s.sendto(send_data,(sever_ip,69))
f = open(file_name,"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("操作码:{},ACK:{},服务器端口:{},数据长度{}".format(caozuoma,ack_num,rand_port,len(recv_data)))

老师您好,我确认文件在桌面,但是一直返回操作码5,是什么原因呢

具体打印recv_data如下:

(b'\x00\x05\x00\x04Illegal TFTP operation\x00', ('192.168.2.120', 50869))

文件不存在

from socket import *
s= socket(AF_INET,SOCK_DGRAM)
addr = ("192.168.2.120",8083)
a = input("请输入:")
s.sendto(a.encode("gb2312"),addr)
redata = s.recv(2048)
print(redata[0].decode("gb2312"))
s.close()

我在调试助手发送消息后,提示这个报错:

Traceback (most recent call last):

  File "E:/project/multiprocessing/testsocket.py", line 7, in <module>

    print(redata[0].decode("gb2312"))

AttributeError: 'int' object has no attribute 'decode'

老师我的运行结果怎么这样？系统太随意了么？跟你的咋不一样?

import threading,time
num = 0
def work1():
    global num
    for i in range(100):
        num +=1
        print("in work1,num is %d"%num)
def work2():
    global num
    for i in range(100):
        num +=1
        print("in work2,num is %d"%num)
t1 = threading.Thread(target=work1)
t1.start()
t2 = threading.Thread(target=work2)
t2.start()
print("计算之后num=",num)

主进程下子进程，子进程下子线程，    

主进程下主线程，主线程下子线程，

进程池涵盖多进程。

子进程可以调用外部一个模块实现互相通信

在一个主进程下，import该怎么调用模块，因为他们互相之间是互通的，写代码第一行就应该用import把他们都罗列出来么？

我下面写的不是程序，只是想表达的意思，他们同时存在？如何同时调用？因为有时候需要通信，我就懵了

而且如果罗列到一起后，程序写完，主进程下的，我应该叫他    子进程？还是主线程？

这些叫法我听着有点绕呢，但是实际摆在眼前的就是一个程序，我理解就是一个主程序，下面有两个子进程，子进程里有两个子线程，从上到下实现。但是课程讲的是这三个进程是各干各的？还没有规律？懵了，老师帮我缕缕吧。。。

from multiprocessing import Process
from multiprocessing import Pool
from multiprocessing import Queue
import threading

代码是：

from socket import *
import  struct
cmb_buf = struct.pack("!H5sb5sb",1,b"1.jpg",0,b"octet",0)
udpSock = socket(AF_APPLETALK,SOCK_DGRAM)
udpSock.sendto(cmb_buf,("10.2.100.167",69))
f = open("1.jpg","ab")

为什么会报错呀 老师

老师，我想完成两个聊天室的实时聊天：

聊天室1的代码如下：

from socket import *
import time
#1创建套接字
udpSocket = socket(AF_INET, SOCK_DGRAM)
bindAddr = ("",7088)
udpSocket.bind(bindAddr)#绑定
data = input("请输入：")
udpSocket.sendto(data.encode("gb2312"),("",8080))
while True:
    #接收对方发送的数据
    recvData = udpSocket.recvfrom(1024)
    print('【%s】 %s.%s' %(time.ctime(),recvData[1],recvData[0].decode("GB2312")))
    a = input("请输入：")
    udpSocket.sendto(a.encode('GB2312'),recvData[1])
#5关闭套接字
udpSocket.close()

聊天室2的代码如下：

from socket import *
import time
#1创建套接字
udpSocket = socket(AF_INET, SOCK_DGRAM)
bindAddr = ("",8080)
udpSocket.bind(bindAddr)#绑定
while True:
    #接收对方发送的数据
    recvData = udpSocket.recvfrom(1024)
    print('【%s】 %s.%s' %(time.ctime(),recvData[1],recvData[0].decode("GB2312")))
    a = input("请输入：")
    udpSocket.sendto(a.encode('GB2312'),recvData[1])
#5关闭套接字
udpSocket.close()

始终会报错，麻烦您帮我看一下

老师，您好，关于第一章进程我还是听不怎么懂，投许多疑惑，如下代码

from multiprocessing import Process

def run(name):
    print("子进程"+name+"正在执行")

if __name__=="__main__":
    p=Process(target=run,args=("t1",),name="pro1")
    print("子进程将要启动")
    p.start()
    print(p.name)
    p.join()

输出的结果是子进程将要启动，pro1，子进程t1正在执行。①这里的父进程是谁呢?是p吗？p.start()是子进程吗？②程序执行的顺序不是先print（“子进程将要启动”），然后p.stat()，最后是print（p.name），输出的结果应该是子程序将要启动，子进程t1正在执行，pro1。③p.start（）执行结果是子进程t1正在执行，为什么不是子进程pro1正在执行，这个args说表示调用对象的位置参数元组，为什么会打印出t1呢？老师，这一节却是很懵懂，希望老师能讲解的清楚点。理解能力比较差，抱歉了。谢谢您。

这里到底是重载threading.Thread类的run方法,还是重写threading.Thread类的run方法?

老师您好：

     请问queue模块是python3.X版本的吗？我用的是arcgis软件集成的python2.7.14，因为要用到里面的arcpy。

问题：广播通信讲完就没有一个case去演示一下吗？老师，我感觉听着还是晕乎乎的，很虚

问题：不知道为啥，我的电脑不能和飞秋进行通信。我的飞秋是2015版本的，老师指导一下吧

问题：对协程理解不好，请老师多指导，咱们用的生产者-消费者是不是一个协程的运作，请老师指导！！！！！

from multiprocessing import Pool,Manager
import time
import os
def copy_information(source_folder,dest_folder,file):
    start_time = time.time()
    try:
        fr = open('H:\pythonShangxuetang/'+source_folder+'/'+file,'r',encoding='utf-8')
        fw = open('./'+dest_folder+'/'+file,'w',encoding='utf-8')
        try:

            print('文件%s开始复制'%file)
            fr_content = fr.read()
            fw.write(fr_content)
            end_time = time.time()
            print('文件%s复制所用时间：%d'%(file,end_time-start_time))
        except Exception as e:
            print('文件读写错误原因是：%s'%e.args)
    except Exception as d:
        pass
    finally:
        fr.close()
        fw.close()
def main():
    count =0
    #定位具体所需要复制的文件夹
    folder_name = input('请输入需要复制的文件夹：')
    #创建新的文件夹名称
    newFolderName = folder_name +'复件'
    os.mkdir(folder_name+'复件')
    #获取文件夹中的所有文本
    qu = Manager().Queue()   #创建queue，进程间通信
    file_names = os.listdir('H:\pythonShangxuetang/'+folder_name)
    qu.put(file_names)
    #创建进程池进行多任务配合
    p1 = Pool(5)
    # for i in file_names:
    while True:
        if not qu.empty():
            p1.apply_async(copy_information,args=(folder_name,newFolderName,qu.get()))
            count +=1
        else:
            break
    print('文件复制start')
    p1.close()
    p1.join()
    print('一共复制%d个文件'%count)
    print('文件复制end')

if __name__=='__main__':
    main()

问题：复制不成功，逻辑思维manager.queue让进程间通信，将目录文件夹下的文件信息保存到queue中。

问题：为何这句话有时候会出现是2个，有时候会出现3个，这个线程不是同一刻发出的吗？

老师，为什么使用互斥锁之后，子线程不出错了，但是主线程还是出错呢