後續程式碼更新和功能新增會提交到 個人github主頁 ，有興趣可以一起來完善！

如果只是拿過去執行看結果，請注意平臺相關性以及python版本號，本示例開發執行平臺為win7x86_64 pycharm community，python版本號為3.5!!!

TALK IS CHEAP, SHOW YOU MY CODE:

客戶端

​
  #coding:utf-8
  '''
   file:client.py.py
   date:2017/9/11 11:01
   author:lockey
   email:[email protected]
   platform:win7.x86_64 pycharm python3
   desc:p2p communication clientside
   '''
  from socket import *
  import threading,sys,json,re
  #引入json模組主要是為了資料的封裝傳輸，re的話是做一些合法性的驗證
  HOST = '192.168.1.7'
  PORT=8022
  BUFSIZE = 1024 ##緩衝區大小 1K
  ADDR = (HOST,PORT)
  myre = r"^[_a-zA-Z]\w{0,}"
  tcpCliSock = socket(AF_INET,SOCK_STREAM)
  #建立一個socket連線
  userAccount = None
  #使用者登入標誌，也用來記錄登入的使用者名稱稱
  def register():
  #使用者註冊函式
   print("""
   Glad to have you a member of us!
   """)
   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
   regInfo = [accout,password1,'register']
   datastr = json.dumps(regInfo)
   tcpCliSock.send(datastr.encode('utf-8'))
   data = tcpCliSock.recv(BUFSIZE)
   data = data.decode('utf-8')
   if data == '0':
   print('Success to register!')
   return True
   elif data == '1':
   print('Failed to register, account existed!')
   return False
   else:
   print('Failed for exceptions!')
   return False
  
  def login():
  #使用者登入函式
   print("""
   Welcome to login in!
   """)
   accout = input('Account: ')
   if not re.findall(myre, accout):
   print('Account illegal!')
   return None
   password = input('Password: ')
   if not password:
   print('Password illegal!')
   return None
   global userAccount
   userAccount = accout
   loginInfo = [accout, password,'login']
   datastr = json.dumps(loginInfo)
   tcpCliSock.send(datastr.encode('utf-8'))
   data = tcpCliSock.recv(BUFSIZE)
   if data == '0':
   print('Success to login!')
   return True
   else:
   print('Failed to login in(user not exist or username not match the password)!')
   return False
  def addGroup():
  #群組新增
   groupname = input('Please input group name: ')
   if not re.findall(myre, groupname):
   print('group name illegal!')
   return None
   return groupname
  
  def chat(target):
  #進入聊天（群聊和點對點聊天可以選擇）
   while True:
   print('{} -> {}: '.format(userAccount,target))
   msg = input()
   if len(msg) > 0 and not msg in 'qQ':
    if 'group' in target:
    optype = 'cg'
    else:
    optype = 'cp'
  
    dataObj = {'type': optype, 'to': target, 'msg': msg, 'froms': userAccount}
    datastr = json.dumps(dataObj)
    tcpCliSock.send(datastr.encode('utf-8'))
    continue
   elif msg in 'qQ':
    break
   else:
    print('Send data illegal!')
  class inputdata(threading.Thread):
  #使用者輸入選擇然後執行不同的功能程式
   def run(self):
   menu = """
      (CP): Chat with individual
      (CG): Chat with group member
      (AG): Add a group
      (EG): Enter a group
      (H): For help menu
      (Q): Quit the system
      """
   print(menu)
   while True:
    operation = input('Please input your operation("h" for help): ')
    if operation in 'cPCPCpcp':
    #進入個人聊天
    target = input('Who would you like to chat with: ')
    chat(target)
    continue
  
    if operation in 'cgCGCgcG':
    #進入群聊
    target = input('Which group would you like to chat with: ')
    chat('group'+target)
    continue
    if operation in 'agAGAgaG':
    #新增群組
    groupName = addGroup()
    if groupName:
     dataObj = {'type': 'ag', 'groupName': groupName}
     dataObj = json.dumps(dataObj)
     tcpCliSock.send(dataObj.encode('utf-8'))
    continue
  
    if operation in 'egEGEgeG':
    #入群
    groupname = input('Please input group name fro entering: ')
    if not re.findall(myre, groupname):
     print('group name illegal!')
     return None
    dataObj = {'type': 'eg', 'groupName': 'group'+groupname}
    dataObj = json.dumps(dataObj)
    tcpCliSock.send(
 
dataObj.encode('utf-8'))
    continue
    if operation in 'hH':
    print(menu)
    continue
  
    if operation in 'qQ':
    sys.exit(1)
    else:
    print('No such operation!')
  
  class getdata(threading.Thread):
  #接收資料執行緒
   def run(self):
   while True:
    data = tcpCliSock.recv(BUFSIZE).decode('utf-8')
    
 
