Use Redis to complete the chat room function-Redis-php.cn

Home

Database

Redis

Use Redis to complete the chat room function

齐天大圣

May 20, 2020 am 08:44 AM

redis

Redis provides a Pub/Sub (publish/subscribe) model messaging mechanism. The publisher publishes messages to the specified channel, and subscribers who subscribe to the channel can obtain the messages. Through this mechanism, we can complete functions such as chat rooms and bulletin boards.

First, let’s introduce some commands about pub/sub.

Publish message

publish channel message Publish a message to the specified channel

If there is a car Friends group, at this time a user posted a message

127.0.0.1:6379> publish car:fans hello,everyone
(integer) 0

The return value of this command is the number of subscribers who have subscribed to this channel. As you can see, no one has subscribed to this channel yet.

Subscribe message

subscribe channel [channel] Subscribers can subscribe to one or more users

127.0.0.1:6379> subscribe car:fans
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "car:fans"
3) (integer) 1

At this time, a user has already joined the rider group. Gradually, more and more people join the group.

When a user posts a message, other group members can see the message.

127.0.0.1:6379> publish car:fans 'How are you'
(integer) 2127.0.0.1:6379> subscribe car:fans
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "car:fans"
3) (integer) 1
1) "message"
2) "car:fans"
3) "How are you"

Note: When the client executes the subscription command, it enters the subscription state and can only execute pub/sub related commands. In addition, new users who join the group cannot see previous messages because this mechanism does not persist messages. Although the functions are limited, it is simple enough.

One more thing, the more functions the better, it mainly depends on whether it is suitable for the scene. If you can do it, the simpler the better.

View the number of subscriptions

pubsub numsub [channel ...]

Want to view How many users are there in the group

127.0.0.1:6379> pubsub numsub car:fans
1) "car:fans"
2) (integer) 2

The group currently has 2 users.

Unsubscribe

unsubscribe [channel [channel ...]]

redis-cli UNSUBSCRIBE
1) "unsubscribe"
2) (nil)
3) (integer) 0

Practical combat

After introducing the above knowledge, we can complete the function of a chat room.

The pseudocode for publishing a message is very simple. The pseudocode for publishing a message is as follows:

function publist ($chanel, $message)
{
    $redis->publist($channel, $message);
}

The pseudocode for obtaining a message is as follows:

