C# 怎样才能实现客户端通过服务器端连接数据库服务器？？？

可以处理的，步骤为：
1客户端与服务器连（用Socket通讯）
2客户端向处服务器发送SQL语句，如搜索一个表的数据
3服务器接到请求，执行SQL语句返回一个DataTable
4服务器将这个DataTable进行序列化、并且压缩
5服务器将序列化和压缩后的byte[] msg数组传给客户端
6客户端收到byte[] msg数组先进行解压缩、和反序列化为DataTable
7再将DataTable通过DataSet和SqlDataAdapterUpdate(Table)存在SQL中
下面我只给一些关键的代码，我有实现过的
第一步客户端==》连接服务器并通讯，主要是发送SQL给服务器返回一个DataTable表
using System;
using SystemCollectionsGeneric;
using SystemComponentModel;
using SystemData;
using SystemDrawing;
using SystemLinq;
using SystemText;
using SystemWindowsForms;
using SystemNet;
using SystemNetSockets;
using SystemXml;
using SystemXmlSerialization;
using SystemIO;
using SystemIOCompression;
namespace Client
{
public partial class FormClient : Form
{
DataTable dt;
public FormClient()
{
InitializeComponent();
}
private void ClientTest(string str)
{
Socket client;
String returnData;
byte[] buf = new byte[9991024]; //此处可能有些问题
//IPAddress local = IPAddressParse("1162583127");
IPAddress local = IPAddressParse("127001");//可改为远程IP地址
IPEndPoint iep = new IPEndPoint(local, 6060);
try
{
client = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp);
clientConnect(iep);
}
catch (SocketException)
{
ConsoleWriteLine("无法连接到服务器!");
return ;
}
//输入exit，可以断开与服务器的连接
if (str == "")
{
return;
}
//发送SQL语句给服务器
clientSend(EncodingUnicodeGetBytes(str));
//得到实际收到的字节总数
Int32 rec = clientReceive(buf);
ConsoleWriteLine(EncodingASCIIGetString(buf, 0, rec));
//接收服务器返回的数据
returnData = SystemTextEncodingUnicodeGetString(buf,0,rec);
//将returnData解压缩后，再反序列化转成DataTable dt = DeserializerDataTable(Decompress(returnData));
ConsoleWriteLine("断开与服务器的连接");
clientClose();
dataGridView1DataSource = dt;
}
//将DataTable表反序列化
private DataTable DeserializerDataTable(string pXml)
{
StringReader strReader = new StringReader(pXml);
XmlReader xmlReader = XmlReaderCreate(strReader);
XmlSerializer serializer = new XmlSerializer(typeof(DataTable));
DataTable dt = serializerDeserialize(xmlReader) as DataTable;
return dt; }
//给服务器传SQL语句
private void buttonSearch_Click(object sender, EventArgs e)
{
string Sql = StringFormat("Select top {0} From Part Where CorpCode_='PT'", textBox1TextTrim()); ;
ClientTest(Sql);
}
#region 压缩和解压缩
public string Compress(string str)
{
byte[] buffer = EncodingUnicodeGetBytes(str);
MemoryStream ms = new MemoryStream();
using (GZipStream zip = new GZipStream(ms, CompressionModeCompress, true))
{
zipWrite(buffer, 0, bufferLength);
}
msPosition = 0;
MemoryStream outStream = new MemoryStream();
byte[] compressed = new byte[msLength];
msRead(compressed, 0, compressedLength);
byte[] gzBuffer = new byte[compressedLength + 4];
SystemBufferBlockCopy(compressed, 0, gzBuffer, 4, compressedLength);
SystemBufferBlockCopy(BitConverterGetBytes(bufferLength), 0, gzBuffer, 0, 4);
return ConvertToBase64String(gzBuffer);
}
//解压缩
public string Decompress(string compressedText)
{
byte[] gzBuffer = ConvertFromBase64String(compressedText);
using (MemoryStream ms = new MemoryStream())
{
int msgLength = BitConverterToInt32(gzBuffer, 0);
msWrite(gzBuffer, 4, gzBufferLength - 4);
byte[] buffer = new byte[msgLength];
msPosition = 0;
using (GZipStream zip = new GZipStream(ms, CompressionModeDecompress))
{
zipRead(buffer, 0, bufferLength);
}
return EncodingUnicodeGetString(buffer);
}
}
#endregion
}
}
第二步服务器收到SQL语句执行，并回传一个表给客户端
服务器接到请求，执行SQL语句返回一个DataTable
服务器将这个DataTable进行序列化、并且压缩
服务器将序列化和压缩后的byte[] msg数组传给客户端
using System;
using SystemCollectionsGeneric;
using SystemComponentModel;
using SystemData;
using SystemDrawing;
using SystemLinq;
using SystemText;
using SystemWindowsForms;
using SystemNet;
using SystemNetSockets; //可以使用套接字
using SystemThreading; //可以使用多线程
using SystemDataSqlClient;
using SystemXml;
using SystemXmlSerialization;
using SystemIO;
using SystemIOCompression;
namespace AppServer
{
public partial class FormApp : Form
{
public FormApp()
{
InitializeComponent();
}
private void FormApp_Load(object sender, EventArgs e)
{
// AppService instance = new AppService();
}
private void buttonStartService_Click(object sender, EventArgs e)
{
AppService();
}
private Socket server;
private Socket client;
private void AppService()
{
/
//本机IP
string name = DnsGetHostName();
IPHostEntry host = DnsGetHostByName(name);
IPAddress id= hostAddressList[0];
/
//IPAddress local = IPAddressParse("1921680100");
IPEndPoint iep = new IPEndPoint(IPAddressAny, 6060);
server = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp);
// 将套接字与本地终结点绑定
serverBind(iep);
//在本地13000端口号上进行监听
serverListen(10);
while (true)
{
// 得到包含客户端信息的套接字
client = serverAccept();
//创建消息服务线程对象ClientService方法委托给线程
Thread newthread = new Thread(new ThreadStart(ClientService));
// 启动消息服务线程
newthreadStart();
}
}
private Int32 i;
private void ClientService()
{
Socket s = client;
String data = null;
String returnData = null;
byte[] bytes = new byte[1024];
while ((i = sReceive(bytes)) != 0)
{
//接收客户端的SQL
data = SystemTextEncodingUnicodeGetString(bytes, 0, i);
//将接到的String 执行SQL返回表
DBAccess obj = new DBAccess(); //专门传给SQL的类相当于DBHELP
DataTable dt = objFillData(data, "TEST", 1);//执行SQL返回表
//将返回的表转为String,并将returnData压缩
returnData = objCompress(objSerializeDataTableXml(dt));
byte[] msg = SystemTextEncodingUnicodeGetBytes(returnData);
// 发送数据表给客户端 sSend(msg);
if ((i = sReceive(bytes)) == 0)
continue;
}
//关闭套接字
sClose();
}
}
//DBAccess的部份代码
class DBAccess
{
#region DataTable序列化与反序列化
public string SerializeDataTableXml(DataTable dt)
{
StringBuilder sb = new StringBuilder();
XmlWriter writer = XmlWriterCreate(sb);
XmlSerializer serializer = new XmlSerializer(typeof(DataTable));
serializerSerialize(writer, dt);
writerClose();
return sbToString(); }
public DataTable DeserializerDataTable(string pXml)
{
StringReader strReader = new StringReader(pXml);
XmlReader xmlReader = XmlReaderCreate(strReader);
XmlSerializer serializer = new XmlSerializer(typeof(DataTable));
DataTable dt = serializerDeserialize(xmlReader) as DataTable;
return dt; }
#endregion
#region 压缩和解压缩
public string Compress(string str)
{
byte[] buffer = EncodingUnicodeGetBytes(str);
MemoryStream ms = new MemoryStream();
using (GZipStream zip = new GZipStream(ms, CompressionModeCompress, true))
{
zipWrite(buffer, 0, bufferLength);
}
msPosition = 0;
MemoryStream outStream = new MemoryStream();
byte[] compressed = new byte[msLength];
msRead(compressed, 0, compressedLength);
byte[] gzBuffer = new byte[compressedLength + 4];
SystemBufferBlockCopy(compressed, 0, gzBuffer, 4, compressedLength);
SystemBufferBlockCopy(BitConverterGetBytes(bufferLength), 0, gzBuffer, 0, 4);
return ConvertToBase64String(gzBuffer);
}
public string Decompress(string compressedText)
{
byte[] gzBuffer = ConvertFromBase64String(compressedText);
using (MemoryStream ms = new MemoryStream())
{
int msgLength = BitConverterToInt32(gzBuffer, 0);
msWrite(gzBuffer, 4, gzBufferLength - 4);
byte[] buffer = new byte[msgLength];
msPosition = 0;
using (GZipStream zip = new GZipStream(ms, CompressionModeDecompress))
{
zipRead(buffer, 0, bufferLength);
}
return EncodingUnicodeGetString(buffer);
}
}
#endregion
}
第三步调用DataSet和SqlDataAdapterUpdate(Table)存在SQL中，这个是传入一个DataGridView ，可在客户端中使用保存（部份代码，没有连接SQL数据库的）
#region 公共保存DataGridView
public bool DataGridViewSave(DataTable table,string tableName,string CorpCode)
{
string Sql = StringFormat("Select Top 0 From {0} Where CorpCode_='{1}' ", tableName, CorpCode);
SqlDataAdapter sda = new SqlDataAdapter(thisCreateCommand(Sql, null, 1));
SqlCommandBuilder scb = new SqlCommandBuilder(sda);
sdaUpdate(table);
thisClose();
return true;
}
#endregion

