C#+flash socket 聊天程序(flash源代码)

*/
function OnConnect(success) {
 if (success) {
  trace("Connection succeeded!");
  isConn = true;
  socket.send("CONN|"+userNameIt.text);
  userList.addItem(’所有人’);
 } else {
  trace("Connection failed!");
 }
}
function OnData(src) {
 // 此处是您的语句
 trace(src)
 strArray = src.split(’|’);
 
 temp = strArray[0];
 trace(strArray.length+’\t’+strArray);
 if (temp == ’LIST’) {
  userList.removeAll();
  for (i=1; i<strArray.length; i++) {
   userList.addItem(strArray[i]);
  }
 } else if (temp == ’JOIN’) {
  userList.addItem(strArray[1]);
  smgText.text += strArray[1] + ’进来了···’+’\n’;
 } else if (temp == ’CHAT’) {
  smgText.text += strArray[1]+’\n’;
 } else if (temp == ’PRIV’) {
  smgText.text += strArray[strArray.length-1]+’\n’;
  break;
 } else if (temp == ’GONE’) {
  for (var i = 0; i<userList.length; i++) {
   if (userList.getItemAt(i).label == strArray[1]) {
    smgText.text += userList.getItemAt(i).label + ’离开了···’+’\n’;
    userList.removeItemAt(i);
   }
  }
 } else if (strArray[1] == ’CHAT’) {
  smgText.text += strArray[2]+’\n’;
 }
 temp = "";
 smgText.vPosition = smgText.maxVPosition;
}

connectBtn.onRelease = function() {
 socket = new XMLSocket();
 socket.onConnect = OnConnect;
 socket.onData = OnData;
 //
 if (!socket.connect("192.168.0.132", 9050)) {
  trace("Connection failed!");
 }
};
/////////////////////////////////////////
sendMsgBtn.onRelease = function() {
 if (msgIt.text != ’’) {
  if (userList.selectedItem == undefined || userList.selectedItem.label == ’所有人’ || userList.selectedItem.label == userNameIt.text) {
   socket.send("CHAT|"+userNameIt.text+’ 说：’+msgIt.text);
  } else if (!privateCheckBox.selected) {
   socket.send("CHAT|"+userNameIt.text+’ 对 ’+userList.selectedItem.label+’ 说：’+msgIt.text);
  } else {
   socket.send("PRIV|"+userNameIt.text+’|’+userList.selectedItem.label+’|’+userNameIt.text+’ 悄悄的对 ’+userList.selectedItem.label+’ 说：’+msgIt.text);
  }
 }
 msgIt.text = ’’;
};
disconnectBtn.onRelease = function() {
 isConn = false;
 socket.send("GONE|"+userNameIt.text);
 socket.close();
};
function init() {

 connected=false;
 
 smgText.text = ’’;
 temp = ’’;
}
init();
//连接到服务器
var isConn:Boolean = false;

myListener = new Object();
myListener.onKeyDown = function () {
if(Key.getCode() == 13)
sendMsgBtn.onRelease();
}

Key.addListener(myListener);

