Python을 사용하여 나만의 대화방을 만드는 방법-파이썬 튜토리얼-php.cn

Python을 사용하여 나만의 대화방을 만드는 방법

PHPz

풀어 주다： 2023-05-11 20:46:04

앞으로

1180명이 탐색했습니다.

1. 네트워크 프로그래밍의 기본 개념

IP 주소: 네트워크에 있는 각 장치의 고유 식별자로, 네트워크에서 장치를 찾는 데 사용됩니다.
포트: 장치의 다양한 네트워크 애플리케이션을 식별하며 포트 하나는 특정 서비스나 애플리케이션에 해당합니다.
프로토콜: TCP, UDP 등 데이터 통신에 대한 규칙입니다.

2. 소켓 프로그래밍의 소개 및 원리

소켓은 네트워크에서 데이터를 전송하는 데 사용되는 통신 핸들입니다.
Python의 socket 라이브러리는 네트워크 프로그래밍 구현을 위한 풍부한 기능과 클래스 세트를 제공합니다.
소켓 프로그래밍에는 주로 소켓 객체 생성, 주소 및 포트 바인딩, 연결 모니터링, 데이터 수락 및 전송 등과 같은 작업이 포함됩니다.

3. 채팅방 아키텍처 및 기능 요구 사항

채팅방은 서버 측과 클라이언트 측으로 구분됩니다.
서버는 클라이언트의 연결 요청을 수신하고 클라이언트의 메시지를 전달하는 역할을 담당합니다.
클라이언트는 서버와의 연결 설정과 메시지 송수신을 담당합니다.
대화방은 동시에 여러 클라이언트를 온라인으로 지원하고 실시간으로 메시지를 주고받을 수 있어야 합니다.

4. 채팅방 서버측 구현

1. 소켓을 사용하여 서버측 소켓 객체를 생성합니다.

import socket
import threading
 
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

로그인 후 복사

2. IP 주소와 포트를 바인딩합니다.

server.bind(("0.0.0.0", 8080))

로그인 후 복사

3. 클라이언트 연결을 들어보세요.

server.listen(5)

로그인 후 복사

4. 새로운 클라이언트가 연결되면 연결된 클라이언트 목록에 추가하세요.

clients = []
 
while True:
    client_socket, client_address = server.accept()
    clients.append(client_socket)
    thread = threading.Thread(target=handle_client, args=(client_socket, client_address))
    thread.start()

로그인 후 복사

5. 멀티스레딩을 사용하여 각 클라이언트에 대한 메시지 수신 및 전송을 처리합니다.

def handle_client(client_socket, client_address):
    print(f"[INFO] Client {client_address} connected.")
    while True:
        try:
            message = client_socket.recv(1024).decode("utf-8")
            if not message:
                break
            print(f"[{client_address}] {message}")
            broadcast(client_socket, f"[{client_address}] {message}")
        except:
            break
    print(f"[INFO] Client {client_address} disconnected.")
    clients.remove(client_socket)
    client_socket.close()
``

로그인 후 복사

6. 클라이언트 연결이 끊어지면 클라이언트 목록에서 제거하세요.

    clients.remove(client_socket)
    client_socket.close()

로그인 후 복사

7. 메시지를 다른 클라이언트에게 방송하세요.

def broadcast(from_client_socket, message):
    for client_socket in clients:
        if client_socket != from_client_socket:
            client_socket.send(message.encode("utf-8"))

로그인 후 복사

8. 채팅방 서버의 전체 코드:

import socket
import threading
 
def handle_client(client_socket, client_address):
    print(f"[INFO] Client {client_address} connected.")
    while True:
        try:
            message = client_socket.recv(1024).decode("utf-8")
            if not message:
                break
            print(f"[{client_address}] {message}")
            broadcast(client_socket, f"[{client_address}] {message}")
        except:
            break
    print(f"[INFO] Client {client_address} disconnected.")
    clients.remove(client_socket)
    client_socket.close()
 
def broadcast(from_client_socket, message):
    for client_socket in clients:
        if client_socket != from_client_socket:
            client_socket.send(message.encode("utf-8"))
 
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(("0.0.0.0", 8080))
server.listen(5)
 
print("[INFO] Server is listening...")
 
clients = []
 
while True:
    client_socket, client_address = server.accept()
    clients.append(client_socket)
    thread = threading.Thread(target=handle_client, args=(client_socket, client_address))
    thread.start()

로그인 후 복사

5. 채팅방 클라이언트 구현

1. 소켓을 사용하여 클라이언트 소켓 개체를 만듭니다.

import socket
import threading
 
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

로그인 후 복사

2. 서버의 IP 주소와 포트에 연결합니다.

client.connect(("127.0.0.1", 8080))

로그인 후 복사

3. 멀티스레딩을 사용하여 서버에서 보낸 메시지를 처리합니다.

def receive_message():
    while True:
        message = client.recv(1024).decode("utf-8")
        print(message)
 
thread = threading.Thread(target=receive_message)
thread.start()

로그인 후 복사

4. 사용자가 입력한 메시지를 받아 서버로 보냅니다.

while True:
    message = input()
    client.send(message.encode("utf-8"))

로그인 후 복사

5. 채팅방 클라이언트의 전체 코드:

import socket
import threading
 
def receive_message():
    while True:
        message = client.recv(1024).decode("utf-8")
        print(message)
 
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(("127.0.0.1", 8080))
 
print("[INFO] Connected to the server.")
 
thread = threading.Thread(target=receive_message)
thread.start()
 
while True:
    message = input()
    client.send(message.encode("utf-8"))

로그인 후 복사