python实现简单点对点（p2p）聊天

2020-01-04 16:44:23

字体：大中小

来源：转载

供稿：网友

点对点聊天首先是基于多线程的网络编程，其次就是将每一个连接都保存为一个具有独一属性的对象并添加到连接列表中，对于每一个连接对象发送过来的信息必须要包含主要的三项内容（from,to,messages），这样当信息发送到服务器之后服务器根据to的连接对象遍历连接列表找到目标对象将信息发送给目标，目标拿到信息后就知道是谁发过来的，然后根据id号码进行回复。此实现将会继续完善，后续新加功能将会在我个人github主页展现

服务器端实现：

#coding:utf-8'''file:server.pydate:2017/9/10 12:43author:lockeyemail:lockey@123.complatform:win7.x86_64 pycharm python3desc:p2p communication serverside'''import socketserver,jsonimport subprocessconnLst = []## 连接列表，用来保存一个连接的信息（代号 地址和端口 连接对象）class Connector(object):#连接对象类 def __init__(self,account,password,addrPort,conObj): self.account = account self.password = password self.addrPort = addrPort self.conObj = conObjclass MyServer(socketserver.BaseRequestHandler): def handle(self): print("got connection from",self.client_address) register = False while True:  conn = self.request  data = conn.recv(1024)  if not data:  continue  dataobj = json.loads(data.decode('utf-8'))  #如果连接客户端发送过来的信息格式是一个列表且注册标识为False时进行用户注册  if type(dataobj) == list and not register:  account = dataobj[0]  password = dataobj[1]  conObj = Connector(account,password,self.client_address,self.request)  connLst.append(conObj)  register = True  continue  print(connLst)  #如果目标客户端在发送数据给目标客服端  if len(connLst) > 1 and type(dataobj) == dict:  sendok = False  for obj in connLst:   if dataobj['to'] == obj.account:   obj.conObj.sendall(data)   sendok = True  if sendok == False:   print('no target valid!')  else:  conn.sendall('nobody recevied!'.encode('utf-8'))  continueif __name__ == '__main__': server = socketserver.ThreadingTCPServer(('192.168.1.4',8022),MyServer) print('waiting for connection...') server.serve_forever()

客户端实现：

#coding:utf-8'''file:client.py.pydate:2017/9/10 11:01author:lockeyemail:lockey@123.complatform:win7.x86_64 pycharm python3desc:p2p communication clientside'''from socket import *import threading,sys,json,reHOST = '192.168.1.4' ##PORT=8022BUFSIZ = 1024 ##缓冲区大小 1KADDR = (HOST,PORT)tcpCliSock = socket(AF_INET,SOCK_STREAM)tcpCliSock.connect(ADDR)userAccount = Nonedef register(): myre = r"^[_a-zA-Z]/w{0,}" #正则验证用户名是否合乎规范 accout = input('Please input your account: ') if not re.findall(myre, accout): print('Account illegal!') return None password1 = input('Please input your password: ') password2 = input('Please confirm your password: ') if not (password1 and password1 == password2): print('Password not illegal!') return None global userAccount userAccount = accout return (accout,password1)class inputdata(threading.Thread): def run(self): while True:  sendto = input('to>>:')  msg = input('msg>>:')  dataObj = {'to':sendto,'msg':msg,'froms':userAccount}  datastr = json.dumps(dataObj)  tcpCliSock.send(datastr.encode('utf-8'))class getdata(threading.Thread): def run(self): while True:  data = tcpCliSock.recv(BUFSIZ)  dataObj = json.loads(data.decode('utf-8'))  print('{} -> {}'.format(dataObj['froms'],dataObj['msg']))def main(): while True: regInfo = register() if regInfo:  datastr = json.dumps(regInfo)  tcpCliSock.send(datastr.encode('utf-8'))  break myinputd = inputdata() mygetdata = getdata() myinputd.start() mygetdata.start() myinputd.join() mygetdata.join()if __name__ == '__main__': main()

运行结果示例：

服务器端结果：

python,点对点,聊天