PHP와 소켓을 사용하여 실시간 데이터 통신을 구현하는 방법-PHP 튜토리얼-php.cn

인터넷의 지속적인 발전으로 실시간 데이터 통신은 다양한 애플리케이션의 표준이 되었습니다. PHP와 소켓을 사용하여 실시간 데이터 통신을 구현하는 것은 일반적인 방법 중 하나입니다. 이 기사에서는 PHP와 소켓을 사용하여 실시간 데이터 통신을 구현하는 방법을 소개합니다.

소켓은 애플리케이션 간 통신에 사용되는 메커니즘입니다. 이는 서로 다른 응용 프로그램이 서로 다른 컴퓨터 간에 통신할 수 있도록 하는 표준 인터페이스 세트를 제공합니다. PHP에서는 소켓 확장 라이브러리를 사용하여 소켓 통신을 구현할 수 있습니다.

소켓 연결 구현

소켓 연결을 사용하여 실시간 데이터 통신을 구현하려면 먼저 소켓 연결을 설정해야 합니다. 소켓 연결은 일반적으로 서버측과 클라이언트측이라는 두 개의 끝점으로 구성됩니다.

서버 측:

$ip = '127.0.0.1'; $port = 8888; $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_bind($server, $ip, $port); socket_listen($server); $client = socket_accept($server); socket_close($server);

로그인 후 복사

클라이언트 측:

$ip = '127.0.0.1'; $port = 8888; $client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_connect($client, $ip, $port); socket_close($client);

로그인 후 복사

위는 소켓 연결을 설정하는 기본 작업입니다. 소켓 개체는socket_create함수를 사용하여 생성되고 socket_bind함수 로컬 바인딩의 경우 socket_listen함수는 클라이언트의 연결 요청을 수신하기 시작합니다. socket_accept함수가 반환될 때까지 차단됩니다. 새 소켓 개체를 만듭니다. 클라이언트의 동작도 비교적 간단합니다. 서버에 연결하려면 socket_connect함수를 사용하고, 연결을 닫으려면 socket_close함수를 사용하세요. socket_create函数创建一个 Socket 对象， socket_bind函数实现本机的绑定， socket_listen函数开始监听来自客户端的连接请求，它会一直阻塞直到有客户端连接上来， socket_accept函数返回一个新的 Socket 对象用于新建连接。客户端的操作也比较简单，使用 socket_connect函数连接到服务器，并用 socket_close函数关闭连接。

实现实时数据通信

成功建立 Socket 连接后，就可以开始进行实时数据通信了。在Socket连接中，数据是通过流传输的。服务器端可以通过socket_recv函数接收客户端发来的数据，而客户端可以通过socket_send函数向服务器端发送数据。

服务器端：

$ip = '127.0.0.1'; $port = 8888; $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_bind($server, $ip, $port); socket_listen($server); $client = socket_accept($server); while(true){ $message = socket_recv($client, 1024, MSG_WAITALL); if($message === false){ socket_close($client); break; } echo "收到消息: $message "; } socket_close($server);

로그인 후 복사

客户端：

$ip = '127.0.0.1'; $port = 8888; $client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_connect($client, $ip, $port); $message = "Hello World!"; socket_send($client, $message, strlen($message), 0); socket_close($client);

로그인 후 복사

以上是发送和接收消息的基本操作，在服务器端通过循环解决了一次只能接收一条消息的弊端。这种实时数据通信的方式使用简单、高效，若使用合理，十分有利。

使用WebSocket实现实时数据通信

WebSocket是一种基于HTTP协议的协议，可以在浏览器和服务器之间创建持久连接。在PHP中，可以使用Ratchet等第三方库来实现WebSocket通信。

实现WebSocket连接

服务端代码：

require __DIR__ . '/vendor/autoload.php'; use RatchetMessageComponentInterface; use RatchetConnectionInterface; class WebSocketServer implements MessageComponentInterface { protected $clients; public function __construct() { $this->clients = new SplObjectStorage; } public function onOpen(ConnectionInterface $conn) { $this->clients->attach($conn); echo "有新的客户端连接：{$conn->resourceId} "; } public function onMessage(ConnectionInterface $from, $message) { foreach ($this->clients as $client) { if ($from !== $client) { $client->send($message); } } } public function onClose(ConnectionInterface $conn) { $this->clients->detach($conn); echo "客户端离开：{$conn->resourceId} "; } public function onError(ConnectionInterface $conn, Exception $e) { echo "发生错误：{$e->getMessage()} "; $conn->close(); } public function run() { $server = RatchetServerIoServer::factory( new RatchetHttpHttpServer( new RatchetWebSocketWsServer( $this ) ), 8080 ); echo "WebSocket服务已启动... "; $server->run(); } } $server = new WebSocketServer(); $server->run();

