如何对.NET远程处理框架相关知识简介
2012-12-05 10:45
489 查看
第1章 系统总体结构
1.1 总体结构
系统实现需要部署服务器端的远程对象(即一个DbServerLibrary.dll),服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器,同时根据SQL解析的结果向各个服务器发送命令,并将结果显示在客户端界面,服务器端可以接受并显示相应的命令。
1.2 关键组件结构
系统结构中关键的组件有远程对象,和本地服务器,实现的功能基本一致。下面以远程对象为例,说明组件的实现。远程对象在服务器端解决方案下的库文件中声明,通过服务器端进行注册,客户端通过TCP通道与服务器端远程对象通信,实现数据集的查询和传输。主要的数据成员有:SqlConnection(SQL Server数据库的连接对象)、 SqlCommand (SQL命令对象)、SqlDataAdapter(数据适配器,填充数据集)组件——DbServerLibrary。
第2章 .NET远程处理框架提供的强大技术
因时间仓促,未实现数据字典,所有实验要求的SQL经过解析后,直接通过代码判断,向相应场地发送命令。 代码分为三部分:远程对象,服务器端代码和客户端代码。
其中:远程对象部署在各个服务器端,客户端除了实现查询命令的解析和传送外外,还有一个本地服务器,进行相应的本地查询。
远程对象代码:
usingSystem; usingSystem.Runtime.Serialization; usingSystem.Data; usingSystem.Data.SqlClient; usingSystem.Windows.Forms; namespaceDbServerLibrary{ [SerializableAttribute]//ItisveryimportantforRemotingData publicclassDbServer:MarshalByRefObject{ privatestringconnStr; privatestringclientSql; publicSqlConnectionsqlConn; publicSqlCommandsqlComm; publicSqlDataAdaptersqlAdapter; publicvoidGetClientSql(stringsql){ if(clientSql!=null){ clientSql=null; } clientSql=sql; MessageBox.Show(clientSql); } publicDbServer(){ //LocalDataInitialize cnnStr="DataSource=localhost;InitialCatalog=DDB;UserID=sa;Password=;"; sqlConn=newSqlConnection(connStr); } publicDataSetGetDataSet() //执行select DataSetds=newDataSet(); if(sqlComm!=null){ sqlComm=null; } if(sqlConn.State==ConnectionState.Closed){ sqlConn.Open(); } try{ sqlComm=newSqlCommand(); sqlComm.Connection=sqlConn; sqlComm.CommandText=clientSql; sqlComm.CommandType=CommandType.Text; sqlAdapter=newSqlDataAdapter(); sqlAdapter.SelectCommand=sqlComm; sqlAdapter.Fill(ds); } catch(SqlExceptionex){ MessageBox.Show(ex.Message); } returnds; } publicintExecuteSql()//执行insert和delete{ intaffectedNumber; if(sqlComm!=null){ sqlComm=null; } if(sqlConn.State==ConnectionState.Closed){ sqlConn.Open(); } try{ sqlComm=newSqlCommand(); sqlComm.Connection=sqlConn; sqlComm.CommandType=CommandType.Text; sqlComm.CommandText=clientSql; affectedNumber=sqlComm.ExecuteNonQuery(); returnaffectedNumber; } catch(SqlExceptionex){ MessageBox.Show(ex.Message); return0; } } } }
服务器端代码:
privatevoidfrmSupplierServer_Load(objectsender,System.EventArgse) {TcpChannelchan=newTcpChannel(8888); ChannelServices.RegisterChannel(chan); //注册提供服务的远程对象 RemotingConfiguration.RegisterWellKnownServiceType(typeof(DbServerLibrary.DbServer)"DbServer",WellKnownObjectMode.Singleton); }
客户端代码:
解析SQL:SqlParse.cs
namespaceSupplierClient{ publicclassSqlParse{ //得到sql语句的类型 publicstringGetSqlType(stringsqlText)//typeofSQLstatements{ } //得到select语句要查询的表名 publicstringGetSelectTableName(stringsqlText){ } //得到select语句中的where子句 publicstringGetWhereClause(stringsqlText){ } //得到查询条件中的字段名 publicstringGetSelectField(stringsqlText){ } //得到分片依据,返回Scity的值 publicstringGetSelectCityValue(stringsqlText){ } //设定select语句经解析后的格式 publicArrayListSetSelectList(stringsqlText){ } //如果没有分片信息,则向3个场地都发送命令 publicArrayListSendToAllSite(stringsqlText){ } //得到insert语句要查询的表名 publicstringGetInsertTableName(stringsqlText){ } //根据插入的表和值,设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity publicstringGetInsertCityValue(stringsqlText){ } //如果表名是Supplier,则根据city值设定向哪个场地发送命令 publicArrayListSetInsertSite(stringsqlText){ } //生成解析后的insert命令列表 publicArrayListSetInsertList(stringsqlText){ } namespaceSupplierClient{ publicclassLocalServer{ } //返回查询结果 publicDataSetMakeDataSet(stringsqlText){ } //执行插入和删除操作,并返回影响记录数 publicintExecuteSql(stringsqlText){ }
第3章 界面
3.1 客户端
客户端启动后,用户首先在文本框中输入SQL命令,然后通过解析后向相应场地发送命令,并将返回的结果集进行合并,显示在界面中,显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。
3.2 服务器
服务器端仅实现对远程对象的注册,因此界面不需要实现功能,只需要在启动时注册远程对象即可,接收到的客户端的用户命令是通过消息框显示的。如上图所示。
第4章 命令处理及核心算法流程
Insert 操作——
//得到insert语句要查询的表名 publicstringGetInsertTableName(stringsqlText){ } //根据插入的表和值,设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity publicstringGetInsertCityValue(stringsqlText){ } //如果表名是Supplier,则根据city值设定向哪个场地发送命令 publicArrayListSetInsertSite(stringsqlText){ } //生成解析后的insert命令列表 publicArrayListSetInsertList(stringsqlText){ } Delete 操作——
向各个场地发送,通过定义数据库中表的关系及约束来保证完整性和一致性,如果删除命令不成功,则返回异常信息,否则,返回各个场地成功执行命令影响的记录数目。
Select 操作——
//得到sql语句的类型 publicstringGetSqlType(stringsqlText)//typeofSQLstatements{ } //得到select语句要查询的表名 publicstringGetSelectTableName(stringsqlText){ } //得到select语句中的where子句 publicstringGetWhereClause(stringsqlText){ } //得到查询条件中的字段名 publicstringGetSelectField(stringsqlText){ } //得到分片依据,返回Scity的值 publicstringGetSelectCityValue(stringsqlText){ } //设定select语句经解析后的格式 publicArrayListSetSelectList(stringsqlText){ } //如果没有分片信息,则向3个场地都发送命令 publicArrayListSendToAllSite(stringsqlText){ }
第5章 结论
.NET远程处理框架提供的一项强大的技术,利用它可以使位于任何位置的应用程序互相通信,这些应用程序可能在同一台计算机上运行,也可能位于同一局域网中的不同计算机上,或者位于相隔万里的有巨大差异的网络中。
使用.NET Remoting技术结合ADO.Net能够高效、可靠地解决这两方面的问题。具体表现为,在C#中通过使用.Net远程处理框架能够方便地解决数据、命令远程传递问题;C#通过ADO.Net对数据库进行操作,使分布式数据库系统中对数据库的各种操作变得高效、可靠,同时易于解决数据一致性问题。
由于时间关系,程序中仍有部分bug,将在下一步继续完善,而且,还应进一步完善数据字典,使程序结构更加清晰,增强可扩充性。
1.1 总体结构
系统实现需要部署服务器端的远程对象(即一个DbServerLibrary.dll),服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器,同时根据SQL解析的结果向各个服务器发送命令,并将结果显示在客户端界面,服务器端可以接受并显示相应的命令。
1.2 关键组件结构
系统结构中关键的组件有远程对象,和本地服务器,实现的功能基本一致。下面以远程对象为例,说明组件的实现。远程对象在服务器端解决方案下的库文件中声明,通过服务器端进行注册,客户端通过TCP通道与服务器端远程对象通信,实现数据集的查询和传输。主要的数据成员有:SqlConnection(SQL Server数据库的连接对象)、 SqlCommand (SQL命令对象)、SqlDataAdapter(数据适配器,填充数据集)组件——DbServerLibrary。
第2章 .NET远程处理框架提供的强大技术
因时间仓促,未实现数据字典,所有实验要求的SQL经过解析后,直接通过代码判断,向相应场地发送命令。 代码分为三部分:远程对象,服务器端代码和客户端代码。
其中:远程对象部署在各个服务器端,客户端除了实现查询命令的解析和传送外外,还有一个本地服务器,进行相应的本地查询。
远程对象代码:
usingSystem; usingSystem.Runtime.Serialization; usingSystem.Data; usingSystem.Data.SqlClient; usingSystem.Windows.Forms; namespaceDbServerLibrary{ [SerializableAttribute]//ItisveryimportantforRemotingData publicclassDbServer:MarshalByRefObject{ privatestringconnStr; privatestringclientSql; publicSqlConnectionsqlConn; publicSqlCommandsqlComm; publicSqlDataAdaptersqlAdapter; publicvoidGetClientSql(stringsql){ if(clientSql!=null){ clientSql=null; } clientSql=sql; MessageBox.Show(clientSql); } publicDbServer(){ //LocalDataInitialize cnnStr="DataSource=localhost;InitialCatalog=DDB;UserID=sa;Password=;"; sqlConn=newSqlConnection(connStr); } publicDataSetGetDataSet() //执行select DataSetds=newDataSet(); if(sqlComm!=null){ sqlComm=null; } if(sqlConn.State==ConnectionState.Closed){ sqlConn.Open(); } try{ sqlComm=newSqlCommand(); sqlComm.Connection=sqlConn; sqlComm.CommandText=clientSql; sqlComm.CommandType=CommandType.Text; sqlAdapter=newSqlDataAdapter(); sqlAdapter.SelectCommand=sqlComm; sqlAdapter.Fill(ds); } catch(SqlExceptionex){ MessageBox.Show(ex.Message); } returnds; } publicintExecuteSql()//执行insert和delete{ intaffectedNumber; if(sqlComm!=null){ sqlComm=null; } if(sqlConn.State==ConnectionState.Closed){ sqlConn.Open(); } try{ sqlComm=newSqlCommand(); sqlComm.Connection=sqlConn; sqlComm.CommandType=CommandType.Text; sqlComm.CommandText=clientSql; affectedNumber=sqlComm.ExecuteNonQuery(); returnaffectedNumber; } catch(SqlExceptionex){ MessageBox.Show(ex.Message); return0; } } } }
服务器端代码:
privatevoidfrmSupplierServer_Load(objectsender,System.EventArgse) {TcpChannelchan=newTcpChannel(8888); ChannelServices.RegisterChannel(chan); //注册提供服务的远程对象 RemotingConfiguration.RegisterWellKnownServiceType(typeof(DbServerLibrary.DbServer)"DbServer",WellKnownObjectMode.Singleton); }
客户端代码:
解析SQL:SqlParse.cs
namespaceSupplierClient{ publicclassSqlParse{ //得到sql语句的类型 publicstringGetSqlType(stringsqlText)//typeofSQLstatements{ } //得到select语句要查询的表名 publicstringGetSelectTableName(stringsqlText){ } //得到select语句中的where子句 publicstringGetWhereClause(stringsqlText){ } //得到查询条件中的字段名 publicstringGetSelectField(stringsqlText){ } //得到分片依据,返回Scity的值 publicstringGetSelectCityValue(stringsqlText){ } //设定select语句经解析后的格式 publicArrayListSetSelectList(stringsqlText){ } //如果没有分片信息,则向3个场地都发送命令 publicArrayListSendToAllSite(stringsqlText){ } //得到insert语句要查询的表名 publicstringGetInsertTableName(stringsqlText){ } //根据插入的表和值,设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity publicstringGetInsertCityValue(stringsqlText){ } //如果表名是Supplier,则根据city值设定向哪个场地发送命令 publicArrayListSetInsertSite(stringsqlText){ } //生成解析后的insert命令列表 publicArrayListSetInsertList(stringsqlText){ } namespaceSupplierClient{ publicclassLocalServer{ } //返回查询结果 publicDataSetMakeDataSet(stringsqlText){ } //执行插入和删除操作,并返回影响记录数 publicintExecuteSql(stringsqlText){ }
第3章 界面
3.1 客户端
客户端启动后,用户首先在文本框中输入SQL命令,然后通过解析后向相应场地发送命令,并将返回的结果集进行合并,显示在界面中,显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。
3.2 服务器
服务器端仅实现对远程对象的注册,因此界面不需要实现功能,只需要在启动时注册远程对象即可,接收到的客户端的用户命令是通过消息框显示的。如上图所示。
第4章 命令处理及核心算法流程
Insert 操作——
//得到insert语句要查询的表名 publicstringGetInsertTableName(stringsqlText){ } //根据插入的表和值,设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity publicstringGetInsertCityValue(stringsqlText){ } //如果表名是Supplier,则根据city值设定向哪个场地发送命令 publicArrayListSetInsertSite(stringsqlText){ } //生成解析后的insert命令列表 publicArrayListSetInsertList(stringsqlText){ } Delete 操作——
向各个场地发送,通过定义数据库中表的关系及约束来保证完整性和一致性,如果删除命令不成功,则返回异常信息,否则,返回各个场地成功执行命令影响的记录数目。
Select 操作——
//得到sql语句的类型 publicstringGetSqlType(stringsqlText)//typeofSQLstatements{ } //得到select语句要查询的表名 publicstringGetSelectTableName(stringsqlText){ } //得到select语句中的where子句 publicstringGetWhereClause(stringsqlText){ } //得到查询条件中的字段名 publicstringGetSelectField(stringsqlText){ } //得到分片依据,返回Scity的值 publicstringGetSelectCityValue(stringsqlText){ } //设定select语句经解析后的格式 publicArrayListSetSelectList(stringsqlText){ } //如果没有分片信息,则向3个场地都发送命令 publicArrayListSendToAllSite(stringsqlText){ }
第5章 结论
.NET远程处理框架提供的一项强大的技术,利用它可以使位于任何位置的应用程序互相通信,这些应用程序可能在同一台计算机上运行,也可能位于同一局域网中的不同计算机上,或者位于相隔万里的有巨大差异的网络中。
使用.NET Remoting技术结合ADO.Net能够高效、可靠地解决这两方面的问题。具体表现为,在C#中通过使用.Net远程处理框架能够方便地解决数据、命令远程传递问题;C#通过ADO.Net对数据库进行操作,使分布式数据库系统中对数据库的各种操作变得高效、可靠,同时易于解决数据一致性问题。
由于时间关系,程序中仍有部分bug,将在下一步继续完善,而且,还应进一步完善数据字典,使程序结构更加清晰,增强可扩充性。
相关文章推荐
- 一起谈.NET技术,.NET远程处理框架详解
- 不改变中间层,如何玩转 .NET 的远程处理功能?
- 掌握基于消息与.Net Remoting的分布式处理架构相关详细知识
- 不改变中间层,如何玩转 .NET 的远程处理功能?
- 如何处理java相关网络协议占内存的问题啊?为何时间越长,内存占用越大?
- 详解Python的Django框架中的Cookie相关处理
- 并发处理相关知识
- .NET如何处理AJAX传入的JSON数据
- 远程调用rpc的时候 远程的异常如何处理
- 如何解决EnterLib异常处理框架最大的局限——基于异常"类型"的异常处理策略
- 如何解决在网页里输不出中文及Cookies的相关知识
- Windows 10系统点击任务计划程序,提示找不到远程电脑如何处理
- 快速入门过程与方法:设计与思路;如何学习新的知识框架,建立思维模式,熟悉应用场景体系
- 电商之梳理springmvc相关知识---开发基础框架
- 电商之梳理mina相关知识---框架
- xml相关知识简介
- .net如何处理高并发socket,建立高性能健壮的socket服务
- Linux的内存管理,硬盘数据恢复的相关知识,SQL恢复技术,如何让多个系统共享资源
- python中如何查看statsmodels相关知识
- 【远程调用框架】如何实现一个简单的RPC框架(三)优化一:利用动态代理改变用户服务调用方式