xwl2023/Yi.Framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v1.0.1

Browse Source
This commit is contained in:
454313500@qq.com
2021-03-20 21:56:15 +08:00
parent 2e5b991db0
commit 367f8f8830
16 changed files with 240 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
CC.Yi.DAL/DbContentFactory.cs
View File

@@ -8,43 +8,36 @@ namespace CC.Yi.DAL
{
public class DbContentFactory
{
private static DataContext Webcontext;
public DbContentFactory(DataContext webContext)
private static DataContext Webcontext;
public static void Initialize(DataContext webContext)
{
Webcontext = webContext;
}
//public static void Initialize(DataContext webContext)
//{
// Webcontext = webContext;
//}
public static DataContext GetCurrentDbContent()
{
////return new DataModelContainer();
////一次请求共用一个上下文实例
////每一次http请求都会开启一个新的线程，保证在一个线程中,DbContext是唯一的
////CallContext：是线程内部唯一的数据槽（一块内存空间/容器）,相当于一个键值对数据容器，通过key获取value了,需要引入System.Runtime.Remoting.Messaging;命名空间
//DbContext db = CallContext.GetData("DbContext") as DbContext;
////从 CallContext 中检索具有指定key“DbContext”的对象，并强转为DbContext
//if (db == null)//线程在数据槽里面没有此上下文
//{
// db = Webcontext;
// CallContext.SetData("DbContext", db);//放到数据槽中去,DbContext是key，db是value
//}
//return db;
return Webcontext;
//return new DataModelContainer();
//一次请求共用一个上下文实例
//每一次http请求都会开启一个新的线程，保证在一个线程中,DbContext是唯一的
//CallContext：是线程内部唯一的数据槽（一块内存空间/容器）,相当于一个键值对数据容器，通过key获取value了,需要引入System.Runtime.Remoting.Messaging;命名空间
DataContext db = CallContext.GetData("DbContext") as DataContext;
//从 CallContext 中检索具有指定key“DbContext”的对象，并强转为DbContext
if (db == null)//线程在数据槽里面没有此上下文
{
db = Webcontext;
CallContext.SetData("DbContext", db);//放到数据槽中去,DbContext是key，db是value
}
return db;
}
//private static class CallContext
//{
// static ConcurrentDictionary<string, AsyncLocal<object>> state = new ConcurrentDictionary<string, AsyncLocal<object>>();
private static class CallContext
{
static ConcurrentDictionary<string, AsyncLocal<object>> state = new ConcurrentDictionary<string, AsyncLocal<object>>();
// public static void SetData(string name, object data) =>
// state.GetOrAdd(name, _ => new AsyncLocal<object>()).Value = data;
public static void SetData(string name, object data) =>
state.GetOrAdd(name, _ => new AsyncLocal<object>()).Value = data;
// public static object GetData(string name) =>
// state.TryGetValue(name, out AsyncLocal<object> data) ? data.Value : null;
//}
public static object GetData(string name) =>
state.TryGetValue(name, out AsyncLocal<object> data) ? data.Value : null;
}
}
}