C# Socket多线程编程实例

新客网 XKER.COM 2008-04-24 来源：新客网整理转载收藏本文

　对于服务器端，主要的作用是监听客户端的连接请求并确认其请求。程序一开始便打开一个StartListening（）线程。

private void StartListening()
{
　 listener = new TcpListener(listenport);
　 listener.Start();
　 while (true)
　 {
　　 try
　　 {
　　　 Socket s = listener.AcceptSocket();
　　　 clientsocket = s;
　　　 clientservice = new Thread(new ThreadStart(ServiceClient));
　　　 clientservice.Start();
　　 }
　　 catch(Exception e)
　　 {
　　　 Console.WriteLine(e.ToString() );
　　 }
　 }
}
　　该线程是一直处于运行状态的。当服务器端接收到一个来自客户端的连接请求后，它就打开一个ServiceClient（）线程来服务客户端。当一个连接被建立后，每个客户端就被赋予一个属于它自己的套接字。同时，一个Client类的对象被建立。该对象包含了客户端的一些相关信息，该信息被保存在一个数组列表中。　　 Client类如下：

using System;
using System.Threading;

namespace ChatServer
{
using System.Net.Sockets;
using System.Net;

///
/// Client 的摘要说明。
///
public class Client
{
private Thread clthread;
private EndPoint endpoint;
private string name;
private Socket sock;

public Client(string _name, EndPoint _endpoint, Thread _thread, Socket _sock)
{
// TODO: 在此处添加构造函数逻辑
clthread = _thread;
endpoint = _endpoint;
name = _name;
sock = _sock;
}

public override string ToString()
{
return endpoint.ToString()+ " : " + name;
}

public Thread CLThread
{
get{return clthread;}
set{clthread = value;}
}

public EndPoint Host
{
get{return endpoint;}
set{endpoint = value;}
}

public string Name
{
get{return name;}
set{name = value;}
}

public Socket Sock
{
get{return sock;}
set{sock = value;}
}
}
}
　　程序的主体部分应是ServiceClient（）函数。该函数是一个独立的线程，其主要部分是一个while循环。在循环体内，程序处理各种客户端命令。服务器端接收来自客户端的以ASCII码给出的字符串，其中包含了一个“|”形式的分隔符。字符串中“|”以前的部分就是具体的命令，包括CONN、CHAT、PRIV、GONE四种类型。CONN命令建立一个新的客户端连接，将现有的用户列表发送给新用户并告知其他用户有一个新用户加入。CHAT命令将新的信息发送给所有用户。PRIV命令将悄悄话发送给某个用户。GONE命令从用户列表中除去一个已离开的用户并告知其他的用户某某已经离开了。同时，GONE命令可以设置布尔型的变量keepalive为false从而结束与客户端连接的线程。ServiceClient（）函数如下：

private void ServiceClient()
{
Socket client = clientsocket;
bool keepalive = true;

while (keepalive)
{
Byte[] buffer = new Byte[1024];
client.Receive(buffer);
string clientcommand = System.Text.Encoding.ASCII.GetString(buffer);

string[] tokens = clientcommand.Split(new Char[]{'|'});
Console.WriteLine(clientcommand);

if (tokens[0] == "CONN")
{
for(int n=0; n
{
Client cl = (Client)clients[n];
SendToClient(cl, "JOIN|" + tokens[1]);
}
EndPoint ep = client.RemoteEndPoint;
Client c = new Client(tokens[1], ep, clientservice, client);
clients.Add(c);
string message = "LIST|" + GetChatterList() +"\r\n";
SendToClient(c, message);

lbClients.Items.Add(c);

}
if (tokens[0] == "CHAT")
{
for(int n=0; n
{
Client cl = (Client)clients[n];
SendToClient(cl, clientcommand);
}
}
if (tokens[0] == "PRIV")
{
string destclient = tokens[3];
for(int n=0; n
{
Client cl = (Client)clients[n];
if(cl.Name.CompareTo(tokens[3]) == 0)
SendToClient(cl, clientcommand);
if(cl.Name.CompareTo(tokens[1]) == 0)
SendToClient(cl, clientcommand);
}
}
if (tokens[0] == "GONE")
{
int remove = 0;
bool found = false;
int c = clients.Count;
for(int n=0; n
{
Client cl = (Client)clients[n];
SendToClient(cl, clientcommand);
if(cl.Name.CompareTo(tokens[1]) == 0)
{
remove = n;
found = true;
lbClients.Items.Remove(cl);
}
}
if(found)
clients.RemoveAt(remove);
client.Close();
keepalive = false;
}
}
}

共4页: 上一页 [1] [2] [3] [4] 下一页

上一篇：C# 实现注销、关机、重启电脑功能下一篇：C# 调用Delphi写的动态链接库

【收藏】【评论】【推荐】【投稿】【打印】【关闭】