C# 怎样才能实现客户端通过服务器端连接数据库服务器？？？
作者&投稿：那于 （若有异议请与网页底部的电邮联系）
不能与数据库连接的
Android客户端不能直接与服务器数据库连接。数据库是需要非常大的内存，安装之后有好几G，连接数据库要有一个像SQLServer里的webservice，这样的一个桥梁来间接访问。就是在服务器运行一个服务端程序，该服务端程序通过接收来自android客户端的指令，对数据库进行操作。
客户端的http请求可以通过 HttpClient类实现，在anddroid 4.0之后，客户端的网络请求已经不被允许在主线程中运行，所以还需注意另开启一个子线程进行网络请求。
扩展资料：
Android安全权限机制：
Android默认设置下，所有应用都没有权限对其他应用、系统或用户进行较大影响的操作。这其中包括读写用户隐私数据（联系人或电子邮件），读写其他应用文件，访问网络或阻止设备待机等。安装应用时，在检查程序签名提及的权限，且经过用户确认后，软件包安装器会给予应用权限。
下载一款Android应用通常会要求如下的权限：拨打电话、发送短信或彩信、修改/删除SD卡上的内容、读取联系人的信息、读取日程信的息，写入日程数据、读取电话状态或识别码、精确的（基于GPS）地理位置、模糊的（基于网络获取）地理位置、创建蓝牙连接、
还有对互联网的完全访问、查看网络状态，查看WiFi状态、避免手机待机、修改系统全局设置、读取同步设定、开机自启动、重启其他应用、终止运行中的应用、设定偏好应用、震动控制、拍摄图片等。
参考资料来源：百度百科——Android
其实服务器就相当于一个中介样
比如就像服务器在你本机上样，该怎样连接就怎么样连接
如果服务器不在你的本机上就把那个连接写成服务器的地址
例如：server=IP地址；user=用户名；password=密码；database=数据库
1.客户端与服务器连（用Socket通讯）
2.客户端向处服务器发送SQL语句，如搜索一个表的数据
3.服务器接到请求，执行SQL语句返回一个DataTable
4.服务器将这个DataTable进行序列化、并且压缩
5.服务器将【序列化和压缩】后的byte[] msg数组传给客户端
6.客户端收到byte[] msg数组先进行解压缩、和反序列化为DataTable
7.再将DataTable通过DataSet和SqlDataAdapter.Update(Table)存在SQL中
下面我只给一些关键的代码，我有实现过的
第一步.客户端==》连接服务器并通讯，主要是发送SQL给服务器返回一个DataTable表
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Xml;
using System.Xml.Serialization;
using System.IO;
using System.IO.Compression;
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 = IPAddress.Parse("116.25.83.127");
IPAddress local = IPAddress.Parse("127.0.0.1");//可改为远程IP地址
IPEndPoint iep = new IPEndPoint(local, 6060);
try
{
client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
client.Connect(iep);
}
catch (SocketException)
{
Console.WriteLine("无法连接到服务器!");
return ;
}
//输入exit，可以断开与服务器的连接
if (str == "")
{
return;
}
//发送SQL语句给服务器
client.Send(Encoding.Unicode.GetBytes(str));
//得到实际收到的字节总数
Int32 rec = client.Receive(buf);
Console.WriteLine(Encoding.ASCII.GetString(buf, 0, rec));
//接收服务器返回的数据
returnData = System.Text.Encoding.Unicode.GetString(buf,0,rec);
//将returnData解压缩后，再反序列化转成DataTable dt = DeserializerDataTable(Decompress(returnData));
Console.WriteLine("断开与服务器的连接......");
client.Close();
dataGridView1.DataSource = dt;
}
//将DataTable表反序列化
private DataTable DeserializerDataTable(string pXml)
{
StringReader strReader = new StringReader(pXml);
XmlReader xmlReader = XmlReader.Create(strReader);
XmlSerializer serializer = new XmlSerializer(typeof(DataTable));
DataTable dt = serializer.Deserialize(xmlReader) as DataTable;
return dt; }
//给服务器传SQL语句
private void buttonSearch_Click(object sender, EventArgs e)
{
string Sql = String.Format("Select top {0} * From Part Where CorpCode_='PT'", textBox1.Text.Trim()); ;
ClientTest(Sql);
}
#region 压缩和解压缩
public string Compress(string str)
{
byte[] buffer = Encoding.Unicode.GetBytes(str);
MemoryStream ms = new MemoryStream();
using (GZipStream zip = new GZipStream(ms, CompressionMode.Compress, true))
{
zip.Write(buffer, 0, buffer.Length);
}
ms.Position = 0;
MemoryStream outStream = new MemoryStream();
byte[] compressed = new byte[ms.Length];
ms.Read(compressed, 0, compressed.Length);
byte[] gzBuffer = new byte[compressed.Length + 4];
System.Buffer.BlockCopy(compressed, 0, gzBuffer, 4, compressed.Length);
System.Buffer.BlockCopy(BitConverter.GetBytes(buffer.Length), 0, gzBuffer, 0, 4);
return Convert.ToBase64String(gzBuffer);
}
//解压缩
public string Decompress(string compressedText)
{
byte[] gzBuffer = Convert.FromBase64String(compressedText);
using (MemoryStream ms = new MemoryStream())
{
int msgLength = BitConverter.ToInt32(gzBuffer, 0);
ms.Write(gzBuffer, 4, gzBuffer.Length - 4);
byte[] buffer = new byte[msgLength];
ms.Position = 0;
using (GZipStream zip = new GZipStream(ms, CompressionMode.Decompress))
{
zip.Read(buffer, 0, buffer.Length);
}
return Encoding.Unicode.GetString(buffer);
}
}
#endregion
}
}
第二步.服务器收到SQL语句执行，并回传一个表给客户端
服务器接到请求，执行SQL语句返回一个DataTable
服务器将这个DataTable进行序列化、并且压缩
服务器将【序列化和压缩】后的byte[] msg数组传给客户端
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets; //可以使用套接字
using System.Threading; //可以使用多线程
using System.Data.SqlClient;
using System.Xml;
using System.Xml.Serialization;
using System.IO;
using System.IO.Compression;
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 = Dns.GetHostName();
IPHostEntry host = Dns.GetHostByName(name);
IPAddress id= host.AddressList[0];
* */
//IPAddress local = IPAddress.Parse("192.168.0.100");
IPEndPoint iep = new IPEndPoint(IPAddress.Any, 6060);
server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
// 将套接字与本地终结点绑定
server.Bind(iep);
//在本地13000端口号上进行监听
server.Listen(10);
while (true)
{
// 得到包含客户端信息的套接字
client = server.Accept();
//创建消息服务线程对象ClientService方法委托给线程
Thread newthread = new Thread(new ThreadStart(ClientService));
// 启动消息服务线程
newthread.Start();
}
}
private Int32 i;
private void ClientService()
{
Socket s = client;
String data = null;
String returnData = null;
byte[] bytes = new byte[1024];
while ((i = s.Receive(bytes)) != 0)
{
//接收客户端的SQL
data = System.Text.Encoding.Unicode.GetString(bytes, 0, i);
//将接到的String 执行SQL返回表
DBAccess obj = new DBAccess(); //专门传给SQL的类相当于DBHELP
DataTable dt = obj.FillData(data, "TEST", 1);//执行SQL返回表
//将返回的表转为String,并将returnData压缩
returnData = obj.Compress(obj.SerializeDataTableXml(dt));
byte[] msg = System.Text.Encoding.Unicode.GetBytes(returnData);
// 发送数据表给客户端 s.Send(msg);
if ((i = s.Receive(bytes)) == 0)
continue;
}
//关闭套接字
s.Close();
}
}
//DBAccess的部份代码
class DBAccess
{
#region DataTable序列化与反序列化
public string SerializeDataTableXml(DataTable dt)
{
StringBuilder sb = new StringBuilder();
XmlWriter writer = XmlWriter.Create(sb);
XmlSerializer serializer = new XmlSerializer(typeof(DataTable));
serializer.Serialize(writer, dt);
writer.Close();
return sb.ToString(); }
public DataTable DeserializerDataTable(string pXml)
{
StringReader strReader = new StringReader(pXml);
XmlReader xmlReader = XmlReader.Create(strReader);
XmlSerializer serializer = new XmlSerializer(typeof(DataTable));
DataTable dt = serializer.Deserialize(xmlReader) as DataTable;
return dt; }
#endregion
#region 压缩和解压缩
public string Compress(string str)
{
byte[] buffer = Encoding.Unicode.GetBytes(str);
MemoryStream ms = new MemoryStream();
using (GZipStream zip = new GZipStream(ms, CompressionMode.Compress, true))
{
zip.Write(buffer, 0, buffer.Length);
}
ms.Position = 0;
MemoryStream outStream = new MemoryStream();
byte[] compressed = new byte[ms.Length];
ms.Read(compressed, 0, compressed.Length);
byte[] gzBuffer = new byte[compressed.Length + 4];
System.Buffer.BlockCopy(compressed, 0, gzBuffer, 4, compressed.Length);
System.Buffer.BlockCopy(BitConverter.GetBytes(buffer.Length), 0, gzBuffer, 0, 4);
return Convert.ToBase64String(gzBuffer);
}
public string Decompress(string compressedText)
{
byte[] gzBuffer = Convert.FromBase64String(compressedText);
using (MemoryStream ms = new MemoryStream())
{
int msgLength = BitConverter.ToInt32(gzBuffer, 0);
ms.Write(gzBuffer, 4, gzBuffer.Length - 4);
byte[] buffer = new byte[msgLength];
ms.Position = 0;
using (GZipStream zip = new GZipStream(ms, CompressionMode.Decompress))
{
zip.Read(buffer, 0, buffer.Length);
}
return Encoding.Unicode.GetString(buffer);
}
}
#endregion
}
第三步.调用DataSet和SqlDataAdapter.Update(Table)存在SQL中，这个是传入一个DataGridView ，可在客户端中使用保存（部份代码，没有连接SQL数据库的）
#region 公共保存DataGridView
public bool DataGridViewSave(DataTable table,string tableName,string CorpCode)
{
string Sql = String.Format("Select Top 0 * From {0} Where CorpCode_='{1}' ", tableName, CorpCode);
SqlDataAdapter sda = new SqlDataAdapter(this.CreateCommand(Sql, null, 1));
SqlCommandBuilder scb = new SqlCommandBuilder(sda);
sda.Update(table);
this.Close();
return true;
}
#endregion
你这样的就输入分布式开发，现在流行的主要就是WCF,WebService,Remoting 服务端给出接口，客户端连接到服务器后，只需要调用服务器的方法，具体的业务操作，数据操作都是服务器来执行，如果初学建议去看下WebService相关知识，应该很容易上手
那就是服务器接口客户端的sql和参数，然后服务端执行sql，把得到的结果序列化后发送出去嘛
或者使用wcf功能
08 或之后的用wcf
像05的webservice、remoting
实例网上找找吧
最简单的是使用webservice
第怜派奇： 服务器只是安装数据库就行,客户端需要写一个连接服务器的参数即可.
宁武县17625197809： C#客户端与客户端如何通过服务器通信 - ？
第怜派奇： 看题主是打算 A、B 之间不直接通信,而是通过服务器来中转,是这样吧?题主这两种理解都是正确的.第一种无非是服务器多了一步存储发送的消息的过程(这就是所谓的“云端聊天记录”了).不知题主打算采用何种协议,亦或是底层的 Socket 方式来通信?如果 TCP 协议的话相对简单一些,A、B 只需要分别与服务器维持一个 TCP 连接即可.
宁武县17625197809： c# 如何实现客户端与服务器互传文件? - ？
第怜派奇： 如果你想写ftp 服务端与客户端的话,那要先熟悉一下ftp 协议,见rfc959.不知道你的目的是什么,如果不是出于学习的目录的话,从你的提问来看,不建议你去写ftp服务端,这可是比较大的一项工程.如果你想学习的话,网上可以找到开源的FTP服务器代码,可以拿来学习的.
宁武县17625197809： C# 如何实现服务端发送对象到客户端 - ？
第怜派奇： 显然不是socket,既然选用C#当然Remoting才是王道,首先需要一个interface(或者叫抽象类?)作为服务端和客户端的通讯协议.然后server完全实现这个接口类,客户端就可以直接调用对应的方法.服务端缓存所有客户对象,然后就可以根...
宁武县17625197809： C#怎样实现客户端与服务器,服务器与数据库的通信 - ？
第怜派奇： 其实服务器就相当于一个中介样 比如就像服务器在你本机上样,该怎样连接就怎么样连接 如果服务器不在你的本机上就把那个连接写成服务器的地址 例如:server=IP地址;user=用户名;password=密码;database=数据库
宁武县17625197809： 客户端与服务器同步用C#实现 - ？
第怜派奇： 同步什么呢?给的需求太飘渺了,如果是数据库数据同步,可以交给数据库去执行,如果是页面上数据同步刷新的话可以采用AJAX技术
宁武县17625197809： C#实现服务器和客户端通信问题 - ？
第怜派奇： import java.net.*; import java.io.*; public class Server { public static void main(String[] args) throws IOException { String s = ＂＂;//用stringbuffer试试 String s1 = ＂＂; ServerSocket server = new ServerSocket(60000); System.out.println(＂可以开...
宁武县17625197809： 【急】在C#项目中客户端与服务器端连接 用什么技术? - ？
第怜派奇： 1. 可以用UDP,tcp,socket...2. 一大堆..oledb, gui+, udp, tcp, socket, sql =====
宁武县17625197809： C#中服务器与客户端怎么连续通信啊？
第怜派奇： 创建协议,给定IP,端口,开始监听,无线循环(死循环)监听客户端发送过来的数据,在进行解析,流程就是这样
宁武县17625197809： 用C#怎么实现客户端和服务器的交互 - ？
第怜派奇： CS架构可以用Socket来进行交互百度C# 套接字编程当然也可以用数据库做中间者进行交互
