1. IT知识观首页
  2. 编程

Python socket TCP群聊软件服务端编程使用场景及应用示例

云烟 • • 编程 • 阅读 198

Python socket TCP群聊软件服务端编程使用场景及应用示例#头条创作挑战赛#以下是使用Python的socket模块实现的几个案例：Python socket TCP群聊软件服务端编程的原理是基于TCP

欢迎大家来到IT世界,在知识的湖畔探索吧!

#头条创作挑战赛#

以下是使用Python的socket模块实现的几个案例：

Python socket TCP群聊软件服务端编程的原理是基于TCP协议的网络通信。TCP（传输控制协议）是一种可靠的、面向连接的协议，它提供了可靠的数据传输、流控制和拥塞控制等功能。

服务端通过监听指定的IP和端口，等待客户端的连接。一旦有客户端连接成功，服务端会为每个客户端创建一个独立的线程用于处理与该客户端的通信。在服务端接收到客户端的消息后，会将消息发送给所有连接的客户端（除了发送者）。

Python socket TCP群聊软件服务端编程使用场景及应用示例

使用场景

以下是一些可能的使用场景：

  • 在线聊天室：多个用户可以同时连接到服务端，彼此之间可以发送消息进行聊天。
  • 多人协同编辑：多个用户可以同时连接到服务端，实时编辑共享的文档或代码。
  • 在线游戏：多个玩家可以通过连接到服务端进行实时的游戏对战或合作。
  • 实时监控系统：多个监控设备连接到服务端，将实时的监控数据发送给服务端，服务端将数据发送给所有连接的客户端进行实时监控。
  • 远程控制系统：客户端连接到服务端，通过服务端中转控制命令，实现远程控制被控制设备的功能。

应用示例

在线聊天室：

服务端代码：

import socket
import threading

# 服务器IP和端口
SERVER_HOST = '0.0.0.0'
SERVER_PORT = 12345

# 存储所有连接的客户端socket
client_sockets = []

def handle_client(client_socket):
    while True:
        try:
            # 接收客户端消息
            message = client_socket.recv(1024).decode('utf-8')
            if message:
                print(f"收到消息：{message}")
                
                # 将消息发送给所有连接的客户端（除了发送者）
                for socket in client_sockets:
                    if socket != client_socket:
                        socket.send(message.encode('utf-8'))
            else:
                # 客户端断开连接
                remove_client(client_socket)
                break
        except:
            # 出现异常，断开连接
            remove_client(client_socket)
            break

def remove_client(client_socket):
    # 移除客户端socket
    client_sockets.remove(client_socket)
    client_socket.close()

def start_server():
    # 创建服务器socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    
    # 绑定IP和端口
    server_socket.bind((SERVER_HOST, SERVER_PORT))
    
    # 监听连接
    server_socket.listen()
    
    print(f"聊天室服务器已启动，监听端口：{SERVER_PORT}")
    
    while True:
        # 接受客户端连接
        client_socket, client_address = server_socket.accept()
        client_sockets.append(client_socket)
        
        # 创建线程处理客户端消息
        client_thread = threading.Thread(target=handle_client, args=(client_socket,))
        client_thread.start()

start_server()

欢迎大家来到IT世界,在知识的湖畔探索吧!

客户端代码：

欢迎大家来到IT世界,在知识的湖畔探索吧!import socket
import threading

# 服务器IP和端口
SERVER_HOST = '127.0.0.1'
SERVER_PORT = 12345

def receive_message(client_socket):
    while True:
        try:
            # 接收服务器消息
            message = client_socket.recv(1024).decode('utf-8')
            print(message)
        except:
            print("与服务器的连接断开")
            break

def start_client():
    # 创建客户端socket
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
    try:
        # 连接服务器
        client_socket.connect((SERVER_HOST, SERVER_PORT))
        
        # 创建线程接收服务器消息
        receive_thread = threading.Thread(target=receive_message, args=(client_socket,))
        receive_thread.start()
        
        while True:
            # 发送消息给服务器
            message = input()
            client_socket.send(message.encode('utf-8'))
    except:
        print("无法连接到服务器")

start_client()

多人协同编辑：

import socket
import threading

HOST = 'localhost'  # 服务器IP地址
PORT = 5000  # 服务器端口号

# 创建一个socket对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定IP地址和端口号
server_socket.bind((HOST, PORT))
# 监听连接
server_socket.listen()

clients = []  # 存储连接的客户端socket对象
nicknames = []  # 存储客户端的昵称

def broadcast(message):
    # 向所有客户端广播消息
    for client in clients:
        client.send(message)

