科技行者

行者学院 转型私董会 科技行者专题报道 网红大战科技行者

知识库

知识库 安全导航

至顶网软件频道.NET Remoting 实现分布式数据库查询

.NET Remoting 实现分布式数据库查询

  • 扫一扫
    分享文章到微信

  • 扫一扫
    关注官方公众号
    至顶头条

     开始动手之前,你需要了解.NET Remoting 技术的基本理论,熟悉分布式数据库原理,熟练掌握ADO.NET,并熟悉VS.NET的开发环境。下面仅就这几个方面做些简单的介绍。      Remoting:一种分布式处理方式。

作者:中国IT实验室 来源:中国IT实验室 2007年9月29日

关键字: 编程

  • 评论
  • 分享微博
  • 分享邮件
  
  开始动手之前,你需要了解.NET Remoting 技术的基本理论,熟悉分布式数据库原理,熟练掌握ADO.NET,并熟悉VS.NET的开发环境。下面仅就这几个方面做些简单的介绍。
  
  Remoting:一种分布式处理方式,也可将它看作是DCOM的一种升级,它改善了很多功能,并极好的融合到.Net平台下。.NET Remoting 提供了一种允许对象通过应用程序域与另一对象进行交互的框架。
  
  在Remoting中是通过通道(channel)来实现两个应用程序域之间对象的通信的。
  
  首先,客户端通过Remoting,访问通道以获得服务端对象,再通过代理解析为客户端对象。这就提供一种可能性,即以服务的方式来发布服务器对象。远程对象代码可以运行在服务器上(如服务器激活的对象和客户端激活的对象),然后客户端再通过Remoting连接服务器,获得该服务对象并通过序列化在客户端运行。
  
  在Remoting中,对于要传递的对象,设计者除了需要了解通道的类型和端口号之外,无需再了解数据包的格式。但必须注意的是,客户端在获取服务器端对象时,并不是获得实际的服务端对象,而是获得它的引用。这既保证了客户端和服务器端有关对象的松散耦合,同时也优化了通信的性能。
  
  分布式数据库系统
  
  就其本质而言,分布式数据库系统的数据在逻辑上是统一的,而在物理上却是分散的。与集中式数据库相比它有如下主要优点:
  
  ? 解决组织机构分散而数据需要相互联系的问题。
  
  ? 均衡负载。负载在各处理机间分担,可避免临界瓶颈。
  
  ? 可靠性高。数据分布在不同场地,且存有多个副本,即使个别场地发生故障,不致引起整个系统的瘫痪。
  
  ? 可扩充性好。当需要增加新的相对自主的组织单位时,可在对当前机构影响最小的情况下进行扩充。
  
  ADO.NET
  
  分布式数据库系统虽然有诸多优点,但它同时也带来了许多新问题。如:数据一致性问题、数据远程传递的实现、通信开销的降低等,这使得分布式数据库系统的开发变得较为复杂。幸运的是,微软的.NET开发环境为我们提供了C#开发语言和ADO.NET数据访问模型,结合两者来开发分布式数据库系统能够大大简化开发工作。
  
  ADO.NET以XML为核心,是.Net数据库应用程序的解决方案。它使用离线数据结构,数据源中的数据被缓存到数据集(DataSet)对象中,用户无须锁定数据源,数据以XML格式保存。在分布式数据库系统中,很可能出现多个用户同时访问和修改数据的情况,因此,对于分布式数据库系统,数据一致性是不可或缺的。ADO.NET通过使用乐观一致性方案来控制数据一致性(实际上DataSet对象被设计成支持使用乐观一致性控制机制),即数据行只有在数据库中真正被更新时才会被锁定,而在悲观一致性方案中,数据行在从被提取出来到在数据库中更
  
  新这段时间内一直被锁定。因此,使用ADO.NET能够在更少的时间内响应数量巨大的用户。
  
  另外,在分布式数据库系统中,还会经常遇到当用户修改自从提取出来以来已经被修改的行时,违反一致性原则。对此问题ADO.NET也作了很好地解决,即使用DataSet对象为每一条修改过的记录维护两个版本:原始版本和更新版本,在更新的记录被写回数据库之前,先要把数据集中记录的原始版本与数据库中的当前版本进行比较,如果两个版本匹配,就在数据库中更新记录;否则,就会出现违反一致性原则的错误。
  
  下面开始程序实现。
  
  第1章 系统总体结构
  
  1.1 总体结构图
  
  系统实现需要部署服务器端的远程对象(即一个DbServerLibrary.dll),服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器,同时根据SQL解析的结果向各个服务器发送命令,并将结果显示在客户端界面,服务器端可以接受并显示相应的命令。
  
  1.2 关键组件结构图
  
  系统结构中关键的组件有远程对象,和本地服务器,实现的功能基本一致。下面以远程对象为例,说明组件的实现。远程对象在服务器端解决方案下的库文件中声明,通过服务器端进行注册,客户端通过TCP通道与服务器端远程对象通信,实现数据集的查询和传输。主要的数据成员有:SqlConnection(SQL Server数据库的连接对象)、 SqlCommand (SQL命令对象)、SqlDataAdapter(数据适配器,填充数据集)组件――DbServerLibrary:
  
  第2 章 数据字典结构
  
  因时间仓促,未实现数据字典,所有实验要求的SQL经过解析后,直接通过代码判断,向相应场地发送命令。
  
  第3 章 代码结构
  
  代码分为三部分:远程对象,服务器端代码和客户端代码。
  
  其中:远程对象部署在各个服务器端,客户端除了实现查询命令的解析和传送外外,还有一个本地服务器,进行相应的本地查询。
  
  远程对象代码:
  
  using System;
  
  using System.Runtime.Serialization;
  
  using System.Data;
  
  using System.Data.SqlClient;
  
  using System.Windows.Forms;
  
  namespace DbServerLibrary
  
  {
  
  [SerializableAttribute]  //It is very important for Remoting Data
  
  public class DbServer : MarshalByRefObject
  
  {
  
  private string connStr;
  
  private string clientSql;
  
  public SqlConnection sqlConn;
  
  public SqlCommand sqlComm;
  
  public SqlDataAdapter sqlAdapter;
  
  public void GetClientSql(string sql)
  
  {
  
  if(clientSql != null)
  
  {
  
  clientSql = null;
  
  }
  
  clientSql = sql;
  
  MessageBox.Show(clientSql);
  
  }
  
  public DbServer()
  
  {
  
  //LocalData Initialize
  
  connStr = "Data Source = localhost;Initial Catalog=DDB;User ID=sa;Password=;";
  
  sqlConn = new SqlConnection(connStr);
  
  }
  
  public DataSet GetDataSet() // 执行select
  
  {
  
  DataSet ds = new DataSet();
  
  if (sqlComm != null)
  
  {
  
  sqlComm = null;
  
  }
  
  if(sqlConn.State == ConnectionState.Closed)
  
  {
  
  sqlConn.Open();
  
  }
  
  try
  
  {
  
  sqlComm = new SqlCommand();
  
  sqlComm.Connection = sqlConn;
  
  sqlComm.CommandText = clientSql;
  
  sqlComm.CommandType = CommandType.Text;
  
  sqlAdapter = new SqlDataAdapter();
  
  sqlAdapter.SelectCommand = sqlComm;
  
  sqlAdapter.Fill(ds);
  
  }
  
  catch(SqlException ex)
  
  {
  
  MessageBox.Show(ex.Message);
  
  }
  
  return ds;
  
  }
  public int ExecuteSql()  //执行insert和delete
  
  {
  
  int affectedNumber;
  
  if (sqlComm != null)
  
  {
  
  sqlComm = null;
  
  }
  
  if(sqlConn.State == ConnectionState.Closed)
  
  {
  
  sqlConn.Open();
  
  }
  
  try
  
  {
  
  sqlComm = new SqlCommand();
  
  sqlComm.Connection = sqlConn;
  
  sqlComm.CommandType = CommandType.Text;
  
  sqlComm.CommandText = clientSql;
  
  affectedNumber = sqlComm.ExecuteNonQuery();
  
  return affectedNumber;
  
  }
  
  catch(SqlException ex)
  
  {
  
  MessageBox.Show(ex.Message);
  
  return 0;
  
  }
  
  }
  
  }
  
  }
  
  服务器端代码:
  
  private void frmSupplierServer_Load(object sender, System.EventArgs e)
  
  {
  
  TcpChannel chan = new TcpChannel(8888);
  
  ChannelServices.RegisterChannel(chan);
  
  //注册提供服务的远程对象     RemotingConfiguration.RegisterWellKnownServiceType(typeof(DbServerLibrary.DbServer)                ,"DbServer",WellKnownObjectMode.Singleton);
  
  }
  
  客户端代码:
  
  解析SQL:SqlParse.cs
  
  namespace SupplierClient
  
  {
  
  public class SqlParse
  
  {
  
  //得到sql语句的类型
  
  public string GetSqlType(string sqlText) //type of SQL statements
  
  {
  
  }
  
  //得到select语句要查询的表名
  
  public string GetSelectTableName(string sqlText)
  
  {
  
  }
  
  //得到select语句中的where子句
  
  public string GetWhereClause(string sqlText)
  
  {

查看本文来源

    • 评论
    • 分享微博
    • 分享邮件
    邮件订阅

    如果您非常迫切的想了解IT领域最新产品与技术信息,那么订阅至顶网技术邮件将是您的最佳途径之一。

    重磅专题
    往期文章
    最新文章