Python의 TCP 대화방

소개

이번 블로그에서는 Python을 사용하여 완벽하게 작동하는 TCP 채팅방을 구현해 보겠습니다. 방을 호스팅하는 하나의 서버와 방에 연결하여 서로 통신하는 여러 클라이언트를 갖게 됩니다.

TCP 및 클라이언트 서버 아키텍처 정보

전송 제어 프로토콜은 네트워크를 통해 서로 다른 장치 간에 메시지를 교환하는 데 도움이 되는 통신용 연결 지향 프로토콜입니다.

채팅방 구현을 위해 클라이언트-서버 아키텍처를 사용하겠습니다. 이는 여러 클라이언트(사용자)와 모든 것을 호스팅하고 이러한 클라이언트에 데이터를 제공하는 하나의 중앙 서버를 갖게 된다는 것을 의미합니다.

---

서버 설정( server.py )

1. 기본 서버를 설정하려면 소켓과 스레딩이라는 두 개의 라이브러리를 가져와야 합니다. 소켓 라이브러리는 네트워크 연결을 설정하고 설정하는 데 사용되며 스레딩 라이브러리는 다양한 작업을 동시에 수행하는 데 필요합니다.

import socket
import threading

2. 다음 작업은 서버 데이터를 정의하고 소켓을 초기화하는 것입니다. 호스트의 IP 주소와 서버의 사용 가능한 포트 번호가 필요합니다. 이 블로그에서는 주소 127.0.0.1, 즉 localhost와 포트 5500을 사용합니다.

포트 번호는 상관없지만, 사용하고 있는 포트가 무료이고 예약되지 않은 포트인지 확인해야 합니다. 실제 서버나 가상 머신에서 이 채팅방을 운영하는 경우, 채팅방 서버의 IP 주소를 가상 머신이나 서버의 호스트 IP 주소로 지정하세요.

자세한 내용은 예약된 포트 번호 목록을 확인하세요.

# Server Data
host = '127.0.0.1'
port = 5500

3. 소켓을 정의할 때 두 개의 매개변수를 전달해야 합니다. 이는 우리가 사용하려는 소켓 유형을 정의합니다. 첫 번째 항목(AF_INET)은 Unix 소켓이 아닌 인터넷 소켓을 사용하고 있음을 나타냅니다. 두 번째 매개변수는 우리가 사용하려는 프로토콜을 나타냅니다. SOCK_STREAM은 TCP를 사용하고 있음을 나타냅니다.

소켓을 정의한 후 두 값을 모두 포함하는 튜플을 전달하여 호스트와 지정된 포트에 소켓을 바인딩하거나 연결합니다. 그런 다음 서버를 청취 모드로 전환하여 클라이언트가 연결하고 메시지를 보낼 때까지 기다립니다..

# Start the Server
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((host, port))
server.listen()

4. 또한 두 개의 빈 목록을 생성하여 나중에 연결된 클라이언트와 해당 닉네임을 저장하는 데 사용할 것입니다.

import socket
import threading

5. 이제 메시지 방송에 도움이 되는 모든 기능을 정의하겠습니다. 연결되어 클라이언트 목록에 있는 각 클라이언트에게 메시지를 보냅니다.

# Server Data
host = '127.0.0.1'
port = 5500

6. 이제 핸들() 함수를 만들어 보겠습니다. 이 함수는 클라이언트의 메시지를 처리하는 역할을 합니다. 이 함수는 while 루프에서 실행됩니다. 이 함수는 클라이언트를 매개변수로 받아들이고 오류가 발생하거나 클라이언트 자체의 연결이 끊어질 때까지 무한 루프로 처리합니다.

# Start the Server
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((host, port))
server.listen()

7. 이제 클라이언트로부터 메시지를 받아 연결된 모든 클라이언트에게 브로드캐스트해야 합니다. 따라서 한 클라이언트가 메시지를 보내면 다른 모든 사람이 Broadcast() 함수를 통해 이 메시지를 볼 수 있습니다. 이제 어떤 이유로 이 클라이언트 연결에 오류가 발생하면 해당 클라이언트와 닉네임을 제거하고 연결을 닫은 다음 이 클라이언트가 채팅에서 나갔다는 사실을 방송합니다.

