python实现多人聊天服务器以及客户端_Python

本文实例为大家分享了python实现多人聊天服务器以及客户端，供大家参考，具体内容如下

所用python的知识点：

网络编程：socket

多线程：threading

图形化编程：tkinter

首先要模拟出一个服务器，以供客户端连接，注意这里的要用死循环，要让服务区一直处于开放的状态

其次要运用多线程，因为多线程共享变量而且可以同时并发的执行操作，否则服务器就只可以连接一个客户端

下面先附上代码后在解释其怎么操作：

第一个py文件--服务器

				?

									import tkinter

									import socket, threading

									win = tkinter.tk()  # 创建主窗口

									win.title('模拟服务器')

									win.geometry("400x400+200+20")

									users = {}#用户字典，也可以连接数据库

									def run(ck, ca):

									    username = ck.recv(1024)#接受客户端发送的信息以1k作为单位这里接受到的信息为byte类型

									    users[username.decode("utf-8")] = ck#解码并储存用户的信息

									    #print(users)

									    printstr = "" + username.decode("utf-8") + "连接\n"#在连接显示框中显示是否连接成功

									    text.insert(tkinter.insert, printstr)

									    while true:

									        rdata = ck.recv(1024)#接受客户端发送的信息以1k作为单位这里接受到的信息为byte类型

									        datastr = rdata.decode("utf-8")

									        infolist = datastr.split(":")#分割字符串从而得到所要发送的用户名和客户端所发送的信息

									        users[infolist[0]].send((username.decode("utf-8") + "说" + infolist[1]).encode("utf"))

									        #要发送信息的客户端向目标客户端发送信息

									def start():

									    ipstr = eip.get()#从输入端中获取ip

									    portstr = eport.get()#从输入端中获取端口，注意端口取得时候不能被占用（可以取8080，9876，等）

									    server = socket.socket(socket.af_inet, socket.sock_stream)#socked所准守ipv4或ipv6，和相关协议的

									    server.bind((ipstr, int(portstr)))#绑定ip和端口号！！！1:注意输入的端口号是str型而这里的要传入int型

									    #2:bind()的参数是一个元组的形式

									    server.listen(10)#设置监听，和设置连接的最大的数量

									    printstr = "服务器启动成功\n"#，是否连接成功

									    text.insert(tkinter.insert, printstr)#显示在信息窗口中

									    while true:#这里用死循环是因为模拟的服务器要一直运行

									        ck, ca = server.accept()#接受所连接的客户端的信息

									        # 其中ca是ip和端口号组成的元组，ck有关客户端的信息

									        t = threading.thread(target=run, args=(ck, ca))#每连接一个客户端就开启一个线程

									        #其中thread函数中的传入函数的参数也是以元组的形式

									        t.start()#开启线程

									def startsever():

									    s = threading.thread(target=start)#启用一个线程开启服务器

									    s.start()#开启线程

									#下面是关于界面的操作

									labelip = tkinter.label(win, text='ip').grid(row=0, column=0)

									labelport = tkinter.label(win, text='port').grid(row=1, column=0)

									eip = tkinter.variable()

									eport = tkinter.variable()

									entryip = tkinter.entry(win, textvariable=eip).grid(row=0, column=1)

									entryport = tkinter.entry(win, textvariable=eport).grid(row=1, column=1)

									button = tkinter.button(win, text="启动", command=startsever).grid(row=2, column=0)

									text = tkinter.text(win, height=5, width=30)

									labeltext = tkinter.label(win, text='连接消息').grid(row=3, column=0)

									text.grid(row=3, column=1)

									win.mainloop()

第二个py文件---客户端

				?

									import tkinter

									import socket

									import threading

									win = tkinter.tk()

									win.title("客户端2")

									win.geometry("400x400+200+20")

									ck = none#用于储存客户端的信息

									def getinfo():

									    while true:

									        data = ck.recv(1024)#用于接受服务其发送的信息

									        text.insert(tkinter.insert, data.decode("utf-8"))#显示在信息框上

									def connectserver():

									    global ck

									    ipstr = eip.get()

									    portstr = eport.get()

									    userstr = euser.get()

									    client = socket.socket(socket.af_inet, socket.sock_stream)#socked所准守ipv4或ipv6，和相关协议的

									    client.connect((ipstr, int(portstr)))#连接ip和端口号！！！1:注意输入的端口号是str型而这里的要传入int型

									    #2:bind()的参数是一个元组的形式

									    client.send(userstr.encode("utf-8"))

									    ck = client

									    t = threading.thread(target=getinfo)

									    t.start()

									def sendmail():

									    friend = efriend.get()

									    sendstr = esend.get()

									    sendstr = friend + ":" + sendstr

									    ck.send(sendstr.encode("utf-8"))

									#下面是界面

									labeluse = tkinter.label(win, text="username").grid(row=0, column=0)

									euser = tkinter.variable()

									entryuser = tkinter.entry(win, textvariable=euser).grid(row=0, column=1)

									labelip = tkinter.label(win, text="ip").grid(row=1, column=0)

									eip = tkinter.variable()

									entryip = tkinter.entry(win, textvariable=eip).grid(row=1, column=1)

									labelport = tkinter.label(win, text="port").grid(row=2, column=0)

									eport = tkinter.variable()

									entryport = tkinter.entry(win, textvariable=eport).grid(row=2, column=1)

									button = tkinter.button(win, text="启动", command=connectserver).grid(row=3, column=0)

									text = tkinter.text(win, height=5, width=30)

									labeltext= tkinter.label(win, text="显示消息").grid(row=4, column=0)

									text.grid(row=4, column=1)

									esend = tkinter.variable()

									labelesend = tkinter.label(win, text="发送的消息").grid(row=5, column=0)

									entrysend = tkinter.entry(win, textvariable=esend).grid(row=5, column=1)

									efriend = tkinter.variable()

									labelefriend= tkinter.label(win, text="发给谁").grid(row=6, column=0)

									entryfriend = tkinter.entry(win, textvariable=efriend).grid(row=6, column=1)

									button2 = tkinter.button(win, text="发送", command=sendmail).grid(row=7, column=0)

									win.mainloop()