目录

1       大概思路... 1

2       Nginx集群之WCF大文件上传及下载... 1

3       BasicHttpBinding相关配置解析... 2

4       编写WCF服务、客户端程序... 3

5       URL保留项... 8

6       部署WCF服务程序到局域网内1台PC机... 8

7       Nginx集群配置搭建... 9

8       WCF客户端程序的运行结果... 11

9       总结... 13

using System.ServiceModel;

using Service;

using System;

namespace FileTransferHosting

{

    class Program

    {

        static void Main(string[] args)

        {

            using (ServiceHost host = new ServiceHost(typeof(FileTransferOperation)))

            {

                host.Opened += delegate

                {

                    Console.WriteLine(host.Description.Endpoints[].Address.Uri + "已经启动，按任意键终止服务！");

                };

                host.Open();

                Console.Read();

            }

        }

    }

}

using Service.Interface;

using System;

using System.IO;

using System.ServiceModel;

namespace Service

{

    [ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Multiple)]

    public class FileTransferOperation : IFileTransferOperation

    {

        /// <summary>

        /// 上传文件

        /// </summary>

        /// <param name="remoteFile"></param>

        public void UploadLoad(RemoteFileInfo remoteFile)

        {

            StreamToFile(remoteFile);

        }

        /// <summary>

        /// 写文件

        /// </summary>

        /// <param name="remoteFile"></param>

        public void StreamToFile(RemoteFileInfo remoteFile)

        {

            string fileFullPath = Path.Combine(System.Environment.CurrentDirectory, remoteFile.FileName);

            Stream sourceStream = remoteFile.FileByteStream;

            if (sourceStream == null) { return; }

            if (!sourceStream.CanRead) { return; }

            //创建文件流，读取流中的数据生成文件

            using (FileStream fs = new FileStream(fileFullPath, FileMode.Create, FileAccess.Write, FileShare.None))

            {

                const int bufferLength = ;

                byte[] myBuffer = new byte[bufferLength];//数据缓冲区

                int count;

                while ((count = sourceStream.Read(myBuffer, , bufferLength)) > )

                {

                    fs.Write(myBuffer, , count);

                }

                fs.Close();

                sourceStream.Close();

            }

        }

        /// <summary>

        /// 下载文件

        /// </summary>

        /// <param name="fileName"></param>

        /// <returns></returns>

        public Stream DownLoad(string fileName)

        {

            string fileFullPath = Path.Combine(System.Environment.CurrentDirectory, fileName);

            if (!File.Exists(fileFullPath))//判断文件是否存在

            {

                return null;

            }

            try

            {

                Stream myStream = File.OpenRead(fileFullPath);

                return myStream;

            }

            catch { return null; }

        }

    }

}

<?xml version="1.0" encoding="utf-8" ?>

<configuration>

  <system.serviceModel>

    <behaviors>

      <serviceBehaviors>

        <behavior name="FileTransferBehavior">

          <serviceMetadata httpGetEnabled="true" />

          <serviceDebug includeExceptionDetailInFaults="true" />

        </behavior>

      </serviceBehaviors>

    </behaviors>

    <bindings>

      <basicHttpBinding>

        <binding name="FileTransferdBinding" receiveTimeout="00:30:00" sendTimeout="00:30:00" maxReceivedMessageSize="" transferMode="Streamed"

            messageEncoding="Mtom" />

      </basicHttpBinding>

    </bindings>

    <services>

      <service behaviorConfiguration="FileTransferBehavior" name="Service.FileTransferOperation">

        <endpoint binding="basicHttpBinding" bindingConfiguration="FileTransferdBinding"

            contract="Service.Interface.IFileTransferOperation" />

        <host>

          <baseAddresses>

            <add baseAddress="http://127.0.0.1:5600/fileupload" />

          </baseAddresses>

        </host>

      </service>

    </services>

  </system.serviceModel>

