python网络通信socket

import socket
s = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM, proto=0, fileno=None)

server = socket.socket()  # 创建

server.bind(('127.0.0.1', 8000))   # 绑定本机地址和端口

server.listen() # 开始监听端口

# 阻塞等待客户端的连接，连接后返回一个新的可与客户端通信的socket和客户端的（ip，port）
s, raddr = server.accept()

C:\Users\user>netstat -anp tcp | findstr 8000
TCP    127.0.0.1:8000         0.0.0.0:0              LISTENING

import socket
import threading

class Server:
    def __init__(self, ip='127.0.0.1', port=8000):  # 设置默认值
        self.addr = ip, port
        self.lock = threading.Lock()
        self.sock = socket.socket()
        self.sock.bind(self.addr)
        self.socks = {"accept": self.sock}  # 将所有创建的socket都放字典，方便释放

    def start(self):  # 启动接口
        self.sock.listen()
        threading.Thread(target=self.accept, name="accept", daemon=True).start()

    def accept(self):  # 该线程等待连接并创建处理线程
        while True:
            s, raddr = self.sock.accept()
            with self.lock:
                self.socks[raddr] = s
            threading.Thread(target=self.recv, args=(s, raddr), name="recv", daemon=True).start()

    def recv(self, s, raddr):  # 每个客户端开启一个线程与其交互
        while True:
            data = s.recv(1024).decode()
            if data.strip() == "" or data.strip() == "quit":  # 客户端结束条件
                with self.lock:
                    self.socks.pop(raddr)
                    s.close()
                    break
            print(data)
            s.send("server:{}\n".format(data).encode())

    def stop(self):
        with self.lock:
            for s in self.socks.values():
                s.close()
s = Server()
s.start()

while True:
    cmd = input("server commond:>>>")
    if cmd == "quit":  # 服务器退出条件
        s.stop()
        break
    print(threading.enumerate())

sock = socket.socket()
file = sock.makefile("rw")  # mode="rw" 可读可写

data = file.read()   # 等价于socket.recv()

data = file.read(10) # 指定读取字符大小长度，满10个字符才会返回。
data = file.readlin()   # 每次读取一行，遇到换行符才返回。
# 写入数据
msg = "hello world"
file.write(msg)
file.flush()      # 手动flush，否则在缓冲区满或者退出时自动才写入socket。同文件写入操作

import socket
import threading
import datetime

class Client:
    def __init__(self, rip, rport):  # 服务器ip 和 端口
        self._raddr = rip, rport
        self._sock = socket.socket()
        self._connect()

    def _connect(self):
        self._sock.connect(self._raddr)   # 尝试连接指定的地址
        self.f = self._sock.makefile("rw")
        self.f.write("i am client at {}\n".format(self._sock.getsockname()))
        self.f.flush()
        threading.Thread(target=self.recv, name="recv", daemon=True).start()  # 一个进程接收消息
        self.send()   # 主进程发送消息

    def send(self):
        while True:
            msg = input(">>>").strip()
            self.f.write(msg)
            self.f.flush()
            if msg == "quit":
                self.stop()
                break

    def recv(self):
        while True:
            msg = self.f.readline()
            print("server:{}{:%Y/%m/%d %H:%M:%S}\n\t{}".format(self._sock.getpeername(), datetime.datetime.now(), msg))

    def stop(self):
        self.f.close()
        self._sock.close()

c = Client("127.0.0.1", 8000)