def handle(client):
    while True:
        try:
            # 接收客户端发送的消息
            message = client.recv(1024)
            # 广播消息给其他客户端
            broadcast(message)
        except:
            # 客户端断开连接
            index = clients.index(client)
            clients.remove(client)
            client.close()
            nickname = nicknames[index]
            nicknames.remove(nickname)
            broadcast(f'{nickname}离开了聊天室'.encode('utf-8'))
            break

def receive():
    while True:
        # 接受客户端连接
        client, address = server_socket.accept()
        print(f'已连接到 {address}')
        client.send('NICK'.encode('utf-8'))
        nickname = client.recv(1024).decode('utf-8')
        nicknames.append(nickname)
        clients.append(client)
        print(f'昵称为 {nickname} 的用户已加入聊天室')
        broadcast(f'{nickname}加入了聊天室'.encode('utf-8'))
        client.send('已成功加入聊天室'.encode('utf-8'))
        client.send('你可以开始聊天了'.encode('utf-8'))
        # 启动一个新的线程处理客户端的消息
        thread = threading.Thread(target=handle, args=(client,))
        thread.start()

print('服务器正在运行...')
receive()

这个示例代码创建了一个聊天服务器，当有客户端连接时，将其加入聊天室，并向所有客户端广播该用户已加入聊天室的消息。当客户端发送消息时，服务器会将其广播给其他客户端。当客户端断开连接时，服务器会将其从聊天室中移除，并向其他客户端广播该用户已离开的消息。

你可以在客户端使用socket模块连接到该服务器，并发送消息来实现多人协同编辑的功能。

在线游戏：

要使用Python的socket模块实现在线游戏，需要设计一个服务器来处理玩家之间的通信和游戏逻辑。以下是一个简单的示例代码，演示了如何使用socket模块实现一个简单的多人在线游戏：

欢迎大家来到IT世界,在知识的湖畔探索吧!import socket
import threading

HOST = 'localhost'  # 服务器IP地址
PORT = 5000  # 服务器端口号

# 创建一个socket对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定IP地址和端口号
server_socket.bind((HOST, PORT))
# 监听连接
server_socket.listen()

clients = []  # 存储连接的客户端socket对象
player_positions = {}  # 存储玩家的位置信息

def broadcast(message):
    # 向所有客户端广播消息
    for client in clients:
        client.send(message)

def handle(client):
    while True:
        try:
            # 接收客户端发送的消息
            message = client.recv(1024)
            # 广播消息给其他客户端
            broadcast(message)
        except:
            # 客户端断开连接
            index = clients.index(client)
            clients.remove(client)
            client.close()
            del player_positions[client]
            broadcast(f'Player {index+1}离开了游戏'.encode('utf-8'))
            break

def receive():
    while True:
        # 接受客户端连接
        client, address = server_socket.accept()
        print(f'已连接到 {address}')
        clients.append(client)
        player_positions[client] = (0, 0)  # 初始化玩家位置
        print(f'Player {len(clients)}加入了游戏')
        broadcast(f'Player {len(clients)}加入了游戏'.encode('utf-8'))
        client.send('已成功加入游戏'.encode('utf-8'))
        client.send('你可以开始游戏了'.encode('utf-8'))
        # 启动一个新的线程处理客户端的消息
        thread = threading.Thread(target=handle, args=(client,))
        thread.start()

print('服务器正在运行...')
receive()

这个示例代码创建了一个游戏服务器，当有客户端连接时，将其加入游戏，并向所有客户端广播该玩家已加入游戏的消息。当客户端发送消息时，服务器会将其广播给其他客户端。当客户端断开连接时，服务器会将其从游戏中移除，并向其他客户端广播该玩家已离开游戏的消息。

你可以在客户端使用socket模块连接到该服务器，并发送消息来与其他玩家进行交互。你可以根据游戏的需求，在服务器端添加游戏逻辑来处理玩家的移动、攻击等操作，并将相关信息广播给其他玩家。

实时监控系统：

服务端代码：

 import socket
import cv2
import numpy as np
import threading

# 服务器IP和端口
SERVER_HOST = '0.0.0.0'
SERVER_PORT = 12345

# 存储所有连接的客户端socket
client_sockets = []

def handle_client(client_socket):
    cap = cv2.VideoCapture(0)
    
    while True:
        try:
            ret, frame = cap.read()
            if ret:
                # 将视频帧转换为字符串
                data = frame.tostring()
                
                # 将视频帧发送给所有连接的客户端
                for socket in client_sockets:
                    socket.send(data)
            else:
                # 客户端断开连接
                remove_client(client_socket)
                break
        except:
            # 出现异常，断开连接
            remove_client(client_socket)
            break
    
    cap.release()

