我正在尝试使 System.Runtime.Caching 命名空间中包含的新 SqlChangeMonitor 功能正常工作,并且得到了一些意想不到的结果。
我有一个简单的控制台应用程序设置:
static void Main(string[] args)
{
var cacher = new Cacher();
cacher.Start();
Console.WriteLine("Watching for changes...");
while (true)
{
if (cacher.HasData)
{
Console.Write(".");
Thread.Sleep(1000);
}
else
{
Console.WriteLine();
Console.WriteLine("Cache EMPTY!");
Console.ReadLine();
cacher.Start();
}
}
}
Cacher 类定义为:
public class Cacher
{
private MemoryCache cache = new MemoryCache("test");
public Boolean HasData
{
get { return cache.Contains("data"); }
}
public void Start()
{
var connectionString = "Data Source=.;Initial Catalog=CachingTest;Integrated Security=True";
var list = new NameValueCollection();
var policy = new CacheItemPolicy();
SqlDependency.Start(connectionString);
using (var connection = new SqlConnection(connectionString))
{
using (var command = new SqlCommand("SELECT * FROM dbo.Table_1", connection))
{
var dependency = new SqlDependency(command);
connection.Open();
var reader = command.ExecuteReader();
while (reader.Read())
{
list.Add(reader["Name"].ToString(), reader["Value"].ToString());
}
var monitor = new SqlChangeMonitor(dependency);
policy.ChangeMonitors.Add(monitor);
}
cache.Add("data", list, policy);
}
}
}
当我运行代码时,我收到 Waiting 消息和一个单点“。”,延迟一秒,然后是“Cache Empty”消息。在我按下一个键重新启动循环后重复此操作。
我错过了什么?