//form1.cs
using System;
using System.IO;
using System.Drawing;
using System.Collections;//ArrayList引用到这个命名空间的类
using System.ComponentModel;
using System.Windows.Forms;
using System.Data;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace ChatServer//服务器端命名空间
{
 /// <summary>
 /// Form1 的摘要说明。
 /// </summary>
 public class Form1 : System.Windows.Forms.Form
 {
  private int listenport = 9050;//监听端口
  private TcpListener listener;//监听者
  private ArrayList clients;//所有的client
  private Thread processor;//处理线程
  private Socket clientsocket;//client套接字
  private Thread clientservice;//client的服务
  private System.Windows.Forms.ListBox lbClients;
  private System.Windows.Forms.Label label1;//显示在线人员的List控件

  private TcpClient tclient;

  private NetworkStream ns;
  private System.Windows.Forms.Button button1;

  /// <summary>
  /// 必需的设计器变量。
  /// </summary>
  private System.ComponentModel.Container components = null;

  public Form1()
  {
   //
   // Windows 窗体设计器支持所必需的
   //
   InitializeComponent();
   Thread.CurrentThread.IsBackground = true;
   //
   // TODO: 在 InitializeComponent 调用后添加任何构造函数代码
   //
   clients = new ArrayList();//新建一个ArrayList类型用以存储所有的client
   processor = new Thread(new ThreadStart(StartListening));//新建一个处理线程
   processor.Start();//线程开始
   //

  }


  /// <summary>
  /// 清理所有正在使用的资源。
  /// </summary>
  protected override void Dispose( bool disposing )
  {

  
    int c = clients.Count;
    for(int n=0; n<c; n++)
    {
     Client cl = (Client)clients[n];
     cl.Sock.Close();
     cl.CLThread.Abort();
    }
   


   //client.Close();
   listener.Stop();
   processor.Abort();
   if( disposing )
   {
    if (components != null) 
    {
     components.Dispose();
    }
   }
   base.Dispose( disposing );
  }


  /// <summary>
  /// 开始监听
  /// </summary>
  private void StartListening()
  {

   IPAddress ipAddress = Dns.Resolve(Dns.GetHostName()).AddressList[0];
   //IPAddress ipAddress = IPAddress.Parse("192.168.0.132");

   
   label1.Text=ipAddress.ToString();
   IPEndPoint ipLocalEndPoint = new IPEndPoint(ipAddress, listenport);

   listener = new TcpListener(ipLocalEndPoint);
   listener.Start();
   while (true) 
   {
    try
    {
     Socket s = listener.AcceptSocket();//接收一个套接字
     clientsocket = s;//赋值给clientsocket
     clientservice = new Thread(new ThreadStart(ServiceClient));//为新进client服

务建立线程
     clientservice.Start();//线程开始
    }
    catch(Exception e)//如果出现异常则打控制台打印到屏幕
    {
     Console.WriteLine(e.ToString() );
    }
   }
  }

  /// <summary>
  /// 给一个客户提供服务
  /// </summary>
  private void ServiceClient()
  {
   Socket client = clientsocket;//赋值给client
   bool keepalive = true;
   bool s;
   while (keepalive)
   {

    Byte[] buffer = new Byte[1024];//一个1024bits的缓存区
    try
    {
     client.Receive(buffer);
    } 
    catch(SocketException ex) 
    { 
     //客户端退出  
     //MessageBox.Show(ex.ToString());
     string leaveName="";
     int remove = 0;
     bool found = false;
     int c = clients.Count;
     //从client的ArrayList中查找有没有相符的client
     //有的话就作好删掉的准备
     for(int n=0; n<c; n++)
     {
      Client cl = (Client)clients[n];
      if(cl.Host==client.RemoteEndPoint)
      {
       leaveName = cl.Name;
       remove = n;
       found = true;
       lbClients.Items.Remove(cl);//List控件中删除这个client
       break;
      }
     }

     if(found)
     {
      for(int n=0; n<c; n++)
      {
       Client cl = (Client)clients[n];
       //MessageBox.Show( "GONE|"+leaveName);
       SendToClient(cl, "GONE|"+leaveName);
      }
     
      clients.RemoveAt(remove);//从clients的ArrayList里面删掉要当前要退出

的client
      client.Close();//关闭套接口
      keepalive = false;//keepalive=false则这个线程服务完毕
     }

    }



    string clientcommand = System.Text.Encoding.UTF8.GetString(buffer);//把得到的数据用

ASCII的编码形式读出解决中文的显示问题

    label1.Text=clientcommand;

    string[] tokens = clientcommand.Split(new Char[]{’|’});//以|号划分的命令数据
    Console.WriteLine(clientcommand);

    if (tokens[0] == "CONN")//连接命令消息
    {
     //给现有的client发送新进一个client的消息
     for(int n=0; n<clients.Count; n++) 
     {
      Client cl = (Client)clients[n];
      SendToClient(cl, "JOIN|" + tokens[1]);
     }
     
     //新加一个client
     EndPoint ep = client.RemoteEndPoint;
     Client c = new Client(tokens[1], ep, clientservice, client);
     clients.Add(c);
     
     //给每个client发一个当前所有client的列表消息
     //string message = "LIST|" + GetChatterList();

     //new byte(0)
     //byte b = 0;

     string message = "LIST|"+"asdasd";
     //MessageBox.Show(message.Length +"="+message);
     SendToClient(c, message);

     //MessageBox.Show(message);

     //服务器List控件新加这个client
     lbClients.Items.Add(c);
     
    }
    else
     if (tokens[0] == "CHAT")//聊天命令消息
    {
     //给每个client发送聊天消息
     for(int n=0; n<clients.Count; n++)
     {
      Client cl = (Client)clients[n];
      SendToClient(cl, clientcommand);
     }
    }
    else
     if (tokens[0] == "PRIV") //私聊命令消息
    {
     
     string destclient = tokens[2];//目标client
     for(int n=0; n<clients.Count; n++) 
     {
      Client cl = (Client)clients[n];
      if(cl.Name.CompareTo(tokens[2]) == 0)//给目标client发聊天消息
       SendToClient(cl, clientcommand);
      if(cl.Name.CompareTo(tokens[1]) == 0)//给自己发聊天消息
       SendToClient(cl, clientcommand);
     }
    }
    else
     if (tokens[0] == "GONE")//离开命令消息
    {
     int remove = 0;
     bool found = false;
     int c = clients.Count;
     //从client的ArrayList中查找有没有相符的client
     //有的话就作好删掉的准备
     for(int n=0; n<c; n++)
     {
      Client cl = (Client)clients[n];
      SendToClient(cl, clientcommand);
      if(cl.Name.CompareTo(tokens[1]) == 0)
      {
       remove = n;
       found = true;
       lbClients.Items.Remove(cl);//List控件中删除这个client
      }
     }
     if(found)
      clients.RemoveAt(remove);//从clients的ArrayList里面删掉要当前要退出

的client
     client.Close();//关闭套接口
     keepalive = false;//keepalive=false则这个线程服务完毕
    }
    else
    {
     //MessageBox.Show(clientcommand);
     for(int n=0; n<clients.Count; n++)
     {
      Client cl = (Client)clients[n];
      SendToClient(cl, "-");
     }
    }
   } 
  

  }

  /// <summary>
  /// 发送消息到指定的client
  /// </summary>
  /// <param name="cl">client</param>
  /// <param name="message">消息</param>
  private void SendToClient(Client cl, string message)
  {
   try
   {
    //MessageBox.Show(message);
    message += "0";
    byte[] buffer = System.Text.Encoding.UTF8.GetBytes(message.ToCharArray());
    buffer[buffer.Length -2] = 0;
    cl.Sock.Send(buffer,buffer.Length,0);
   }
   catch(Exception)//如果有异常则退出
   {
    //MessageBox.Show(message);
    clients.Remove(cl);
    lbClients.Items.Remove(cl.Name + " : " + cl.Host.ToString());
    for(int n=0; n<clients.Count; n++)
    {
     Client cl1 = (Client)clients[n];
     SendToClient(cl1, "GONE|"+cl.Name);
    }
    cl.Sock.Close();
    cl.CLThread.Abort();
    
   }
  }

  /// <summary>
  /// 获得所有聊天者的列表
  /// 中间以"|"符号间隔
  /// </summary>
  /// <returns></returns>
  private string GetChatterList()
  {
   string chatters = "";
   for(int n=0; n<clients.Count; n++)
   {
    Client cl = (Client)clients[n];
    chatters += cl.Name;
    //MessageBox.Show(cl.Name.Length +"=" +cl.Name);
    //chatters += "welcome";
    chatters += "|";
    //MessageBox.Show(cl.Name);
    
   }
   //chatters += "欢迎你的到来";
   //MessageBox.Show(chatters);
   chatters.Trim(new char[]{’|’});
  
   return chatters;

   
  }

  /// <summary>
  /// 应用程序的主入口点。
  /// </summary>
  [STAThread]
  static void Main() 
  {
   Application.Run(new Form1());
  }

  
  //管理员消息```
  private void button1_Click(object sender, System.EventArgs e)
  {
   //initClient();
   if(clients.Count > 0)
   {
    int c = clients.Count;
    for(int n=0; n<c; n++)
    {
     string message = "CHAT|..";
   
     Client cl = (Client)clients[n];
     SendToClient(cl, message);
    }

   }
  }



 }
}