NetworkStreamToString()这个方法是用来显示NetworkStream完整类名称的~其实就是ObjectToString()~
你要获得NetworkStream的内容自然要读取数据留里的信息然后转码~
假设你用的是ASCII码传输
const int bufferSize = 1024;
byte[] buffer = new byte[bufferSize];
int readBytes = 0;
try
{
readBytes = NetStreamRead(buffer, 0, bufferSize);
string str = EncodingASCIIGetString(buffer)Substring(0, readBytes);
MessageBoxShow(str);
}

这。。。。。。。。应该不是随便回答的

服务端叫大S，作内应
客户端叫大C，作外和

要干这件事（让我描述的像偷鸡摸狗），首先要有约定也就是协议
(1)等待
S一边干活一边等C的暗号汪汪
(2)暗号
汪汪，有暗号，你再喵喵叫几下！不行？暗号不对你不是C
汪汪，有暗号，你再喵喵叫几下！喵喵！暗号对了你就是C，握爪成功
(3)交易
S把C的货交给他
(4)断后
如果是偷(黑客)，就清蛛丝马迹
如果是光明正大的，就记录在案
以上是大概流程，细节当然你说了算

可以获取服务器端响应到客户端数据的是客户端所发送的请求。当客户端向服务器发送请求时，服务器会对请求进行处理，并返回相应的数据给客户端。客户端可以在接收到服务器响应后，将其解析并呈现给用户或进一步处理。通常，这个过程是通过使用网络协议（如>