#coding=utf-8

为何一定要这个注释，没有会报错

client_socket,client_info = server_socket.accept()

老师，服务端持续接收信息中这句程序为什么不是写在循环中的呢

redata[1]是什么意思

老师请问下，收到的信息为什么要这么写：

print(f"收到远程信息：{recv_data[0].decode('gbk')},from {recv_data[1]}")

为什么用

recv_data[0]

代表收到，而

recv_data[1]

代表从客户端发来的呢？

忽略上个问题，找到原因了！

客户端：

from socket import *
from threading import Thread

# 不停的接收
def recv_data():
    while True:
        redata = udp_socket.recvfrom(1024)
        recontent = redata[0].decode("gbk")
        print(f"收到远程信息：{recontent},from {redata[1]}")
        if redata == "88":
            print("聊天结束！")
            break

def send_data():
    addr = ("127.0.0.1",8986)
    while True:
        data = input("请输入：")
        udp_socket.sendto(data.encode("gbk"),addr)
        if data == "88":
            print("聊天结束！")
            break

if __name__ == '__main__':
    udp_socket = socket(AF_INET,SOCK_DGRAM)
    # 绑定接受信息的端口
    udp_socket.bind(("127.0.0.1",9896))
    # 创建两个线程
    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    # 启动线程
    t1.start()
    t2.start()
    # 结束子线程，再结束主线程
    t1.join()
    t2.join()

服务端：

from socket import *
from threading import Thread

# 不停的接收
def recv_data():
    while True:
        redata = udp_socket.recvfrom(1024)
        recontent = redata[0].decode("gbk")
        print(f"收到远程信息：{recontent},from {redata[1]}")
        if redata == "88":
            print("聊天结束！")
            break

def send_data():
    addr = ("127.0.0.1",9896)
    while True:
        data = input("请输入：")
        udp_socket.sendto(data.encode("gbk"),addr)
        if data == "88":
            print("聊天结束！")
            break

if __name__ == '__main__':
    udp_socket = socket(AF_INET,SOCK_DGRAM)
    # 绑定接受信息的端口
    udp_socket.bind(("127.0.0.1",8986))
    # 创建两个线程
    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    # 启动线程
    t1.start()
    t2.start()
    # 结束子线程，再结束主线程
    t1.join()
    t2.join()

问题：客户端发送“88”信号，本身能收到“聊天结束”，但是服务端却没有收到“聊天结束标志”！麻烦老师看下，是不是代码哪儿写错了！

并且客户端再次输入“88”,循环仍为结束！

老师，从这节开始怎么没文档了

为什么直接把函数体recv_data()和send_data()传入Thread里面,可以连接成功，但是为什么无法交互

Traceback (most recent call last):

  File "C:\Users\18785\PycharmProjects\pythonProject1\venv\tcp客户端发送信息案例.py", line 4, in <module>

    client_socket.connect(("127.0.0.1",8899))

ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝，无法连接。

老师，这是咋了么？

为什么没有打印p=MyRocess("p")

time sleep
multiprocessing Process
os

MyProcess(Process):
    (,name):
        Process.()
        .name=name

    ():
        (.name,os.getpid())
        (.name,os.getcwd())



__name__ == :

    (,os.getpid())
    p = MyProcess()
    p1 = MyProcess()
    p.start()
    p1.start()

我这个代码运行后只运行了

 print(f"当前ID：",os.getpid())

其他的跟没有调用一样。是python或pychram版本的问题？

socket *
threading Thread

():
    :
        redata = udp_socket.recvfrom()
        recv_content = recv_data[].decode()
        (recv_contentredata[])
        recv_content == :
           ()
           ():
    addr = (, )
    :
        data = ()
        udp_socket.sendto(data.encode(), addr)
        data == :
            ()
            __name__==:
    udp_socket = socket(AF_INET, SOCK_DGRAM)
    udp_socket.bind((, ))
    t1 = Thread(=send_data)
    t2 = Thread(=recv_data)
    t2.start()
    t1.start()
    t1.join()
    t2.join()

运行上述代码后报错：
输入信息：Exception in thread Thread-2 (recv_data):
Traceback (most recent call last):
  File "C:\Program Files\Python311\Lib\threading.py", line 1045, in _bootstrap_inner
    self.run()
  File "C:\Program Files\Python311\Lib\threading.py", line 982, in run
    self._target(*self._args, **self._kwargs)
  File "D:\Study\PythonBigData\mypro1\UDP客户端1.py", line 8, in recv_data
    redata = udp_socket.recvfrom(1024)
             ^^^^^^^^^^^^^^^^^^^^^^^^^
ConnectionResetError: [WinError 10054] 远程主机强迫关闭了一个现有的连接。

请问是出了什么问题？

if __name__ == '__main__':
    # 创建进程列表
    t_list = []
    mq = Queue()
    mq.put('1')
    mq.put('2')
    mq.put('3')
    # 循环创建进程
    for i in range(3):
        t = MyProcess('p{}'.format(i), mq)
        t.start()
        t_list.append(t)
    # 等待进程结束
    for t in t_list:
        t.join()
    print(mq.get())
    print(mq.get())
    print(mq.get())

老师您好，请问，上面这段代码为什么要写两个for循环？不是很理解。第一个for循环运行了三个进程，然后第二个for循环依次等待三个进程？我不理解的是，第一个for循环是否会将三个进程都运行完，然后再执行第二个for循环，依次等待?如果是这样，第一个for循环运行后，三个进程都运行了，还要第二个for循环有什么意义？ 如果稍作修改代码，如下，会有何问题？

if __name__ == '__main__':
    # 创建进程列表
    t_list = []
    mq = Queue()
    mq.put('1')
    mq.put('2')
    mq.put('3')
    # 循环创建进程
    for i in range(3):
        t = MyProcess('p{}'.format(i), mq)
        t.start()
        t_list.append(t)
        t.join()
    print(mq.get())
    print(mq.get())
    print(mq.get())

def producer():
    num = 1
    if num < 10:
        if queue.qsize() < 10:
            print(f'生产:{num}号，大馒头')
            queue.put(f'大馒头：{num}号')
            num += 1
    else:
        print('馒头框满了,等待来人消费啊！')
    sleep(1)

def consumer():
    if queue.qsize() > 0:
        print(f'获取馒头：{queue.get()}')
        sleep(1)
    else:
        print('没有馒头了！')


if __name__ == '__main__':
    queue = Queue()
    t = Thread(target=producer)
    t.start()
    c = Thread(target=consumer)
    c.start()

老师，我自己写的代码，但是始终都只能生产一个馒头并获取一个馒头。请问问题出在哪里？谢谢！

便利  for i in range （3）这是干嘛了

孩子有点懵