Socket传输大文件(发送与接收)

下载

Client

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.IO;
using System.Windows.Forms;


namespace SocketClient
{
    class Program
    {
        [STAThread]
        static void Main(string[] args)
        {
            SocketClient();
        }
        public static string serverIp = "127.0.0.1";//设置服务端IP
        public static int serverPort = 8888;//服务端端口
        public static Socket socketClient;//定义socket
        public static Thread threadClient;//定义线程
        public static byte[] result = new byte[1024];//定义缓存
        public static void SocketClient()
        {
            socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建一个socket的对象
            IPAddress ip = IPAddress.Parse(serverIp);//获取服务器IP地址
            IPEndPoint point = new IPEndPoint(ip, serverPort);//获取端口
            try
            {
                socketClient.Connect(point);//链接服务器IP与端口
                Console.WriteLine("连接服务器中.....");

            }
            catch (Exception)
            {
                Console.WriteLine("与服务器链接失败！！！");
                return;
            }
            Console.WriteLine("与服务器链接成功！！！");
            try
            {
                Thread.Sleep(1000);    //等待1秒钟  
                //通过 socketClient 向服务器发送数据
                string sendMessage = "已成功接到SocketClient发送的消息";//发送到服务端的内容
                byte[] send = Encoding.UTF8.GetBytes(sendMessage);//Encoding.UTF8.GetBytes()将要发送的字符串转换成UTF8字节数组
                byte[] SendMsg = new byte[send.Length + 1];//定义新的字节数组
                SendMsg[0] = 0;//将数组第一位设置为0，来表示发送的是消息数据  
                Buffer.BlockCopy(send, 0, SendMsg, 1, send.Length);//偏移复制字节数组
                socketClient.Send(SendMsg);  //将接受成功的消息返回给SocketServer服务器 
                Console.WriteLine("发送完毕：{0}", sendMessage);

            }                                                                                                                     
            catch
            {
                socketClient.Shutdown(SocketShutdown.Both);//禁止Socket上的发送和接受
                socketClient.Close();//关闭Socket并释放资源
            }
            //打开文件
            OpenFileDialog ofd = new OpenFileDialog();
            ofd.Title = "选择要传的文件";
            ofd.InitialDirectory = @"E:IVSDown";
            //ofd.Filter = "文本文件|*.txt|图片文件|*.jpg|视频文件|*.avi|所有文件|*.*";
            ofd.ShowDialog();
            //得到选择文件的路径
            string filePath = ofd.FileName;//获取文件的完整路径
            Console.WriteLine("发送的文件路径为："+filePath);
            using (FileStream fsRead = new FileStream(filePath, FileMode.OpenOrCreate, FileAccess.Read))
            {
                //1. 第一步：发送一个文件，表示文件名和长度，让客户端知道后续要接收几个包来重新组织成一个文件
                string fileName = Path.GetFileName(filePath);
                Console.WriteLine("发送的文件名是：" + fileName);
                long fileLength = fsRead.Length;//文件长度
                Console.WriteLine("发送的文件长度为："+fileLength);
                string totalMsg = string.Format("{0}-{1}", fileName, fileLength);
                byte[] buffer = Encoding.UTF8.GetBytes(totalMsg); 
                byte[] newBuffer = new byte[buffer.Length + 1];
                newBuffer[0] = 2;
                Buffer.BlockCopy(buffer, 0, newBuffer, 1, buffer.Length);
                socketClient.Send(newBuffer);//发送文件前，将文件名和长度发过去
                //2第二步：每次发送一个1MB的包，如果文件较大，则会拆分为多个包
                byte[] Filebuffer = new byte[1024 * 1024 * 5];//定义1MB的缓存空间
                int readLength = 0;  //定义读取的长度
                bool firstRead = true;
                long sentFileLength = 0;//定义发送的长度
                while ((readLength = fsRead.Read(buffer, 0, buffer.Length)) > 0 && sentFileLength < fileLength)
                {
                    sentFileLength += readLength;
                    //第一次发送的字节流上加个前缀1
                    if (firstRead)
                    {
                        byte[] firstBuffer = new byte[readLength + 1];
                        firstBuffer[0] = 1;//标记1，代表为文件
                        Buffer.BlockCopy(buffer, 0, firstBuffer, 1, readLength);
                        socketClient.Send(firstBuffer, 0, readLength + 1, SocketFlags.None);
                        Console.WriteLine("第一次读取数据成功，在前面添加一个标记");
                        firstRead = false;
                        continue;
                    }
                    socketClient.Send(buffer, 0, readLength, SocketFlags.None);
                    Console.WriteLine("{0}: 已发送数据：{1}/{2}", socketClient.RemoteEndPoint, sentFileLength, fileLength);
                }
                fsRead.Close();
                Console.WriteLine("发送完成");
            }
            Console.ReadLine();
        }
    }

}

