Redisを使用してセッション機能を実装する方法
- 王林転載
- 2021-02-22 09:26:047969ブラウズ
Redis について簡単に紹介しましょう。
リモート辞書サービスである Redis (Remote Dictionary Server) は、ANSI C 言語で書かれたオープンソースのログタイプの Key-Value データベースで、ネットワークをサポートし、メモリに基づいて永続化できます。多言語 API を提供します。 2010 年 3 月 15 日以降、Redis の開発は VMware によってホストされています。 2013 年 5 月以来、Redis の開発は Pivotal によって後援されています。
1. 他のユーザー状態保存ソリューションとの比較
一般に、開発ではユーザー状態にセッションまたは Cookie が使用されますが、どちらの方法にも長所と短所があります。
セッション: InProc モードでは失われやすく、同時実行の問題が発生します。 SQLServer または SQLServer モードを使用してパフォーマンスを消費する場合
Cookie によって一部のユーザー情報が簡単に公開される可能性があり、暗号化と復号化によってもパフォーマンスが消費されます。
Redis は、このソリューションを使用していくつかの問題を解決します (
1)。Redis はアクセス速度が高速です。
2. ユーザー データは簡単には失われません。
3. ユーザーが多い場合、クラスターをサポートするのは簡単です。
4. オンライン ユーザーを表示できます。
5. ユーザーが 1 か所でログインできるようにします。 (後で紹介するコードによって実現されます)
6. 永続性をサポートします。 (もちろん役に立たないかもしれません)
2. 実装アイデア
1. セッションは実際にセッション ID を Cookie に保存することがわかっています。ユーザーはアクセスするたびにセッション ID をサーバーに送信します。 、そしてサーバーはIDを渡すと、ユーザーに対応するステータスデータを検索します。
ここでの私のアプローチは、Cookie にセッション ID を定義することです。プログラムがユーザーのステータスを取得する必要がある場合、セッション ID は Redis で検索するためのキーとして使用されます。
2.同時に、セッションは、ユーザーが一定期間アクセスしない場合にセッションをリサイクルすることをサポートします。
この機能をサポートするには、Redis のキーの有効期限機能を借用しますが、更新の観点から、プログラムはリクエストをインターセプトし、このメソッドを独自に呼び出す必要があります (デモには例があります)
以下のコードの説明を開始します
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.セッションの実装
上記のようにセッションIDをCookieに書き込みます
/// <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.更新
デフォルトでは、ユーザーは 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 の新機能の呼び出しと借用を容易にするために、Controller
public static class ExtSessions
{public static Session SessionExt(this Controller controller)
{
return new Session(controller.HttpContext);
}
}Calling メソッドに拡張属性を追加します。
public class HomeController : Controller
{
public ActionResult Index()
{
this.SessionExt().IsLogin();
return View();
}
}6. コードのダウンロード
7. フォローアップ
SessionManager にはユーザー数の取得が含まれますリスト、ユーザーのログアウト、ユーザー ID に基づくユーザー情報の取得、オンライン ユーザー オブジェクト リスト、オンライン ユーザー SessionId リスト、その他のメソッド
ユーザー ログイン機能は、将来的に 1 か所に実装される予定です。
関連する推奨事項:以上がRedisを使用してセッション機能を実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。