C# 使用UDP组播实现局域网桌面共享

时间：2014-05-08 15:23:43 阅读：998 评论：0 收藏：0 [点我收藏+]

最近需要在产品中加入桌面共享的功能，暂时不用实现远程控制；参考了园子里的一些文章，加入了一些自己的修改。

需求：将一台机器的桌面通过网络显示到多个客户端的屏幕上，显示内容可能为PPT，Word文档之类的内容，不含视频。

1）抓屏

参考了网上找到的一段代码如下

static BitmapSource CopyScreen()
{
    using (var screenBmp = new Bitmap((int)SystemParameters.PrimaryScreenWidth, (int)SystemParameters.PrimaryScreenHeight, System.Drawing.Imaging.PixelFormat.Format32bppArgb))
    {
        using (var bmpGraphics = Graphics.FromImage(screenBmp))
        {
            bmpGraphics.CopyFromScreen(0, 0, 0, 0, screenBmp.Size);
            return Imaging.CreateBitmapSourceFromHBitmap(
                screenBmp.GetHbitmap(),
                IntPtr.Zero,
                Int32Rect.Empty,
                BitmapSizeOptions.FromEmptyOptions());
        }
    }
}

看起来很简洁，但是运行后，发现居然有内存泄漏，内存持续上涨，从30MB一直上涨到了1G多，还不停止，遂修改如下，杜绝了内存泄漏：

调用API中的DeleteObject

 [System.Runtime.InteropServices.DllImport("gdi32.dll")]
        public static extern bool DeleteObject(IntPtr hObject);


private BitmapSource CopyScreen()
        {
            var handle = IntPtr.Zero;
            BitmapSource source = null;
            try
            {
                var bitmap = new Bitmap((int)SystemParameters.PrimaryScreenWidth,
                    (int)SystemParameters.PrimaryScreenHeight);

                var g = Graphics.FromImage(bitmap);

                g.CopyFromScreen(0, 0, 0, 0, bitmap.Size);

                handle = bitmap.GetHbitmap();

                source = Imaging.CreateBitmapSourceFromHBitmap(handle, IntPtr.Zero, Int32Rect.Empty,
                    BitmapSizeOptions.FromEmptyOptions());
            }
            finally
            {
                DeleteObject(handle);
            }

            return source;
        }

这样处理后，抓屏不再造成内存泄漏，内存占用稳定不再增长；

2）传输

因为共享客户端可能是一对多，所以不能再采用TCP点对点传输，尝试使用UDP组播的方式来传输数据，遇到了不少问题；

UDP组播的方法就不再赘述，使用组播的好处在于服务端的网络带宽占用不会因为客户端的增加而增加。

问题一：UDP报文有最大长度限制，所以无法一次发送一张图片

解决方案：自行切分传输，在接收端重组，定义报文类

class Packet
{
        public int SN {get;set;}  
        public byte[] Data {get;set;}
        public byte[] ToBytes() {....}
}

切分报文与重组报文，就不再详述。报文发送完毕之后，发送一个END标志，接收端重组报文，再显示图像。本机测试OK，然后放到客户端时，问题出来了。

问题二：UDP本身是不可靠传输，所以报文到达的顺序可能会乱，也有报文会丢失

解决方案：每一张图片，给予一个GUID，并加上一个时间戳；接收端采用具备缓冲区的接收方式；工作方式如下：

1）发送端：每一个时间间隔抓取一张图片，生成一个Guid，然后进行报文分割，再将报文发送到组播地址，每个报文包含GUID、报文数量、报文序号、时间戳以及数据；

2）接收端：

a）接收到一个报文后，放入报文池；

b）丢弃超时的报文（检查时间戳，超过某个时间的报文丢弃，例如5秒，这种应用不要求严格的数据完整性，收不到的，就丢弃）

c）检查缓冲区内的所有报文，检查将时间最早的报文，并检查其完整性（若报文应该有三个，是否已经收到三个同时具备该GUID的报文），若该GUID的报文已完整，则触发图片准备好的事件（ImageReady），并删除该图片的所有报文数据；

d）客户端通过ImageReady事件显示图像；

测试结果：本机测试OK，局域网测试又失败了，查看调试信息发现客户端总是只能收到所有报文中的第一个@……*#……@，其他的都丢失了~

问题三：局域网上UDP报文丢失？@#

解决方案：发送报文时，加入一定的时间间隔。这个是试出来的，原因可能是发太快了，网络传输不了，就丢失了；

最终代码结构如下：

报文类：

class Packet
{
          public double Time {get;set;}
          public int Total {get;set;}
          public int SN {get;set;}
          public byte[] Data {get;set;}
          public Packet() {...}
          public byte[] ToBytes() {....}
          public static Packet FromBytes(byte[] bytes){...}
}

public ShareServer
{
          public ShareServer()
          {

          }
          // 伪代码，非可运行代码
          public void Start()
          {
                    1）初始化UdpClient，进行组播
                    // 2）开一个线程，进入循环
                while (_doing)
                {
                    var source = CopyScreen();

                    if (source == null) continue;

                    var guid = Guid.NewGuid();
                    // JPEG 编码
                    var enc = new JpegBitmapEncoder() { QualityLevel = 40 };
                    var ms = new MemoryStream();
                    enc.Frames.Add(BitmapFrame.Create(source));
                    enc.Save(ms);

                    // 压缩MemoryStream
                    // GZipStream                   
                    var data = Compress(ms.ToArray());
                    // 分割报文
                    var packages = splitPackagets(data, guid);
                    // 传输报文
                    foreach (var packaget in packages)
                    {
                        var bytesArray = packaget.ToBytes();
                        _udpClient.Send(packaget.ToBytes(), bytesArray.Length);
                        // 加入一个间隔
                        Thread.Sleep(100);
                    }
                    // 1 秒抓一次图
                    Thread.Sleep(1000);
                }    
          }
}

接收端：

class BufferedScreenClient
{
        public  event EventHandler<ImageReadyEventArgs> ImageReady;
        private List<Packet> _packets;
        public BufferedScreenClient() {......}
        public void AddPacket(Packet packet)
        {
                1）添加报文
                2）清理超时报文
                3）检查最早的一张图片是否已经OK，如果OK触发ImageReady事件   
                        a) 首先查询出这一组的报文
                        b）合并这一组报文，获取数据
                        c）解压缩
                        d）JPEG解码成BitmapSource
                        e）移除该图片的报文数据
                        f）通过事件，将图片发送给接收端进行显示 

            _packagets.Add(packet);

            CleanPackets();

            var source = GetFirstImage();
            if (source != null)
            {
                OnImageReady(source);
            }
        }

private void CleanPackets(){....} 
        private void MergePackets(IEnuerable<Packet> packets){.....} 
        private BitmapSource GetFirstImage(){......}
}