Swoole을 사용하여 WebSocket 서버를 구현하는 방법

WebSocket은 현대 웹 애플리케이션의 필수 요소가 되었습니다. 서버와 클라이언트 간 실시간 통신이 가능한 Full Duplex 통신 방식을 제공합니다. Swoole은 PHP 기반의 고성능 네트워크 통신 프레임워크로 WebSocket 서버를 쉽게 구현할 수 있습니다.

이 글에서는 Swoole을 사용하여 WebSocket 서버를 구축하는 방법을 소개합니다.

Swoole 설치

Swoole을 설치하려면 PECL(PHP Extension Community Library)을 사용해야 합니다. 터미널을 열고 다음 명령을 입력하세요:

pecl install swoole

설치가 완료되면 Swoole 확장이 자동으로 PHP 확장 목록에 로드됩니다.

WebSocket 서버 생성

WebSocket 서버를 생성하는 가장 쉬운 방법은 Swoole의 WebSocket 서버 클래스를 사용하는 것입니다:

$server = new SwooleWebsocketServer("127.0.0.1", 9501);

$server->on('open', function (SwooleWebsocketServer $server, $request) {
    echo "Client {$request->fd} connected
";
});

$server->on('message', function (SwooleWebsocketServer $server, $frame) {
    echo "Received message: {$frame->data}
";

    // Broadcast message to all connected clients
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

$server->on('close', function (SwooleWebsocketServer $server, $fd) {
    echo "Client {$fd} disconnected
";
});

$server->start();

이 예에서는 로컬 WebSocket 서버를 생성하고 포트 9501에서 수신하도록 설정합니다. 또한 세 가지 콜백 함수를 추가합니다:

• open - 새 WebSocket 클라이언트가 서버에 연결될 때 호출됩니다.
open - 当新的WebSocket客户端连接到服务器时，将被调用。
• message - 当服务器接收到来自客户端的消息时，将被调用。
• close - 当客户端断开连接时，将被调用。

在open函数中，我们向控制台输出一个简单的消息，提示我们已经连接了一个新的客户端。

在message函数中，我们向控制台输出接收到的消息，并向所有已连接的客户端广播此消息。

在close函数中，我们向控制台输出一个消息，提示已断开连接的客户端的fd。

最后，我们通过调用start方法启动WebSocket服务器。

测试WebSocket服务器

为了测试WebSocket服务器，可以使用JavaScript的WebSocket API编写一个简单的客户端。这里提供一个非常简单的例子：

// Connect to WebSocket server
const ws = new WebSocket('ws://127.0.0.1:9501');

// Send a message to the server
ws.onopen = function() {
    ws.send('Hello, server!');
};

// Receive a message from the server
ws.onmessage = function(event) {
    console.log('Received message:', event.data);
};

在这个例子中，我们创建一个WebSocket对象，并连接到刚才创建的WebSocket服务器。我们还定义了两个回调函数：

• onopen - 当WebSocket连接成功建立时，将被调用。在这里我们向服务器发送了一个消息。
• onmessage - 当WebSocket接收到来自服务器的消息时，将被调用。

要测试这个客户端，只需在浏览器中打开控制台并将代码复制粘贴到控制台中即可。

实现更多功能

除了在该例子中演示的功能之外，Swoole还提供了许多其他有用的功能。例如，您可以通过调用pushmessage - 서버가 클라이언트로부터 메시지를 받으면 호출됩니다.

close - 클라이언트 연결이 끊어지면 호출됩니다.

open 함수에서는 새 클라이언트에 연결되었음을 나타내는 간단한 메시지를 콘솔에 출력합니다.

🎜message 함수에서는 수신된 메시지를 콘솔에 출력하고 이 메시지를 연결된 모든 클라이언트에 브로드캐스팅합니다. 🎜🎜 close 함수에서는 연결이 끊긴 클라이언트의 fd를 나타내는 메시지를 콘솔에 출력합니다. 🎜🎜마지막으로 start 메서드를 호출하여 WebSocket 서버를 시작합니다. 🎜🎜WebSocket 서버 테스트🎜🎜WebSocket 서버를 테스트하려면 JavaScript의 WebSocket API를 사용하여 간단한 클라이언트를 작성할 수 있습니다. 다음은 매우 간단한 예입니다. 🎜rrreee🎜 이 예에서는 WebSocket 객체를 생성하고 방금 생성한 WebSocket 서버에 연결합니다. 또한 두 가지 콜백 함수를 정의합니다. 🎜🎜🎜onopen - WebSocket 연결이 성공적으로 설정되면 호출됩니다. 여기서 우리는 서버에 메시지를 보냅니다. 🎜onmessage - WebSocket이 서버로부터 메시지를 받으면 호출됩니다. 🎜이 클라이언트를 테스트하려면 브라우저에서 콘솔을 열고 코드를 복사하여 콘솔에 붙여넣으면 됩니다. 🎜🎜더 많은 기능 달성🎜🎜이 예에서 설명한 기능 외에도 Swoole은 다른 유용한 기능도 많이 제공합니다. 예를 들어 push 메서드를 호출하여 클라이언트에 메시지를 푸시할 수 있습니다. 또한 코루틴을 사용하여 비동기 프로그래밍을 구현할 수 있습니다. 🎜🎜간단히 말하면 Swoole은 WebSocket 서버 구축에 매우 적합합니다. 실시간 웹 애플리케이션 개발을 매우 쉽게 만드는 많은 유용한 기능을 제공합니다. 🎜

위 내용은 Swoole을 사용하여 WebSocket 서버를 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!