日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

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() ); 
　　 } 
　 } 
} 

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: 在此處添加構(gòu)造函數(shù)邏輯 
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;} 
} 
} 
} 

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;
}
}
}

private void EstablishConnection() 
{ 
statusBar1.Text = "正在連接到服務(wù)器"; 
try 
{ 
clientsocket = new TcpClient(serveraddress,serverport); 
ns = clientsocket.GetStream(); 
sr = new StreamReader(ns); 
connected = true; 
} 
catch (Exception) 
{ 
MessageBox.Show("不能連接到服務(wù)器！","錯誤", 
MessageBoxButtons.OK, MessageBoxIcon.Exclamation); 
statusBar1.Text = "已斷開連接"; 
} 
} 

private void RegisterWithServer() 
{ 
try 
{ 
string command = "CONN|" + ChatOut.Text; 
Byte[] outbytes = System.Text.Encoding.ASCII.GetBytes(command.ToCharArray()); 
ns.Write(outbytes,0,outbytes.Length); 
string serverresponse = sr.ReadLine(); 
serverresponse.Trim(); 
string[] tokens = serverresponse.Split(new Char[]{'|'}); 
if(tokens[0] == "LIST") 
{ 
statusBar1.Text = "已連接"; 
btnDisconnect.Enabled = true; 
} 
for(int n=1; n 
lbChatters.Items.Add(tokens[n].Trim(new char[]{'\r','\n'})); 
this.Text = clientname + "：已連接到服務(wù)器"; 
} 
catch (Exception) 
{ 
MessageBox.Show("注冊時發(fā)生錯誤！","錯誤", 
MessageBoxButtons.OK, MessageBoxIcon.Exclamation); 
} 
}  

private void ReceiveChat() 
{ 
bool keepalive = true; 
while (keepalive) 
{ 
try 
{ 
Byte[] buffer = new Byte[2048]; 
ns.Read(buffer,0,buffer.Length); 
string chatter = System.Text.Encoding.ASCII.GetString(buffer); 
string[] tokens = chatter.Split(new Char[]{'|'}); 

if (tokens[0] == "CHAT") 
{ 
rtbChatIn.AppendText(tokens[1]); 
if(logging) 
logwriter.WriteLine(tokens[1]); 
} 
if (tokens[0] == "PRIV") 
{ 
rtbChatIn.AppendText("Private from "); 
rtbChatIn.AppendText(tokens[1].Trim() ); 
rtbChatIn.AppendText(tokens[2] + "\r\n"); 
if(logging) 
{ 
logwriter.Write("Private from "); 
logwriter.Write(tokens[1].Trim() ); 
logwriter.WriteLine(tokens[2] + "\r\n"); 
} 
} 
if (tokens[0] == "JOIN") 
{ 
rtbChatIn.AppendText(tokens[1].Trim() ); 
rtbChatIn.AppendText(" has joined the Chat\r\n"); 
if(logging) 
{ 
logwriter.WriteLine(tokens[1]+" has joined the Chat"); 
} 
string newguy = tokens[1].Trim(new char[]{'\r','\n'}); 
lbChatters.Items.Add(newguy); 
} 
if (tokens[0] == "GONE") 
{ 
rtbChatIn.AppendText(tokens[1].Trim() ); 
rtbChatIn.AppendText(" has left the Chat\r\n"); 
if(logging) 
{ 
logwriter.WriteLine(tokens[1]+" has left the Chat"); 
} 
lbChatters.Items.Remove(tokens[1].Trim(new char[]{'\r','\n'})); 
} 
if (tokens[0] == "QUIT") 
{ 
ns.Close(); 
clientsocket.Close(); 
keepalive = false; 
statusBar1.Text = "服務(wù)器端已停止"; 
connected= false; 
btnSend.Enabled = false; 
btnDisconnect.Enabled = false; 
} 
} 
catch(Exception){} 
} 
} 

private void QuitChat() 
{ 
if(connected) 
{ 
try 
{ 
string command = "GONE|" + clientname; 
Byte[] outbytes = System.Text.Encoding.ASCII.GetBytes(command.ToCharArray()); 
ns.Write(outbytes,0,outbytes.Length); 
clientsocket.Close(); 
} 
catch(Exception) 
{ 
} 
} 
if(logging) 
logwriter.Close(); 
if(receive != null && receive.IsAlive) 
receive.Abort(); 
this.Text = "客戶端"; 
}