一对一 --- 服务端

import socket
ip_port = ('127.0.0.1',9999)

1- 创建socket对象---socket也叫套接字

sk = socket.socket()

2- 绑定ip 端口

sk.bind(ip_port)

3- 开启监听

sk.listen()
print('---socket服务器已经启动完成---')

4- 阻塞 等待客户端来链接 可以返回 连接对象,客户端的ip

conn,addr = sk.accept()

5- 接收数据

clientData = conn.recv(1024).decode('utf-8')#解码
print('接收到的客户端数据>>> ',clientData)

6- 发送数据

sendData = input("请输入发送数据:")
conn.sendall(sendData.encode('utf-8'))#编号

7- 关闭socket

sk.close()

一对一 --- 客户端

import socket
ip_port = ('127.0.0.1',9999)

1- 创建socket对象---socket也叫套接字

sk = socket.socket()

2- 连接服务器

sk.connect(('127.0.0.1',9999))

3- 发送数据

sendData = input("请输入发送数据:")
sk.sendall(sendData.encode('utf-8'))#编号

5- 接收数据

clientData = sk.recv(1024).decode('utf-8')#解码
print('接收到的服务器端的数据>>> ',clientData)

7- 关闭socket

sk.close()

一对多 --- 服务端

import socketserver
class sqServer(socketserver.BaseRequestHandler):
def handle(self):
#1- 描述下服务已经启动
print('---松勤聊天系统已经上线---')
#处理逻辑
while True:
# 接收数据
clientData = self.request.recv(1024).decode('utf-8') # 解码
print('接收到的服务器端的数据>>> ', clientData)
#发送数据
sendData = input("请输入发送数据:")
self.request.sendall(sendData.encode('utf-8')) # 编号
self.request.close()

2- 创建服务端

server = socketserver.ThreadingTCPServer(('127.0.0.1',9999),sqServer)

3- 一直运行

server.serve_forever()

一对多 --- 客户端A

import socket
ip_port = ('127.0.0.1',9999)

1- 创建socket对象---socket也叫套接字

sk = socket.socket()

2- 连接服务器

sk.connect(('127.0.0.1',9999))

while True:
#3- 发送数据
sendData = 'a用户:'+input("请输入发送数据:")
sk.sendall(sendData.encode('utf-8'))#编号
#5- 接收数据
clientData = sk.recv(1024).decode('utf-8')#解码
print('接收到的服务器端的数据>>> ',clientData)

7- 关闭socket

sk.close()

一对多 --- 客户端B

import socket
ip_port = ('127.0.0.1',9999)

1- 创建socket对象---socket也叫套接字

sk = socket.socket()

2- 连接服务器

sk.connect(('127.0.0.1',9999))

while True:
#3- 发送数据
sendData = 'b用户:'+input("请输入发送数据:")
sk.sendall(sendData.encode('utf-8'))#编号
#5- 接收数据
clientData = sk.recv(1024).decode('utf-8')#解码
print('接收到的服务器端的数据>>> ',clientData)

7- 关闭socket

sk.close()
import socket
ip_port = ('127.0.0.1',9999)

1- 创建socket对象---socket也叫套接字

sk = socket.socket()

2- 连接服务器

sk.connect(('127.0.0.1',9999))

while True:
#3- 发送数据
sendData = 'b用户:'+input("请输入发送数据:")
sk.sendall(sendData.encode('utf-8'))#编号
#5- 接收数据
clientData = sk.recv(1024).decode('utf-8')#解码
print('接收到的服务器端的数据>>> ',clientData)

7- 关闭socket

sk.close()