Socket 发送或接收文件_socket发送文件

最近学习了一下Socket ，下面是实现像《飞鸽》类似的功能，这里只提供了简单的使用规则和一些做时遇到地饿问题，

算是备忘吧！！
---------------------------------------------------
----------使用UDP 发送数据报，到指定的网段---------
        using System.Net;
        using System.Net.Sockets;
        using System.Windows.Forms;
        using System.IO;

 /// <summary>
        /// 启动所有线程
        /// </summary>
        private void StartThread()
        {
            //发送用户在线信息
            Thread send = new Thread(new ThreadStart(this.SendUserInfo));
            send.IsBackground = true;
            send.Start();
            //接收用户在线信息
            Thread lsn = new Thread(new ThreadStart(this.StartListening));
            lsn.IsBackground = true;
            lsn.Start();
       
            //侦听消息和文件的传输端口
            Thread sendMsg = new Thread(new ThreadStart(this.m_sendMSG.ListeningMSG));
            sendMsg.IsBackground = true;
            sendMsg.SetApartmentState(ApartmentState.STA);
            sendMsg.Start();

        }

        /// <summary>
        /// 发送UDP 数据报到指定网段内各终端机的 4095 端口
        /// （发送在线用户信息）
        /// </summary>
        public void SendUserInfo()
        {
            UdpClient udpClient = new UdpClient();
            IPEndPoint ep = new IPEndPoint(IPAddress.Parse("192.168.1.255"), 4095);

            string str = "user:" + System.Net.Dns.GetHostName()
                + ":" + System.Net.Dns.GetHostEntry(System.Net.Dns.GetHostName()).AddressList[0];

            byte[] dgram = System.Text.Encoding.Default.GetBytes(str);

            while (true)
            {
                udpClient.Send(dgram, dgram.Length, ep);
 
                System.Threading.Thread.Sleep(2000); //使调用该方法的线程休眠2000毫秒
            }
        }

        /// <summary>
        /// 接收 4095 端口所有数据包
        /// （监听线用户发送的在线确认信息）
        /// </summary>
        public void StartListening()
        {
            UdpClient udpClient = new UdpClient(4095);//udp 通讯的端口号
            IPEndPoint ep = new IPEndPoint(IPAddress.Any, 0);

            while (true)
            {
                byte[] dgram = udpClient.Receive(ref ep);
                string str = System.Text.Encoding.Default.GetString(dgram);
                string[] arr = str.Split(':');
                if (arr == null || arr.Length < 3)
                    continue;

                if (arr[0] != "user")
                    continue;

                string houtName = arr[1];
                string ip = arr[2];
               
                if (!hs.Contains(ip))
                {
                    hs.Add(ip, houtName);
                }
                 
                ···  ···   
            }
        }
    }

-------------------------------------------------------
-------------------通过 TCP 发送消息-------------------

1.通过指定的寻址方案，以字符流方式和Tcp通信，初始化套接字
  socketSent = new Socket(AddressFamily.InterNetwork,
                                   SocketType.Stream,
                                   ProtocolType.Tcp);
2. 设置服务器IP地址和端口
   ipSent = new IPEndPoint(IPAddress.Parse(ip), 8001);

3. 与服务器进行连接
   socketSent.Connect(ipSent);

4. 将要发送的消息转化为字节流，然后发送
   socketSent.Send(Encoding.Default.GetBytes(msg));
----------------------------------------------------
         通过 TCP 发送文件（最基本的设置）
      首先要设置端口的监听，之后再发送数据包

1.命名空间：
using System.Net;
using System.Net.Sockets;
using System.Windows.Forms;
using System.IO;

2.监听端口设置
 
  //初始化接受套接字：寻址方案，以字符流方式和Tcp通信
  Socket socketMsg = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  //获取本机IP地址
  IPAddress hostIP=Dns.GetHostEntry(Dns.GetHostName()).AddressList[0];
  //
  PEndPoint hostPoint=new IPEndPoint("本机IP地址",8000);
  //设置服务器IP地址和端口
  socketMsg.Bind(hostPoint);
  //建立监听
  socketMsg.Listen(1024);
 
  while (true)
  {
      Socket newSocket = socketMsg.Accept();
      //缓冲区
      byte[] buffer = new byte[1024]; 
      //接受数据流到缓冲区，len为接受到的字节数
      int len = newSocket.Receive(buffer);
      //创建写文件流
      FileStream writer = new FileStream("c://test1.txt", FileMode.OpenOrCreate, FileAccess.Write);

      byte[] buffer = new byte[1024];
      len  = newSocket.Receive(buffer)
      string msg=Encoding.Default.GetString(buffer, 0, len );

      if(msg!="开始传送的标志符")
  continue;
  
      while ((len  = newSocket.Receive(buffer)) != 0)
      {
         msg = Encoding.Default.GetString(buffer, 0, len );

         if (msg == "结束传送的标志符")
             break;    

         writer.Write(buffer, 0, len );
      }
  
      writer.Close();
  }

3.送文件
  //初始化文件读写流
  FileStream readSream = new FileStream("c://test2.txt", FileMode.Open, FileAccess.Read);
  //初始化接受套接字：寻址方案，以字符流方式和Tcp通信
  Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  //
  IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse("IP地址"), 8000);
  //建立连接
  socket.Connect(endPoint);

  //1.发送：文件发送开始标记和文件名
  socket.Send(Encoding.Default.GetBytes("开始传送的标志符"));

  //2.发送文件
  byte[] buffer = new byte[1024];
  int n = 0;
  while ((n = readSream.Read(buffer, 0, 1024)) != 0)
  {
       //调试时使用
       //string str = Encoding.Default.GetString(buffer, 0, n);
       //发送字节流
       socket.Send(buffer,n,SocketFlags.None);
       //socket.Send(buffer);
  }

  //3.发送：文件发送结束符
  socket.Send(Encoding.Default.GetBytes("结束传送的标志符"));

  socket.Close();
  readSream.Close();  

----------------------------------------------------
遇到的异常及解决方法：
1.在可以调用 OLE 之前，必须将当前线程设置为单线程单元(STA)模式。请确保您的 Main 函数带有 STAThreadAttribute 标记。 只有将调试器附加到该进程才会引发此异常。
  分析：因为使用线程，在线程中有调用了保存组件所以发生此异常
  解决：将线程的模式设置为STA模式。
        TreadName.SetApartmentState(ApartmentState.STA);

2.线程间操作无效: 从不是创建控件“lv”的线程访问它。
  分析：因为在非本窗体的线程上，操作了本窗体的控件，所以引发了该异常。
  解决：使用线程封送处理该问题，通过本窗体的 this.BeginInvoke() 方法，使其它线程可以操作窗体控件

        /// <summary>
        /// 修改本窗体控件（封送处理所需的方法，该代理要于线程的方法的参数列表匹配）
        /// </summary>
        private delegate void InvokeInitIpList(ListeningAgos ags);

        /// <summary>
        /// 线程调用的本窗体中的方法
        /// </summary>
        /// <param name="sa">包含所有在线用户信息</param>
        void m_lsn_OnListening(ListeningAgos sa)
        {
            //在其它线程中通过安全的线程访问本窗体控件(其它线程访问本窗体控件,如不用该方法调用会发生异常)
            //事件封送处理
            this.BeginInvoke(new InvokeInitIpList(InitIpList),new object[]{sa});
        }