.net - 使SqlChangeMonitor工作

我正在尝试使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);
        }
    }
}

运行代码时，我收到等待消息和一个点“。”，延迟一秒钟，然后出现“ Cache Empty”消息。在我按一个键重新启动循环后，将重复此过程。

我想念什么？

最佳答案

原来，我的原始问题是由SELECT语句中使用星号（*）通配符引起的。一旦列出列名，缓存就开始正常工作。

我还想在缓存已更新/清除时以代码形式接收通知。 ChangeMonitor的NotifyOnChanged方法不适用于内部使用。

事实证明，CacheItemPolicy对象具有两个回调：可用于这些目的的RemovedCallback和UpdateCallback。只需将这些属性设置为代码中的方法，然后采取所需的操作即可。

鉴于SqlChangeMonitor上缺少可用的文档，我希望这对遇到这些问题的其他人有所帮助。

关于.net - 使SqlChangeMonitor工作，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/7878464/