//--------------------------------------------------------------------------------------------------------------

//Client.cs
using System;
using System.Threading;

namespace ChatServer //定义命名空间
{
 using System.Net.Sockets;
 using System.Net;

 /// <summary>
 /// Client 的摘要说明。
 /// </summary>
 public class Client
 {
  private Thread clthread;//client的线程
  private EndPoint endpoint;//终端
  private string name;//client的名称
  private Socket sock;//套接口

  /// <summary>
  /// 构造函数，初始化所有的私有变量
  /// </summary>
  /// <param name="_name">名称</param>
  /// <param name="_endpoint">终端</param>
  /// <param name="_thread">线程</param>
  /// <param name="_sock">套接口</param>
  public Client(string _name, EndPoint _endpoint, Thread _thread, Socket _sock)
  {
   // TODO: 在此处添加构造函数逻辑
   clthread = _thread;
   endpoint = _endpoint;
   name = _name;
   sock = _sock;
  }

  /// <summary>
  /// 重载:转成字串
  /// </summary>
  /// <returns>返回终端加上client名称</returns>
  public override string ToString()
  {
   return endpoint.ToString()+ " : " + name;
  }

  /// <summary>
  /// 获取和设置线程
  /// </summary>
  public Thread CLThread
  {
   get{return clthread;}
   set{clthread = value;}
  }

  /// <summary>
  /// 获取和设置终端
  /// </summary>
  public EndPoint Host
  {
   get{return endpoint;}
   set{endpoint = value;}
  }

  /// <summary>
  /// 获取和设置client名称
  /// </summary>
  public string Name
  {
   get{return name;}
   set{name = value;}
  }

  /// <summary>
  /// 获取和设置套接口
  /// </summary>
  public Socket Sock
  {
   get{return sock;}
   set{sock = value;}
  }
 }
}