C#+flash socket 聊天程序(转)

简介:


很多人在研究flash的socket中经常会出现一些问题,所以提供一个别人的程序代码出来给大家参考...
 
这是VS2003下的c#程序的主要源代码,经过测试的。不包含一些自动生成的代码。
这些代码是根据一个开源的C# socket程序改编的,而且已经写了比较详细的注释了。

C#源代码
Windows 应用的窗体程序: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();//线程开始
            
//

        }



        
private void initClient()
        
{
            tclient 
= new TcpClient(Dns.GetHostName(),listenport);
            ns 
= tclient.GetStream();
            
            
//StreamReader sr = new StreamReader(ns); 

            
//ns.Write();
            
//MessageBox.Show("wwwwwwww");
        
            
//while()
            Thread cthread = new Thread(new ThreadStart(crun));
            cthread.Start();
            
        }

        
private void crun()
        
{
            
//MessageBox.Show("wwwwwwww");
            bool state = true;
            
//bool b = false;
            while(state)
            
{
                
//MessageBox.Show("wwwwwwww");
                string message;
                
//if(!b)
                
//{
                
//    message = "CONN|host";
                
//    b = !b;
                
//}
                
//else
                message = "CHAT|test";
                
byte[] bf = System.Text.Encoding.UTF8.GetBytes(message.ToCharArray());
                ns.Write(bf, 
0, bf.Length);
                Thread.Sleep(
2000);
            }


        }



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


        
Windows Form Designer generated code

        
/// <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 Form1_Load(object sender, System.EventArgs e)
        
{
        
        }


        
private void lbClients_SelectedIndexChanged(object sender, System.EventArgs e)
        
{
        
        }


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


            }

        }


    }

}


Class 类程序: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;}
        }

    }

}


flash源代码
这是flash的代码,代码比较简单,没有写什么注释。
聊天.fla

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



本文转自钢钢博客园博客,原文链接http://www.cnblogs.com/xugang/archive/2007/12/04/982084.html,如需转载请自行联系原作者
相关文章
|
18天前
|
C# 开发者
C# 一分钟浅谈:Socket 编程基础
【10月更文挑战第7天】本文介绍了Socket编程的基础知识、基本操作及常见问题,通过C#代码示例详细展示了服务器端和客户端的Socket通信过程,包括创建、绑定、监听、连接、数据收发及关闭等步骤,帮助开发者掌握Socket编程的核心技术和注意事项。
66 3
C# 一分钟浅谈:Socket 编程基础
|
20天前
|
缓存 C# Windows
C#程序如何编译成Native代码
【10月更文挑战第15天】在C#中,可以通过.NET Native和第三方工具(如Ngen.exe)将程序编译成Native代码,以提升性能和启动速度。.NET Native适用于UWP应用,而Ngen.exe则通过预编译托管程序集为本地机器代码来加速启动。不过,这些方法也可能增加编译时间和部署复杂度。
|
6天前
|
消息中间件 网络协议 C#
C#使用Socket实现分布式事件总线,不依赖第三方MQ
`CodeWF.EventBus.Socket` 是一个轻量级的、基于Socket的分布式事件总线系统,旨在简化分布式架构中的事件通信。它允许进程之间通过发布/订阅模式进行通信,无需依赖外部消息队列服务。
C#使用Socket实现分布式事件总线,不依赖第三方MQ
|
10天前
|
设计模式 程序员 C#
C# 使用 WinForm MDI 模式管理多个子窗体程序的详细步骤
WinForm MDI 模式就像是有超能力一般,让多个子窗体井然有序地排列在一个主窗体之下,既美观又实用。不过,也要小心管理好子窗体们的生命周期哦,否则一不小心就会出现一些意想不到的小bug
|
23天前
|
XML 存储 安全
C#开发的程序如何良好的防止反编译被破解?ConfuserEx .NET混淆工具使用介绍
C#开发的程序如何良好的防止反编译被破解?ConfuserEx .NET混淆工具使用介绍
40 0
|
25天前
|
安全 API C#
C# 如何让程序后台进程不被Windows任务管理器强制结束
C# 如何让程序后台进程不被Windows任务管理器强制结束
49 0
|
2月前
|
C# 容器
C#中的命名空间与程序集管理
在C#编程中,`命名空间`和`程序集`是组织代码的关键概念,有助于提高代码的可维护性和复用性。本文从基础入手,详细解释了命名空间的逻辑组织方式及其基本语法,展示了如何使用`using`指令访问其他命名空间中的类型,并提供了常见问题的解决方案。接着介绍了程序集这一.NET框架的基本单位,包括其创建、引用及高级特性如强名称和延迟加载等。通过具体示例,展示了如何创建和使用自定义程序集,并提出了针对版本不匹配和性能问题的有效策略。理解并善用这些概念,能显著提升开发效率和代码质量。
79 4
|
26天前
|
API C#
C#实现Winform程序右下角弹窗消息提示
C#实现Winform程序右下角弹窗消息提示
59 0
|
2月前
|
Linux C# 开发者
Uno Platform 驱动的跨平台应用开发:从零开始的全方位资源指南与定制化学习路径规划,助您轻松上手并精通 C# 与 XAML 编程技巧,打造高效多端一致用户体验的移动与桌面应用程序
【9月更文挑战第8天】Uno Platform 的社区资源与学习路径推荐旨在为初学者和开发者提供全面指南,涵盖官方文档、GitHub 仓库及社区支持,助您掌握使用 C# 和 XAML 创建跨平台原生 UI 的技能。从官网入门教程到进阶技巧,再到活跃社区如 Discord,本指南带领您逐步深入了解 Uno Platform,并提供实用示例代码,帮助您在 Windows、iOS、Android、macOS、Linux 和 WebAssembly 等平台上高效开发。建议先熟悉 C# 和 XAML 基础,然后实践官方教程,研究 GitHub 示例项目,并积极参与社区讨论,不断提升技能。
54 2