Python サーバープログラミング: Twisted を使用した非同期マルチユーザーチャットルームの構築-Python チュートリアル-php.cn

Python サーバープログラミング: Twisted を使用した非同期マルチユーザーチャットルームの構築

王林

リリース： 2023-06-18 20:57:09

オリジナル

1261 人が閲覧しました

Python サーバープログラミング: Twisted を使用して非同期マルチユーザーチャットルームを構築する

現代のコンピューターサイエンスにおいて、ネットワークアプリケーションはその最も重要な部分の 1 つになっています。サーバー側プログラミングは、これらのネットワークアプリケーションに不可欠な部分です。 Python は高級プログラミング言語として、非常に強力なサーバー側プログラミング機能を備えています。 Twisted は、Python を使用して効率的なイベント駆動型のネットワークアプリケーションを作成できる非同期ネットワークフレームワークです。この記事では、Twisted を使用して非同期マルチユーザーチャットルームを構築する方法を検討します。

1.ツイストとは何ですか?

Twisted は、イベントベースの Web アプリケーションとクライアントを作成するための Python フレームワークです。これは、Web サーバー、チャットプログラム、メールサーバーなどの大規模で同時実行性の高いネットワークアプリケーションを作成するのに非常に適した非同期ネットワークフレームワークです。

2. Twisted チャットルームのアーキテクチャ

まず、Twisted チャットルームのアーキテクチャを見てみましょう:

Twisted サーバーは TCP ポートをリッスンします。そしてクライアントが接続するのを待ちます。
クライアントが正常に接続すると、サーバーは新しい ChatProtocol インスタンスを作成します。
各 ChatProtocol インスタンスはクライアント接続を表し、クライアントのすべての入出力を処理します。
ChatProtocol インスタンスは新しいメッセージを受信すると、そのメッセージを他のすべてのクライアントに転送します。

3. Twisted チャットルームの実装

次に、Twisted を使用してチャットルームを実装してみましょう。まず、Twisted ライブラリをインストールする必要があります:

pip install twisted

ログイン後にコピー

次に、すべての接続とメッセージを処理するために ChatProtocol クラスを定義する必要があります:

from twisted.internet.protocol import Protocol

class ChatProtocol(Protocol):

    def __init__(self, factory):
        self.factory = factory
        self.name = None

    def connectionMade(self):
        self.factory.clients.add(self)
        self.factory.notifyAllClients("New user connected.")

    def connectionLost(self, reason):
        self.factory.clients.remove(self)
        self.factory.notifyAllClients("User disconnected.")

    def dataReceived(self, data):
        message = data.decode().rstrip()
        
        if self.name is None:
            self.name = message
            self.factory.notifyAllClients("{} joined the room.".format(self.name))
        else:
            self.factory.notifyAllClients("{}: {}".format(self.name, message))

    def sendMessage(self, message):
        self.transport.write(message.encode())

ログイン後にコピー

上記のコードでは、ChatProtocol クラスを定義します。 Protocol クラスから継承するこのクラスは、接続とメッセージを処理するためのメソッドを定義します。

__init__ メソッドでは、変数 factory と name を初期化します。 factory はすべてのクライアント接続を管理するために使用されるファクトリクラスで、name はクライアントの名前を表します。クライアントが正常に接続すると、name は になります。なし＃＃＃。

connectionMade メソッドでは、新しいクライアント接続を追加し、他のすべてのクライアントに通知メッセージを送信します。

connectionLost メソッドでは、切断されたクライアントを削除し、他のすべてのクライアントに通知メッセージを送信します。

dataReceived メソッドでは、受信したメッセージを処理します。クライアントの名前が None の場合、このメッセージをクライアントの名前に設定し、他のすべてのクライアントに通知メッセージを送信します。それ以外の場合、このメッセージは他のすべてのクライアントに送信されます。

最後に、

sendMessage メソッドで、メッセージをクライアントに送信します。

ここで、すべてのクライアント接続を管理するために ChatFactory クラスを定義する必要があります:

from twisted.internet.protocol import Factory

class ChatFactory(Factory):

    def __init__(self):
        self.clients = set()

    def buildProtocol(self, addr):
        return ChatProtocol(self)

    def notifyAllClients(self, message):
        for client in self.clients:
            client.sendMessage(message)

ログイン後にコピー

上記のコードでは、Factory クラスを継承する ChatFactory クラスを定義します。このクラスはメソッドを定義します。新しい ChatProtocol インスタンスを作成するため。

__init__ メソッドでは、すべてのクライアント接続を保存するために使用される変数 clients を初期化します。

buildProtocol メソッドで、新しい ChatProtocol インスタンスを作成し、それに self を渡します。

最後に、

notifyAllClients メソッドで、すべてのクライアントにメッセージを送信します。

ChatProtocol クラスと ChatFactory クラスを定義したので、Twisted サーバーを作成し、ChatFactory をそのファクトリーとして使用しましょう:

from twisted.internet import reactor

factory = ChatFactory()
reactor.listenTCP(1234, factory)
reactor.run()

ログイン後にコピー

上記のコードでは、まず ChatFactory インスタンスを作成し、それを Twisted サーバーの

listenTCP メソッドに渡します。このメソッドは、サーバーが TCP ポート 1234 上のすべての接続をリッスンすることを示します。最後に、Twisted サーバーを起動して、接続の待機とメッセージの処理を開始します。

4. Twisted チャットルームの使用

これで、Twisted を使用して非同期マルチユーザーチャットルームを構築することに成功しました。テストしてみましょう!まず、サーバー側の Python コードを実行する必要があります:

python chat_server.py

ログイン後にコピー

次に、複数のターミナルウィンドウでクライアント側の Python コードを実行する必要があります:

import socket

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(("localhost", 1234))

sock.sendall("Alice
".encode())
sock.sendall("Hello!
".encode())

sock.sendall("Bob
".encode())
sock.sendall("Hi there!
".encode())

sock.sendall("Charlie
".encode())
sock.sendall("How are you guys?
".encode())

ログイン後にコピー

上記のコードでは、まずサーバー側のポート 1234 に接続する TCP を作成し、次に各クライアントの名前と送信するメッセージを送信します。このコードを複数のターミナルウィンドウで実行すると、複数のユーザーが同時にチャットルームに参加し、リアルタイムで相互に通信できるようになります。

概要

この記事では、Twisted フレームワークと、それを使用して非同期マルチユーザーチャットルームを構築する方法を紹介しました。この例を通じて、Twisted の強力な非同期ネットワークプログラミング機能と、Python を使用して効率的なイベント駆動型ネットワークアプリケーションを作成する機能を体験しました。

以上がPython サーバープログラミング: Twisted を使用した非同期マルチユーザーチャットルームの構築の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。