How to develop a chat room using swoole and websocket
这次给大家带来如何用swoole与websocket开发一个聊天室，用swoole与websocket开发聊天室的注意事项有哪些，下面就是实战案例，一起来看一下。
首先，我想说下写代码的一些习惯，第一，任何可配置的参数或变量都要写到一个config文件中。第二，代码中一定要有日志记录和完善的报错并记录报错。言归正传，swoole应该是每个phper必须要了解的，它号称重新定义了php。此聊天室利用了swoole高并发并且异步非阻塞的特点提高了程序的性能。
首先，定义一个 swoole_lock 和 swoole_websocket_server ，并且配置参数，具体参数详情可以去swoole官网查看。
public function start()
{
$this->lock = new swoole_lock(SWOOLE_MUTEX);
// 对文件或数组进行锁操作，已达到同步
$this->server = new swoole_websocket_server($this->addr, $this->port);
// swoole提供的Websocket Server
$this->server->set(array(
'daemonize' => 0,
'worker_num' => 4,
'task_worker_num' => 10,
'max_request' => 1000,
'log_file' => ROOT_PATH . 'storage\\logs\\swoole.log'
// swoole日志路径，必须是绝对路径
));
$this->server->on('open', array($this, 'onOpen'));
$this->server->on('message', array($this, 'onMessage'));
$this->server->on('task', array($this, 'onTask'));
$this->server->on('finish', array($this, 'onFinish'));
$this->server->on('close', array($this, 'onClose'));
// 启动服务
$this->server->start();
}当有客户端链接时，简单记录客户端的信息。
public function onOpen($server, $request)
{
$message = array(
'remote_addr' => $request->server['remote_addr'],
'request_time' => date('Y-m-d H:i:s', $request->server['request_time'])
);
write_log($message);
}当有客户端发送信息时，对信息进行处理。
public function onMessage($server, $frame)
{
$data = json_decode($frame->data);
switch ($data->type) {
case 'init':
case 'INIT':
$this->users[$frame->fd] = $data->message; 、
// 记录每个链接的信息，同样不要尝试打印出来看，因为你只能看到自己的链接信息
$message = '欢迎' . $data->message . '加入了聊天室';
$response = array(
'type' => 1, // 1代表系统消息，2代表用户聊天
'message' => $message
);
break;
case 'chat':
case 'CHAT':
$message = $data->message;
$response = array(
'type' => 2, // 1代表系统消息，2代表用户聊天
'username' => $this->users[$frame->fd],
'message' => $message
);
break;
default:
return false;
}
// 将信息交给task处理
$this->server->task($response);
}
public function onTask($server, $task_id, $from_id, $message)
{
// 迭代所有的客户端链接，将消息推送过去。（如果你尝试将 $this->server->connections 打印出来，那么你会发现他是空的。但当时用 foreach 去循环时，它确实有用。）
foreach ($this->server->connections as $fd) {
$this->server->push($fd, json_encode($message));
}
$server->finish( 'Task' . $task_id . 'Finished' . PHP_EOL);
}最后，当客户端断开链接时，利用锁机制，同步删除客户端信息，并记录日志。
public function onClose($server, $fd)
{
$username = $this->users[$fd];
// 释放客户端，利用锁进行同步
$this->lock->lock();
unset($this->users[$fd]);
$this->lock->unlock();
if( $username ) {
$response = array(
'type' => 1, // 1代表系统消息，2代表用户聊天
'message' => $username . '离开了聊天室'
);
$this->server->task($response);
}
write_log( $fd . ' disconnected');
}服务端完了，下面就是客户端，很简单，只需要用websocket链接就ok！
// websocket
let address = 'ws://<?php echo CLIENT_CONNECT_ADDR . ':' . CLIENT_CONNECT_PORT ?>';
let webSocket = new WebSocket(address);
webSocket.onerror = function (event) {
alert('服务器连接错误，请稍后重试');
};
webSocket.onopen = function (event) {
if(!sessionStorage.getItem('username')) {
setName();
}else {
username = sessionStorage.getItem('username')
webSocket.send(JSON.stringify({
'message': username,
'type': 'init'
}));
}
};
webSocket.onmessage = function (event) {
console.log(event);
let data = JSON.parse(event.data);
if (data.type == 1) {
$('#chat-list2').append('<li class="ui-border-tb"><span class="username">系统消息:</span><span class="message">' + data.message + '</span></li>');
} else if (data.type == 2) {
$('#chat-list2').append('<li class="ui-border-tb"><span class="username">' + data.username + ':</span><span class="message">' + data.message + '</span></li>');
}
};
webSocket.onclose = function (event) {
alert('散了吧，服务器都关了');
};相信看了本文案例你已经掌握了方法，更多精彩请关注php中文网其它相关文章！
推荐阅读：
The above is the detailed content of How to develop a chat room using swoole and websocket. For more information, please follow other related articles on the PHP Chinese website!
Hot AI Tools
Undresser.AI Undress
AI-powered app for creating realistic nude photos
AI Clothes Remover
Online AI tool for removing clothes from photos.
Undress AI Tool
Undress images for free
Clothoff.io
AI clothes remover
Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!
Hot Article
Hot Tools
Notepad++7.3.1
Easy-to-use and free code editor
SublimeText3 Chinese version
Chinese version, very easy to use
Zend Studio 13.0.1
Powerful PHP integrated development environment
Dreamweaver CS6
Visual web development tools
SublimeText3 Mac version
God-level code editing software (SublimeText3)
Hot Topics
PHP and WebSocket: Best practices for real-time data transfer
Dec 18, 2023 pm 02:10 PM
PHP and WebSocket: Best Practice Methods for Real-Time Data Transfer Introduction: In web application development, real-time data transfer is a very important technical requirement. The traditional HTTP protocol is a request-response model protocol and cannot effectively achieve real-time data transmission. In order to meet the needs of real-time data transmission, the WebSocket protocol came into being. WebSocket is a full-duplex communication protocol that provides a way to communicate full-duplex over a single TCP connection. Compared to H
How to use swoole coroutine in laravel
Apr 09, 2024 pm 06:48 PM
Using Swoole coroutines in Laravel can process a large number of requests concurrently. The advantages include: Concurrent processing: allows multiple requests to be processed at the same time. High performance: Based on the Linux epoll event mechanism, it processes requests efficiently. Low resource consumption: requires fewer server resources. Easy to integrate: Seamless integration with Laravel framework, simple to use.
SSE and WebSocket
Apr 17, 2024 pm 02:18 PM
In this article, we will compare Server Sent Events (SSE) and WebSockets, both of which are reliable methods for delivering data. We will analyze them in eight aspects, including communication direction, underlying protocol, security, ease of use, performance, message structure, ease of use, and testing tools. A comparison of these aspects is summarized as follows: Category Server Sent Event (SSE) WebSocket Communication Direction Unidirectional Bidirectional Underlying Protocol HTTP WebSocket Protocol Security Same as HTTP Existing security vulnerabilities Ease of use Setup Simple setup Complex performance Fast message sending speed Affected by message processing and connection management Message structure Plain text or binary Ease of use Widely available Helpful for WebSocket integration
golang WebSocket programming tips: handling concurrent connections
Dec 18, 2023 am 10:54 AM
Golang is a powerful programming language, and its use in WebSocket programming is increasingly valued by developers. WebSocket is a TCP-based protocol that allows two-way communication between client and server. In this article, we will introduce how to use Golang to write an efficient WebSocket server that handles multiple concurrent connections at the same time. Before introducing the techniques, let's first learn what WebSocket is. Introduction to WebSocketWeb
How to use WebSocket for file transfer in golang
Dec 18, 2023 am 09:06 AM
How to use WebSocket for file transfer in golang WebSocket is a network protocol that supports two-way communication and can establish a persistent connection between the browser and the server. In golang, we can use the third-party library gorilla/websocket to implement WebSocket functionality. This article will introduce how to use golang and gorilla/websocket libraries for file transfer. First, we need to install gorilla
How does swoole_process allow users to switch?
Apr 09, 2024 pm 06:21 PM
Swoole Process allows users to switch. The specific steps are: create a process; set the process user; start the process.
Which one is better, swoole or workerman?
Apr 09, 2024 pm 07:00 PM
Swoole and Workerman are both high-performance PHP server frameworks. Known for its asynchronous processing, excellent performance, and scalability, Swoole is suitable for projects that need to handle a large number of concurrent requests and high throughput. Workerman offers the flexibility of both asynchronous and synchronous modes, with an intuitive API that is better suited for ease of use and projects that handle lower concurrency volumes.
PHP Websocket development guide to implement real-time translation function
Dec 18, 2023 pm 05:52 PM
PHP Websocket Development Guide: Implementing Real-time Translation Function Introduction: With the development of the Internet, real-time communication is becoming more and more important in various application scenarios. As an emerging communication protocol, Websocket provides good support for real-time communication. This article will take you through a detailed understanding of how to use PHP to develop Websocket applications, and combine the real-time translation function to demonstrate its specific application. 1. What is the Websocket protocol? The Websocket protocol is a