//设置php脚本执行时间
set_time_limit(0);
//设置socket连接超时时间
ini_set(&#39;default_socket_timeout&#39;, -1);
 
//声明频道名称
$channelName = "testpubsub";
 
try {
    $redis = new \Redis();
    $redis->pconnect(&#39;localhost&#39;, 6379);
    $redis->subscribe([$channelName], function ($redis, $channel, $msg)
    {
        echo &#39;channel:&#39; . $channel . &#39;,message:&#39; . $msg . PHP_EOL;
    });
} catch (\Exception $e) {
    echo $e->getMessage();
}

There are several points to note here:

Consumers need to create a redis long connection,
Set set_time_limit and default_socket_timeout to ensure that php does not time out when blocking the message acquisition process, and the socket connection does not time out.

Currently, Redis provides a new Stream type, which is much more powerful. Interested friends can check the relevant information themselves.

The above is the detailed content of Use Redis to complete the chat room function. For more information, please follow other related articles on the PHP Chinese website!

Statement

The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

How to read an element by its index using LINDEX?Jul 23, 2025 am 01:20 AM

LINDEX is a command in Redis to get the element of the specified index position in a list. Its syntax is LINDEXkeyindex, which supports positive and negative indexes. Positive numbers start from the head, 0 represents the first element; negative numbers are counted from the tail, and -1 is the last element. This command is suitable for scenes where you only need to get a single element and is more efficient than LRANGE. Pay attention to when using: 1. Make sure that the index is within the list length range, otherwise nil will be returned; 2. The list length can be obtained through LLEN to verify the index legitimacy; 3. Support negative indexes to facilitate access to the end elements; 4. Avoid frequent use of large lists, because their time complexity is O(N) may affect performance.

What happens to a message if there are no subscribers?Jul 23, 2025 am 01:16 AM

Ifamessageispublishedtoatopicorchannelwithnosubscribers,ittypicallygetslostunlessspecificmechanismsareinplace.1.InRabbitMQ,messagesmaystayinaqueueuntilaconsumerconnectsifnoconsumerisbound.2.InPub/SubsystemslikeGoogleCloudPub/Sub,messagesareusuallydis

What is the difference between an in-memory database and a disk-based database?Jul 23, 2025 am 12:16 AM

1. The memory database stores data in RAM, which is suitable for scenarios that require ultra-low latency, but is easily lost after power failure; 2. The disk database stores data on a hard disk or SSD, which has data durability and is suitable for applications that cannot tolerate data loss; 3. The memory database is fast and suitable for real-time analysis, high-frequency trading and other scenarios, while the disk database is suitable for large-scale data and long-term storage; 4. The memory database requires additional measures to ensure durability, and the cost is high. Choice should be determined based on speed, reliability and cost requirements.

How to retrieve a range of elements from a list using LRANGE?Jul 23, 2025 am 12:01 AM

LRANGE is used to take out elements of the specified range from the Redis list, supporting positive and negative indexes; 1. Use 0 to -1 for the entire list; 2. Use 0 to N-1 for the first N; 3. Use -N to -1 for the last N; 4. Use -N to -1 for the page; 4. Use paging to control by start and stop; note that starting is greater than the length or stop exceeds the end, will return empty or valid part, and start>stop also returns empty, which is suitable for cache, log, queue and other scenarios.

What are 'slowlog' commands and how do you configure them?Jul 22, 2025 am 12:36 AM

Redisslowlog is a log system that records commands that take too long to execute, and is used to identify performance issues. 1. It records each command that exceeds the specified execution time, including log ID, timestamp, execution time, commands and parameters; 2. Use redis-clislowlogget to view the log, and the 10 slowest commands are returned by default, and the number can be specified by parameters; 3. Use slowlog-log-slower-than to configure the threshold, which is 10 milliseconds by default, -1 means recording all commands, and 0 means disable; 4. The maximum number of log entries is controlled by slowlog-max-len, and the default is 128, which can be adjusted but will occupy memory; 5. It is often used to troubleshoot slowdowns in applications, impacts and characteristics of new functions.

How to set multiple key-value pairs in one command using MSET?Jul 22, 2025 am 12:22 AM

Redis's MSET command allows multiple key-value pairs to be set in one operation. The basic syntax is MSETkey1value1key2value2...keyNvalueN, for example, MSETusernamejohn_doeemailjohn@example.comstatusactive can store multiple user information at once. Using MSET has the following advantages over using SET commands multiple times: 1. Improve efficiency and reduce network round trips; 2. Ensure the atomicity of the operation (all success or failure); 3. Make the code more concise and easy to maintain. But two points should be noted: 1. MSET will overwrite existing keys, which may lead to data loss; 2. The command does not provide details

What is Redis Cluster and how does it provide horizontal scaling?Jul 22, 2025 am 12:16 AM

RedisCluster achieves horizontal expansion through data sharding, dividing the key space into 16,384 hash slots, each node is responsible for a portion of the slots. 1. Automatic data sharding: Use the CRC16 algorithm to map keys to specific slots to avoid single-point bottlenecks; 2. Distributed architecture: No central coordinator, communication between nodes through gossip protocol, supporting master-slave replication to ensure high availability; 3. Automatic rebalancing: Automatically reassign slots when adding and deleting nodes; 4. Client redirection: The client connects any node and is directed to the correct node. Deployment requires at least three master nodes, use the redis-cli command to create a cluster and configure a client driver that supports the cluster. Common problems include multi-key operations that need to coexist, network partitioning may cause brain splits,

What is the use case for the blocking version BRPOPLPUSH?Jul 22, 2025 am 12:05 AM

BRPOPLPUSH is suitable for blocking task queues, atomic data transfers and simulated delay queue scenarios. 1. Implement a task queue with blocking: In the producer-consumer model, this command allows consumers to automatically block and wait when there is no task, avoiding wasting resources; 2. Move elements atomically and retain backups: Ensure that the process of taking out elements from one list and inserting into another list is uninterrupted, suitable for scenarios where task processing fails to be retryed or analyzed; 3. Used to implement circular queues or delay queue logic: By combining additional judgment logic, lightweight delay queues can be simulated, and the task can be determined according to conditions.

See all articles