分类导航

silverlight 发布时间：2022-05-03 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了Silverlight访问摄像头和麦克风(2)视频对话，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

概述

今天使用wcf的duplex方式实现了视频对话，但是很卡，晚上准备改写为Socket方式或者将客户端定时请求服务器资源改变为服务器主动回调客户端取资源。简要将今天的尝试记录一下。思路是文本聊天通过duplex方式进行，而视频部分则通过客户端定时将截屏发送到服务器，再由服务器转发到聊天对象。编写WCF服务端定义服务契约：代码 [serviceContract(CallBACkContrac

今天使用wcf的duplex方式实现了视频对话，但是很卡，晚上准备改写为Socket方式或者将客户端定时请求服务器资源改变为服务器主动回调客户端取资源。简要将今天的尝试记录一下。

思路是文本聊天通过duplex方式进行，而视频部分则通过客户端定时将截屏发送到服务器，再由服务器转发到聊天对象。

编写WCF服务端

定义服务契约：

代码

[serviceContract(CallBACkContract = typeof (IChatserviceCallBACk))]
     public interface IChatservice
    {
        [OperationContract]
         bool Login( String user, String partner);

        [OperationContract]
         bool Sendmessage(messageInfo messagE);

        [OperationContract]
        List < Uservideo > GetVideosByte( String userName, String partnerName);

        [OperationContract]
         void SendVideoByte(Uservideo video);
    }


    [serviceContract]
     public interface IChatserviceCallBACk
    {
        [OperationContract(IsOneWay = true )]
         void receive(List < messageInfo > messages);
    }

实现服务：

代码

public class Userupdate // 记录用户上次取消息的时间
   {
        public String UserName{ get ; set ;}
        public datetiR_727_11845@e LatestTime{ get ; set ;}
   }
    public class Chatservice : IChatservice
   {
       IChatserviceCallBACk callBACk;
       Timer timer;
        String _user;
        String _partner;
        public static List < Userupdate > listuserupdate = new List < Userupdate > (); // 存放用户取得消息的最近时间
        public static List < messageInfo > listmessages = new List < messageInfo > (); // 模拟存放聊天信息
        public static List < Uservideo > listVideos = new List < Uservideo > (); // 临时存放视频信息
        public void StartTimer()
       {
           timer = new Timer( new TimerCallBACk(CallClientToReceiveMsg), null , 500 , 500 ); // 定时回调客户端，传送资源
       }
        public bool Login( String user, String partner)
       {
            try
           {
               _user = user;
               _partner = partner;
                if (listuserupdate.Where(m => m.UserName == user).ToList().Count == 0 )
               {
                   listuserupdate.Add( new Userupdate() { UserName = user, LatestTime = datetiR_727_11845@e.Now });
               }
               callBACk = OperationContext.Current.GetCallBACkChAnnel < IChatserviceCallBACk > ();
               StartTimer();
                return true ;
           }
            catch
           {
                return false ;
           }
       }
        private void CallClientToReceiveMsg( object o) // 客户端回调完成后
        {
            try
           {
               datetiR_727_11845@e dt = listuserupdate.Where(m => m.UserName == _user).ToList()[ 0 ].LatestTime;
               listuserupdate.Remove(listuserupdate.Where(m => m.UserName == _user).ToList()[ 0 ]);
               listuserupdate.Add( new Userupdate() { UserName = _user, LatestTime = datetiR_727_11845@e.Now });
               callBACk.Receive(listmessages.Where(m => (m.Sender == _user && m.ReceiveUser == _partner && m.SendTime > dt) || (m.ReceiveUser == _user && m.Sender == _partner && m.SendTime > dt)).ToList());
           }
            catch
           {
               timer.Dispose();
               StartTimer();
           }
       }
        public bool Sendmessage(messageInfo messagE) // 发送消息方法
        {
            try
           {
               listmessages.Add(messagE);
                return true ;
           }
            catch
           {
                return false ;
           }
       }

        public List < Uservideo > GetVideosByte( String userName, String partnerName) // 取得视频信息
        {
           List < Uservideo > list = new List < Uservideo > ();
           list = listVideos.Where(m => (m.UserName == partnerName && @H_216_48@m.PartnerName == userName)).ToList();
            if (list.Count > 0 )
           {
               listVideos.RemoveAll(m => (m.UserName == partnerName && m.PartnerName == userName));
           }
            return list;
       }

        public void SendVideoByte(Uservideo video)
       {
           listVideos.Add(video);
       }
   }

消息契约和用户视频对象

代码

[DataContract]
     public class messageInfo
    {
        [DataMember]
         public String ID { set ; get ; }
        [DataMember]
         public String title { set ; get ; }
        [DataMember]
         public String message { set ; get ; }
        [DataMember]
         public datetiR_727_11845@e SendTime { set ; get ; }
        [DataMember]
         public datetiR_727_11845@e ? readTime { set ; get ; }
        [DataMember]
         public String Sender { set ; get ; }
        [DataMember]
         public String receiveUser { set ; get ; }
        [DataMember]
         public String receiveOrgan { set ; get ; }
        [DataMember]
         public String receiveMode { set ; get ; }
        [DataMember]
         public int State { set ; get ; }
        [DataMember]
         public int receipt { set ; get ; }
        [DataMember]
         public String source { set ; get ; }
    }

[DataContract]
     public class Uservideo
    {
        [DataMember]
         public String UserName { get ; set ; }
        [DataMember]
         public String PartnerName { set ; get ; }
        [DataMember]
         public byte [] VideoByte { set ; get ; }
    }

Silverlight客户端代码

首先需要登录服务器，使服务器开始监控消息

代码

address = new EndpointAddress( " http://localhost:8752/Chatservice.svc%22);
            binding = new PollingDuplexhttpBinding(PollingDuplexMode.MultiplemessagesPerPoll);
            proxy = new ChatserviceClient(binding, address);
            proxy.ReceiveReceived += new EventHandler < ReceiveReceivedEventArgs > (proxy_ReceiveReceived);
            proxy.LoginCompleted += new EventHandler < LoginCompletedEventArgs > (proxy_LoginCompleted);
            proxy.LoginAsync(User, Partner);

当链接到服务器之后呢，就开始监控对方视频资源，当然这里可以做成邀请-同意的模式另外触发这个事件

void proxy_LoginCompleted( object sender, LoginCompletedEventArgs E)
        {
            AddText( " connected " );
             // 连接到服务器后开始接收视频
            receiveVideo();
        }

当连接到服务器之后，一旦服务器收到对方发给自己的信息就可以执行回调操作

代码

void proxy_ReceiveReceived( object sender, receiveReceivedEventArgs E)
        {
             if (e.Error == null )
            {
                 foreach (messageInfo msg in e.messages)
                {
                    AddText(msg.Sender + "   say: " + msg.messagE);
                }
            }
        }

这里采用的方式比较简单，就是有客户端定时去服务器上取得数据。

代码

void receiveVideo()
        {
            System.Windows.Threading.DispatcherTimer timerForReceive = new System.Windows.Threading.DispatcherTimer();
            timerForReceive.Interval = new TimeSpan( 0 , 0 , 200 );
            timerForReceive.Tick += new EventHandler(timerForReceive_Tick);
            timerForReceive.Start();
            AddText( " start to receive video " );
        }

         void timerForReceive_Tick( object sender, EventArgs E)
        {
            proxy.GetVideosByteCompleted += new EventHandler < GetVideosByteCompletedEventArgs > (proxy_GetVideosByteCompleted);
            proxy.GetVideosByteAsync(User, Partner);
        }

         void proxy_GetVideosByteCompleted( object sender, GetVideosByteCompletedEventArgs E)
        {
             if (e.Error == null )
            {
                 foreach (Chatservice.Uservideo video in e.Result)
                {
                    MemoryStream ms = new MemoryStream(video.VideoBytE);
                    BitmapImage bitmap = new BitmapImage();
                    bitmap.Setsource(ms);
                    imagePartner.source = bitmap;
                    ms.Close();
                }
            }
        }

而向服务器传递数据也是通过定时截图发送的方式进行

代码

void btnSendVideo_Click( object sender, routedEventArgs E)
        {
            System.Windows.Threading.DispatcherTimer timer = new System.Windows.Threading.DispatcherTimer();
            timer.Interval = new TimeSpan( 0 , 0 , 200 );
            timer.Tick += new EventHandler(timer_Tick);
            timer.Start();
            AddText( " start sending video " );
        }

此方法为向服务器发送视频比特流

代码

void timer_Tick( object sender, EventArgs E)
        {
            WriteableBitmap bmp = new WriteableBitmap( this .rectangleUser, null );
            MemoryStream ms = new MemoryStream();
            EncodeJpeg(bmp, ms);
            Uservideo uservideo = new Uservideo();
            uservideo.PartnerName = this .Partner;
            uservideo.UserName = this .User;
            uservideo.VideoByte = ms.GetBuffer();
            proxy.SendVideoByteAsync(uservideo);
            AddText( " send a video jpg " );
        }

         // 编码
         public static void EncodeJpeg(WriteableBitmap bmp, Stream dstStream)
        {
             // Init buffer in FluxJpeg format
             int w = bmp.pixelWidth;
             int h = bmp.pixelHeight;
             int [] p = bmp.pixels;
             byte [][,] pixelsForJpeg = new byte [ 3 ][,]; // rGB colors
            pixelsForJpeg[ 0 ] = new byte [w, h];
            pixelsForJpeg[ 1 ] = new byte [w, h];
            pixelsForJpeg[ 2 ] = new byte [w, h];

             // Copy WriteableBitmap data into buffer for FluxJpeg
             int i = 0 ;
             for ( int y = 0 ; y < h; y ++ )
            {
                 for ( int x = 0 ; x < w; x ++ )
                {
                     int color = p[i ++ ];
                    pixelsForJpeg[ 0 ][x, y] = ( byte )(color >> 16 ); // r
                    pixelsForJpeg[ 1 ][x, y] = ( byte )(color >> 8 );   // G
                    pixelsForJpeg[ 2 ][x, y] = ( byte )(color);        // B
                }
            }
             // Encode Image as JPEG
            var jpegImage = new FluxJpeg.Core.Image( new ColorModel { colorspace = ColorSpace.RGB }, pixelsForJpeg);
            var encoder = new JpegEncoder(jpegImage, 95 , dstStream);
            encoder.Encode();
        }
         // 解码
         public static WriteableBitmap DecodeJpeg(Stream srcStream)
        {
             // Decode JPEG
            var decoder = new FluxJpeg.Core.Decoder.JpegDecoder(srcStream);
            var jpegDecoded = decoder.Decode();
            var img = jpegDecoded.Image;
            img.ChangeColorSpace(ColorSpace.RGB);

             // Init Buffer
             int w = img.Width;
             int h = img.Height;
            var result = new WriteableBitmap(w, h);
             int [] p = result.Pixels;
             byte [][,] pixelsFromJpeg = img.Raster;
             // Copy FluxJpeg buffer into WriteableBitmap
             int i = 0 ;
             for ( int x = 0 ; x < w; x ++ )
            {
                 for ( int y = 0 ; y < h; y ++ )
                {
                    p[i ++ ] = ( 0xFF << 24 ) // A
                                 | (pixelsFromJpeg[ 0 ][x, y] << 16 ) // r
                                 | (pixelsFromJpeg[ 1 ][x, y] << 8 )   // G
                                 | pixelsFromJpeg[ 2 ][x, y];        // B
                }
            }

             return result;
        }

此处为视频开始的事件

代码

void btnVideo_Click( object sender, routedEventArgs E)
        {
             if (source != null )
            {
                source.Stop();
                source.VideoCaptureDevice = CaptureDeviceConfiguration.GetDefaultVideoCaptureDevice();
                VideoBrush vBrush = new VideoBrush();
                vBrush.Setsource(sourc E);
                 this .rectangleUser.Fill = vBrush;
                 if (CaptureDeviceConfiguration.AllowedDeviceAccess || CaptureDeviceConfiguration.requestDeviceAccess())
                {
                    source.Start();
                }

                AddText( " start video " );
            }
        }

         void txtmessage_KeyDown( object sender, KeyEventArgs E)
        {
             if (e.Key == Key.Enter)
            {
                SendMsg();
            }
        }

这个Demo存在的问题有三个

1，视频流传输到服务器再转到对方客户端的过程有些复杂而且费时，打算采用两种方法解决，一是用Socket通信，二是用双通道推送方式。

2，目前的视频流应该经过压缩后传输，在客户端进行解析，否则如此大的数据量解析是个问题。

3，由于是IIS托管WCF服务，在这个DEMO中有WCF回调客户端的方式，这种方式一旦客户端掉线，服务端回调不到客户端就会出现异常，这种异常靠 try catch解决不了。

4，在某些电脑的IE8上打开视频时会卡死。

如果您看到这篇文章对这几个问题比较了解，兄弟我还是非常想请教一下的，谢谢。

大佬总结

以上是大佬教程为你收集整理的Silverlight访问摄像头和麦克风(2)视频对话全部内容，希望文章能够帮你解决Silverlight访问摄像头和麦克风(2)视频对话所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。

标签：silverlight 对话摄像头视频访问麦克风

上一篇: Silverlight 4新控件PivotViewer... 下一篇:WCF回调操作以及应用技巧讲解

猜你在找的silverlight相关文章

silverlight – 如何在Windows Phone 7中创建连续动画？ 2022-05-04
wpf – 嵌入图像在UserControl中不显示 2022-05-03
WPF的Deepzoom 2022-05-03
silverlight – 设置ComboBoxItem的文本和值 2022-05-03
wpf – 寻找股票图表组件 2022-05-03
如何在Silverlight中以编程方式转到特定的URL？ 2022-05-03
Silverlight Webservice“远程服务器返回错误：NotFound” 2022-05-03
osx – 无法输入Silverlight 5输入字段(Chrome)MacOS 2022-05-03
客户端WCF DataContract具有来自服务的空/空值 2022-05-03
使用MVVM Light Messenger与Silverlight 4 ChildWindow对话框类 2022-05-03