.NET Remoting构建分布式数据库查询

本文涉及的产品
全局流量管理 GTM,标准版 1个月
云解析 DNS,旗舰版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介:
第1章 系统总体结构
1.1 总体结构图
系统实现需要部署服务器端的远程对象(即一个DbServerLibrary.dll),服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器,同时根据SQL解析的结果向各个服务器发送命令,并将结果显示在客户端界面,服务器端可以接受并显示相应的命令。系统结构如下所示:
  点击在新窗口查看全图

说明:服务器分别为:219.224.49.108(数据库为DDB)和219.224.49.82(数据库为DDB),因资源限制,客户端也部署在219.224.49.82上,但是数据库为DDBS。
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
using System;
using System.Collections;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace SupplierClient
{
 /// <summary>
 /// SqlParse 的摘要说明。
 /// </summary>
 public class SqlParse
 {
  //得到sql语句的类型
  public string GetSqlType(string sqlText)  //type of SQL statements
  {
   string[] sqltype = sqlText.Split(' ');
   if (sqltype[0].Equals("SELECT"))
   {
    return "SELECT";
   }
   else if (sqltype[0].Equals("INSERT"))
   {
    return "INSERT";
   }
   else if (sqltype[0].Equals("DELETE"))
   {
    return "DELETE";
   }
   else
   {
    return "OK";
   }
  }
  //得到select语句要查询的表名
  public string GetSelectTableName(string sqlText)
  {
   string tableName = null;
   string[] sql = sqlText.Split(' ');
   for (int i=1; i < sql.Length; i ++)
   {
    if(sql[i].Equals("FROM"))
    {
     tableName = sql[i+1];
    }
   }
   return tableName;
  }
  //得到select语句中的where子句
  public string GetWhereClause(string sqlText)
  {
  }
  //得到查询条件中的字段名
  public string GetSelectField(string sqlText)
  {
  }
  //得到分片依据,返回Scity的值
  public string GetSelectCityValue(string sqlText)
  {
  }
  //设定select语句经解析后的格式
  public ArrayList SetSelectList(string sqlText)
  {
  }
  //如果没有分片信息,则向3个场地都发送命令
  public ArrayList SendToAllSite(string sqlText)
  {
  
  }
  //得到insert语句要查询的表名
  public string GetInsertTableName(string sqlText)
  {
 
  }
  //根据插入的表和值,设定场地
  public string GetInsertCityValue(string sqlText)
  {
  }
  //如果表名是Supplier,则根据city值设定向哪个场地发送命令
  public ArrayList SetInsertSite(string sqlText)
  {
      }
  //生成解析后的insert命令列表
  public ArrayList SetInsertList(string sqlText)
  {
  
  }
 }
}
本地服务器查询代码:LocalServer.cs
using System;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace SupplierClient
{
 public class LocalServer
 {
  private SqlConnection sqlConn;
  private SqlCommand sqlComm;
  private SqlDataAdapter sqlAdapter;
  public LocalServer()
  {
   sqlConn = new SqlConnection();
   sqlConn.ConnectionString = "Data Source=ZYF;Initial Catalog=DDBS;User Id=sa;Password=;";
   sqlConn.Open();
  }
  //返回查询结果
  public DataSet MakeDataSet(string sqlText)
  {
   sqlAdapter = new SqlDataAdapter(sqlText,sqlConn);
   DataSet ds = new DataSet();
   try
   {
    sqlAdapter.Fill(ds);
    return ds;
   }
   catch(SqlException ex)
   {
    MessageBox.Show(ex.Message);
    return null;
   }
   finally
   {
    sqlConn.Dispose();
    sqlAdapter.Dispose();
   }
  }
  //执行插入和删除操作,并返回影响记录数
  public int ExecuteSql(string sqlText)
  {
   try
   {
    sqlComm = new SqlCommand();
    sqlComm.Connection = sqlConn;
    sqlComm.CommandType = CommandType.Text;
    sqlComm.CommandText = sqlText;
    int affectedNumber = sqlComm.ExecuteNonQuery();
    return affectedNumber;
   }
   catch (SqlException ex)
   {
    MessageBox.Show(ex.Message);
    return 0;
   }   
  }
 }
}
 
