服务端
server.py
"""__author__zhangdong__"""
"""
注意：
1.想要结束一个进程就是让它里面的所有的线程都结束
2.想要关闭一个子线程，就是想方设法让子线程中的任务结束(就是让run方法结束)
3.一个线程崩溃(发生异常)，不会影响其他线程
"""
import pygame
import socket
from color import Color
import myThread
def crest_server():
"""创建服务器"""
server = socket.socket()
server.bind(('10.7.181.97', 8081))
server.listen(512)
#在一个子线程中监听客户端的请求
server_thread = myThread.Server_Thread(server)
server_thread.start()
if __name__ == '__main__':
crest_server()
#准备显示信息的屏幕
pygame.init()
screen = pygame.display.set_mode((600,400))
screen.fill(Color.white)
pygame.display.set_caption('良心主播')
pygame.display.flip()
print(pygame.font.get_fonts())
#让屏幕可以一直存在
while True:
for event in pygame.event.get():
if event.type == pygame.QUIT:
exit()
#获取每条信息显示在屏幕上
screen.fill(Color.white)
for message in myThread.ConversationThread.all_message[:]:
if message.alive:
#显示信息
pygame.time.delay(30)
#方正兰亭超细黑简体
font = pygame.font.SysFont('stsong', 40)
text = font.render(message.text, True,message.color)
screen.blit(text,(message.x,message.y))
#动起来
message.move()
else:
myThread.ConversationThread.all_message.remove(message)
pygame.display.update()
my_Thread.py
"""__author__zhangdong__"""
from threading import Thread
import socket
from random import randint
from color import Color
class Message:
"""文字信息类"""
def __init__(self,text):
self.text = text
self.x = -100
self.y = randint(0,380)
self.color = Color.rand_color()
self.speed = randint(2,5)
self.alive = True
def move(self):
self.x += self.speed
#越界处理
if self.x> 600+50:
self.alive = False
class ConversationThread(Thread):
all_message = []
"""处理不同的客户端信息"""
def __init__(self,conversation:socket.socket):
super().__init__()
self.conversation = conversation
def run(self):
"""让服务器和客户端一直保持通话"""
while True:
try:
self.conversation.send('欢迎来到直播间'.encode())
re_message = self.conversation.recv(1024).decode(encoding='utf-8')
#接收到一条消息就创建一个消息对象
message = Message(re_message)
#保存所有的消息
ConversationThread.all_message.append(message)
except ConnectionResetError:
break
class Server_Thread(Thread):
"""接收请求的线程类"""
def __init__(self,server:socket.socket):
super().__init__()
self.server = server
def run(self):
"""不断接受客户端请求"""
while True:
conversation,address = self.server.accept()
print('接收到客户端的请求')
#来了一个客户端请求就给他创建一个线程来处理对应的消息
t1 = ConversationThread(conversation)
t1.start()
if __name__ == '__main__':
pass
客户端
client.py
"""__author__zhangdong__"""
import socket
if __name__ == '__main__':
client = socket.socket()
client.connect(('10.7.181.97',8081))
while True:
print(client.recv(1024).decode(encoding='utf-8'))
message = input('>>>')
client.send(message.encode())