def remove_client(client_socket):
    # 移除客户端socket
    client_sockets.remove(client_socket)
    client_socket.close()

def start_server():
    # 创建服务器socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    
    # 绑定IP和端口
    server_socket.bind((SERVER_HOST, SERVER_PORT))
    
    # 监听连接
    server_socket.listen()
    
    print(f"监控系统服务器已启动，监听端口：{SERVER_PORT}")
    
    while True:
        # 接受客户端连接
        client_socket, client_address = server_socket.accept()
        client_sockets.append(client_socket)
        
        # 创建线程处理客户端视频流
        client_thread = threading.Thread(target=handle_client, args=(client_socket,))
        client_thread.start()

start_server()

客户端代码：

import socket
import cv2
import numpy as np
import threading

# 服务器IP和端口
SERVER_HOST = '127.0.0.1'
SERVER_PORT = 12345

def receive_video(client_socket):
    while True:
        try:
            # 接收服务器发送的视频帧数据
            data = client_socket.recv(921600)
            
            # 将字符串转换为视频帧
            frame = np.frombuffer(data, dtype=np.uint8).reshape((480, 640, 3))
            
            # 显示视频帧
            cv2.imshow("Video", frame)
            
            if cv2.waitKey(1) & 0xFF == ord('q'):
                break
        except:
            print("与服务器的连接断开")
            break
    
    cv2.destroyAllWindows()

def start_client():
    # 创建客户端socket
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
    try:
        # 连接服务器
        client_socket.connect((SERVER_HOST, SERVER_PORT))
        
        # 创建线程接收服务器视频流
        receive_thread = threading.Thread(target=receive_video, args=(client_socket,))
        receive_thread.start()
        
        while True:
            pass
    except:
        print("无法连接到服务器")

start_client()

远程控制系统：

服务端代码：

import socket
import threading
import pyautogui

# 服务器IP和端口
SERVER_HOST = '0.0.0.0'
SERVER_PORT = 12345

# 存储所有连接的客户端socket
client_sockets = []

def handle_client(client_socket):
    while True:
        try:
            # 接收客户端消息
            message = client_socket.recv(1024).decode('utf-8')
            if message:
                print(f"收到消息：{message}")
                
                # 执行客户端发送的命令
                if message == 'left_click':
                    pyautogui.click()
                elif message.startswith('move_mouse'):
                    _, x, y = message.split()
                    pyautogui.moveTo(int(x), int(y))
            else:
                # 客户端断开连接
                remove_client(client_socket)
                break
        except:
            # 出现异常，断开连接
            remove_client(client_socket)
            break

def remove_client(client_socket):
    # 移除客户端socket
    client_sockets.remove(client_socket)
    client_socket.close()

def start_server():
    # 创建服务器socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    
    # 绑定IP和端口
    server_socket.bind((SERVER_HOST, SERVER_PORT))
    
    # 监听连接
    server_socket.listen()
    
    print(f"远程控制系统服务器已启动，监听端口：{SERVER_PORT}")
    
    while True:
        # 接受客户端连接
        client_socket, client_address = server_socket.accept()
        client_sockets.append(client_socket)
        
        # 创建线程处理客户端消息
        client_thread = threading.Thread(target=handle_client, args=(client_socket,))
        client_thread.start()

start_server()

客户端代码：

import socket

# 服务器IP和端口
SERVER_HOST = '127.0.0.1'
SERVER_PORT = 12345

def start_client():
    # 创建客户端socket
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
    try:
        # 连接服务器
        client_socket.connect((SERVER_HOST, SERVER_PORT))
        
        while True:
            # 获取命令
            command = input("请输入命令（left_click, move_mouse <x> <y>）：")
            
            # 发送命令给服务器
            client_socket.send(command.encode('utf-8'))
    except:
        print("无法连接到服务器")

start_client()

以上是一些使用Python的socket模块实现的在线聊天室、多人协同编辑、在线游戏、实时监控系统、远程控制系统的简单示例代码。这些示例代码仅供参考，具体应用中可能需要根据需求进行相应的改进和优化。

免责声明：本站所有文章内容,图片，视频等均是来源于用户投稿和互联网及文摘转载整编而成，不代表本站观点，不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益，请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权，请联系删除，如若转载，请注明出处：https://itzsg.com/31241.html

赞 (0)
云烟云烟
0
上一篇 2023年 10月 20日 下午5:00
下一篇 2023年 10月 25日 下午8:00

相关推荐

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

联系我们YX

mu99908888

在线咨询： 微信交谈

邮件：itzsgw@126.com

工作时间：时刻准备着!

关注微信