.NET远程处理框架详解

第1章 系统总体结构

1.1 总体结构

系统实现需要部署服务器端的远程对象（即一个DbServerLibrary.dll），服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器，同时根据SQL解析的结果向各个服务器发送命令，并将结果显示在客户端界面，服务器端可以接受并显示相应的命令。

1.2 关键组件结构

系统结构中关键的组件有远程对象，和本地服务器，实现的功能基本一致。下面以远程对象为例，说明组件的实现。远程对象在服务器端解决方案下的库文件中声明，通过服务器端进行注册，客户端通过TCP通道与服务器端远程对象通信，实现数据集的查询和传输。主要的数据成员有：SqlConnection（SQL Server数据库的连接对象）、 SqlCommand （SQL命令对象）、SqlDataAdapter（数据适配器，填充数据集）组件——DbServerLibrary。

第2 章 .NET远程处理框架提供的强大技术

因时间仓促，未实现数据字典，所有实验要求的SQL经过解析后，直接通过代码判断，向相应场地发送命令。

代码分为三部分：远程对象，服务器端代码和客户端代码。

其中：远程对象部署在各个服务器端，客户端除了实现查询命令的解析和传送外外，还有一个本地服务器，进行相应的本地查询。

远程对象代码： 

 
 
 
    
  
  
  
  1. usingSystem;  
    2.   
  
  
  2. usingSystem.Runtime.Serialization;  
    3.   
  
  
  3. usingSystem.Data;  
    4.   
  
  
  4. usingSystem.Data.SqlClient;  
    5.   
  
  
  5. usingSystem.Windows.Forms;  
    6.   
  
  
  6. namespaceDbServerLibrary{  
    7.   
  
  
  7. [SerializableAttribute]//ItisveryimportantforRemotingData  
    8.   
  
  
  8. publicclassDbServer:MarshalByRefObject{  
    9.   
  
  
  9. privatestringconnStr;  
    10.   
  
  
  10. privatestringclientSql;  
    11.   
  
  
  11. publicSqlConnectionsqlConn;  
    12.   
  
  
  12. publicSqlCommandsqlComm;  
    13.   
  
  
  13. publicSqlDataAdaptersqlAdapter;  
    14.   
  
  
  14. publicvoidGetClientSql(stringsql){  
    15.   
  
  
  15. if(clientSql!=null){  
    16.   
  
  
  16. clientSql=null;  
    17.   
  
  
  17. }  
    18.   
  
  
  18. clientSql=sql;  
    19.   
  
  
  19. MessageBox.Show(clientSql);  
    20.   
  
  
  20. }  
    21.   
  
  
  21. publicDbServer(){  
    22.   
  
  
  22. //LocalDataInitialize  
    23.   
  
  
  23. cnnStr="DataSource=localhost;InitialCatalog=DDB;UserID=sa;Password=;";  
    24.   
  
  
  24. sqlConn=newSqlConnection(connStr);  
    25.   
  
  
  25. }  
    26.   
  
  
  26. publicDataSetGetDataSet()  
    27.   
  
  
  27. //执行select  
    28.   
  
  
  28. DataSetds=newDataSet();  
    29.   
  
  
  29. if(sqlComm!=null){  
    30.   
  
  
  30. sqlComm=null;  
    31.   
  
  
  31. }  
    32.   
  
  
  32. if(sqlConn.State==ConnectionState.Closed){  
    33.   
  
  
  33. sqlConn.Open();  
    34.   
  
  
  34. }  
    35.   
  
  
  35. try{  
    36.   
  
  
  36. sqlComm=newSqlCommand();  
    37.   
  
  
  37. sqlComm.Connection=sqlConn;  
    38.   
  
  
  38. sqlComm.CommandText=clientSql;  
    39.   
  
  
  39. sqlComm.CommandType=CommandType.Text;  
    40.   
  
  
  40. sqlAdapter=newSqlDataAdapter();  
    41.   
  
  
  41. sqlAdapter.SelectCommand=sqlComm;  
    42.   
  
  
  42. sqlAdapter.Fill(ds);  
    43.   
  
  
  43. }  
    44.   
  
  
  44. catch(SqlExceptionex){  
    45.   
  
  
  45. MessageBox.Show(ex.Message);  
    46.   
  
  
  46. }  
    47.   
  
  
  47. returnds;  
    48.   
  
  
  48. }  
    49.   
  
  
  49. publicintExecuteSql()//执行insert和delete{  
    50.   
  
  
  50. intaffectedNumber;  
    51.   
  
  
  51. if(sqlComm!=null){  
    52.   
  
  
  52. sqlComm=null;  
    53.   
  
  
  53. }  
    54.   
  
  
  54. if(sqlConn.State==ConnectionState.Closed){  
    55.   
  
  
  55. sqlConn.Open();  
    56.   
  
  
  56. }  
    57.   
  
  
  57. try{  
    58.   
  
  
  58. sqlComm=newSqlCommand();  
    59.   
  
  
  59. sqlComm.Connection=sqlConn;  
    60.   
  
  
  60. sqlComm.CommandType=CommandType.Text;  
    61.   
  
  
  61. sqlComm.CommandText=clientSql;  
    62.   
  
  
  62. affectedNumber=sqlComm.ExecuteNonQuery();  
    63.   
  
  
  63. returnaffectedNumber;  
    64.   
  
  
  64. }  
    65.   
  
  
  65. catch(SqlExceptionex){  
    66.   
  
  
  66. MessageBox.Show(ex.Message);  
    67.   
  
  
  67. return0;  
    68.   
  
  
  68. }  
    69.   
  
  
  69. }  
    70.   
  
  
  70. }  
    71.   
  
  
  71. } 
    72.

