Python高级编程和异步IO并发编程10_3Socket实现聊天和多用户连接

单用户连接&＃xff1a;

# coding:utf-8
# server端程序
import socket # 导入socket 模块address &＃61; (&＃39;0.0.0.0&＃39;, 50000) # IP地址和端口号
print(&＃39;Waiting for a client now !&＃39;)
server &＃61; socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 创建一个空的套接字&＃xff0c;socket.AF_INET表示创建一个IP套接字;
# socket.SOCK_STREAM表示流式socket,TCP模式;sock_DGRAM表示数据报式socket,UDP模式
server.bind(address) # 绑定&＃xff08;监听这个IP地址和端口的所有数据&＃xff09;到这个套接字上
server.listen(5) # 表示最多可以和5个客户端连接&＃xff0c;超过5个就会拒绝
# 调用accept方法时&＃xff0c;socket会时入“waiting”状态。客户请求连接时&＃xff0c;方法建立连接并返回服务器。
# accept方法返回一个含有两个元素的元组(connection,address)。
# 第一个元素connection是新的socket对象&＃xff0c;服务器必须通过它与客户通信&＃xff1b;第二个元素address是客户的Internet地址
client, addr &＃61; server.accept()
data &＃61; client.recv(1000) # 指定最大可以接受消息长度为1000字节
print("Client:", client, "Said", data) # 输出client客户端信息以及接收到的数据data
client.sendall(&＃39;hello&＃39;.encode("utf8")) # 发送数据
client.close() # 关闭
server.close()


# coding:utf-8
# client端程序
import socket # 导入 socket 模块try:address &＃61; (&＃39;127.0.0.1&＃39;, 50000)client &＃61; socket.socket(socket.AF_INET, socket.SOCK_STREAM)client.connect(address) # 与指定地址建立连接print("Connection succeeded!")client.sendall(&＃39;Hi!&＃39;.encode("utf8")) # 发送数据data &＃61; client.recv(1000)print("Server reply", data.decode("utf8"))client.close()
except:print("Connection failed.")


聊天程序

Server.py

# 聊天程序
import socket
# socket Sever&＃xff0c;首先做了绑定&＃xff0c;在server上不停的监听&＃xff0c;当监听到有一个新生成的连接&＃xff0c;就绑定一个socket&＃xff0c;因此后续的发送是socket&＃xff0c;而不是server
server &＃61; socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind((&＃39;0.0.0.0&＃39;,9999)) # bind必须绑定tuple。 如果绑定127.0.0.1&＃xff0c;会导致通过局域网的ip无法访问
print(&＃39;Waiting for a client now !&＃39;)
server.listen(5)
sock,addr &＃61; server.accept() # 全局的接收&＃xff0c;只能接收一次请求&＃xff0c;接受以后&＃xff0c;双方做数据交流&＃xff0c;server用来监听&＃xff0c;socket用于用户连通while True: # 接受后&＃xff0c;不可以closedata &＃61; sock.recv(1024) # 一次获取1KB数据print(data.decode("utf8"))re_data &＃61; input() # 通过手工输入来做交互sock.send(re_data.encode("utf8"))

Client.py

import socket
# 初始化的client就是我们一直要用到的client&＃xff0c;因此只需要一个client即可
client &＃61; socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.connect(("127.0.0.1",9999)) # 连接本地服务器
print("Connection succeeded!")
while True: # 接受后&＃xff0c;不可以closere_data &＃61; input() # 通过手工输入来做交互client.send(re_data.encode("utf8"))data &＃61; client.recv(1024) # 由发起端先发送数据过去&＃xff0c;从client端请求数据。 而服务器端是先recv数据print(data.decode("utf8")) # 打印放在recv之后

多用户聊天

Server.py

# 聊天程序
import socket
import threading
# socket Sever&＃xff0c;首先做了绑定&＃xff0c;在server上不停的监听&＃xff0c;当监听到有一个新生成的连接&＃xff0c;就绑定一个socket&＃xff0c;因此后续的发送是socket&＃xff0c;而不是server
server &＃61; socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind((&＃39;0.0.0.0&＃39;,9999)) # bind必须绑定tuple。 如果绑定127.0.0.1&＃xff0c;会导致通过局域网的ip无法访问
print(&＃39;Waiting for a client now !&＃39;)
server.listen(5)
# sock,addr &＃61; server.accept() # 全局的接收&＃xff0c;只能接收一次请求&＃xff0c;接受以后&＃xff0c;双方做数据交流&＃xff0c;server用来监听&＃xff0c;socket用于用户连通
# 目前&＃xff0c;一次只能连接一个client&＃xff0c;如何实现多用户聊天&＃xff0c;同时接入server&＃xff1f; 就需要用到多线程&＃xff0c;在线程里面进行循环。主线程不停的接收其它请求def handle_sock(sock,addr):while True: # 接受后&＃xff0c;不可以closedata &＃61; sock.recv(1024) # 由发起端先发送数据过去&＃xff0c;从client端请求数据。 而服务器端是先recv数据print(data.decode("utf8")) # 打印放在recv之后re_data &＃61; input() # 通过手工输入来做交互sock.send(re_data.encode("utf8"))while True: # 接受后&＃xff0c;不可以closesock,addr &＃61; server.accept() # 接收到新请求时&＃xff0c;立即交给线程&＃xff0c;由线程进行处理新的socket。# 用线程去处理新接收的连接&＃xff08;用户&＃xff09;client_thread &＃61; threading.Thread(target&＃61;handle_sock,args&＃61;(sock,addr)) # target传递的一定是函数的名称&＃xff0c;而不是函数的调用client_thread.start() # 启动线程


Client-x.py

# client-n.py
import socket
# 初始化的client就是我们一直要用到的client&＃xff0c;因此只需要一个client即可
client &＃61; socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.connect(("127.0.0.1",9999)) # 连接本地服务器
print("Connection succeeded!")
while True: # 接受后&＃xff0c;不可以closere_data &＃61; input() # 通过手工输入来做交互client.send(re_data.encode("utf8"))data &＃61; client.recv(1024) # 由发起端先发送数据过去&＃xff0c;从client端请求数据。 而服务器端是先recv数据print(data.decode("utf8")) # 打印放在recv之后

先运行Server.py, 提示“Waiting for a client now !"

运行Client-1.py, 提示Connection  succeeded!

在Client-1端&＃xff0c;输入“Client-1”&＃xff0c; 查看Server 端&＃xff0c;发现Server端已经收到“Client-1”

在Server端&＃xff0c;输入“Server-1”&＃xff0c;查看Client端&＃xff0c;发现Client端收到了“Server-1”

再运行Client-2.py&＃xff0c;提示Connection succeed&＃xff01;

在Client-2端&＃xff0c;输入“Client-2”&＃xff0c; 查看Server 端&＃xff0c;发现Server端已经收到“Client-2”

在Server端&＃xff0c;输入“Server-2”&＃xff0c;查看Client-2端&＃xff0c;发现Client端收到了“Server-2”&＃xff1b;查看Client-1端&＃xff0c;发现Client端没有收到“Server-2”