python socket实现多人聊天室

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python socket实现多人聊天室，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1869字，纯文字阅读大概需要3分钟。

内容图文

服务器端：

import socket
import select
import threading
import time

ss = socket.socket(
            socket.AF_INET, socket.SOCK_STREAM) 
host=socket.gethostname()#本地ip
port=9999
addr=(host,port)
ss.bind(addr)
ss.listen(5)#最多监听5个
print('runing server')

fd_name={}
SL=[]
SL.append(ss)

while True:
    r,w,e=select.select(SL,[],[])#python的select函数 select的三个列表分别表示发生变化的socket，没变化的，以及出错的 交给r,w,e
    for temp in r:
        if temp is ss:#ss变化说明有新连接
                connection,address = temp.accept()
                print('new connection address:',address)
                SL.append(connection)#将新连接加入SL
                name=connection.recv(1024).decode('utf-8')#记得将传来的比特流转成字符
                fd_name[connection]=name

                ###
        else:#
            disconnect=False
            try:
                #
                thetime=time.asctime( time.localtime(time.time()) )
                data=temp.recv(1024).decode('utf-8')
                data=thetime+'\n'+fd_name[temp]+':'+data+'\n\n'
            except socket.error:
                    data=fd_name[temp]+' leave the room\n'
                    disconnect=True

            if disconnect:
                    SL.remove(temp)
                    print(data)
                    for other in SL:
                        if other!=ss and other!=temp:
                            try:
                                other.send(data.encode('utf-8'))
                            except Exception(e):
                                print(e)                    
                    del fd_name[temp]

            else:
                print(data)
                for other in SL:
                    if other!=ss:
                        try:
                            other.send(data.encode('utf-8'))
                        except Exception(e):
                            print(e)    
               

                

client.py:

import socket
import select
import threading
import time
 
def lis(s):
    my=[s]
    while True:
        r,w,e=select.select(my,[],[])
        if s in r:
            try:
                print(s.recv(1024).decode('utf-8'))
            except socket.error:
                print('socket is error')
                exit()
            
def talk(s):
    while True:
        try:
            info=input('>>>')
        except Exception(e):
            print('can\'t input')
            exit()
        try:
            s.send(info.encode('utf-8'))
        except Exception(e):
            print(e)
            exit()

            
ss=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host=socket.gethostname()#因为是本机
addr=(host,9999)
try:
    ss.connect(addr)
    print('welcome.please enter your name.....')
except Exception(e):
            print('connection failed')
            exit()
t=threading.Thread(target=lis,args=(ss,))
t.start()
t1=threading.Thread(target=talk,args=(ss,))
t1.start()
#双线程边监听边接受发送 

内容总结

以上是互联网集市为您收集整理的python socket实现多人聊天室全部内容，希望文章能够帮你解决python socket实现多人聊天室所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端