Redis精准统计在线人数（redis 查看在线人数）

Redis精准统计在线人数

在现代网络应用开发中，对于实时在线人数的统计是非常关键和常见的一项功能。Redis作为一种高性能的缓存和数据结构存储，可以有效地处理这类需求。

以下是一些使用Redis实现在线人数统计的方法。

方法一：使用计数器

最简单的方法是使用Redis的计数器功能。我们可以将每个用户的登录视为一个加一操作，将每个用户的注销视为一个减一操作。Redis中提供了incr和decr命令可以实现这些操作。incr命令会将指定的key中的值加1，如果该key不存在则会被初始化为0；而decr命令则是将指定的key中的值减1。

下面是一个示例代码，实现了一个基于计数器的在线人数统计：

import redis
pool = redis.ConnectionPool(host='localhost', port=6379, db=0)
redis_conn = redis.Redis(connection_pool=pool)
def login(user_id):
    redis_conn.incr('online')
def logout(user_id):
    redis_conn.decr('online')
def get_online_count():
    return redis_conn.get('online')

我们可以在用户登录时调用login函数，在用户注销时调用logout函数，同时可以调用get_online_count函数获取当前在线人数。

需要注意的是，如果系统遇到了错误或者宕机等异常情况，可能会导致在线人数数据出现错误，需要使用业务规则和异常处理逻辑避免这类问题的发生。

方法二：使用SortedSet（有序集合）

另一种方法是使用Redis的SortedSet（有序集合）功能。我们把用户的登录时间作为SortedSet的分值，用户ID作为SortedSet的成员，这样就可以统计出在线用户的人数，并且可以按照登录时间进行排序。

下面是一个示例代码，实现了一个基于SortedSet的在线人数统计：

import redis
import time

pool = redis.ConnectionPool(host='localhost', port=6379, db=0)
redis_conn = redis.Redis(connection_pool=pool)
def login(user_id):
    redis_conn.zadd('online', {user_id: time.time()})
def logout(user_id):
    redis_conn.zrem('online', user_id)
def get_online_count():
    return redis_conn.zcount('online', '-inf', '+inf')

我们可以在用户登录时调用login函数，在用户注销时调用logout函数，同时可以调用get_online_count函数获取当前在线人数。

需要注意的是，SortedSet本身是按照分值进行排序的，如果不按照分值排序需要进行处理。另外，在获取在线人数的方法中，如果不需要有序性，可以使用zcard命令直接获取SortedSet的元素数量。

方法三：基于Pub/Sub实现实时在线人数统计

以上两种方法都存在一定的延迟，不能实现实时统计在线人数的需求。为了实现实时在线人数统计，可以使用Redis的Pub/Sub（发布/订阅）机制。我们可以在用户登录/注销时，向某个频道（Channel）发布消息，同时在某个位置订阅该频道，来实现在线人数实时统计。

以下是一个示例代码，实现了一个基于Pub/Sub的实时在线人数统计：

import redis
pool = redis.ConnectionPool(host='localhost', port=6379, db=0)
redis_conn = redis.Redis(connection_pool=pool)
subscriber = redis_conn.pubsub()

def login(user_id):
    redis_conn.publish('online', '+1')
def logout(user_id):
    redis_conn.publish('online', '-1')
def get_online_count():
    subscriber.subscribe('online')
    for message in subscriber.listen():
        if message['type'] == 'message':
            return int(message['data'])

我们可以在用户登录时调用login函数，在用户注销时调用logout函数，可以实现对在线人数变化的订阅。

但是需要注意的是，Pub/Sub的实时性是有限制的，取决于客户端与Redis之间的网络延迟，并不是绝对的实时性。同时，如果系统遇到了异常情况，可能会导致订阅失败或数据不一致等问题，需要使用异常处理逻辑避免这类问题的发生。