第4 章 界面
4.1 客户端 
  点击在新窗口查看全图

客户端启动后,用户首先在文本框中输入SQL命令,然后通过解析后向相应场地发送命令,并将返回的结果集进行合并,显示在界面中,显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。
4.2 服务器
  点击在新窗口查看全图

服务器端仅实现对远程对象的注册,因此界面不需要实现功能,只需要在启动时注册远程对象即可,接收到的客户端的用户命令是通过消息框显示的。如上图所示。
第5 章 命令处理及核心算法流程
Insert 操作——
 //得到insert语句要查询的表名
  public string GetInsertTableName(string sqlText)
  {
   string tableName = null;
   string[] sql = sqlText.Split(' ');
   for (int i=1; i < sql.Length; i ++)
   {
    if(sql[i].Equals("INTO"))
    {
     tableName = sql[i+1];
    }
   }
   return tableName;
  }
//根据插入的表和值,设定场地:INSERT INTO Supplier VALUES('no','name','city'),return city
  public string GetInsertCityValue(string sqlText)
  {
   string tableName = GetInsertTableName(sqlText);
   string[] city = sqlText.Split(',');
   string cityName = city[2];
   cityName = cityName.Substring(1,cityName.Length-3);
   return cityName;
  }
  //如果表名是Supplier,则根据city值设定向哪个场地发送命令
  public ArrayList SetInsertSite(string sqlText)
  {
   string cityName = GetInsertCityValue(sqlText);
   ArrayList insertArray = new ArrayList();
   if(cityName.Equals("London"))
   {
    insertArray.Add(sqlText + "@Site1");
    return insertArray;
   }
   else if(cityName.Equals("Paris"))
   {
    insertArray.Add(sqlText + "@Site2");
    return insertArray;
   }
   else
   {
    insertArray.Add(sqlText + "@Site3");
    return insertArray;
   }
     }
  //生成解析后的insert命令列表
  public ArrayList SetInsertList(string sqlText)
  {
   string tableName = GetInsertTableName(sqlText);
   ArrayList insertArray = new ArrayList();
   if(tableName.Equals("Supplier"))
   {
    insertArray = SetInsertSite(sqlText);    
   }
   else
   {
    insertArray = SendToAllSite(sqlText);
   }
   return insertArray;
  }
Delete 操作——
向各个场地发送,通过定义数据库中表的关系及约束来保证完整性和一致性,如果删除命令不成功,则返回异常信息,否则,返回各个场地成功执行命令影响的记录数目。
Select 操作——
  //得到sql语句的类型
  public string GetSqlType(string sqlText)  //type of SQL statements
  {
  }
  //得到select语句要查询的表名
  public string GetSelectTableName(string sqlText)
  {
  }
  //得到select语句中的where子句
  public string GetWhereClause(string sqlText)
  {
  }
  //得到查询条件中的字段名
  public string GetSelectField(string sqlText)
  {
 
  }
  //得到分片依据,返回Scity的值
  public string GetSelectCityValue(string sqlText)
  {
  }
  //设定select语句经解析后的格式
  public ArrayList SetSelectList(string sqlText)
  {
  }
  //如果没有分片信息,则向3个场地都发送命令
  public ArrayList SendToAllSite(string sqlText)
  {
  }
第6章 结论

远程处理是.NET框架提供的一项强大的技术,利用它可以使位于任何位置的应用程序互相通信,这些应用程序可能在同一台计算机上运行,也可能位于同一局域网中的不同计算机上,或者位于相隔万里的有巨大差异的网络中。
使用.NET Remoting技术结合ADO.Net能够高效、可靠地解决这两方面的问题。具体表现为,在C#中通过使用.Net远程处理框架能够方便地解决数据、命令远程传递问题;C#通过ADO.Net对数据库进行操作,使分布式数据库系统中对数据库的各种操作变得高效、可靠,同时易于解决数据一致性问题。
由于时间关系,程序中仍有部分bug,将在下一步继续完善,而且,还应进一步完善数据字典,使程序结构更加清晰,增强可扩充性。