# Lists For Clients and Their Nicknames
clients = []
nicknames = []

서버를 실행할 준비가 되면 수신 기능을 실행하겠습니다. 클라이언트가 서버에 연결되면 'NAME'이라는 문자열을 보내어 클라이언트에게 별명이 요청되었음을 알립니다. 그런 다음 응답을 기다리고 해당 별명과 함께 클라이언트를 목록에 추가하고 해당 특정 클라이언트에 대한 handler() 함수에 대한 스레드를 시작합니다.

8. 이제 이 함수만 실행하면 서버가 완성됩니다.

# Sending Messages To All Connected Clients
def broadcast(message):
    for client in clients:
        client.send(message)

---

클라이언트 설정( client.py )

이제 클라이언트를 구현해 보겠습니다. 이를 위해서는 동일한 라이브러리를 다시 가져와야 합니다.

# Handling Clients
def handle(client):
    while True:
        try:
            # Broadcasting Messages
            message = client.recv(1024)
            broadcast(message)
        except:
            # Removing And Closing Clients
            index = clients.index(client)
            clients.remove(client)
            client.close()
            nickname = nicknames[index]
            broadcast('{} left!'.format(nickname).encode('ascii'))
            nicknames.remove(nickname)
            break

1. 클라이언트의 첫 번째 단계는 닉네임을 선택하고 서버에 연결하는 것입니다. 서버가 실행되는 정확한 주소와 포트를 알아야 합니다. 데이터를 바인딩하고 수신하는 대신 클라이언트로서 기존 서버에 연결합니다.

# Receiving `Function
def receive():
    while True:
        # Accept Connection
        client, address = server.accept()
        print("Connected with {}".format(str(address)))

        # Request And Store Nickname
        client.send('NAME'.encode('ascii'))
        nickname = client.recv(1024).decode('ascii')
        nicknames.append(nickname)
        clients.append(client)

        # Print And Broadcast Nickname
        print("Nickname is {}".format(nickname))
        broadcast("{} joined!".format(nickname).encode('ascii'))
        client.send('Connected to server!'.encode('ascii'))

        # Start Handling Thread For Client
        thread = threading.Thread(target=handle, args=(client,))
        thread.start()

2. 이제 클라이언트에는 동시에 실행되는 두 개의 스레드가 필요합니다. 첫 번째는 서버로부터 지속적으로 데이터를 수신하고 두 번째는 서버에 자체 메시지를 보냅니다.

receive()

여기에도 끝없는 while 루프가 있습니다. 지속적으로 메시지를 수신하고 화면에 인쇄하려고 시도합니다. 단, 메시지가 'NAME'이면 출력하지 않고 서버에 닉네임을 보냅니다.

글쓰기 기능은 꽤 짧은 기능입니다. 또한 항상 사용자의 입력을 기다리는 무한 루프에서 실행됩니다. 일부를 얻으면 닉네임과 결합하여 서버로 보냅니다.

3. 마지막으로 해야 할 일은 이 두 기능을 실행하는 두 개의 스레드를 시작하는 것입니다.

import socket
import threading

이제 끝났습니다. 우리는 완벽하게 작동하는 서버와 서버에 연결하여 서로 통신할 수 있는 작동 중인 클라이언트를 보유하고 있습니다.

---

채팅방을 운영하다

시운전을 하러 가볼까요? 항상 서버를 먼저 시작해야 한다는 점을 명심하세요. 그렇지 않으면 클라이언트가 존재하지 않는 호스트에 연결할 수 없기 때문입니다.

*서버 로그 : *

# Server Data
host = '127.0.0.1'
port = 5500

*Client One 로그 : *

# Start the Server
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((host, port))
server.listen()

*클라이언트 2 로그 : *

# Lists For Clients and Their Nicknames
clients = []
nicknames = []

---

그리고 우리는 Python의 Transmission Control Protocol을 기반으로 한 대화방을 성공적으로 만들었습니다! ? ?

여기에서 전체 코드를 찾으세요:https://github.com/rajatuiwebdev/tcp-chatroom-in-python
인스타그램에서 나를 팔로우하세요: https://instagram.com/rajatrajput.dev
Linkedin에서 나를 팔로우하세요: https://linkedin.com/in/rajatrajput2004

위 내용은 Python의 TCP 대화방의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!