- Rongsen.Com.Cn 版权所有 2008-2010 京ICP备08007000号 京公海网安备11010802026356号 朝阳网安编号:110105199号
- 北京黑客防线网安工作室-黑客防线网安服务器维护基地为您提供专业的服务器维护,企业网站维护,网站维护服务
- (建议采用1024×768分辨率,以达到最佳视觉效果) Powered by 黑客防线网安 ©2009-2010 www.rongsen.com.cn
 
  
    
| 作者:黑客防线网安SQL维护基地 来源:黑客防线网安SQL维护基地 浏览次数:0 | 
Sql server 7.0/2000下 SqlCacheDependency使用轮询的方式进行缓存失效检查, 虽然ms说对服务器压力不大, 但还是有一些的, 而且对于不常改动的混存内容无休止的轮询感觉有点浪费, 不很经济.
Sql server 2005/2008下增加使用查询通知方式进行缓存失效检查, 它通过Sql Server内部的消息队列进行异步通知, 这样就大大减轻了服务器的压力, 实现的很经济, 下面就是具体的步骤:
1.检测是否已经启用Service Broker
Select DATABASEpRoPERTYEX('数据库名称','IsBrokerEnabled') -- 1 表示已经启用 0 表示没有启用
2.启用Service Broker
ALTER DATABASE 数据库名称 SET ENABLE_BROKER;
注意:如果执行此语句处于假死状态,请重启(restart)数据库,然后什么都别做, 先执行上面启用Service Broker这个语句就行了!
3.给您的数据库访问帐号授予权限
GRANT SUBSCRIBE QUERY NOTIFICATIONS TO test
注意:这一步非常重要, 如果没有权限, 数据库改变的通知将无法接收, cache永远都不会被刷新,我开始是用的sa帐号,死活都不刷新,花了我两天时间调试这个问题, 还是无法给sa授此权限(ms禁止), 所以,换个数据库访问帐号即可.
4.确定数据库连接字符串.
您可以在web.config里增加一个数据库连接字符串.
  <connectionStrings>
    <add name="TestConnectionString" connectionString="Data Source=bob-pc\DEVDBServer;Initial Catalog=GFDB;Persist Security Info=True;User ID=test;Password=*" 
    providerName="System.Data.sqlClient"/>
  </connectionStrings>
  <system.web>
  </system.web>
如果您的应用程序数据库连接字符串如果不存放在web.config中, 也没关系, 这不是必须的,您只要能在下面访问到即可.
5.启动SqlDependency监听.
在Global.ascx里的Application_Start和Application_End里增加如下代码:
    void Application_Start(object sender, EventArgs e) 
    {
        string connString = System.Web.Configuration.WebConfigurationManager.ConnectionStrings["TestConnectionString"].ConnectionString;
        System.Data.SqlClient.SqlDependency.Start(connString);
    }    
    void Application_End(object sender, EventArgs e) 
    {       
        string connString = System.Web.Configuration.WebConfigurationManager.ConnectionStrings["TestConnectionString"].ConnectionString;
        System.Data.SqlClient.SqlDependency.Stop(connString);
    }
注意:System.Data.SqlClient.SqlDependency.Start(connString)可以多次执行,也就是说,除了在这里,您还可以在您程序的代码里加上这句。
6.主体程序
从cache或db中获取数据。
private DataSet GetData()
{
            if (HttpRuntime.Cache["EntityResourceCollection"] != null)
            {
                //get entity resource collection from cache
                return (DataSet)HttpRuntime.Cache["EntityResourceCollection"];
            }
            else
            {
                //get from database
                DataSet ds = new DataSet();
                SqlDependency.Start(ConfigurationManager.ConnectionStrings["GFDBConnectionString"].ConnectionString);
                using (SqlConnection connection = new SqlConnection(ConfigurationManager.ConnectionStrings["GFDBConnectionString"].ConnectionString))
                {
                    string sql = " Select cityid, cityname From dbo.tbl_city";
                    using (SqlCommand command = new SqlCommand(sql, connection))
                    {
                        SqlCacheDependency dependency = new SqlCacheDependency(command);
                        using (SqlDataAdapter adapter = new SqlDataAdapter()) //查询数据
                        {
                            adapter.SelectCommand = command;
                            adapter.Fill(ds);
                        }
                        HttpRuntime.Cache.Insert("EntityResourceCollection", ds, dependency);
                    }
                }
                return ds;
            }
        }
  注意: string sql = " Select cityid, cityname From dbo.tbl_city";语句的要求非常严格,具体请参照msdn介绍。
基本上就是这6步。
注意,如果您的代码中使用了SqlCacheDependencyAdmin.EnableNotifications(connectionString),或者SqlCacheDependency是使用(库名,表名)方式构建的 SqlCacheDependency scd = new SqlCacheDependency("数据库名称","表名"),这说明,您仍然在使用sqlserver 7.0/2000 轮询的方式进行缓存依赖检查,虽然在sql 2005/2008里运行没问题,但有些不经济。
| 我要申请本站:N点 | 黑客防线官网 | | 
| 专业服务器维护及网站维护手工安全搭建环境,网站安全加固服务。黑客防线网安服务器维护基地招商进行中!QQ:29769479 |