首页
/ CmdChat 项目使用教程

CmdChat 项目使用教程

2024-08-17 19:49:05作者:董斯意

1. 项目的目录结构及介绍

CmdChat 项目的目录结构如下:

cmdchat/
├── README.md
├── cmdchat.py
├── config.json
└── config.py

目录结构介绍

  • README.md: 项目说明文件,包含项目的基本介绍和使用说明。
  • cmdchat.py: 项目的主启动文件,负责启动聊天服务器和客户端。
  • config.json: 项目的配置文件,包含服务器的端口号等信息。
  • config.py: 配置文件的解析模块,负责读取和解析 config.json 文件。

2. 项目的启动文件介绍

cmdchat.py

cmdchat.py 是项目的主启动文件,负责启动聊天服务器和客户端。以下是文件的主要内容和功能介绍:

import socket
import threading
import json
from config import Config

# 读取配置文件
config = Config()

# 服务器类
class Server:
    def __init__(self, host, port):
        self.host = host
        self.port = port
        self.server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.server.bind((self.host, self.port))
        self.server.listen(5)
        self.clients = []

    def broadcast(self, message):
        for client in self.clients:
            client.send(message)

    def handle(self, client):
        while True:
            try:
                message = client.recv(1024)
                self.broadcast(message)
            except:
                index = self.clients.index(client)
                self.clients.remove(client)
                client.close()
                break

    def receive(self):
        while True:
            client, address = self.server.accept()
            print(f"Connected with {str(address)}")
            client.send('NICK'.encode('ascii'))
            nickname = client.recv(1024).decode('ascii')
            self.clients.append(client)
            print(f"Nickname of the client is {nickname}!")
            self.broadcast(f"{nickname} joined the chat!".encode('ascii'))
            client.send('Connected to the server!'.encode('ascii'))
            thread = threading.Thread(target=self.handle, args=(client,))
            thread.start()

# 客户端类
class Client:
    def __init__(self, host, port):
        self.host = host
        self.port = port
        self.client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.client.connect((self.host, self.port))

    def receive(self):
        while True:
            try:
                message = self.client.recv(1024).decode('ascii')
                if message == 'NICK':
                    self.client.send(nickname.encode('ascii'))
                else:
                    print(message)
            except:
                print("An error occured!")
                self.client.close()
                break

    def write(self):
        while True:
            message = f'{nickname}: {input("")}'
            self.client.send(message.encode('ascii'))

# 主函数
def main():
    if config.mode == "server":
        server = Server(config.host, config.port)
        server.receive()
    else:
        client = Client(config.host, config.port)
        receive_thread = threading.Thread(target=client.receive)
        write_thread = threading.Thread(target=client.write)
        receive_thread.start()
        write_thread.start()

if __name__ == "__main__":
    main()

功能介绍

  • Server 类:负责启动服务器,处理客户端连接和消息广播。
  • Client 类:负责启动客户端,处理消息接收和发送。
  • main 函数:根据配置文件中的模式(服务器或客户端)启动相应的实例。

3. 项目的配置文件介绍

config.json

config.json 是项目的配置文件,包含服务器的端口号等信息。以下

登录后查看全文
热门项目推荐