11

gx_api/GxPress/Api/GxPress.Api/AppControllers/videoController.cs

@@ -1,12 +1,10 @@
 using System.IO;
-using System.Threading.Tasks;
-using Aliyun.Acs.Core.Http;
-using Aliyun.Acs.Core.Utils;
+using GxPress.Service.Interface.Video;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.StaticFiles;
-
+using Microsoft.Extensions.Caching.Distributed;
 namespace GxPress.Api.AppControllers
 {
     /// <summary>
@@ -18,10 +16,13 @@ namespace GxPress.Api.AppControllers
     public class VideoController : ControllerBase
     {
         private readonly IWebHostEnvironment _environment;
-
-        public VideoController(IWebHostEnvironment environment)
+        private readonly IDistributedCache _cache;
+        private readonly IVideoService videoService;
+        public VideoController(IWebHostEnvironment environment, IDistributedCache cache, IVideoService videoService)
         {
             _environment = environment;
+            _cache = cache;
+            this.videoService = videoService;
         }
         /// <summary>
         /// 
@@ -29,24 +30,40 @@ namespace GxPress.Api.AppControllers
         /// <returns></returns>
         [HttpGet]
         [AllowAnonymous]
-        public IActionResult GetVideo()
+        public IActionResult GetVideo(int page)
         {
             try
             {
-                // HttpResponse response = new HttpResponse();
-                var dd = Common.Tools.StringUtils.GetWebRootPath(_environment.WebRootPath);
-                var fis = new FileStream(dd + "/cache/20200428/music.mp4", FileMode.Open);
-                var size = fis.Length; // 得到文件大小
-                var data = new byte[size];
-                fis.Write(data, 0, data.Length);
-                var filepath = dd + "/cache/20200428/music.mp4";
-                var provider = new FileExtensionContentTypeProvider();
+                var path = Common.Tools.StringUtils.GetWebRootPath(_environment.WebRootPath);
+                var filepath = path + "/cache/20200428/music.mp4";
                 FileInfo fileInfo = new FileInfo(filepath);
+                var key = $"music.mp4{page}";
+                var result = _cache.Get(key);
+                if (result != null)
+                {
+                    return File(result, "application/octet-stream", fileInfo.Name);
+                }
+                var blength = 1024 * 1024 * 5;
+                byte[] bytsize = new byte[blength];
+                //获取文件名后缀
+                string extension = Path.GetExtension(filepath);
+                //
+                videoService.RedisVideo(filepath, bytsize, blength, "music.mp4");
+                //获取文件流
+                using (FileStream stream = new FileStream(filepath, FileMode.OpenOrCreate, FileAccess.ReadWrite))
+                {
+                    while (true)
+                    {
+                        int r = stream.Read(bytsize, 0, blength);
+                        //如果读取到的字节数为0，说明已到达文件结尾，则退出while循
+                        break;
+                    }
+                    stream.Close();
+                }
+                //获取后缀名
                 var ext = fileInfo.Extension;
                 new FileExtensionContentTypeProvider().Mappings.TryGetValue(ext, out var contenttype);
-                var result = File(data, contenttype ?? "application/octet-stream", fileInfo.Name);
-                fis.Close();
-                return result;
+                return File(bytsize, contenttype ?? "application/octet-stream", fileInfo.Name);
             }
             catch (FileNotFoundException e)
             {

gx_api/GxPress/Service/GxPress.Service.Implement/Video/VideoService.cs

@@ -0,0 +1,67 @@
+using System;
+using System.IO;
+using System.Threading;
+using GxPress.Service.Interface.Video;
+using Microsoft.Extensions.Caching.Distributed;
+
+namespace GxPress.Service.Implement.Video
+{
+    public class VideoService : IVideoService
+    {
+        private readonly IDistributedCache _cache;
+        public VideoService(IDistributedCache cache)
+        {
+            _cache = cache;
+        }
+        public void RedisVideo(string filepath, byte[] bytsize, int blength, string videoName)
+        {
+            //创建后台工作线程
+            Thread t2 = new Thread(new ParameterizedThreadStart(RedisSendAsync));
+            t2.IsBackground = true;//设置为后台线程
+            var redisVideoModel = new RedisVideoParameter
+            {
+                ByteLength = blength,
+                FilePath = filepath,
+                ByteSize = bytsize,
+                VideoName = videoName
+            };
+            t2.Start(redisVideoModel);
+        }
+        public void RedisSendAsync(object data)
+        {
+            //转换
+            var redisVideoModel = data as RedisVideoParameter;
+            var byteSize = new byte[redisVideoModel.ByteLength];
+            //获取文件流
+            using (FileStream stream = new FileStream(redisVideoModel.FilePath, FileMode.OpenOrCreate, FileAccess.ReadWrite))
+            {
+                int i = 1;
+                while (true)
+                {
+                    var cacheKey = redisVideoModel.VideoName + i;
+                    var result = _cache.Get(cacheKey);
+                    int r = stream.Read(redisVideoModel.ByteSize, 0, redisVideoModel.ByteLength);
+                    //如果读取到的字节数为0，说明已到达文件结尾，则退出while循
+                    if (r == 0)
+                        break;
+                    if (result==null)
+                    {
+                        _cache.Set(cacheKey, redisVideoModel.ByteSize, new DistributedCacheEntryOptions { AbsoluteExpirationRelativeToNow = TimeSpan.FromSeconds(6000) });
+                    }
+                    //初始化
+                    redisVideoModel.ByteSize = new byte[redisVideoModel.ByteLength];
+                    i++;
+                }
+                stream.Close();
+            }
+        }
+    }
+
+    public class RedisVideoParameter
+    {
+        public string FilePath { get; set; }
+        public byte[] ByteSize { get; set; }
+        public int ByteLength { get; set; }
+        public string VideoName { get; set; }
+    }
+}

gx_api/GxPress/Service/GxPress.Service.Interface/Video/IVideoService.cs

@@ -0,0 +1,7 @@
+namespace GxPress.Service.Interface.Video
+{
+    public interface IVideoService : IService
+    {
+        void RedisVideo(string filepath, byte[] bytsize, int blength, string videoName);
+    }
+}