一·思路
服务器端：
首先是服务端思路，第一步需要告诉用户服务端的ip地址，端口号，第二步需要告诉服务器可以接受的最大接听数，第三步需要设置阻塞，也就是当有用户接入时，让其他用户暂时等待状态
bind（）设置连接端口
listen（）设置监听
accept（）设置阻塞，返回的参数有服务器地址和端口，客户端的服务器和端口
sendall()发送信息
import socket
sk = socket.socket()
#设置端口
sk.bind(("192.168.0.****",9999))
#设置可接入数量
sk.listen(5)
#阻塞
conn, adress = sk.accept()
#向客户端发送消息
conn.sendall(bytes("欢迎光临",encoding='utf-8'))
print(adress,conn)
客户端：
首先要确定连接的服务器ip和端口，第二部接受设置接受数值
这里要知道两个函数
connect（）函数用来连接端口
recv（） 用来接受消息
import socket
obj = socket.socket()
obj.connect(("192.168.101",9999))
rec_str = obj.recv(1024)
print(str(rec_str, encoding="utf-8"))
二、简单的问答
有时候我们会看到一些机器客服的接入，你选择响应的问题的，机器人对相应的问题进行解答我们要做的就是进行问答
我们先写服务器端的机器人
import socket
sk = socket.socket()
#设置端口
sk.bind(("192.168.0.101",9999))
#设置可接入数量
sk.listen(5)
#阻塞
conn, adress = sk.accept()
#向客户端发送消息
conn.sendall(bytes("欢迎光临",encoding='utf-8'))
while True:
#设置接收用户端的信息
str_c = conn.recv(1024)
print(str(str_c,encoding='utf-8'))
rec_str = str(str_c, encoding='utf-8')
#像用户端发送信息中加前缀‘好’
conn.sendall(bytes('好的'+rec_str,encoding='utf-8'))
print(adress,conn)
客户端做的处理：
import socket
obj = socket.socket()
#。连接端口信息
obj.connect(("192.168.101",9999))
while True:
# 接受信息
rec_str = obj.recv(1024)
#打印内容
print(str(rec_str, encoding="utf-8"))
#输入内容
str_inp = input("请输入内容")
obj.sendall(bytes(str_inp,encoding='utf-8'))
三、文件的传送
用户端发送文件大信息，当发送文件的时候我们可以用到函数open，对文件进行读取。
在这之前我们先回一下QQ发送文件时候的步骤，首先A 用户发送文件给B，B用户先接到文件的大小和是否接受文件，这里为什么要做告诉用户文件大小呢？可能大家觉得是一个友好提示，但实际上是为了告诉接受方在读取多少信息时文件发送完毕
用具体事例来验证
构造用户端：
import socket
import os
obj = socket.socket()
obj.connect(("192.168.0.101", 9999))
while True:
#发送图片大小
size = os.stat("客户端图片.png").st_size
obj.sendall(bytes(str(size),encoding="utf-8"))
with open("客户端图片.png",'rb') as f:
for i in f:
#发送图片内容
obj.sendall(i)
接受端：
import socket
sk = socket.socket()
sk.bind(("192.168.101",9999))
sk.listen(5)
while True:
conn, adress = sk.accept()
str_file = conn.recv(1024)
#接收图片大小
size = str(str_file,encoding="utf-8")
total_size = int(size)
total = 0
f = open("new.png",'wb')
while True:
if total_size == total:
print("结束")
break
#再次发起接受
str_concent = conn.recv(1024)
f.write(str_concent)
total +=len(str_concent)
f.close()
四、多并发
import socketserver
class MyServer(socketserver.BaseRequestHandler):
def handle(self):
conn = self.request
conn.sendall(bytes("欢迎光临", encoding='utf-8'))
while True:
# 设置接收用户端的信息
str_c = conn.recv(1024)
print(str(str_c, encoding='utf-8'))
rec_str = str(str_c, encoding='utf-8')
# 像用户端发送信息中加前缀‘好’
conn.sendall(bytes('好的' + rec_str, encoding='utf-8'))
print(adress, conn)
if __name__ == '__main__':
server = socketserver.ThreadingTCPServer(('192.168.0.101',9999),MyServer)
server.serve_forever()
