socket聊天室

Posted wshr210

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了socket聊天室相关的知识,希望对你有一定的参考价值。

  1 #服务端
  2 from socket import *
  3 import json
  4 def recvMsg(s):
  5     while True:
  6         #接收用户的信息
  7         data,address = s.recvfrom(1024)
  8         data = json.loads(data)
  9         print(data,address)
 10 
 11         if data[type] == enter:
 12             # 将用户进入聊天室的信息发给其它所有在线用户
 13             sendToAll((>>系统:%s进入了聊天室%data[content]).encode(utf-8),s,address)
 14             #将用户信息加入users字典
 15             if address not in users:users[address]=data[content]
 16         elif data[type] == quit:
 17             # 将用户离开聊天室的信息发给其它所有在线用户
 18             sendToAll((>>系统:%s离开了聊天室 % data[content]).encode(utf-8), s, address)
 19             # 将退出的用户从users中删除
 20             users.pop(address)
 21 
 22         elif data[type] == msg:
 23             sendToAll((>>%s:%s%(users[address],data[content])).encode(utf-8),s,address)
 24 
 25         else:
 26             for i in users:
 27                 if users[i] == data[name]:
 28                     s.sendto((>>%s私信你说:%s%(users[address],data[content])).encode(utf-8),i)
 29 
 30 def sendToAll(msg,s,address):
 31     for addr in users:
 32         if addr != address:
 33             s.sendto(msg,addr)
 34 
 35 
 36 def main():
 37     #创建socket
 38     s = socket(AF_INET,SOCK_DGRAM)
 39     #绑定服务器ip和端口
 40     s.bind((172.16.11.199,8888))
 41     #接收用户的信息
 42     recvMsg(s)
 43     #发送信息给用户
 44 if __name__ == __main__:
 45     #设置一个全局的变量,保存所有进入聊天室的用户信息{‘地址‘:‘昵称‘,‘地址‘:‘昵称‘,....}
 46     users = {}
 47     # print(users)
 48     main()
 49 
 50 
 51 
 52 #客户端
 53 from socket import *
 54 import json
 55 from threading import Thread
 56 def sendMsg(c,server):
 57     while True:
 58         msg = input("").strip()
 59         #发送消息
 60         if not msg:
 61             continue
 62         elif msg.lower() == quit:
 63             # 发送进入聊天室的信息
 64             msg = {type: quit, content: username}
 65             c.sendto(json.dumps(msg).encode(utf-8), server)
 66             break
 67         #私聊
 68         elif msg.startswith(@):
 69             name = str(msg[1:])
 70             msg2 = input(>>请输入你要对他说的话: ).strip()
 71             msg3 = {type:msg2,content:msg2,name:name}
 72             print(">>我对%s说: %s"%(name ,msg2))
 73             c.sendto(json.dumps(msg3).encode(utf-8),server)
 74         else:
 75             #正常信息
 76             msg1 = {type:msg,content:msg}
 77             print(">>我说:%s"%msg)
 78             c.sendto(json.dumps(msg1).encode(utf-8), server)
 79 
 80 def recvMsg(c):
 81     while True:
 82         data,address = c.recvfrom(1024)
 83         #打印出接收到的消息
 84         print(data.decode(utf-8))
 85 
 86 def main():
 87     c = socket(AF_INET,SOCK_DGRAM)
 88     #服务器的地址
 89     server = (172.16.11.199,8888)
 90     #发送进入聊天室的信息
 91     msg = {type:enter,content:username}
 92     c.sendto(json.dumps(msg).encode(utf-8),server)
 93     #用户发送消息
 94     t1 = Thread(target=sendMsg,args=(c,server))
 95     #用户接收消息
 96     t2 = Thread(target=recvMsg,args=(c,))
 97 
 98     t1.start()
 99     t2.start()
100     t1.join()
101     t2.join()
102 
103     c.close()
104 if __name__ == __main__:
105     #输入昵称
106     username = input(昵称:).strip()
107     print("%s,你已成功进入xx聊天室,想要退出请输入‘quit‘"%username)
108     main()

 

以上是关于socket聊天室的主要内容,如果未能解决你的问题,请参考以下文章

简易聊天室代码分享 js+socket.io

简易聊天室代码分享 js+socket.io

1500行代码!拥有自己的聊天室------ socket聊天室实现(GUI,线程,TCP)

Python--网络编程-----socket代码实例--聊天软件升级版

字节码学院之Java socket 控制台聊天室

安卓socket聊天