《[计算机]Csocket通讯.doc》由会员分享，可在线阅读，更多相关《[计算机]Csocket通讯.doc（13页珍藏版）》请在三一办公上搜索。
1、C# 2.0 套接字编程实例初探时间:2009-06-03 20:24:58来源:网络 作者:未知 点击:87次 首先从原理上解释一下采用Socket接口的网络通讯，这里以最常用的C/S模式作为范例，首先，服务端有一个进程（或多个进程）在指定的端口等待客户来连接，服务程序等待客户的连接信息，一旦连接上之后，就可以按设计的数据交换方法和格首先从原理上解释一下采用Socket接口的网络通讯，这里以最常用的C/S模式作为范例，首先，服务端有一个进程（或多个进程）在指定的端口等待客户来连接，服务程序等待客户的连接信息，一旦连接上之后，就可以按设计的数据交换方法和格式进行数据传输。客户端在需要的时刻发出
2、向服务端的连接请求。这里为了便于理解，提到了一些调用及其大致的功能。使用socket调用后，仅产生了一个可以使用的socket描述符，这时还不能进行通信，还要使用其他的调用，以使得socket所指的结构中使用的信息被填写完。在使用TCP协议时，一般服务端进程先使用socket调用得到一个描述符，然后使用bind调用将一个名字与socket描述符连接起来，对于Internet域就是将Internet地址联编到socket。之后，服务端使用listen调用指出等待服务请求队列的长度。然后就可以使用accept调用等待客户端发起连接，一般是阻塞等待连接，一旦有客户端发出连接，accept返回客户的地
3、址信息，并返回一个新的socket描述符，该描述符与原先的socket有相同的特性，这时服务端就可以使用这个新的socket进行读写操作了。一般服务端可能在accept返回后创建一个新的进程进行与客户的通信，父进程则再到accept调用处等待另一个连接。客户端进程一般先使用socket调用得到一个socket描述符，然后使用connect向指定的服务器上的指定端口发起连接，一旦连接成功返回，就说明已经建立了与服务器的连接，这时就可以通过socket描述符进行读写操作了。.NetFrameWork为Socket通讯提供了System.Net.Socket命名空间，在这个命名空间里面有以下几个常用
4、的重要类分别是:Socket类 这个低层的类用于管理连接，WebRequest，TcpClient和UdpClient在内部使用这个类。NetworkStream类 这个类是从Stream派生出来的，它表示来自网络的数据流TcpClient类 允许创建和使用TCP连接TcpListener类 允许监听传入的TCP连接请求UdpClient类 用于UDP客户创建连接(UDP是另外一种TCP协议，但没有得到广泛的使用，主要用于本地网络)下面我们来看一个基于Socket的双机通信代码的C#版本首先创建Socket对象的实例，这可以通过Socket类的构造方法来实现：public Socket(Add
5、ressFamily addressFamily,SocketType socketType,ProtocolType protocolType); 其中，addressFamily 参数指定 Socket 使用的寻址方案，socketType 参数指定 Socket 的类型，protocolType 参数指定 Socket 使用的协议。 下面的示例语句创建一个 Socket，它可用于在基于 TCP/IP 的网络（如 Internet）上通讯。Socket temp = new Socket(AddressFamily.InterNetwork, SocketType.Stream, Prot
6、ocolType.Tcp); 若要使用 UDP 而不是 TCP，需要更改协议类型，如下面的示例所示： Socket temp = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); 一旦创建 Socket，在客户端，你将可以通过Connect方法连接到指定的服务器（你可以在Connect方法前Bind端口，就是以指定的端口发起连接，如果不事先Bind端口号的话，系统会默认在1024到5000随机绑定一个端口号），并通过Send方法向远程服务器发送数据，而后可以通过Receive从服务端接收数据；
7、而在服务器端，你需要使用Bind方法绑定所指定的接口使Socket与一个本地终结点相联，并通过Listen方法侦听该接口上的请求，当侦听到用户端的连接时，调用Accept完成连接的操作，创建新的Socket以处理传入的连接请求。使用完 Socket 后，使用 Close 方法关闭 Socket。 可以看出，以上许多方法包含EndPoint类型的参数，在Internet中，TCP/IP 使用一个网络地址和一个服务端口号来唯一标识设备。网络地址标识网络上的特定设备；端口号标识要连接到的该设备上的特定服务。网络地址和服务端口的组合称为终结点，在 .NET 框架中正是由 EndPoint 类表示这个终
8、结点，它提供表示网络资源或服务的抽象，用以标志网络地址等信息。.Net同时也为每个受支持的地址族定义了 EndPoint 的子代；对于 IP 地址族，该类为 IPEndPoint。IPEndPoint 类包含应用程序连接到主机上的服务所需的主机和端口信息，通过组合服务的主机IP地址和端口号，IPEndPoint 类形成到服务的连接点。用到IPEndPoint类的时候就不可避免地涉及到计算机IP地址，System.Net命名空间中有两种类可以得到IP地址实例： IPAddress类：IPAddress 类包含计算机在 IP 网络上的地址。其Parse方法可将 IP 地址字符串转换为 IPAddr
9、ess 实例。下面的语句创建一个 IPAddress 实例： IPAddress myIP = IPAddress.Parse(192.168.0.1); 需要知道的是：Socket 类支持两种基本模式：同步和异步。其区别在于：在同步模式中，按块传输，对执行网络操作的函数（如 Send 和 Receive）的调用一直等到所有内容传送操作完成后才将控制返回给调用程序。在异步模式中，是按位传输，需要指定发送的开始和结束。同步模式是最常用的模式，我们这里的例子也是使用同步模式。下面看一个完整的例子，client向server发送一段测试字符串，server接收并显示出来，给予client成功响应。/
10、client端using System;using System.Text;using System.IO;using System.Net;using System.Net.Sockets;namespace socketsampleclass Class1static void Main()tryint port = 2000;string host = 127.0.0.1;IPAddress ip = IPAddress.Parse(host);IPEndPoint ipe = new IPEndPoint(ip, port);/把ip和端口转化为IPEndPoint实例Socket c
11、 = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);/创建一个SocketConsole.WriteLine(Conneting.);c.Connect(ipe);/连接到服务器string sendStr = hello!This is a socket test;byte bs = Encoding.ASCII.GetBytes(sendStr);Console.WriteLine(Send Message);c.Send(bs, bs.Length, 0);/发送测试信息string
12、 recvStr = ;byte recvBytes = new byte1024;int bytes;bytes = c.Receive(recvBytes, recvBytes.Length, 0);/从服务器端接受返回信息recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);Console.WriteLine(Client Get Message:0, recvStr);/显示服务器返回信息c.Close();catch (ArgumentNullException e)Console.WriteLine(ArgumentNul
13、lException: 0, e);catch (SocketException e)Console.WriteLine(SocketException: 0, e);Console.WriteLine(Press Enter to Exit);Console.ReadLine(); /server端using System;using System.Text;using System.IO;using System.Net;using System.Net.Sockets;namespace Project1class Class2static void Main()tryint port
14、= 2000;string host = 127.0.0.1;IPAddress ip = IPAddress.Parse(host);IPEndPoint ipe = new IPEndPoint(ip, port);Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);/创建一个Socket类s.Bind(ipe);/绑定2000端口s.Listen(0);/开始监听Console.WriteLine(Wait for connect);Socket temp = s.A
15、ccept();/为新建连接创建新的Socket。Console.WriteLine(Get a connect);string recvStr = ;byte recvBytes = new byte1024;int bytes;bytes = temp.Receive(recvBytes, recvBytes.Length, 0);/从客户端接受信息recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);Console.WriteLine(Server Get Message:0,recvStr);/把客户端传来的信息显示出来str
16、ing sendStr = Ok!Client Send Message Sucessful!;byte bs = Encoding.ASCII.GetBytes(sendStr);temp.Send(bs, bs.Length, 0);/返回客户端成功信息temp.Close();s.Close();catch (ArgumentNullException e)Console.WriteLine(ArgumentNullException: 0, e);catch (SocketException e)Console.WriteLine(SocketException: 0, e);Cons
17、ole.WriteLine(Press Enter to Exit);Console.ReadLine();上面的例子是用的Socket类，System.Net.Socket命名空间还提供了两个抽象高级类TCPClient和UDPClient和用于通讯流处理的NetWorkStream,让我们看下例子客户端TcpClient tcpClient=new TcpCLient(主机IP,端口号);NetworkStream ns=tcp.Client.GetStream();服务端TcpListener tcpListener=new TcpListener(监听端口);tcpListener.S
18、tart();TcpClient tcpClient=tcpListener.AcceptTcpClient();NetworkStream ns=tcpClient.GetStream();服务端用TcpListener监听,然后把连接的对象实例化为一个TcpClient,调用TcpClient.GetStream()方法,返回网络流实例化为一个NetworlStream流,下面就是用流的方法进行Send,Receive如果是UdpClient的话,就直接UdpClient实例化,然后调用UdpClient的Send和Receive方法,需要注意的事,UdpClient没有返回网络流的方法,
19、就是说没有GetStream方法,所以无法流化,而且使用Udp通信的时候,不要服务器监听。现在我们大致了解了.Net Socket通信的流程，下面我们来作一个稍微复杂点的程序，一个广播式的C/S聊天程序。客户端设计需要一个1个ListBox，用于显示聊天内容，一个TextBox输入你要说的话，一个Button发送留言，一个Button建立连接。点击建立连接的Button后出来一个对话框，提示输入连接服务器的IP，端口，和你的昵称，启动一个接受线程，负责接受从服务器传来的信息并显示在ListBox上面。服务器端2个Button，一个启动服务，一个T掉已建立连接的客户端，一个ListBox显示连接
20、上的客户端的Ip和端口。比较重要的地方是字符串编码的问题，需要先把需要传送的字符串按照UTF8编码，然后接受的时候再还原成为GB2312，不然中文显示会是乱码。还有一个就是接收线程，我这里简单写成一个While(ture)循环，不断判断是否有信息流入，有就接收，并显示在ListBox上，这里有问题，在.Net2.0里面，交错线程修改窗体空间属性的时候会引发一个异常，不可以直接修改，需要定义一个委托来修改。 当客户端需要断开连接的时候，比如点击窗体右上角的XX，就需要定义一个this.FormClosing += new System.Windows.Forms.FormClosingEvent
21、Handler(this.Closing);（.Net2.0是FormClosing系统事件），在Closing()函数里面，发送Close字符给服务端，服务器判断循环判断所有的连接上的客户端传来的信息，如果是以Close开头，断开与其的连接。看到这里，读者就会问了，如果我在聊天窗口输入Close是不是也断开连接呢？不是的，在聊天窗口输入的信息传给服务器的时候开头都要加上Ip信息和昵称，所以不会冲突。C#数据库连接（4个例子）时间:2010-06-07 16:18:08来源:网络 作者:未知 点击:454次 1.C#连接连接AccessusingSystem.Data;1.C#连接连接Acce
22、ssusing System.Data; using System.Data.OleDb; string strConnection=Provider=Microsoft.Jet.OleDb.4.0; strConnection +=Data Source=C:BegASPNETNorthwind.mdb; OleDbConnection objConnection=new OleDbConnection(strConnection); objConnection.Open(); objConnection.Close(); 解释:连接Access数据库需要导入额外的命名空间,所以有了最前面的
23、两条using命令,这是必不可少的!strConnection这个变量里存放的是连接数据库所需要的连接字符串,他指定了要使用的数据提供者和要使用的数据源.Provider=Microsoft.Jet.OleDb.4.0;是指数据提供者,这里使用的是Microsoft Jet引擎,也就是Access中的数据引擎,就是靠这个和Access的数据库连接的.Data Source=C:BegASPNETNorthwind.mdb是指明数据源的位置,他的标准形式是Data Source=MyDrive:MyPathMyFile.MDB.PS:1. =后面的符号是防止将后面字符串中的解析为转义字符.2.如
24、果要连接的数据库文件和当前文件在同一个目录下,还可以使用如下的方法连接:strConnection =Data Source=;strConnection +=MapPath(Northwind.mdb);这样就可以省得你写一大堆东西了!3.要注意连接字符串中的参数之间要用分号来分隔.OleDbConnection objConnection=new OleDbConnection(strConnection);这一句是利用定义好的连接字符串来建立了一个链接对象,以后对数据库的操作我们都要和这个对象打交道.objConnection.Open();这用来打开连接.至此,与Access数据库的连
25、接完成.2.C#连接SQL Serverusing System.Data; using System.Data.SqlClient; /.string strConnection=user id=sa;password=; strConnection =initial catalog=Northwind;Server=YourSQLServer; strConnection +=Connect Timeout=30; SqlConnection objConnection=new SqlConnection(strConnection); /.objConnection.Open(); ob
26、jConnection.Close(); /.解释:连接SQL Server数据库的机制与连接Access的机制没有什么太大的区别,只是改变了Connection对象和连接字符串中的不同参数.首先,连接SQL Server使用的命名空间不是System.Data.OleDb,而是System.Data.SqlClient.其次就是他的连接字符串了,我们一个一个参数来介绍(注意:参数间用分号分隔):user id=sa:连接数据库的验证用户名为sa.他还有一个别名uid,所以这句我们还可以写成uid=sa.password=:连接数据库的验证密码为空.他的别名为pwd,所以我们可以写为pwd=.
27、这里注意,你的SQL Server必须已经设置了需要用户名和密码来登录,否则不能用这样的方式来登录.如果你的SQL Server设置为Windows登录,那么在这里就不需要使用user id和password这样的方式来登录,而需要使用Trusted_Connection=SSPI来进行登录.initial catalog=Northwind:使用的数据源为Northwind这个数据库.他的别名为Database,本句可以写成Database=Northwind.Server=YourSQLServer:使用名为YourSQLServer的服务器.他的别名为Data Source,Addres
28、s,Addr.如果使用的是本地数据库且定义了实例名,则可以写为Server=(local)实例名;如果是远程服务器,则将(local)替换为远程服务器的名称或IP地址.Connect Timeout=30:连接超时时间为30秒.在这里,建立连接对象用的构造函数为:SqlConnection.using System.Data.OracleClient; using System.Data; /在窗体上添加一个按钮，叫Button1，双击Button1，输入以下代码 private void Button1_Click(object sender, System.EventArgs e) str
29、ing ConnectionString=Data Source=sky;user=system;password=manager;/写连接串 OracleConnection conn=new OracleConnection(ConnectionString);/创建一个新连接 try conn.Open(); OracleCommand cmd=conn.CreateCommand(); cmd.CommandText=select * from MyTable;/在这儿写sql语句 OracleDataReader odr=cmd.ExecuteReader();/创建一个Oracle
30、DateReader对象 while(odr.Read()/读取数据，如果odr.Read()返回为false的话，就说明到记录集的尾部了 Response.Write(odr.GetOracleString(1).ToString();/输出字段1，这个数是字段索引，具体怎么使用字段名还有待研究 odr.Close(); catch(Exception ee) Response.Write(ee.Message); /如果有错误，输出错误信息 finally conn.Close(); /关闭连接 using MySQLDriverCS; / 建立数据库连接 MySQLConnection
31、DBConn; DBConn = new MySQLConnection(new MySQLConnectionString(localhost,mysql,root,3306).AsString); DBConn.Open(); / 执行查询语句 MySQLCommand DBComm; DBComm = new MySQLCommand(select Host,User from user,DBConn); / 读取数据 MySQLDataReader DBReader = DBComm.ExecuteReaderEx(); / 显示数据 try while (DBReader.Read(
32、) Console.WriteLine(Host = 0 and User = 1, DBReader.GetString(0),DBReader.GetString(1); finally DBReader.Close(); DBConn.Close(); /关闭数据库连接 DBConn.Close(); java环境变量配置时间:2010-02-08 18:11:56来源:网络 作者:未知 点击:18988次 windowsxp下配置JDK环境变量：1.安装JDK，安装过程中可以自定义安装目录等信息，例如我们选择安装目录为D:javajdk1.5.0_08；windows xp下配置JDK
33、环境变量： 1.安装JDK，安装过程中可以自定义安装目录等信息，例如我们选择安装目录为D:javajdk1.5.0_08；2.安装完成后，右击“我的电脑”，点击“属性”； 3.选择“高级”选项卡，点击“环境变量”； 4.在“系统变量”中，设置3项属性，JAVA_HOME,PATH,CLASSPATH(大小写无所谓),若已存在则点击“编辑”，不存在则点击“新建”； 5.JAVA_HOME指明JDK安装路径，就是刚才安装时所选择的路径D:javajdk1.5.0_08，此路径下包括lib，bin，jre等文件夹（此变量最好设置，因为以后运行tomcat，eclipse等都需要依*此变量）； Pat
34、h使得系统可以在任何路径下识别java命令，设为：%JAVA_HOME%bin;%JAVA_HOME%jrebin CLASSPATH为java加载类(class or lib)路径，只有类在classpath中，java命令才能识别，设为：.;%JAVA_HOME%libdt.jar;%JAVA_HOME%libtools.jar (要加.表示当前路径)%JAVA_HOME%就是引用前面指定的JAVA_HOME； 6.“开始”;“运行”，键入“cmd”； 7.键入命令“java -version”，“java”，“javac”几个命令，出现画面，说明环境变量配置成功； 8.好了，打完收工。下
35、面开始你的第一个java程序吧。下面讲讲java几个环境变量的含义和linux下的配置方法：通常，我们需要设置三个环境变量：JAVA_HOME、PATH 和 CLASSPATH。JAVA_HOME：该环境变量的值就是 Java 所在的目录，一些 Java 版的软件和一些 Java 的工具需要用到该变量，设置 PATH 和 CLASSPATH 的时候，也可以使用该变量以方便设置。PATH：指定一个路径列表，用于搜索可执行文件的。执行一个可执行文件时，如果该文件不能在当前路径下找到，则依次寻找 PATH 中的每一个路径，直至找到。或者找完 PATH 中的路径也不能找到，则报错。Java 的编译命令
36、 (javac)，执行命令 (java) 和一些工具命令 (javadoc, jdb 等) 都在其安装路径下的 bin 目录中。因此我们应该将该路径添加到 PATH 变量中。CLASSPATH：也指定一个路径列表，是用于搜索 Java 编译或者运行时需要用到的类。在 CLASSPATH 列表中除了可以包含路径外，还可以包含 .jar 文件。Java 查找类时会把这个 .jar 文件当作一个目录来进行查找。通常，我们需要把 JDK 安装路径下的 jrelib t.jar (Linux: jre/lib/rt.jar) 包含在 CLASSPATH 中。PATH 和 CLASSPATH 都指定路径列
37、表，列表中的各项 (即各个路径) 之间使用分隔符分隔。在 Windows 下，分隔符是分号 (;)，而在 Linux 下，分隔符是冒号 (:)。下面分别说明三个环境变量在 Windows 和 Linux 下如何设置，不过在此之前，我们需要做个假设。假设 JDK 在 Windows 下的安装路径是 C:jdk，在 Linux 下的安装路径是 /usr/local/jdk/。那么，安装后的 JDK 至少会包括如下内容：C:jdk (/usr/local/jdk) |- bin |- demo |- include |- jre | |- bin | - lib - lib* 在 Windows 下
38、设置Windows 下使用 set 命令设置环境变量，为了使每一次启动计算机都设置这些环境变量，应该在系统盘根目录下的 autoexec.bat 文件中进行设置，如：set JAVA_HOME=C:jdk set PATH=%JAVA_HOME%bin;C:Windows;C:WindowsCommand set CLASSPATH=%JAVA_HOME%jrelib t.jar;.有些版本的 Windows 不能用 %变量名% 来替换环境变量的内容，那么就只好直接写 C:jdk 而不是 %JAVA_HOME% 了。另外，C:Windows 和 C:WindowsCommand 是 Windo
39、ws 会自动加入路径的，所以可以从设置中去掉。如果在 autoexec.bat 中已经设置了 PATH，那只需要将 %JAVA_HOME%bin 加到原来设置 PATH 的那条语句中就行了。CLASSPATH 也可以根据需要设置或者加入其它的路径，比如你想把自己写的一些类放在 C:java 中，就可以把 C:java 也添加到 CLASSPATH 中去，set CLASSPATH=%JAVA_HOME%jrelib t.jar;C:java;.。注意，在 CLASSPATH 中包含了一个“当前目录 (.)”。包含了该目录后，就可以到任意目录下去执行需要用到该目录下某个类的 Java 程序，即使
40、该路径并未包含在 CLASSPATH 中也可以。原因很简单：虽然没有明确的把该路径包含在 CLASSPATH 中，但 CLASSPATH 中的 “.” 在此时就代表了该路径，如：假设在 C:java 目录下有可运行的类 HelloJava.class，那么C: set CLASSPATH=C:jdkjrelib t.jar;. / 设置 CLASSPATH 环境变量，注意最后有一个 “.” C: cd java / 转到 C:java 目录 C:java java HelloJava / 运行 HelloJava Hello, Java. / 运行结果 C:java _java环境变量配置时间
41、:2010-02-08 18:11:56来源:网络 作者:未知 点击:18988次 windowsxp下配置JDK环境变量：1.安装JDK，安装过程中可以自定义安装目录等信息，例如我们选择安装目录为D:javajdk1.5.0_08；* 在 Linux 下设置Linux 下使用“变量名=变量值”设置变量，并使用 export 命令将其导出为环境变量。为了使每一次登录都自动设置好这些变量，你需要在 /.bash_profile 里或者 ./bashrc 里进行设置，如export JAVA_HOME=/usr/local/jdk export PATH=$JAVA_HOME/bin:$PATH
42、export CLASSPATH=$JAVA_HOME/jre/lib/rt.jar:.设置 PATH 时用的 $JAVA_HOME 是指替换变量 JAVA_HOME 的值到 $JAVA_HOME 所在位置。如上句实际就是 export PATH=/usr/local/jdk/bin:$PATH。这句中 $PATH 也是同样的作用，不过这里的 PATH 是指以前设置的 PATH 变量的值，而非本次设置 PATH 变量的值。注意，在 CLASSPATH 中包含了一个“当前目录 (.)”。包含了该目录后，就可以到任意目录下去执行需要用到该目录下某个类的 Java 程序，即使该路径并未包含在 CLA
43、SSPATH 中也可以。原因很简单：虽然没有明确的把该路径包含在 CLASSPATH 中，但 CLASSPATH 中的 “.” 在此时就代表了该路径，例如假设在 /home/fancy/java 目录下有可运行的类 HelloJava.class，那么fancymatrix fancy$ export CLASSPATH=/usr/local/jdk/jre/lib/rt.jar:. / 设置 CLASSPATH，注意最后的“.” fancymatrix fancy$ cd /java / 转到 /home/fancy/java fancymatrix java$ pwd / 显示当前目录 /
44、home/fancy/java / 当前目录是 /home/fancy/java fancymatrix java$ java HelloJava / 运行 HelloJava Hello, Java / 运行结果 fancymatrix java$ _析* 实例分析只是操作系统不同，略有差别。两个例子都提到一个“可运行的类”，它是指包含了 public static void main(String args) 方法的类，这将在下一章 HelloJava 一节中详述。例中的 CLASSPATH 均未包含 HelloJava.class 所在的目录(C:java, /home/fancy/java)，但是均包含了当前目录 (.)。因此转到包含 HelloJava.class 的目录下去执行 java HelloJava，在 Java 寻找到 CLASSPATH 中的“. (当前目录，C:java, /home/fancy/java)”时，找到了 HelloJava.class，运行成功。
