Redis를 사용하여 세션 기능을 구현하는 방법

Redis에 대해 간단히 소개하겠습니다.

원격 사전 서비스인 Redis(Remote Dictionary Server)는 ANSI C 언어로 작성된 오픈소스 로그형 Key-Value 데이터베이스로, 네트워크를 지원하고 메모리 기반 및 영속성이 가능하며 다국어로 API를 제공합니다. 2010년 3월 15일부터 Redis 개발은 VMware에서 호스팅되었습니다. 2013년 5월부터 Redis 개발은 Pivotal의 후원을 받아 왔습니다.

1. 다른 사용자 상태 저장 솔루션과의 비교

일반적으로 개발 중에는 사용자 상태가 세션 또는 쿠키를 사용합니다. 두 가지 방법 모두 장단점이 있습니다.

세션: InProc 모드에서는 길을 잃기 쉽고 동시성 문제가 발생합니다. SQLServer 또는 SQLServer 모드를 사용하여 성능을 소모하는 경우 쿠키로 인해 일부 사용자 정보가 쉽게 노출될 수 있으며 암호화 및 암호 해독도 성능을 소모합니다.

Redis는 이 솔루션을 사용하여 여러 가지 문제를 해결합니다.

1 Redis는 빠른 액세스 속도를 제공합니다.

2. 사용자 데이터는 쉽게 손실되지 않습니다.

3. 사용자가 많을 때 클러스터 지원이 쉽습니다.

4. 온라인 사용자를 볼 수 있는 기능.

5. 사용자가 한 곳에서 로그인할 수 있습니다. (코드를 통해 달성, 나중에 소개)

6. 지속성을 지원합니다. (물론 쓸모가 없을 수도 있습니다)

2. 구현 아이디어

1. 우리는 세션이 실제로 세션 ID를 쿠키에 저장한다는 것을 알고 있습니다. 사용자의 해당 상태 데이터를 찾습니다.

여기서 내 접근 방식은 프로그램이 사용자 상태를 얻어야 할 때 세션 ID를 쿠키에 정의하는 것입니다. 이 세션 ID는 Redis에서 검색하는 키로 사용됩니다.

2. 동시에, 세션은 사용자가 일정 기간 동안 접속하지 않을 경우 세션을 재활용할 수 있도록 지원합니다.

이 기능을 지원하기 위해 Redis의 Keys 만료 시간 기능을 차용하지만 갱신 측면에서 프로그램이 요청을 가로채서 이 메서드를 자체적으로 호출해야 합니다(데모에는 예제가 있음)

아래 코드 설명 시작

3 . Redis 호출 인터페이스

ServiceStack 관련 DLL의 첫 번째 견적입니다.

web.config에 구성을 추가합니다. 이 구성은 Redis 호출 주소를 설정하는 데 사용됩니다. 각 서비스는 [,]로 구분됩니다. 호스트가 먼저 작성됩니다

<appSettings>

    <!--每台Redis之间用,分割.第一个必须为主机-->
    <add key="SessionRedis" value="127.0.0.1:6384,127.0.0.1:6384"/>

</appSettings>

초기 구성

static Managers()
        {
            string sessionRedis= ConfigurationManager.AppSettings["SessionRedis"];
            string timeOut = ConfigurationManager.AppSettings["SessionRedisTimeOut"];

            if (string.IsNullOrEmpty(sessionRedis))
            {
                throw new Exception("web.config 缺少配置SessionRedis,每台Redis之间用,分割.第一个必须为主机");
            }

            if (string.IsNullOrEmpty(timeOut)==false)
            {
                TimeOut = Convert.ToInt32(timeOut);
            }

            var host = sessionRedis.Split(char.Parse(","));
            var writeHost = new string[] { host[0] };
            var readHosts = host.Skip(1).ToArray();

            ClientManagers = new PooledRedisClientManager(writeHost, readHosts, new RedisClientManagerConfig
            {
                MaxWritePoolSize = writeReadCount,//“写”链接池链接数
                MaxReadPoolSize = writeReadCount,//“读”链接池链接数
                AutoStart = true
            });
        }

델리게이트는 제어용으로 작성됩니다

/// <summary>
        /// 写入
        /// </summary>
        /// <typeparam name="F"></typeparam>
        /// <param name="doWrite"></param>
        /// <returns></returns>
        public F TryRedisWrite<F>(Func<IRedisClient, F> doWrite)
        {
            PooledRedisClientManager prcm = new Managers().GetClientManagers();
            IRedisClient client = null;
            try
            {
                using (client = prcm.GetClient())
                {
                    return doWrite(client);
                }
            }
            catch (RedisException)
            {
                throw new Exception("Redis写入异常.Host:" + client.Host + ",Port:" + client.Port);
            }
            finally
            {
                if (client != null)
                {
                    client.Dispose();
                }
            }
        }

