作者:小白学习哈 | 来源:互联网 | 2023-09-12 20:55
TCP聊天工具[python]-文章目录一、实验名称二、实验目的三、实验内容和要求四、实验环境五、操作方法与实验步骤六、实验数据记录和结果分析一、实验名称建立聊天工
一、实验名称
建立聊天工具
二、实验目的
掌握Socket编程中流套接字的技术,实现多台电脑之间的聊天。
三、实验内容和要求
vii.掌握利用Socket进行编程的技术
viii.必须掌握多线程技术,保证双方可以同时发送
ix.建立聊天工具
x.可以和多个人同时进行聊天
xi.必须使用图形界面,显示双方的语录
四、实验环境
PC多台,操作系统Win7,win10(32位、64位)
具备软件python3.6 。
五、操作方法与实验步骤
服务端
1.调入多线程、与scoket包,用于实现多线程连接
2.记录本地地址与端口,开启监听,等待请求
3.收到某个客户端的请求,建立连接,为每一个客户端分配一个线程,并记录客户端地址与端口
4.收到某个客户端发送的数据,将数据转发给所有与服务器连接的客户机。
5.当某个客户端断开连接,通知所有与服务器连接的客户机。
6.服务器一直保持监听状态,等待其他客户端接入服务器
7.代码
import socket
import threading
num=0
def chat(service_client_socket,addr):
if not addr in user:
print('Accept new connection from %s:%s...' % addr)
for scs in serv_clie_socket:
serv_clie_socket[scs].send(data +' 进入聊天室...'.encode('utf-8'))
user[addr] = data.decode('utf-8')
serv_clie_socket[addr] = service_client_socket
while True:
d = service_client_socket.recv(1024)
if (('EXIT'.lower() in d.decode('utf-8'))|(d.decode('utf-8') == 'error1')):
name = user[addr]
user.pop(addr)
serv_clie_socket.pop(addr)
for scs in serv_clie_socket:
serv_clie_socket[scs].send((name + ' 离开了聊天室...').encode('utf-8'))
print('Connection from %s:%s closed.' % addr)
global num
num = num-1
break
else:
print('"%s" from %s:%s' %(d.decode('utf-8'), addr[0], addr[1]))
for scs in serv_clie_socket:
if serv_clie_socket[scs] != service_client_socket:
serv_clie_socket[scs].send(d)
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
addr = ('127.0.0.1', 9999)
s.bind(addr)
s.listen(128)
print('TCP Server on', addr[0], ":",addr[1],"......")
user = {}
serv_clie_socket = {}
while True:
try:
print("等待接收客户端的连接请求....")
service_client_socket, addr = s.accept()
print("接收到客户端的连接请求....")
except ConnectionResetError:
print('Someone left unexcept.')
data = service_client_socket.recv(1024)
if data.decode()=='error1':
print(addr,"关闭了登录窗口。。。")
continue
print("data = ",data.decode())
num=num+1
r = threading.Thread(target=chat, args=(service_client_socket,addr), daemon=True)
r.start()
print("聊天室人数:",num)
客户端
1.调入多线程、与scoket包,用于实现多线程连接,调入tkinter包,用于图形化页面展示
2.记录本地地址与端口,向服务器发送连接请求,建立持续连接
3.图形化登录界面,记录输入的用户名,发送给服务器
4.进入聊天界面,从服务器接收到的消息显示在左边,发送给服务器的消息显示在右边
5.退出时,弹出警示界面。退出后,与服务器断开连接,结束。
6.代码
7.其他:客户端代码中的server改成服务器地址,客户端可以在不同的电脑上运行连接服务器,通过服务器与其他的客户端通讯。
import tkinter
from tkinter import font
import tkinter.messagebox
import socket
import threading
import time
string=''
def my_string(s_input):
string = s_input.get()
def Send(sock):
'''
发送数据的方法
参数:
sock:定义一个实例化socket对象
server:传递的服务器IP和端口
'''
if string!='':
message = name + ' : ' + string
data = message.encode('utf-8')
sock.send(data)
if string.lower() == 'EXIT'.lower():
exit()
def recv(sock):
sock.send(name.encode('utf-8'))
while True:
data = sock.recv(1024)
time_tuple = time.localtime(time.time())
str = ("{}点{}分".format(time_tuple[3],time_tuple[4]))
rrecv = tkinter.Label(t,text=data.decode('utf-8'),width=40,anchor='w',bg='pink')
rrecv.pack()
def left():
global string
string = rv1.get()
Send(s)
if string!='':
rleft = tkinter.Label(t,text=string,width=40,anchor='e')
rleft.pack()
rv1.set('')
def Creat():
global name
name = n.get()
tr = threading.Thread(target=recv, args=(s,), daemon=True)
tr.start()
l.destroy()
e.destroy()
b.destroy()
t.title("聊天室")
t.geometry("500x600")
rL0 = tkinter.Label(t,text='%s的聊天室'%name,width=40)
rL0.pack()
rL1 = tkinter.Label(t,text='请输入消息:',width=20, height=1)
rL1.place(x=0,y=450)
rE1 = tkinter.Entry(t, textvariable = rv1)
rE1.place(x=200,y=450)
rB1 = tkinter.Button(t, text="发送",command=left)
rB1.place(x=380,y=450)
def JieShu():
tkinter.messagebox.showwarning(title='你确定退出吗?', message='刚才你点击了关闭按钮')
s.send("error1".encode('utf-8'))
exit(0)
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server = ('10.100.207.40', 9999)
s.connect(server)
t=tkinter.Tk()
t.title("多人聊天室")
t.geometry("300x200+500+200")
l = tkinter.Label(t,text='多人聊天室欢迎您,请输入你的名称',width=40, height=8)
l.pack()
n = tkinter.StringVar()
e = tkinter.Entry(t, width=15,textvariable = n)
e.pack()
rv1 = tkinter.StringVar()
name = n.get()
b = tkinter.Button(t, text="登录",width=40, height=10,command=Creat)
b.pack()
t.protocol("WM_DELETE_WINDOW", JieShu)
t.mainloop()
s.close()
六、实验数据记录和结果分析
1.服务器启动,等待客户机连接请求
![](https://img.php1.cn/3cd4a/1eebe/cd5/d05d9dfd09a56332.webp)
2.客户端请求服务,客户端弹出登录窗口,输入用户名登录
![](https://img.php1.cn/3cd4a/1eebe/cd5/a5d7215df572c386.webp)
3.服务器接收到请求,分配端口,并持续监听其他客户机的请求
![](https://img.php1.cn/3cd4a/1eebe/cd5/72fd2c126203a875.webp)
![](https://img.php1.cn/3cd4a/1eebe/cd5/7cccb7e4b6cb5cb8.webp)
![](https://img.php1.cn/3cd4a/1eebe/cd5/ed19db63ee478b98.png)
![](https://img.php1.cn/3cd4a/1e618/c5a/d5d40da532c3a782.png)
4.客户端登陆后进入聊天窗口
![](https://img.php1.cn/3cd4a/1eebe/cd5/8be1ccb5166feb93.webp)
5.进入聊天室的用户,发送消息,其他用户都可以接收到,服务器也能看到
![](https://img.php1.cn/3cd4a/1eebe/cd5/e62700fe09f8933e.webp)
![](https://img.php1.cn/3cd4a/1eebe/cd5/02c379d60086f382.webp)
6.客户机退出连接,其他用户都可以接收到,服务器也能看到
![](https://img.php1.cn/3cd4a/1eebe/cd5/e88efe5b0a13a7fa.webp)
![](https://img.php1.cn/3cd4a/1eebe/cd5/1113165c4904ecc5.webp)
7.其他客户机可以中途进入聊天室
![](https://img.php1.cn/3cd4a/1eebe/cd5/8ad8f3bf8da691df.webp)