一起谈.NET技术,.NET远程处理框架详解
2011-09-01 23:43
309 查看
第1章系统总体结构
1.1 总体结构
系统实现需要部署服务器端的远程对象(即一个DbServerLibrary.dll),服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器,同时根据SQL解析的结果向各个服务器发送命令,并将结果显示在客户端界面,服务器端可以接受并显示相应的命令。
1.2 关键组件结构
系统结构中关键的组件有远程对象,和本地服务器,实现的功能基本一致。下面以远程对象为例,说明组件的实现。远程对象在服务器端解决方案下的库文件中声明,通过服务器端进行注册,客户端通过TCP通道与服务器端远程对象通信,实现数据集的查询和传输。主要的数据成员有:SqlConnection(SQL Server数据库的连接对象)、 SqlCommand (SQL命令对象)、SqlDataAdapter(数据适配器,填充数据集)组件——DbServerLibrary。
第2 章.NET远程处理框架提供的强大技术
因时间仓促,未实现数据字典,所有实验要求的SQL经过解析后,直接通过代码判断,向相应场地发送命令。
代码分为三部分:远程对象,服务器端代码和客户端代码。
其中:远程对象部署在各个服务器端,客户端除了实现查询命令的解析和传送外外,还有一个本地服务器,进行相应的本地查询。
远程对象代码:
服务器端代码:
客户端代码:
解析SQL:SqlParse.cs
第4 章界面
4.1 客户端
客户端启动后,用户首先在文本框中输入SQL命令,然后通过解析后向相应场地发送命令,并将返回的结果集进行合并,显示在界面中,显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。
4.2 服务器
服务器端仅实现对远程对象的注册,因此界面不需要实现功能,只需要在启动时注册远程对象即可,接收到的客户端的用户命令是通过消息框显示的。如上图所示。
第5 章命令处理及核心算法流程
Insert 操作——
Delete 操作——
向各个场地发送,通过定义数据库中表的关系及约束来保证完整性和一致性,如果删除命令不成功,则返回异常信息,否则,返回各个场地成功执行命令影响的记录数目。
Select 操作——
第6章结论
.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经过解析后,直接通过代码判断,向相应场地发送命令。
代码分为三部分:远程对象,服务器端代码和客户端代码。
其中:远程对象部署在各个服务器端,客户端除了实现查询命令的解析和传送外外,还有一个本地服务器,进行相应的本地查询。
远程对象代码:
1. usingSystem; 2. usingSystem.Runtime.Serialization; 3. usingSystem.Data; 4. usingSystem.Data.SqlClient; 5. usingSystem.Windows.Forms; 6. namespaceDbServerLibrary{ 7. [SerializableAttribute]//ItisveryimportantforRemotingData 8. publicclassDbServer:MarshalByRefObject{ 9. privatestringconnStr; 10. privatestringclientSql; 11. publicSqlConnectionsqlConn; 12. publicSqlCommandsqlComm; 13. publicSqlDataAdaptersqlAdapter; 14. publicvoidGetClientSql(stringsql){ 15. if(clientSql!=null){ 16. clientSql=null; 17. } 18. clientSql=sql; 19. MessageBox.Show(clientSql); 20. } 21. publicDbServer(){ 22. //LocalDataInitialize 23. cnnStr="DataSource=localhost;InitialCatalog=DDB;UserID=sa;Password=;"; 24. sqlConn=newSqlConnection(connStr); 25. } 26. publicDataSetGetDataSet() 27. //执行select 28. DataSetds=newDataSet(); 29. if(sqlComm!=null){ 30. sqlComm=null; 31. } 32. if(sqlConn.State==ConnectionState.Closed){ 33. sqlConn.Open(); 34. } 35. try{ 36. sqlComm=newSqlCommand(); 37. sqlComm.Connection=sqlConn; 38. sqlComm.CommandText=clientSql; 39. sqlComm.CommandType=CommandType.Text; 40. sqlAdapter=newSqlDataAdapter(); 41. sqlAdapter.SelectCommand=sqlComm; 42. sqlAdapter.Fill(ds); 43. } 44. catch(SqlExceptionex){ 45. MessageBox.Show(ex.Message); 46. } 47. returnds; 48. } 49. publicintExecuteSql()//执行insert和delete{ 50. intaffectedNumber; 51. if(sqlComm!=null){ 52. sqlComm=null; 53. } 54. if(sqlConn.State==ConnectionState.Closed){ 55. sqlConn.Open(); 56. } 57. try{ 58. sqlComm=newSqlCommand(); 59. sqlComm.Connection=sqlConn; 60. sqlComm.CommandType=CommandType.Text; 61. sqlComm.CommandText=clientSql; 62. affectedNumber=sqlComm.ExecuteNonQuery(); 63. returnaffectedNumber; 64. } 65. catch(SqlExceptionex){ 66. MessageBox.Show(ex.Message); 67. return0; 68. } 69. } 70. } 71. }
服务器端代码:
1. privatevoidfrmSupplierServer_Load(objectsender,System.EventArgse) 2. {TcpChannelchan=newTcpChannel(8888); 3. ChannelServices.RegisterChannel(chan); 4. //注册提供服务的远程对象 5. RemotingConfiguration.RegisterWellKnownServiceType (typeof(DbServerLibrary.DbServer) "DbServer",WellKnownObjectMode.Singleton); 6. }
客户端代码:
解析SQL:SqlParse.cs
1. namespaceSupplierClient{ 2. publicclassSqlParse{ 3. //得到sql语句的类型 4. publicstringGetSqlType(stringsqlText)//typeofSQLstatements{ 5. } 6. //得到select语句要查询的表名 7. publicstringGetSelectTableName(stringsqlText){ 8. } 9. //得到select语句中的where子句 10. publicstringGetWhereClause(stringsqlText){ 11. } 12. //得到查询条件中的字段名 13. publicstringGetSelectField(stringsqlText){ 14. } 15. //得到分片依据,返回Scity的值 16. publicstringGetSelectCityValue(stringsqlText){ 17. } 18. //设定select语句经解析后的格式 19. publicArrayListSetSelectList(stringsqlText){ 20. } 21. //如果没有分片信息,则向3个场地都发送命令 22. publicArrayListSendToAllSite(stringsqlText){ 23. } 24. //得到insert语句要查询的表名 25. publicstringGetInsertTableName(stringsqlText){ 26. } 27. //根据插入的表和值,设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity 28. publicstringGetInsertCityValue(stringsqlText){ 29. } 30. //如果表名是Supplier,则根据city值设定向哪个场地发送命令 31. publicArrayListSetInsertSite(stringsqlText){ 32. } 33. //生成解析后的insert命令列表 34. publicArrayListSetInsertList(stringsqlText){ 35. } 36. namespaceSupplierClient{ 37. publicclassLocalServer{ 38. } 39. //返回查询结果 40. publicDataSetMakeDataSet(stringsqlText){ 41. } 42. //执行插入和删除操作,并返回影响记录数 43. publicintExecuteSql(stringsqlText){ 44. }
第4 章界面
4.1 客户端
客户端启动后,用户首先在文本框中输入SQL命令,然后通过解析后向相应场地发送命令,并将返回的结果集进行合并,显示在界面中,显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。
4.2 服务器
服务器端仅实现对远程对象的注册,因此界面不需要实现功能,只需要在启动时注册远程对象即可,接收到的客户端的用户命令是通过消息框显示的。如上图所示。
第5 章命令处理及核心算法流程
Insert 操作——
1. //得到insert语句要查询的表名 2. publicstringGetInsertTableName(stringsqlText){ 3. } 4. //根据插入的表和值,设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity 5. publicstringGetInsertCityValue(stringsqlText){ 6. } 7. //如果表名是Supplier,则根据city值设定向哪个场地发送命令 8. publicArrayListSetInsertSite(stringsqlText){ 9. } 10. //生成解析后的insert命令列表 11. publicArrayListSetInsertList(stringsqlText){ 12. }
Delete 操作——
向各个场地发送,通过定义数据库中表的关系及约束来保证完整性和一致性,如果删除命令不成功,则返回异常信息,否则,返回各个场地成功执行命令影响的记录数目。
Select 操作——
1. //得到sql语句的类型 2. publicstringGetSqlType(stringsqlText)//typeofSQLstatements{ 3. } 4. //得到select语句要查询的表名 5. publicstringGetSelectTableName(stringsqlText){ 6. } 7. //得到select语句中的where子句 8. publicstringGetWhereClause(stringsqlText){ 9. } 10. //得到查询条件中的字段名 11. publicstringGetSelectField(stringsqlText){ 12. } 13. //得到分片依据,返回Scity的值 14. publicstringGetSelectCityValue(stringsqlText){ 15. } 16. //设定select语句经解析后的格式 17. publicArrayListSetSelectList(stringsqlText){ 18. } 19. //如果没有分片信息,则向3个场地都发送命令 20. publicArrayListSendToAllSite(stringsqlText){ 21. }
第6章结论
.NET远程处理框架提供的一项强大的技术,利用它可以使位于任何位置的应用程序互相通信,这些应用程序可能在同一台计算机上运行,也可能位于同一局域网中的不同计算机上,或者位于相隔万里的有巨大差异的网络中。
使用.NET Remoting技术结合ADO.Net能够高效、可靠地解决这两方面的问题。具体表现为,在C#中通过使用.Net远程处理框架能够方便地解决数据、命令远程传递问题;C#通过ADO.Net对数据库进行操作,使分布式数据库系统中对数据库的各种操作变得高效、可靠,同时易于解决数据一致性问题。
由于时间关系,程序中仍有部分bug,将在下一步继续完善,而且,还应进一步完善数据字典,使程序结构更加清晰,增强可扩充性。
相关文章推荐
- 一起谈.NET技术,详解ASP.NET MVC 2中的新ADO.NET实体框架
- 一起谈.NET技术,Silverlight 2.5D RPG游戏技巧与特效处理:(三)动态光影
- 一起谈.NET技术,现有ASP.NET MVC框架应用巧妙移植到手机
- 一起谈.NET技术,ASP.NET 请求处理流程
- 一起谈.NET技术,ASP.NET的Session 详解
- 一起谈.NET技术,JAVA与.NET的相互调用——利用JNBridge桥接模式实现远程通讯
- 一起谈.NET技术,Silverlight 2.5D RPG游戏技巧与特效处理:(十一)AI系统
- 一起谈.NET技术,Silverlight 2.5D RPG游戏技巧与特效处理:(二)纸娃娃系统
- 一起谈.NET技术,LightSwitch:小试一下微软开发框架LightSwitch
- 一起谈.NET技术,细数ASP.NET MVC框架的7大顶级功能
- 一起谈.NET技术,谈谈我处理异常的一般方法
- 一起谈.NET技术,Silverlight 2.5D RPG游戏技巧与特效处理:(九)粒子系统
- 一起谈.NET技术,详解ASP.NET页面的aspx扩展
- 一起谈.NET技术,System.DateTime详解
- 一起谈.NET技术,改善代码设计 —— 处理概括关系(Dealing with Generalization)
- 一起谈.NET技术,技术详解:三招优化.NET中的锁(组团)
- 一起谈.NET技术,ASP.NET MVC功能详解 变身数据展示达人
- 一起谈.NET技术,ASP.NET应用下基于SessionState的“状态编程框架”解决方案
- 一起谈.NET技术,专访微软MVP衣明志:走进ASP.NET MVC 2框架开发
- 一起谈.NET技术,ASP.NET MVC 2中使用jQuery UI控件详解