- 爱易网页
 
                        - 
                            C#教程
 
                        - 请问一下socket从服务器上获取数据表信息的全过程 
 
                         
                    
                    
                    日期:2014-05-18  浏览次数:21104 次 
                    
                        
                         请教一下socket从服务器上获取数据表信息的全过程
从连接到交互方式到关闭的。
简单说明一下,我省点学习时间,呵。下班前结贴
------解决方案--------------------
执行 sql 语句不行嘛 ?  
获取表的信息:  
conn.Open();  
string[] restrictions = new string[4];  
restrictions[1] = "dbo";  
DataTable table = conn.GetSchema("Tables", restrictions);  
conn.Close();  
返回的table是表的所有信息,而不仅仅是名字,可以通过如下语句查看这些信息:  
foreach (System.Data.DataRow row in table.Rows)  
{  
foreach (System.Data.DataColumn col in table.Columns)  
{  
Console.WriteLine("{0} = {1}", col.ColumnName, row[col]);  
}  
}  
要获取指定表的信息,关键是要设置数组restrictions的值。对于表而言,这个数组有如下的含义:  
Restriction[0]表示表所在的Catalog  
Restriction[1]表示表的所有者  
Restriction[2]表示表的名字  
Restriction[3]表示表的类型:  
上面的例子就获取了所有dbo拥有的表的信息。如果要获取所有的用户表,而非系统表,可用如下语句:  
conn.Open();  
string[] restrictions = new string[4];  
restrictions[3] = “BASE TABLE";  
DataTable table = conn.GetSchema("Tables", restrictions);  
conn.Close();  
参考 http://topic.csdn.net/t/20040412/18/2956410.html  建个存储过程
------解决方案--------------------
以下示例程序实现简单的Socket通信,可以开多个客户端。本机测试通过,未做联机测试。
Server:
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Collections;
  
namespace MySocketServer1
{
   public partial class Form1 : Form
   {
       private IPAddress serverIP = IPAddress.Parse("127.0.0.1");//以本机作测试
       private IPEndPoint serverFullAddr;//完整终端地址
       private Socket sock;
       private System.Timers.Timer myTimer;
       private ArrayList alSock;//当建立了多个连接时用于保存连接
  
       public Form1()
       {
           InitializeComponent();
       }
  
       private void btStart_Click(object sender, EventArgs e)
       {
           serverFullAddr = new IPEndPoint(serverIP, 1000);//取端口号1000
//构造Socket对象,套接字类型为“流套接字”,指定五元组中的协议元
           sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream,
ProtocolType.Tcp);  
//指定五元组中的本地二元,即本地主机地址和端口号
           sock.Bind(serverFullAddr);
//监听是否有连接传入,指定挂起的连接队列的最大值为20
           sock.Listen(20);
  
           alSock = new ArrayList();
  
//构造定时器,时间间隙为1秒,即每隔一秒执行一次accept()方法,以获取连接请求队列中//第一个挂起的连接请求
           myTimer =new System.Timers.Timer(1000);
           myTimer.Elapsed +=new System.Timers.ElapsedEventHandler(myTimer_Elapsed);
           myTimer.Enabled = true;
       }
  
       private void myTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
       {
           myTimer.Enabled = false;
//执行accept(),当挂起队列为空时将阻塞本线程,同时由于上一语句,定时器将停止,直//至有连接传入
           Socket acceptSock = sock.Accept();
//将accept()产生的Socket对象存入ArrayList
           alSock.Add(acceptSock);
// 构造Threading.Timer对象,这将导致程序另启线程。线程将执行回调函数,该委托限制//函数参数须为object型。Threading.Timer构造器的第二个参数即传入回调函数的参数;第//三个参数指定调用回调函数之前的延时,取0则立即启动;最后一个参数指定调用回调函数//的时间间隔,取0则只执行一次。
           System.Threading.Timer ti = new System.Threading.Timer(new  
TimerCallback(ReceiveMsg), acceptSock, 0, 0);
           myTimer.Enabled = true;
       }