호출 예시는 소스코드

/// <summary>
        /// 以Key/Value的形式存储对象到缓存中
        /// </summary>
        /// <typeparam name="T">对象类别</typeparam>
        /// <param name="value">要写入的集合</param>
        public void KSet(Dictionary<string, T> value)
        {
            Func<IRedisClient, bool> fun = (IRedisClient client) =>
            {
                client.SetAll<T>(value);
                return true;
            };

            TryRedisWrite(fun);
        }

4를 참조하세요. 위에서 언급한 쿠키 A sessionid

/// <summary>
    /// 用户状态管理
    /// </summary>
    public class Session
    {
        /// <summary>
        /// 初始化
        /// </summary>
        /// <param name="_context"></param>
        public Session(HttpContextBase _context)
        {
            var context = _context;
            var cookie = context.Request.Cookies.Get(SessionName);
            if (cookie == null || string.IsNullOrEmpty(cookie.Value))
            {
                SessionId = NewGuid();
                context.Response.Cookies.Add(new HttpCookie(SessionName, SessionId));
                context.Request.Cookies.Add(new HttpCookie(SessionName, SessionId));
            }
            else
            {
                SessionId = cookie.Value;
            }
        }

    }

사용자 접근 방법

/// <summary>
        /// 获取当前用户信息
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <returns></returns>
        public object Get<T>() where T:class,new()
        {
            return new RedisClient<T>().KGet(SessionId);
        }

        /// <summary>
        /// 用户是否在线
        /// </summary>
        /// <returns></returns>
        public bool IsLogin()
        {
            return new RedisClient<object>().KIsExist(SessionId);
        }

        /// <summary>
        /// 登录
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="obj"></param>
        public void Login<T>(T obj) where T : class,new()
        {
            new RedisClient<T>().KSet(SessionId, obj, new TimeSpan(0, Managers.TimeOut, 0));
        }

6. Renewal

기본적으로 사용자는 30분 이상 로그아웃하지 않았으므로 사용자가 방문할 때마다 사용자의 로그아웃 시간은 다음과 같습니다. 30분 연기

Redis의 갱신 메소드를 호출해야 합니다

/// <summary>
        /// 延期
        /// </summary>
        /// <param name="key"></param>
        /// <param name="expiresTime"></param>
        public void KSetEntryIn(string key, TimeSpan expiresTime)
        {
            Func<IRedisClient, bool> fun = (IRedisClient client) =>
            {
                client.ExpireEntryIn(key, expiresTime);
                return false;
            };

            TryRedisWrite(fun);
        }

캡슐화 후

/// <summary>
/// 续期
/// </summary>
public void Postpone()
{
new RedisClient<object>().KSetEntryIn(SessionId, new TimeSpan(0, Managers.TimeOut, 0));
}

여기서 MVC3의 ActionFilter를 사용하여 모든 사용자 요청을 차단합니다

namespace Test
{
    public class SessionFilterAttribute : ActionFilterAttribute
    {
        /// <summary>
        /// 每次请求都续期
        /// </summary>
        /// <param name="filterContext"></param>
        public override void OnActionExecuting(ActionExecutingContext filterContext)
        {
            new Session(filterContext.HttpContext).Postpone();
        }
    }
}

Global.asax에 등록

public static void RegisterGlobalFilters(GlobalFilterCollection filters)
        {
            filters.Add(new SessionFilterAttribute());
        }

        protected void Application_Start()
        {
            RegisterGlobalFilters(GlobalFilters.Filters);
        }

5 호출 방법

4.0의 새로운 기능을 쉽게 호출하고 차용하려면 컨트롤러에 확장 속성을 추가하세요.

public static class ExtSessions
{public static Session SessionExt(this Controller controller)
    {
        return new Session(controller.HttpContext);
    }
}

호출 방법:

public class HomeController : Controller
    {
        public ActionResult Index()
        {
            this.SessionExt().IsLogin();
            return View();
        }
    }

6. 다운로드하려면 클릭하세요

7. -up

SessionManager에는 사용자 목록 수 획득, 사용자 로그아웃, 사용자 ID를 기반으로 한 사용자 정보 획득, 온라인 사용자 개체 목록, 온라인 사용자 SessionId 목록 및 기타 방법이 포함됩니다.

사용자 로그인 기능은 한 곳에서 구현됩니다. in the future

관련 추천:

redis 데이터베이스 튜토리얼

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