三．c＃网络编程服务器端程序的部分源代码（server.cs）：
由于在此次程序中我们采用的结构是异步阻塞方式，所以在实际的程序中，为了不影响服务器端程序的运行速度，我们在程序中设计了一个线程，使得对网络请求侦听，接受和发送数据都在线程中处理，请在下面的代码中注意这一点，下面是server.cs的完整代码：
using system ;
using system.drawing ;
using system.collections ;
using system.componentmodel ;
using system.windows.forms ;
using system.data ;
using system.net.sockets ;
using system.io ;
using system.threading ;
using system.net ;
//导入程序中使用到的名字空间
public class form1 : form
{
private listbox listbox1 ;
private button button2 ;
private label label1 ;
private textbox textbox1 ;
private button button1 ;
private socket socketforclient ;
private.networkstream.networkstream ;
private tcplistener tcplistener ;
private streamwriter streamwriter ;
private streamreader streamreader ;
private thread _thread1 ;
private system.componentmodel.container components = null ;
public form1 ( )
{
initializecomponent ( ) ;
}
//清除程序中使用的各种资源
protected override void dispose ( bool disposing )
{
if ( disposing )
{
if ( components != null )
{
components.dispose ( ) ;
}
}
base.dispose ( disposing ) ;
}
private void initializecomponent ( )
{
label1 = new label ( ) ;
button2 = new button ( ) ;
button1 = new button ( ) ;
listbox1 = new listbox ( ) ;
textbox1 = new textbox ( ) ;
suspendlayout ( ) ;
label1.location = new point ( 8 , 168 ) ;
label1.name = "label1" ;
label1.size = new size ( 120 , 23 ) ;
label1.tabindex = 3 ;
label1.text = "往客户端反馈信息：" ;
//同样的方式设置其他控件,这里略去
this.controls.add ( button1 ) ;
this.controls.add ( textbox1 ) ;
this.controls.add ( label1 ) ;
this.controls.add ( button2 ) ;
this.controls.add ( listbox1 ) ;
this.maximizebox = false ;
this.minimizebox = false ;
this.name = "form1" ;
this.text = "c＃的网络编程服务器端！" ;
this.closed += new system.eventhandler ( this.form1_closed ) ;
this.resumelayout ( false ) ;
}
private void listen ( )
{
//创建一个tcplistener对象，此对象主要是对给定端口进行侦听
tcplistener = new tcplistener ( 1234 ) ;
//开始侦听
tcplistener.start ( ) ;
//返回可以用以处理连接的socket实例
socketforclient = tcplistener.acceptsocket ( ) ;
try
{
//如果返回值是"true"，则产生的套节字已经接受来自远方的连接请求
if ( socketforclient.connected )
{
listbox1.items.add ( "已经和客户端成功连接！" ) ;
while ( true )
{
//创.networkstream对象通过网络套节字来接受和发送数据
.networkstream = new.networkstream ( socketforclient ) ;
//从当前数据流中读取一行字符，返回值是字符串
streamreader = new streamreader (.networkstream ) ;
string msg = streamreader.readline ( ) ;
listbox1.items.add ( "收到客户端信息：" + msg ) ;
streamwriter = new streamwriter (.networkstream ) ;
if ( textbox1.text != "" )
{
listbox1.items.add ( "往客户端反馈信息：" + textbox1.text ) ;
//往当前的数据流中写入一行字符串
streamwriter.writeline ( textbox1.text ) ;
//刷新当前数据流中的数据
streamwriter.flush ( ) ;
}
}
}
}
catch ( exception ey )
{
messagebox.show ( ey.tostring ( ) ) ;
}
}
static void main ( )
{
application.run ( new form1 ( ) ) ;
}
private void button1_click ( object sender , system.eventargs e )
{
listbox1.items .add ( "服务已经启动！" ) ;
_thread1 = new thread ( new threadstart ( listen ) ) ;
_thread1.start ( ) ;
}
private void button2_click ( object sender , system.eventargs e )
{
//关闭线程和流
.networkstream.close ( ) ;
streamreader.close ( ) ;
streamwriter.close ( ) ;
_thread1.abort ( ) ;
tcplistener.stop ( ) ;
socketforclient.shutdown ( socketshutdown.both ) ;
socketforclient.close ( ) ;
}
private void form1_closed ( object sender , system.eventargs e )
{
//关闭线程和流
.networkstream.close ( ) ;
streamreader.close ( ) ;
streamwriter.close ( ) ;
_thread1.abort ( ) ;
tcplistener.stop ( ) ;
socketforclient.shutdown ( socketshutdown.both ) ;
socketforclient.close ( ) ;
}
}
Java Asp PHP .Net XML C/C++ CGI VB Jsp J2ee J2se J2me EJB Servlet Tomcat Resin Struts Weblogic Eclipse ANT GUI JMS Web servise IDEA Webphere Hibernate Spring Jboss Applet Swing Socket Javamail Perl Ajax P2P 安全 模式 框架 测试 开源 游戏
Windows XP Windows 2000 Windows 2003 Windows Me Windows 9.x Linux UNIX 注册表 操作系统 服务器 应用服务器
