ServiceStack每个请求的NHibernate会话
我开始构建一个应用程序,并计划使用ServiceStack。只是想知道什么是处理NHibernate ISession或其他“按请求”上下文特定会话对象的最佳实践/好方法。ServiceStack每个请求的NHibernate会话
我认为在国际奥委会注册ISessionFactory,如:
container.Register<ISessionFactory>(sessionFactory);
并在需要时得到一个新的Session对象,或者......直接提供会话对象:
container.Register<ISession>(c => sessionFactory.OpenSession()).ReusedWithin(ReuseScope.None);
或者自行处理ISession和通过Global.asax BeginRequest事件的默认事务处理:
protected void Application_BeginRequest(object sender, EventArgs e)
{
var session = factory.OpenSession();
ITransaction itrans = session.BeginTransaction();
Context.Items.Add("session", session);
Context.Items.Add("trans", itrans);
}
所以,我有点迷路,考虑到上述技术或类似的技术,EF或其他Rest-Services框架有哪些最佳实践?
在此先感谢
请参阅此博客张贴的如何最优地使用ServiceStack和NHibernate一起完整的例子:
http://www.philliphaydon.com/2012/06/using-nhibernate-with-servicestack/ 下面是上面的帖子中使用的APPHOST例如:
public class Global : HttpApplication
{
public class SampleServiceAppHost : AppHostBase
{
private readonly IContainerAdapter _containerAdapter;
public SampleServiceAppHost(ISessionFactory sessionFactory)
: base("Service Stack with Fluent NHibernate Sample", typeof(ProductFindService).Assembly)
{
base.Container.Register<ISessionFactory>(sessionFactory);
}
public override void Configure(Funq.Container container)
{
container.Adapter = _containerAdapter;
}
}
void Application_Start(object sender, EventArgs e)
{
var factory = new SessionFactoryManager().CreateSessionFactory();
(new SampleServiceAppHost(factory)).Init();
}
}
使用HttpHandler为每个请求创建一个会话是我找到的最常用的方法。 Ayende解释说,创建一个会话真的很轻。 http://ayende.com/blog/4123/what-is-the-cost-of-opening-a-session
Ayende实际上有一系列的职位,他逐步建立数据访问解决方案。每篇文章解释了他为什么做了他所做的事情,以及到目前为止采取的步骤需要解决哪些问题。从这里开始:http://ayende.com/blog/4803/refactoring-toward-frictionless-odorless-code-the-baseline
以上所有的都是每个请求会话的变化。所有人的共同点是不必手动担心创建会话/事务。他们将自动提交/回滚事务。
我知道这是一个古老的问题,但我想我会继续,并展示谁仍然对另一个答案感兴趣的人,我们如何做到这一点。
我们使用ServiceRunner新ServiceStack API中正是如此:
public class BaseServiceRunner<TRequest> : ServiceRunner<TRequest>
{
public BaseServiceRunner(AppHost appHost, ActionContext actionContext)
: base(appHost, actionContext) { }
public override void OnBeforeExecute(IRequestContext requestContext, TRequest request)
{
var req = request as MyRequestType;
if(req == null)
base.OnBeforeExecute(requestContext, request);
var factory = TryResolve<NHibernate.ISessionFactory>();
var session = factory.OpenSession();
var trans = session.BeginTransaction(IsolationLevel.ReadCommitted);
requestContext.SetItem("session", session);
requestContext.SetItem("transaction", trans);
}
public override object OnAfterExecute(IRequestContext requestContext, object response)
{
var trans = requestContext.GetItem("transaction") as ITransaction;
if (trans != null && trans.IsActive)
trans.Commit();
var session = requestContext.GetItem("session") as ISession;
if (session != null)
{
session.Flush();
session.Close();
}
return base.OnAfterExecute(requestContext, response);
}
public override object HandleException(IRequestContext requestContext, TRequest request, Exception ex)
{
var req = request as MyRequestType;
if(req != null)
{
var trans = requestContext.GetItem("transaction") as ITransaction;
if (trans != null && trans.IsActive)
trans.Rollback();
var session = requestContext.GetItem("session") as ISession;
if (session != null)
{
session.Flush();
session.Close();
}
}
return base.HandleException(requestContext, request, ex);
}
}
能否请您阐述一下您是如何使用的呢? ServiceStack文档对于如何使用这些ServiceRunners确实没有意义。 – slashp 2013-04-17 05:23:39
我添加了代码以添加到您的应用程序主机中。不确定如何使用该服务中的Service runner。 – 2013-07-15 10:54:53
刚刚看到有关更多详细信息的请求,可能已太迟而无法提供帮助,但也许有人想知道。 'code' public class AppHost:AppHostBase { public AppHost():base(“Service”,typeof(AccessService))。大会) {} 公共覆盖无效配置(集装箱货柜) {} 公共 覆盖IServiceRunner CreateServiceRunner (ActionContext中ActionContext中) { 返回新BaseServiceRunner (这一点,ActionContext中); '代码' –
2014-02-07 20:14:44