服务器

import socket


if __name__ == '__main__':
    client = socket.socket()
    client.connect(('10.7.181.88', 8081))

    while True:
        # 接收消息并且打印出来
        print(client.recv(1024).decode(encoding='utf-8'))
        message = input('>>>')
        client.send(message.encode())

客户端

import socket
from threading import Thread


class CoversationThread(Thread):
    def __init__(self, conversation: socket.socket, addr):
        super().__init__()
        self.conversation = conversation
        self.addr = addr

    def run(self):
        while True:
            message = input('...')
            conversation.send(message.encode())
            print(self.addr, self.conversation.recv(1024).decode(encoding='utf=8'))


if __name__ == '__main__':
    server = socket.socket()
    server.bind(('10.7.181.88', 8081))
    server.listen(50)

    # 让服务器不会关闭
    while True:
        conversation, addr = server.accept()
        t = CoversationThread(conversation, addr)
        t.start()

...nihaoma
('10.7.181.88', 51473) haihao 
...

nihaoma
>>>haihao 

现在只实现了多人可以向服务器发送信息，不会阻塞，但是弹幕还没有做。回去慢慢搞。