로그인 후 복사

以上是一个简单的WebSocket Server，使用MessageComponentInterface实现了四个基本方法，分别是onOpen, onMessage, onClose, onError。在onOpen方法中添加了新客户端的资源 ID 以便在客户端离开时识别出该客户端，onMessage方法中广播了接收到的消息，onClose方法中从客户端列表中移除离线客户端，onError方法中处理了与客户端的连接错误。

客户端代码：

var socket = new WebSocket('ws://' + window.location.host + ':8080'); socket.onopen = function() { console.log('WebSocket已打开'); }; socket.onerror = function() { console.log('WebSocket出错'); }; socket.onmessage = function(event) { console.log('收到消息：' + event.data); }; socket.onclose = function() { console.log('WebSocket已关闭'); };

로그인 후 복사

以上是客户端代码，使用WebSocket对象创建了一个 WebSocket 连接，并分别处理了onopen, onerror, onmessage, onclose事件。在onmessage

실시간 데이터 통신

소켓 연결이 성공적으로 이루어지면 실시간 데이터 통신을 시작할 수 있습니다. 소켓 연결에서는 데이터가 스트림을 통해 전송됩니다. 서버는 socket_recv함수를 통해 클라이언트로부터 데이터를 받을 수 있고, 클라이언트는 socket_send함수를 통해 서버로 데이터를 보낼 수 있습니다.

서버 측:

rrreee

클라이언트 측: rrreee위는 메시지를 보내고 받는 기본 작업입니다. 한 번에 하나의 메시지만 수신할 수 있는 단점은 서버 측에서 루핑을 통해 해결됩니다. 이러한 실시간 데이터 통신 방법은 사용이 간단하고 효율적이며 올바르게 사용하면 매우 유익합니다. 실시간 데이터 통신을 위해 WebSocket을 사용하세요WebSocket은 브라우저와 서버 간에 지속적인 연결을 생성할 수 있는 HTTP 프로토콜 기반 프로토콜입니다. PHP에서는 Ratchet과 같은 타사 라이브러리를 사용하여 WebSocket 통신을 구현할 수 있습니다. WebSocket 연결 구현서버 코드: rrreee위는 MessageComponentInterface를 사용하여 네 가지 기본 메서드, 즉 onOpen, onMessage, onClose, onError를 구현하는 간단한 WebSocket 서버입니다. >. 클라이언트가 나갈 때 클라이언트를 식별하기 위해 onOpen메서드에 새 클라이언트의 리소스 ID를 추가하고, onMessage메서드에서 수신된 메시지를 브로드캐스트합니다. 오프라인 클라이언트는 onClose메소드의 클라이언트 목록에서 제거되고 클라이언트와의 연결 오류는 onError메소드에서 처리됩니다. 클라이언트 코드: rrreee위는 WebSocket객체를 사용하여 WebSocket 연결을 생성하고 onopen, onerror, onmessage, onclose이벤트를 처리하는 클라이언트 코드입니다. 각각 . 수신된 메시지는 onmessage메소드로 출력됩니다. WebSocket을 사용하면 기존 소켓보다 브라우저와 서버 간의 실시간 통신이 더 쉬워집니다. Ratchet과 같은 타사 라이브러리를 사용하여 WebSocket 통신을 구현하면 개발 복잡성을 줄일 수 있습니다. 결론위의 소개를 통해 PHP와 소켓을 사용하여 실시간 데이터 통신을 구현하는 것이 상대적으로 더 유연하고 다양한 애플리케이션 시나리오에 적용될 수 있음을 알 수 있습니다. 동시에 Ratchet과 같은 타사 라이브러리를 사용하는 WebSocket 통신은 브라우저 및 서버 측에서 구현되는 기존 소켓 통신보다 시작하기 쉽고 더 짧은 시간에 통신 개발을 가속화할 수 있습니다. 개발자는 자신의 필요에 따라 적절한 통신 방법을 선택할 수 있습니다.

위 내용은 PHP와 소켓을 사용하여 실시간 데이터 통신을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!