#coding=utf-8
'''双向通信Socket之客户端
将控制台输入的信息发送给服务器端
 读取服务器端的数据，将内容输出到控制台'''
from socket import *

tcp_client_socket=socket(AF_INET,SOCK_STREAM)

tcp_client_socket.connect(('127.0.0.1',8888))

while True:
    msg=input(">")
    tcp_client_socket.send(msg.encode("gbk"))
    if msg=='end':
        break
    redata=tcp_client_socket.recv(1024)
    recv_data=redata.decode('gbk')
    print(f"服务器端说:{recv_data}")
tcp_client_socket.close()

# TCP双向持续通信
# 【示例】TCP：双向通信Socket之服务器端
#coding=utf-8

from socket import *

tcp_server_socket=socket(AF_INET,SOCK_STREAM)
tcp_server_socket.bind(('127.0.0.1',8888))
tcp_server_socket.listen(5)
print("服务端已经启动，等待客户端连接！")

tcp_client_socket,host=tcp_server_socket.accept()
print("一个客户端建立连接成功！")
while True:
    re_data = tcp_server_socket.recv(1024)
    re_content =re_data.decode('gbk')
    print(f"客户端说:{re_content},from:{host}")
    if re_content == 'end':
        break
    msg = input(">")
    tcp_server_socket.send(msg.encode("gbk"))
tcp_client_socket.close()
tcp_server_socket.close()

客户端运行输入报错
>121
Traceback (most recent call last):
  File "C:/Users/Administrator/Desktop/python代码练习/udp.py", line 68, in <module>
    redata=tcp_client_socket.recv(1024)
ConnectionAbortedError: [WinError 10053] 你的主机中的软件中止了一个已建立的连接。

这个是为什么啊

'''【示例】UDP接收数据'''
#coding=utf-8
from socket import *
s=socket(AF_INET,SOCK_DGRAM)#创建套接字
s.bind(("127.0.0.1",8888))
print("等待接收数据！")
redata =s.recvfrom(1024)#1024表示本次接收的最⼤字节数,s.recvfrom()
'''接收UDP数据，与recv()类似，但返回值是
（data,address）。其中data是包含接收数据的字符
串，address是发送数据的套接字地址。'''
print(f"收到远程消息：{redata[0]},from {redata[1]}")
s.close()
运行结果

请输入：付水电费第三方第三方

print为什么一直打印不了

#encoding=utf-8
from time import sleep
from queue import Queue
from threading import Thread


def producer():
    num=1
    while True:
        if queue.qsize()<3:
            print(f"生产{num}号大馒头")
            queue.put(f"将{num}号馒头放进框中")
            num+=1
        else:
            print("馒头框满了，等待来人消费啊！")
        sleep(1)

def consumer():
    while True:
        print(f"获取{queue.get()}")
        sleep(1)

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

    c=Thread(target=consumer)
    c.start()

老师，这里的queue.get()返回的是什么内容啊，是queue.put()中的字符串么？

#未使用线程同步和互斥锁的情况
from threading import Thread
from time import sleep

class Account:
    def __init__(self,money,name):
        self.money=money
        self.name=name

#模拟提款的操作
class Drawing(Thread):#继承Thread类
    def __init__(self,drawingNum,account):
        Thread.__init__(self)#包含调用父类构造函数
        self.drawingNum=drawingNum
        self.account=account
        self.expenseTotal=0
    def run(self):
        if self.account.money < self.drawingNum:
            return                            #结束函数
        sleep(1)#判断完可以取钱，则阻塞，就是为了测试发生冲突问题
        self.account.money-=self.drawingNum
        self.expenseTotal+=self.drawingNum
        print(f"账户：{self.account.name}，余额是：{self.account.money}")
        print(f"账户：{self.account.name},总共取了：{self.expenseTotal}")

if __name__ == '__main__':
    a1=Account(100,"gaoqi")#实例化对象
    draw1=Drawing(80,a1)#实例化对象，并将a1作为参数传入
    draw2=Drawing(80,a1)
    draw1.start()
    draw2.start()

老师，这里最终为什么总共不是取了160？draw1和draw2传入的第二个参数是同一个对象a1，是不是因为执行draw2线程时又把self.expenseTotal=0重定义了，所以还是一共取了80？

老师，这是什么原因呢？

一脸懵逼，讲一大堆理论

老师我怎么感觉我的VScode怪怪的要全选才可以把代码运行，直接运行就报错

为什安装有greenlet 但是无法调用咧

这里为什么要用循环啊，不太

明白

老师必须用vs吗

老师好 pycharm里面没有greenlet模块怎么操作呢

老师你好！我想知道向服务器发送确认的这部分代码为什么是放在判断是否最后一次数据传送的后面呢？如果这样，break停止整个循环，最后小于516字节的那一部分就不需要发送ACK确认信息了吗？那这样服务器怎么判定数据包是否丢失呢？

老师print（m_list）放在with manager里和外得出的结论是不一样的

放在with manager外的话代表的是什么，区别是什么

async def compute(x, y):
    print(f'compute:{x}+{y}....')
    await asyncio.sleep(1)
    return x+y


async def print_sum(x, y):
    # 创建task
    task = asyncio.create_task(compute(x, y))        # python3.7以上写法
    # task绑定回调函数
    task.add_done_callback(functools.partial(end, x, y))  # python3.7以上写法
    # 释放下cpu的使用
    await asyncio.sleep(0)
    print('--------------------print_num继续执行---------------------------')
    for i in range(1000000):
        if i % 5000 == 0:
            print(i)
            await asyncio.sleep(0.1)


def end(n, m, t):
    print(f'{n}+{m}={t.result()}')

老师，这个t是什么，是谁传给它的

from multiprocessing import Pool,current_process
import time
def fun1(name):
    print(f"id1为{current_process().pid},接受的数据为{name}")
    time.sleep(3)
    return name
def fun2(args):
    print(args)


if __name__ == '__main__':
    pllo=Pool(3)
    pllo.apply_async(fun1,args=('1',),callback=fun2,)
    pllo.apply_async(fun1,args=('2',))
    pllo.apply_async(fun1,args=('3',))
    pllo.apply_async(fun1,args=('4',))
    pllo.apply_async(fun1,args=('5',))
    pllo.apply_async(fun1,args=('6',))
    pllo.apply_async(fun1,args=('7',))
    pllo.apply_async(fun1,args=('8',))
    pllo.apply_async(fun1,args=('9',))

    pllo.close()

    pllo.join()
    #老师好 这里有时候打印不出数据是怎末回事呢 是一个空行 如下：
    #id1为7628,接受的数据为1id1为7628,接受的数据为1
id1为16176,接受的数据为2
id1为7092,接受的数据为3
1id1为7628,接受的数据为4

id1为16176,接受的数据为5
id1为7092,接受的数据为6
id1为7628,接受的数据为7
id1为16176,接受的数据为8
id1为7092,接受的数据为9

进程已结束，退出代码为 0