一起谈.NET技术，.NET远程处理框架详解

　　第1章系统总体结构

　　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){

18. //设定select语句经解析后的格式

19. publicArrayListSetSelectList(stringsqlText){

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){

7. //如果表名是Supplier,则根据city值设定向哪个场地发送命令

8. publicArrayListSetInsertSite(stringsqlText){

9. }

10. //生成解析后的insert命令列表

11. publicArrayListSetInsertList(stringsqlText){

12. }

　　Delete 操作——

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

　　Select 操作——

1. //得到sql语句的类型

2. publicstringGetSqlType(stringsqlText)//typeofSQLstatements{

4. //得到select语句要查询的表名

5. publicstringGetSelectTableName(stringsqlText){

7. //得到select语句中的where子句

8. publicstringGetWhereClause(stringsqlText){

10. //得到查询条件中的字段名

11. publicstringGetSelectField(stringsqlText){

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，将在下一步继续完善，而且，还应进一步完善数据字典，使程序结构更加清晰，增强可扩充性。