服务器端代码：

 
 
 
    
  
  
  
  1. privatevoidfrmSupplierServer_Load(objectsender,System.EventArgse)  
    2.   
  
  
  2. {TcpChannelchan=newTcpChannel(8888);  
    3.   
  
  
  3. ChannelServices.RegisterChannel(chan);  
    4.   
  
  
  4. //注册提供服务的远程对象  
    5.   
  
  
  5. RemotingConfiguration.RegisterWellKnownServiceType(typeof(DbServerLibrary.DbServer)
    "DbServer",WellKnownObjectMode.Singleton);  
    6.   
  
  
  6. } 
    7.

 客户端代码：

解析SQL：SqlParse.cs 

 
 
 
    
  
  
  
  1. namespaceSupplierClient{  
    2.   
  
  
  2. publicclassSqlParse{  
    3.   
  
  
  3. //得到sql语句的类型  
    4.   
  
  
  4. publicstringGetSqlType(stringsqlText)//typeofSQLstatements{  
    5.   
  
  
  5. }  
    6.   
  
  
  6. //得到select语句要查询的表名  
    7.   
  
  
  7. publicstringGetSelectTableName(stringsqlText){  
    8.   
  
  
  8. }  
    9.   
  
  
  9. //得到select语句中的where子句  
    10.   
  
  
  10. publicstringGetWhereClause(stringsqlText){  
    11.   
  
  
  11. }  
    12.   
  
  
  12. //得到查询条件中的字段名  
    13.   
  
  
  13. publicstringGetSelectField(stringsqlText){  
    14.   
  
  
  14. }  
    15.   
  
  
  15. //得到分片依据，返回Scity的值  
    16.   
  
  
  16. publicstringGetSelectCityValue(stringsqlText){  
    17.   
  
  
  17. }  
    18.   
  
  
  18. //设定select语句经解析后的格式  
    19.   
  
  
  19. publicArrayListSetSelectList(stringsqlText){  
    20.   
  
  
  20. }  
    21.   
  
  
  21. //如果没有分片信息，则向3个场地都发送命令  
    22.   
  
  
  22. publicArrayListSendToAllSite(stringsqlText){  
    23.   
  
  
  23. }  
    24.   
  
  
  24. //得到insert语句要查询的表名  
    25.   
  
  
  25. publicstringGetInsertTableName(stringsqlText){  
    26.   
  
  
  26. }  
    27.   
  
  
  27. //根据插入的表和值，设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity  
    28.   
  
  
  28. publicstringGetInsertCityValue(stringsqlText){  
    29.   
  
  
  29. }  
    30.   
  
  
  30. //如果表名是Supplier,则根据city值设定向哪个场地发送命令  
    31.   
  
  
  31. publicArrayListSetInsertSite(stringsqlText){  
    32.   
  
  
  32. }  
    33.   
  
  
  33. //生成解析后的insert命令列表  
    34.   
  
  
  34. publicArrayListSetInsertList(stringsqlText){  
    35.   
  
  
  35. }  
    36.   
  
  
  36. namespaceSupplierClient{  
    37.   
  
  
  37. publicclassLocalServer{  
    38.   
  
  
  38. }  
    39.   
  
  
  39. //返回查询结果  
    40.   
  
  
  40. publicDataSetMakeDataSet(stringsqlText){  
    41.   
  
  
  41. }  
    42.   
  
  
  42. //执行插入和删除操作，并返回影响记录数  
    43.   
  
  
  43. publicintExecuteSql(stringsqlText){  
    44.   
  
  
  44. } 
    45.

第4 章 界面

4.1 客户端

客户端启动后，用户首先在文本框中输入SQL命令，然后通过解析后向相应场地发送命令，并将返回的结果集进行合并，显示在界面中，显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。

4.2 服务器

服务器端仅实现对远程对象的注册，因此界面不需要实现功能，只需要在启动时注册远程对象即可，接收到的客户端的用户命令是通过消息框显示的。如上图所示。

第5 章 命令处理及核心算法流程

Insert 操作—— 

 
 
 
    
  
  
  
  1. //得到insert语句要查询的表名  
    2.   
  
  
  2. publicstringGetInsertTableName(stringsqlText){  
    3.   
  
  
  3. }  
    4.   
  
  
  4. //根据插入的表和值，设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity  
    5.   
  
  
  5. publicstringGetInsertCityValue(stringsqlText){  
    6.   
  
  
  6. }  
    7.   
  
  
  7. //如果表名是Supplier,则根据city值设定向哪个场地发送命令  
    8.   
  
  
  8. publicArrayListSetInsertSite(stringsqlText){  
    9.   
  
  
  9. }  
    10.   
  
  
  10. //生成解析后的insert命令列表  
    11.   
  
  
  11. publicArrayListSetInsertList(stringsqlText){  
    12.   
  
  
  12. } 
    13.

Delete 操作——

向各个场地发送，通过定义数据库中表的关系及约束来保证完整性和一致性，如果删除命令不成功，则返回异常信息，否则，返回各个场地成功执行命令影响的记录数目。

Select 操作—— 

 
 
 
    
  
  
  
  1. //得到sql语句的类型  
    2.   
  
  
  2. publicstringGetSqlType(stringsqlText)//typeofSQLstatements{  
    3.   
  
  
  3. }  
    4.   
  
  
  4. //得到select语句要查询的表名  
    5.   
  
  
  5. publicstringGetSelectTableName(stringsqlText){  
    6.   
  
  
  6. }  
    7.   
  
  
  7. //得到select语句中的where子句  
    8.   
  
  
  8. publicstringGetWhereClause(stringsqlText){  
    9.   
  
  
  9. }  
    10.   
  
  
  10. //得到查询条件中的字段名  
    11.   
  
  
  11. publicstringGetSelectField(stringsqlText){  
    12.   
  
  
  12. }  
    13.   
  
  
  13. //得到分片依据，返回Scity的值  
    14.   
  
  
  14. publicstringGetSelectCityValue(stringsqlText){  
    15.   
  
  
  15. }  
    16.   
  
  
  16. //设定select语句经解析后的格式  
    17.   
  
  
  17. publicArrayListSetSelectList(stringsqlText){  
    18.   
  
  
  18. }  
    19.   
  
  
  19. //如果没有分片信息，则向3个场地都发送命令  
    20.   
  
  
  20. publicArrayListSendToAllSite(stringsqlText){  
    21.   
  
  
  21. } 
    22.

第6章 结论

.NET远程处理框架提供的一项强大的技术，利用它可以使位于任何位置的应用程序互相通信，这些应用程序可能在同一台计算机上运行，也可能位于同一局域网中的不同计算机上，或者位于相隔万里的有巨大差异的网络中。

使用.NET Remoting技术结合ADO.Net能够高效、可靠地解决这两方面的问题。具体表现为，在C#中通过使用.Net远程处理框架能够方便地解决数据、命令远程传递问题；C#通过ADO.Net对数据库进行操作，使分布式数据库系统中对数据库的各种操作变得高效、可靠，同时易于解决数据一致性问题。

由于时间关系，程序中仍有部分bug，将在下一步继续完善，而且，还应进一步完善数据字典，使程序结构更加清晰，增强可扩充性。

新闻名称：.NET远程处理框架详解
URL分享：http://www.mswzjz.cn/qtweb/news21/354421.html

攀枝花网站建设、攀枝花网站运维推广公司-贝锐智能，是专注品牌与效果的网络营销公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 贝锐智能

贝锐智能技术为您推荐以下文章

商城网站知识

同城分类信息

成都发电机维修　　 　成都400电话　　 　艾瑞格衣柜　　 　成都小程序开发　　 　娃娃鱼鱼苗　　 　UI设计　　 　大吉雪茄　　 　成都广告设计公司　　 　视频运营　　 　云服务器　　 　企业邮箱　　 　名片印刷厂　　 　宣威网站建设　　 　谷歌优化排名　　 　网站运维托管　　 　电商网店　　 　品牌网站建设　　 　全网营销　　 　虚拟主机　　 　雅安机房托管