</configuration>

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Text;

using FileTransferClient.FileTransferService;

namespace FileTransferClient

{

    class Program

    {

        static void Main(string[] args)

        {

            Console.WriteLine("请输入文件完整路径：");

            string fullFilePath = Console.ReadLine().Trim();

            using (FileTransferOperationClient proxy=new FileTransferOperationClient())

            {

                DateTime datetime1 = DateTime.Now;

                byte[] buffer = System.IO.File.ReadAllBytes(fullFilePath);

                Stream streamBuffer= new MemoryStream(buffer);

                //上传文件

                proxy.UploadLoad(buffer.Length, System.IO.Path.GetFileName(fullFilePath), streamBuffer);

                OutPutDiffTime(DateTime.Now, datetime1, "上传成功");

                Console.WriteLine("开始下载文件：");

                DateTime datetime2 = DateTime.Now;

                string filename = System.IO.Path.GetFileName(fullFilePath);

                //下载文件

                Stream sourceStream = proxy.DownLoad(filename);

                if (sourceStream == null) { return; }

                if (!sourceStream.CanRead) { return; }

                //创建文件流，读取流中的数据生成文件

                using (FileStream fs = new FileStream(Path.Combine(System.Environment.CurrentDirectory, filename), FileMode.Create, FileAccess.Write, FileShare.None))

                {

                    const int bufferLength = ;

                    //数据缓冲区

                    byte[] myBuffer = new byte[bufferLength];

                    int count;

                    while ((count = sourceStream.Read(myBuffer, , bufferLength)) > )

                    {

                        fs.Write(myBuffer, , count);

                    }

                    fs.Close();

                    sourceStream.Close();

                }

                OutPutDiffTime(DateTime.Now, datetime2, "下载成功");

                Console.Read();

            }

        }

        public static void OutPutDiffTime(DateTime datetime2,DateTime datetime1,string mesg)

        {

            TimeSpan ts = (datetime2 - datetime1);

            string dateDiff = ts.Hours.ToString() + "小时"

                    + ts.Minutes.ToString() + "分钟"

                    + ts.Seconds.ToString() + "秒";

            Console.WriteLine(String.Format("花费了{0},{1}", dateDiff, mesg));

        }

    }

}

<?xml version="1.0" encoding="utf-8" ?>

<configuration>

  <system.serviceModel>

    <bindings>

      <basicHttpBinding>

        <binding name="BasicHttpBinding_IFileTransferOperation" receiveTimeout="00:30:00"

          sendTimeout="00:30:00" maxReceivedMessageSize="" transferMode="Streamed"

          messageEncoding="Mtom" />

      </basicHttpBinding>

    </bindings>

    <client>

      <endpoint address="http://zhyongfeng.com/fileupload" binding="basicHttpBinding"

        bindingConfiguration="BasicHttpBinding_IFileTransferOperation"

        contract="FileTransferService.IFileTransferOperation" name="BasicHttpBinding_IFileTransferOperation" />

    </client>

  </system.serviceModel>

</configuration>

10.93.85.66    zhyongfeng.com

worker_processes  1;

events {

    worker_connections  1024;

}

http {

    include       mime.types;

    default_type  application/octet-stream;

    sendfile        on;

    keepalive_timeout  65;

    upstream zhyongfeng.com {

        server    10.92.202.56:5600;

        server    10.92.202.57:5700;

        server    10.92.202.58:5800;

    }

    server {

        listen       80;

        server_name  zhyongfeng.com;

        location / {

            proxy_pass   http://zhyongfeng.com;

            proxy_connect_timeout       10s;

        }

    location /fileupload {

            proxy_pass   http://10.92.202.56:5600/fileupload;

            proxy_connect_timeout       10s;

        }

    }

}

D:\DTLDownLoads\nginx-1.10.2>start nginx

D:\DTLDownLoads\nginx-1.10.2>nginx -s reload