Server

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.IO;
using System.Windows.Forms;

namespace SocketServer
{
    class Program
    {
        [STAThread]
        static void Main(string[] args)
        {
            SocketServer();
        }
        public static string serverIp = "127.0.0.1";//设置服务端IP
        public static int serverPort = 8888;//服务端端口
        public static Socket socketServer;//定义socket
        public static Thread threadWatch;//定义线程
        public static byte[] result = new byte[1024 * 1024 * 2];//定义缓存
        //public static string fileName;//获取文件名
        public static string filePath = "";//存储保存文件的路径
        public static void SocketServer()
        {
            socketServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建一个socket的对象
            IPAddress ip = IPAddress.Parse(serverIp);//获取服务器IP地址
            IPEndPoint point = new IPEndPoint(ip, serverPort);//获取端口
            try
            {
                socketServer.Bind(point);//绑定IP地址及端口
            }
            catch (Exception ex)
            {
                Console.WriteLine("绑定IP时出现异常：" + ex.Message);
                return;
            }
            socketServer.Listen(100);//开启监听并设定最多10个排队连接请求
            threadWatch = new Thread(WatchConnect);//创建一个监听进程
            threadWatch.IsBackground = true;//后台启动
            threadWatch.Start();//运行
            Console.WriteLine("服务器{0}监听启动成功！", socketServer.LocalEndPoint.ToString());
            Console.ReadLine();
        }
        public static void WatchConnect()
        {
            while (true)
            {
                Socket watchConnect = socketServer.Accept();//接收连接并返回一个新的Socket
                watchConnect.Send(Encoding.UTF8.GetBytes("服务器连接成功"));//在客户端显示"服务器连接成功"提示
                Thread threadwhat = new Thread(ReceiveMsg);//创建一个接受信息的进程
                threadwhat.IsBackground = true;//后台启动
                threadwhat.Start(watchConnect);//有传入参数的线程
            }
        }
        public static DateTime GetTime()
        {
            DateTime now = new DateTime();
            now = DateTime.Now;
            return now;
        }
        public static void ReceiveMsg(object watchConnect)
        {
            Socket socketServer = watchConnect as Socket;
            long fileLength = 0;//文件长度
            string recStr = null;//文件名
            while (true)
            {
                int firstRcv = 0;
                byte[] buffer = new byte[1024 * 1024 * 5];
                try
                {
                    //获取接受数据的长度，存入内存缓冲区，返回一个字节数组的长度
                    if (socketServer != null) firstRcv = socketServer.Receive(buffer);
                    if (firstRcv > 0)//大于0，说明有东西传过来
                    {
                        if (buffer[0] == 0)//0对应文字信息
                        {
                            string recMsg = Encoding.UTF8.GetString(buffer, 1, firstRcv - 1);
                            Console.WriteLine("客户端接收到信息：" + socketServer.LocalEndPoint.ToString() + "
" + GetTime() + "
" + recMsg + "
");
                        }

                        if (buffer[0] == 1)//1对应文件信息
                        {
                            SaveFileDialog sfDialog = new SaveFileDialog();//创建SaveFileDialog实例
                            string spath = @"E:存放";//制定存储路径
                            string savePath = Path.Combine(spath, recStr);//获取存储路径及文件名
                            int rec = 0;
                            long recFileLength = 0;
                            bool firstWrite = true;
                            using (FileStream fs = new FileStream(savePath, FileMode.Create, FileAccess.Write))
                            {
                                while (recFileLength < fileLength)
                                {
                                    if (firstWrite)
                                    {
                                        fs.Write(buffer, 1, firstRcv - 1);
                                        fs.Flush();
                                        recFileLength += firstRcv - 1;
                                        firstWrite = false;
                                    }
                                    else
                                    {
                                        rec = socketServer.Receive(buffer);
                                        fs.Write(buffer, 0, rec);
                                        fs.Flush();
                                        recFileLength += rec;
                                    }
                                    Console.WriteLine("{0}: 已接收数据：{1}/{2}", socketServer.RemoteEndPoint, recFileLength, fileLength);
                                }
                                fs.Close();
                            }
                            Console.WriteLine("保存成功！！！！");
                        }
                        if (buffer[0] == 2)//2对应文件名字和长度
                        {
                            string fileNameWithLength = Encoding.UTF8.GetString(buffer, 1, firstRcv - 1);
                            recStr = fileNameWithLength.Split('-').First();//获取文件名
                            Console.WriteLine("接收到的文件名为：" + recStr);
                            fileLength = Convert.ToInt64(fileNameWithLength.Split('-').Last());//获取文件长度
                            Console.WriteLine("接收到的文件长度为：" + fileLength);
                        }
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine("系统异常..." + ex.Message);
                    break;
                }
            }

            //while (true)
            //{
            //    int num = -1;//初始化num
            //    string reveiceName;//定义字符串
            //    try
            //    {
            //        num = socketClient.Receive(result);//获取客户端信息
            //        reveiceName = Encoding.UTF8.GetString(result, 0, num);//把从0到num的字节变成String
            //    }
            //    catch (SocketException ex)
            //    {
            //        Console.WriteLine("异常：" + ex.Message + ", RemoteEndPoint: " + socketClient.RemoteEndPoint.ToString());
            //        break;
            //    }
            //    catch (Exception ex)
            //    {
            //        Console.WriteLine("异常：" + ex.Message);
            //        break;
            //    }

            //while (true)
            //{

            //try
            //{
            //    /// <summary>
            //    /// 存储大文件的大小
            //    /// </summary>
            //   long length = 0;
            //   long recive = 0; //接收的大文件总的字节数
            //    while (true)
            //    {
            //        byte[] buffer = new byte[1024 * 1024];
            //        int r = socketClient.Receive(buffer);
            //        Console.WriteLine("接受到的字符长度" + r);
            //        if (r == 0)
            //        {
            //            break;
            //        }
            //        Console.WriteLine("第二次的length长度为：" + length);
            //        if (length > 0)  //判断大文件是否已经保存完
            //        {
            //            //保存接收的文件
            //            using (FileStream fsWrite = new FileStream(filePath, FileMode.Append, FileAccess.Write))
            //            {
            //                Console.WriteLine("-----------------11111111111111111111111-----------------------------");
            //                fsWrite.Write(buffer, 0, r);
            //                length -= r; //减去每次保存的字节数
            //                Console.WriteLine("{0}: 已接收：{1}/{2}", socketClient.RemoteEndPoint, recive - length, recive);
            //                if (length <= 0)
            //                {
            //                    Console.WriteLine(socketClient.RemoteEndPoint + ": 接收文件成功");
            //                }
            //                continue;
            //            }
            //        }
            //        if (buffer[0] == 0) //如果接收的字节数组的第一个字节是0，说明接收的字符串信息
            //        {
            //            string strMsg = Encoding.UTF8.GetString(buffer, 1, r - 1);
            //            Console.WriteLine("*****************0000000000000000000000*********************");
            //            Console.WriteLine(socketClient.RemoteEndPoint.ToString() + ": " + strMsg);
            //        }
            //        else if (buffer[0] == 1) //如果接收的字节数组的第一个字节是1，说明接收的是文件
            //        {
            //            Console.WriteLine("++++++++++++++111111111111111111111+++++++++++++++++++");
            //            length = int.Parse(Encoding.UTF8.GetString(buffer, 1, r - 1));
            //            recive = length;
            //            Console.WriteLine("接收到的字节长度是多少呢：？" + length);
            //            SaveFileDialog sfd = new SaveFileDialog();
            //            sfd.Title = "保存文件";
            //            sfd.InitialDirectory = @"C:UsersAdministratorDesktop";
            //            //sfd.Filter = "文本文件|*.txt|图片文件|*.jpg|视频文件|*.avi|所有文件|*.*";
            //            //如果没有选择保存文件路径就一直打开保存框
            //            SaveFileDialog save = new SaveFileDialog();//创建SaveFileDialog实例
            //            string spath = @"C:UsersadminDesktop";//制定存储路径
            //            filePath = Path.Combine(spath, fileName);//获取存储路径及文件名
            //        }
            //    }
            //}
            //catch { }

            //}
















            //try
            //{
            //    if (reveiceName[0] == 0)//判断数组第一个值，如果为0则说明传的是信息
            //    {
            //        fileName = Encoding.UTF8.GetString(result, 1, num - 1);//提取字节信息并转换成String
            //        Console.WriteLine("接收客户端的消息：{0}", fileName);
            //    }
            //    if (reveiceName[0] == 1)//判断数组第一个值，如果为1则说明传的是文件
            //    {
            //        SaveFileDialog save = new SaveFileDialog();//创建SaveFileDialog实例
            //        string spath = @"C:UsersadminDesktop";//制定存储路径
            //        string fullPath = Path.Combine(spath, fileName);//获取存储路径及文件名
            //        //FileStream filesave = new FileStream(fullPath, FileMode.Create, FileAccess.Write);//创建文件流，用来写入数据
            //        //filesave.Write(result, 1, num - 1);//将数据写入到文件中
            //        //filesave.Close();
            //        //Console.WriteLine("保存成功！！！");
            //        //**************************************************************************************************
            //        while (true)
            //        {
            //            byte[] buffer = new byte[1024 * 1024];
            //            int r = socketClient.Receive(buffer);
            //            Console.WriteLine("从客户端接收到的字节数："+r);
            //            //string leng = Encoding.UTF8.GetString(buffer, 1, r - 1);
            //            int recive = r - 1;
            //            //Console.WriteLine(leng);
            //            //long recive = int.Parse(leng);
            //            //long recive = Convert.ToInt64(Encoding.UTF8.GetString(buffer, 1, r - 1));
            //            Console.WriteLine("总接受字节数：" + recive);
            //            long length = recive;
            //            Console.WriteLine("*******************************************");
            //            if (length > 0)
            //            {
            //                using (FileStream fsWrite = new FileStream(fullPath, FileMode.Append, FileAccess.Write))
            //                {
            //                    Console.WriteLine("---------*************--------------");
            //                    fsWrite.Write(buffer,1, r-1);
            //                    length -= r; //减去每次保存的字节数
            //                    Console.WriteLine("剩余接受字节数："+length);
            //                    Console.WriteLine(string.Format("{0}: 已接收：{1}/{2}", socketClient.RemoteEndPoint, recive - length, recive));
            //                    if (length <= 0)
            //                    {
            //                        Console.WriteLine(socketClient.RemoteEndPoint + ": 接收文件成功");
            //                    }
            //                }
            //            }
            //        }


            //        //long recive = 0; //接收的大文件总的字节数
            //        //while (true)
            //        //{
            //        //    //byte[] buffer = new byte[1024 * 1024];
            //        //    //int r = socketClient.Receive(buffer);

            //        //    if (num == 0)
            //        //    {
            //        //        break;
            //        //    }
            //        //    if (length > 0)  //判断大文件是否已经保存完
            //        //    {
            //        //        //保存接收的文件
            //        //        using (FileStream fsWrite = new FileStream(fullPath, FileMode.Append, FileAccess.Write))
            //        //        {
            //        //            fsWrite.Write(result, 1, num-1);
            //        //            length -= num; //减去每次保存的字节数
            //        //            Console.WriteLine(string.Format("{0}: 已接收：{1}/{2}", socketClient.RemoteEndPoint, recive-length, recive));
            //        //            if (length <= 0)
            //        //            {
            //        //               Console.WriteLine(socketClient.RemoteEndPoint + ": 接收文件成功");
            //        //            }
            //        //            continue;
            //        //        }                        
            //        //    }
            //    }
            //}
            //catch (Exception ex)
            //{

            //    Console.WriteLine(ex.Message);
            //}

            //}

        }
    }
}