图片分布式存储

优点：图片分布式存储主要解决服务器存储压力，以及提高查询速度；

方案：用户发起上传请求，在发起请求的服务器中，根据图片信息表中的数据查找可用的服务器，此时可能查找多台服务器，那么根据从状态表筛选出可用的图片服务器集合记作C,并获取集合的总记录数N。然后用随机函数产生一个随机数R1并用R1与N进行取余运算记作I=R1%N。则C[I]即为要保存图片的图片服务器，选择可用的服务器，然后使用WebClient发起请求，在可用的服务器中存储图片，具体如下：

解决步骤：

          1.在数据库中新建两个表分别是ImageServerInfo，ImageInfo；

           表：ImageServerInfo　　

　　　　　

CREATE TABLE [dbo].[ImageServerInfo](
[ServerId] [int] IDENTITY(1,1) NOT NULL,
[ServerName] [nvarchar](32) NOT NULL,
[ServerUrl] [nvarchar](100) NOT NULL,
[FlgUsable] [bit] NOT NULL,
CONSTRAINT [PK_ImageServerInfo] PRIMARY KEY CLUSTERED
(
[ServerId] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]

GO

         表：ImageInfo  

　　　　　　

CREATE TABLE [dbo].[ImageInfo](
[Id] [int] IDENTITY(1,1) NOT NULL,
[ImageName] [nvarchar](100) NOT NULL,
[ImageServerId] [int] NOT NULL,
CONSTRAINT [PK_ImageInfo] PRIMARY KEY CLUSTERED
(
[Id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]

GO

ALTER TABLE [dbo].[ImageInfo] WITH CHECK ADD CONSTRAINT [FK_ImageInfo_ImageServerInfo] FOREIGN KEY([ImageServerId])
REFERENCES [dbo].[ImageServerInfo] ([ServerId])
GO

ALTER TABLE [dbo].[ImageInfo] CHECK CONSTRAINT [FK_ImageInfo_ImageServerInfo]
GO

           2.新建mvc项目 添加一个控制器 并添加以下方法

public ActionResult FileUpload()
{
HttpPostedFileBase file = Request.Files["ImgFile"];

string fileName = file.FileName;

string fileExt = Path.GetExtension(fileName);

if (fileExt == ".jpg" || fileExt == ".png")
{
ImageServerEntities dbContext = new ImageServerEntities();

var isiList = dbContext.ImageServerInfo.Where(x => x.FlgUsable == true).ToList();

int countN = isiList.Count();

//从状态表筛选出可用的图片服务器集合记作C,并获取集合的总记录数N。然后用随机函数产生一个随机数R1并用R1与N进行取余运算记作I=R1%N。则C[I]即为要保存图片的图片服务器
Random rand = new Random();

int r1 = rand.Next();

int i = r1 % countN;

ImageServerInfo isi = isiList[i];

string url = string.Format("http://{0}/FileUp.ashx?serverId={1}&ext={2}", isi.ServerUrl, isi.ServerId, fileExt);

WebClient wc = new WebClient();

wc.UploadData(url, StreamToByteArray(file.InputStream));

return Content("success");
}
else { return Content("请注意文件类型！"); }
}

private byte[] StreamToByteArray(Stream stream)
{
byte[] buffer = new byte[stream.Length];

stream.Read(buffer, 0, buffer.Length);

stream.Seek(0, SeekOrigin.Begin);//设置当前流所在的位置：第一个参数是相对于第二个参数指定的位置的相对偏移位置。

return buffer;
}

3.新建两个web应用程序 分别代表分布在不同服务器上的应用程序
　　并在一般处理程序下添加如下方法

    

public void ProcessRequest(HttpContext context)
{
context.Response.ContentType = "text/plain";

string imgExt = context.Request["ext"];//获取文件扩展名

string serverId = context.Request["serverId"];//获取数据库中表ImageServerInfo的标识

string imgNewName = Guid.NewGuid().ToString();//用Guid为新的文件重命名

string path = "/ImgFileUpload/" + DateTime.Now.Year + "/" + DateTime.Now.Month + "/" + DateTime.Now.Day + "/";//按照每年每月每天创建新的文件夹 避免因为大量的图片文件在同一个文件夹中，造成打开文件卡死现象

Directory.CreateDirectory(Path.GetDirectoryName(context.Server.MapPath(path)));//创建文件夹 此时类Directory内部已经判断是否存在该文件无需再次判断

string imgFullPath = path + imgNewName + imgExt;//拼接文件路径

using (FileStream fs=File.OpenWrite(context.Request.MapPath(imgFullPath)))
{
context.Request.InputStream.CopyTo(fs);//将请求文件流拷贝到需要写入文件的文件流

ImageServerEntities dbContext = new ImageServerEntities();
ImageInfo img = new ImageInfo() {
ImageName = imgFullPath,
ImageServerId=Convert.ToInt32(serverId)
};
dbContext.ImageInfo.Add(img);
dbContext.SaveChanges();
}
}

4.分别启动相应的应用程序 上传文件并测试