C# 实现IP视频监控（摄像头）画面推送（简单的不能再简单的DEMO）
C# 实现ip视频监控（摄像头）画面推送（简单的不能再简单的DEMO）
最近继续在家休息，在完成上一个Python抓取某音乐网站爬虫后，琢磨着实现一个基于HTTP推送的 IP视频监控，比如外出的时候，在家里
开启一个监控端（摄像头+服务端），可以看到实时画面，如果再加上自动告警，就更好了。公网访问需要在 路由器上设置 花生壳+端口转发。
计划在退休的安卓手机上实现这IP视频监控软件，虽然应用市场一大堆别人写好的软件，不过我觉得吧，既然是程序员，自己敲代码实现的软件会
更有成就感。考虑到需要先验证下方案的可行性，我用比较熟悉的C# 控制台实现了一个DEMO。
设想的方案：
1.实现一个简单HTTP服务器，用来接受请求并启动一个线程处理图片流的推送功能
2.开发一个实时抓取图片的线程，并将图片交给HTTP推送线程
3.HTTP的请求URL参数中 附带推送频率、图片高度和宽度
4.使用一个IP摄像头监控端（或者Firefox浏览器），实时查看视频画面
5.循环录制视频（未实现）
6.对画面进行监控告警（未实现）
核心技术点：
1.HttpListener （HTTP.SYS）
2.HTTP ：multipart/x-mixed-replace;
3.线程同步、委托、事件
4.摄像头驱动、图片抓取（AndrewKirillov 写的）
5.图片流解析，显示（AndrewKirillov 写的，也可以直接在Firefox浏览器打开直接显示）
运行截图：
1.视频监控端 （AndrewKirillov 写的 视频源支持N种，当前配置推送频率50毫秒 w=240&h=120）
2.视频服务端（我写的 简陋的DEMO 不过实现了功能 嘎嘎）
下面开始贴核心源码（最近右胳膊有石膏，左手写代码 凑合看吧！）：
1.建立HTTP服务：
1 using (HttpListener listerner = new HttpListener()) 2 { 3 listerner.AuthenticationSchemes = AuthenticationSchemes.Anonymous;//指定身份验证 Anonymous匿名访问 4 listerner.PRefixes.Add("http://+:6666/"); 5 6 //listerner.Prefixes.Add("http://+/"); 7 //listerner.Prefixes.Add("http://+:8080/"); 8 //listerner.Prefixes.Add("http://+:6666/"); 9 //listerner.Prefixes.Add("http://+/video.cgi/");10 //listerner.Prefixes.Add("http://+:8080/video.cgi/");11 12 listerner.Start();13 Console.WriteLine("WebServer Start Successed.......");14 while (true)15 {16 try17 {18 //等待请求连接19 //没有请求则GetContext处于阻塞状态20 HttpListenerContext ctx = listerner.GetContext();21 22 SendImgService oService = new SendImgService();23 oService.Ctx = ctx;24 localsev.NewFrame += new CameraEventHandler(oService.camera_NewFrame);25 ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc), oService);26 27 //Thread osThread = new Thread(new ThreadStart(oService.ServiceRun));28 //osThread.Start();29 }30 catch (Exception ex)31 {32 Console.WriteLine(ex);33 }34 }35 listerner.Stop();36 listerner.Close();37 }
View Code2.启动本地视频头，并抓取图片
1 public void ServiceRun() 2 { 3 4 FilterCollection filters = new FilterCollection(FilterCategory.VideoInputDevice); 5 6 if (filters.Count == 0) 7 throw new applicationException(); 8 9 // add all devices to combo10 foreach (Filter filter in filters)11 {12 Console.WriteLine(filter.Name + "：" + filter.MonikerString);13 }14 CaptureDevice localSource = new CaptureDevice();15 localSource.VideoSource = filters[0].MonikerString;16 17 // create camera18 camera = new Camera(localSource);19 // start camera20 camera.Start();21 22 23 // set event handlers24 camera.NewFrame += new CameraEventHandler(camera_NewFrame);25 26 }27 28 // On new frame ready29 private void camera_NewFrame(object sender, CameraEventArgs e)30 {31 if (seq == 999)32 {33 seq = 0;34 }35 // Console.WriteLine("LocalCamService get camera_NewFrame ==> {0}", ++seq);36 37 // lock38 Monitor.Enter(this);39 40 if (camera != null)41 {42 camera.Lock();43 44 // dispose old frame45 if (lastFrame != null)46 {47 lastFrame.Dispose();48 }49 // draw frame50 if (camera.LastFrame != null)51 {52 lastFrame = (Bitmap)camera.LastFrame.Clone();53 // notify client54 if (NewFrame != null)55 NewFrame(this, new CameraEventArgs(lastFrame));56 }57 58 59 camera.Unlock();60 }61 62 // unlock63 Monitor.Exit(this);64 }65 }
View Code3.图片推送
1 public void ServiceRun() 2 { 3 remoteInfo = ctx.Request.RemoteEndPoint.ToString(); 4 string intervalstr = ctx.Request.QueryString["i"]; 5 string widthstr = ctx.Request.QueryString["w"]; 6 string heightstr = ctx.Request.QueryString["h"]; 7 8 if (!string.IsNullOrWhiteSpace(intervalstr)) 9 {10 interval = int.Parse(intervalstr);11 }12 if (!string.IsNullOrWhiteSpace(widthstr))13 {14 width = int.Parse(widthstr);15 }16 if (!string.IsNullOrWhiteSpace(heightstr))17 {18 height = int.Parse(heightstr);19 }20 Console.WriteLine("Accept one new request:{0},interval:[{1}]", remoteInfo, interval);21 22 23 ctx.Response.StatusCode = 200;//设置返回给客服端http状态代码24 ctx.Response.ContentType = "multipart/x-mixed-replace; boundary=--BoundaryString";25 26 string rspheard = "--BoundaryString\r\nContent-type: image/jpg\r\nContent-Length: {0}\r\n\r\n";27 string strrn = "\r\n";28 29 using (Stream stream = ctx.Response.OutputStream)30 {31 while (true)32 {33 Thread.Sleep(interval);34 35 try36 {37 // lock38 Monitor.Enter(this);39 40 if (newFrame == null)41 {42 continue;43 }44 //得到一个ms对象45 byte[] imageBuffer;46 using (MemoryStream ms = new MemoryStream())47 {48 49 //newFrame = (Bitmap)GetThumbnail(newFrame, width, height);50 //将图片保存至内存流51 newFrame.Save(ms, ImageFormat.Jpeg);52 53