本文转自 august 51CTO博客,原文链接:http://blog.51cto.com/august/11812,如需转载请自行联系原作者
相关文章
|
2月前
|
SQL 关系型数据库 MySQL
乐观锁在分布式数据库中如何与事务隔离级别结合使用
乐观锁在分布式数据库中如何与事务隔离级别结合使用
|
12天前
|
Cloud Native 关系型数据库 分布式数据库
PolarDB 分布式版 V2.0,安全可靠的集中分布式一体化数据库管理软件
阿里云PolarDB数据库管理软件(分布式版)V2.0 ,安全可靠的集中分布式一体化数据库管理软件。
|
1月前
|
存储 运维 负载均衡
构建高可用性GraphRAG系统:分布式部署与容错机制
【10月更文挑战第28天】作为一名数据科学家和系统架构师,我在构建和维护大规模分布式系统方面有着丰富的经验。最近,我负责了一个基于GraphRAG(Graph Retrieval-Augmented Generation)模型的项目,该模型用于构建一个高可用性的问答系统。在这个过程中,我深刻体会到分布式部署和容错机制的重要性。本文将详细介绍如何在生产环境中构建一个高可用性的GraphRAG系统,包括分布式部署方案、负载均衡、故障检测与恢复机制等方面的内容。
106 4
构建高可用性GraphRAG系统:分布式部署与容错机制
|
1月前
|
SQL 安全 Java
MyBatis-Plus条件构造器:构建安全、高效的数据库查询
MyBatis-Plus 提供了一套强大的条件构造器(Wrapper),用于构建复杂的数据库查询条件。Wrapper 类允许开发者以链式调用的方式构造查询条件,无需编写繁琐的 SQL 语句,从而提高开发效率并减少 SQL 注入的风险。
30 1
MyBatis-Plus条件构造器:构建安全、高效的数据库查询
|
1月前
|
关系型数据库 分布式数据库 数据库
PostgreSQL+Citus分布式数据库
PostgreSQL+Citus分布式数据库
63 15
|
1月前
|
存储 SQL API
探索后端开发:构建高效API与数据库交互
【10月更文挑战第36天】在数字化时代,后端开发是连接用户界面和数据存储的桥梁。本文深入探讨如何设计高效的API以及如何实现API与数据库之间的无缝交互,确保数据的一致性和高性能。我们将从基础概念出发,逐步深入到实战技巧,为读者提供一个清晰的后端开发路线图。
|
2月前
|
运维 供应链 安全
SD-WAN分布式组网:构建高效、灵活的企业网络架构
本文介绍了SD-WAN(软件定义广域网)在企业分布式组网中的应用,强调其智能化流量管理、简化的网络部署、弹性扩展能力和增强的安全性等核心优势,以及在跨国企业、多云环境、零售连锁和制造业中的典型应用场景。通过合理设计网络架构、选择合适的网络连接类型、优化应用流量优先级和定期评估网络性能等最佳实践,SD-WAN助力企业实现高效、稳定的业务连接,加速数字化转型。
SD-WAN分布式组网:构建高效、灵活的企业网络架构
|
1月前
|
缓存 NoSQL 数据库
运用云数据库 Tair 构建缓存为应用提速,完成任务得苹果音响、充电套装等好礼!
本活动将带大家了解云数据库 Tair(兼容 Redis),通过体验构建缓存以提速应用,完成任务,即可领取罗马仕安卓充电套装,限量1000个,先到先得。邀请好友共同参与活动,还可赢取苹果 HomePod mini、小米蓝牙耳机等精美好礼!
|
1月前
|
Java 数据库连接 数据库
如何构建高效稳定的Java数据库连接池,涵盖连接池配置、并发控制和异常处理等方面
本文介绍了如何构建高效稳定的Java数据库连接池,涵盖连接池配置、并发控制和异常处理等方面。通过合理配置初始连接数、最大连接数和空闲连接超时时间,确保系统性能和稳定性。文章还探讨了同步阻塞、异步回调和信号量等并发控制策略,并提供了异常处理的最佳实践。最后,给出了一个简单的连接池示例代码,并推荐使用成熟的连接池框架(如HikariCP、C3P0)以简化开发。
51 2
|
1月前
|
监控 算法 网络协议
下一篇
DataWorks