Python实现同城聊天

ゞ浴缸里的玫瑰 2022-05-20 07:04 147阅读 0赞

# 服务端 #

from socket import socket, AF_INET, SOCK_STREAM
    from threading import Thread
    
    # 创建套接字对象, 使用ipv4, 基于TCP协议的SOCK_STREAM, 如果是UDP 使用SOCK_DGRAM
    server = socket(AF_INET, SOCK_STREAM)
    # 绑定IP地址和端口, 使服务器工作在这个端口, 客户端也必须连这个地址
    server.bind(('10.7.189.54',8080))
    # 设置监听数量, 超过了就连接不上了
    server.listen(64)
    running = True
    # 轮询盒子, 用来转发信息与查看连接数
    clients = []
    print('服务器已经启动')
    while running:
        # 该函数返回接收到的client对象与ip端口地址
        client, addr = server.accept()
        clients.append(client)
        print(addr, '已经连接','总人数',len(clients))
        print(clients)
        # 创建函数, 传入addr和client对象, 用以作身份标识与接收和发送信息(均在服务端)
        def foo(addr, client):
            while 1:
                try:
                    info = client.recv(1024)  #缓存大小
                    info_deco = addr[0] + ':' + str(addr[1]) + '说:' + info.decode('utf-8')
                    for i in clients:
                        if i != client:
                            i.send(info_deco.encode('utf-8'))
                except Exception as e:
                    print(e)
                    # 如果这个客户端发生异常了, 则删除该客户端.结束线程
                    clients.remove(client)
                    break
        # 一个线程对应一个客户端对象
        Thread(target=foo, args=(addr, client)).start()

# 客户端 #

from socket import socket
    from threading import Thread
    
    client = socket()
    client.connect(('10.7.189.54',8080))
    running = True
    def foo():
        while 1:
            info = client.recv(1024).decode('utf-8')
            print(info)
    Thread(target=foo, args=()).start()
    while running:
        info = input('我说:')
        client.send(info.encode('utf-8'))