if data == '-1':
    print('can not connect to target!')
    continue
    if data == 'ag0':
    print('Group added!')
    continue
  
    if data == 'eg0':
    print('Entered group!')
    continue
  
    if data == 'eg1':
    print('Failed to enter group!')
    continue
  
    dataObj = json.loads(data)
    if dataObj[
 
'type'] == 'cg':
    #群組訊息的格式定義
    print('{}(from {})-> : {}'.format(dataObj['froms'], dataObj['to'], dataObj['msg']))
    else:
    #個人訊息的格式定義
    print('{} ->{} : {}'.format(dataObj['froms'], userAccount, dataObj['msg']))
  
  
  def main():
  
   try:
    tcpCliSock.connect(ADDR)
    print('Connected with server')
    while True:
    loginorReg = input('(l)ogin or (r)egister a new account: ')
    if loginorReg in 'lL':
     log = login()
     if log:
     break
    if loginorReg in 'rR':
     reg = register()
     if reg:
     break
  
    myinputd = inputdata()
    mygetdata = getdata()
    myinputd.start()
    mygetdata.start()
    myinputd.join()
    mygetdata.join()
  
   except Exception:
    print('error')
    tcpCliSock.close()
    sys.exit()
  
  
  if __name__ == '__main__':
   main()
  
  

服務端

​
  #coding:utf-8
  '''
   file:server.py
   date:2017/9/11 14:43
   author:lockey
   email:[email protected]
   platform:win7.x86_64 pycharm python3
   desc:p2p communication serverside
   '''
  import socketserver,json,time
  import subprocess
  
  connLst = []
  groupLst = []
  ## 代號 地址和埠 連線物件
  #optype = {'ag':'group adding','cp':'chat with individual','cg':'chat with group'}
  class Connector(object): ##連線物件類
   def __init__(self,account,password,addrPort,conObj):
   self.account = account
   self.password = password
   self.addrPort = addrPort
   self.conObj = conObj
  
  class Group(object):#群組類
   def __init__(self,groupname,groupOwner):
   self.groupId = 'group'+str(len(groupLst)+1)
   self.groupName = 'group'+groupname
   self.groupOwner = groupOwner
   self.createTime = time.time()
   self.members=[groupOwner]
  
  class MyServer(socketserver.BaseRequestHandler):
  
   def handle(self):
   print("got connection from",self.client_address)
   userIn = False
   global connLst
   global groupLst
   while not userIn:
    conn = self.request
    data = conn.recv(1024)
    if not data:
    continue
    dataobj = json.loads(data.decode('utf-8'))
    #如果連線客戶端傳送過來的資訊格式是一個列表且註冊標識為False時進行使用者註冊或者登陸
    ret = '0'
    if type(dataobj) == list and not userIn:
    account = dataobj[0]
    password = dataobj[1]
    optype = dataobj[2]
    existuser = False
    if len(connLst) > 0:
     for obj in connLst:
     if obj.account == account:
      existuser = True
      if obj.password == password:
      userIn = True
      print('{} has logged in system({})'.format(account,self.client_address))
      break
    if optype == 'login' and (not userIn or not existuser):
     ret = '1'
     print('{} failed to logged in system({})'.format(account, self.client_address))
    else:
     if existuser:
     ret = '1'
     print('{} failed to register({}),account existed!'.format(account, self.client_address))
     else:
     try:
      conObj = Connector(account,password,self.client_address,self.request)
      connLst.append(conObj)
      print('{} has registered to system({})'.format(account,self.client_address))
      userIn = True
     except:
      print('%s failed to register for exception!'%account)
      ret = '99'
    conn.sendall(ret.encode('utf-8'))
    if ret == '0':
    break
  
   while True:
   #除登陸註冊之外的請求的監聽
    conn = self.request
    data = conn.recv(1024)
    if not data:
    continue
    print(data)
    dataobj = data.decode('utf-8')
    dataobj = json.loads(dataobj)
    if dataobj['type'] == 'ag' and userIn:
    #如果判斷使用者操作請求型別為新增群組則進行以下操作
    groupName = dataobj['groupName']
    groupObj = Group(groupName,self.request)
    groupLst.append(groupObj)
    conn.sendall('ag0'.encode('utf-8'))
    print('%s added'%groupName)
    continue
  
    if dataobj['type'] == 'eg' and userIn:
    #入群操作
    groupName = dataobj['groupName']
    ret = 'eg1'
    for group in groupLst:
     if groupName == group.groupName:
     group.members.append(self.request)
     print('{} added into {}'.format(self.client_address,groupName))
     ret = 'eg0'
     break
    conn.sendall(ret.encode('utf-8'))
    continue
  
    #客戶端將資料發給伺服器端然後由伺服器轉發給目標客戶端
    print('connLst',connLst)
    print('grouplst',groupLst)
    if len(connLst) > 1:
    sendok = False
    if dataobj['type'] == 'cg':
    #群內廣播（除發訊息的人）
     print('group',data)
     for obj in groupLst:
     if obj.groupName == dataobj['to']:
      for user in obj.members:
      if user != self.request:
       user.sendall(data)
    else:
    #個人資訊傳送
     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('-1'.encode('utf-8'))
    continue
  
  if __name__ == '__main__':
   server = socketserver.ThreadingTCPServer(('192.168.1.7',8022),MyServer)
   print('waiting for connection...')
   server.serve_forever()
  
  

執行結果示例

服務端（記錄著各客戶端的操作）：

客戶端1：

有註冊、建群、群聊、點對點聊天

客戶端2：

客戶端3：

要拷貝程式碼執行的話請注意平臺（win7.x86_64）和python版本號(python3.5)！！！