海康dvr流媒体服务器+客户端

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.IO;
using System.Runtime.InteropServices;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace MediaServerFrom
{
    public partial class Form1 : Form
    {
        #region 定义
        int m_lUserID = -1;
        byte[] headStream;//头数据
        ClientList clientList = ClientList.GetClientList();
        CHCNetSDK.REALDATACALLBACK m_fRealData;
        Socket listenSocket;
        Semaphore m_maxNumberAcceptedClients;
        #endregion

        /// <summary>
        /// Server构造函数，启动服务端Socket及海康SDK获取设备数据
        /// </summary>
        /// <param name="ipPoint">服务端IP配置</param>
        /// <param name="numConnections">最大客户端连接数</param>
        /// <param name="channel">设备监听通道</param>
        public void Server(IPEndPoint ipPoint, int numConnections, int channel)
        {
            if (!InitHK())
            {
                return;
            }
            RunGetStream(channel);

            listenSocket = new Socket(ipPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
            listenSocket.Bind(ipPoint);
            m_maxNumberAcceptedClients = new Semaphore(numConnections, numConnections);
            listenSocket.Listen(100);
            AddInfo("开始监听客户端连接......");
            StartAccept(null);
        }

        #region HKSDK
        /// <summary>
        /// 获取视频数据
        /// </summary>
        /// <param name="channel">通道号</param>
        private void RunGetStream(int channel)
        {
            if (m_lUserID != -1)//初始化成功
            {
                CHCNetSDK.NET_DVR_CLIENTINFO lpClientInfo = new CHCNetSDK.NET_DVR_CLIENTINFO();
                lpClientInfo.lChannel = channel;//通道
                lpClientInfo.lLinkMode = 0x0000;//码流
                lpClientInfo.sMultiCastIP = "";//组播地址，空着就好了
                m_fRealData = new CHCNetSDK.REALDATACALLBACK(RealDataCallBack);
                IntPtr pUser = new IntPtr();
                int m_lRealHandle = CHCNetSDK.NET_DVR_RealPlay_V30(m_lUserID, ref lpClientInfo, m_fRealData, pUser, 1);//获取视频流，视频流处理在回调函数m_fRealData里面做
                AddInfo("开始获取视频数据......");
            }
            else//初始化 失败，因为已经初始化了
            {
                AddInfo("视频数据获取失败......");
            }
        }

        private bool InitHK()
        {
            bool m_bInitSDK = CHCNetSDK.NET_DVR_Init();//初始化SDK
            if (m_bInitSDK == false)
            {
                return false;
            }
            else
            {
                AddInfo("设备SDK初始化成功.......");
                CHCNetSDK.NET_DVR_DEVICEINFO_V30 DeviceInfo = new CHCNetSDK.NET_DVR_DEVICEINFO_V30();
                m_lUserID = CHCNetSDK.NET_DVR_Login_V30(txtDvrIP.Text, Convert.ToInt32(txtDvrPort.Text), txtUserName.Text, txtDvrPwd.Text, ref DeviceInfo);//登录DVR
                if (m_lUserID != -1)
                {
                    AddInfo("监控设备登录成功.......");
                    return true;
                }
                else
                {
                    AddInfo("监控设备登录失败，稍后再试.......");
                    return false;
                }
            }
        }
        /// <summary>
        /// 视频流回调
        /// </summary>
        /// <param name="lRealHandle">播放窗口句柄</param>
        /// <param name="dwDataType">数据类型</param>
        /// <param name="pBuffer">缓冲区指针</param>
        /// <param name="dwBufSize">缓冲区大小</param>
        /// <param name="pUser">用户数据</param>
        private void RealDataCallBack(Int32 lRealHandle, UInt32 dwDataType, IntPtr pBuffer, UInt32 dwBufSize, IntPtr pUser)
        {
            byte[] data = new byte[dwBufSize];
            Marshal.Copy(pBuffer, data, 0, (int)dwBufSize);//写到缓存
            if (dwDataType == CHCNetSDK.NET_DVR_SYSHEAD)
            {
                headStream = data;
            }
            clientList.SetSendData(data);//发送到客户端
            return;
        }

        #endregion

        #region Socket
        /// <summary>
        /// 监听客户端
        /// </summary>
        /// <param name="acceptEventArg"></param>
        private void StartAccept(SocketAsyncEventArgs acceptEventArg)
        {
            if (acceptEventArg == null)
            {
                acceptEventArg = new SocketAsyncEventArgs();
                acceptEventArg.Completed  = new EventHandler<SocketAsyncEventArgs>(IO_Completed);
            }
            else
            {
                acceptEventArg.AcceptSocket = null;
            }

            m_maxNumberAcceptedClients.WaitOne();
            bool willRaiseEvent = listenSocket.AcceptAsync(acceptEventArg);
            if (!willRaiseEvent)
            {
                ProcessAccept(acceptEventArg);
            }
        }
        /// <summary>
        /// 增加客户端列表
        /// </summary>
        /// <param name="e"></param>
        private void ProcessAccept(SocketAsyncEventArgs e)
        {
            clientList.AddClient(new Client(e.AcceptSocket, headStream));
            StartAccept(e);
        }

        /// <summary>
        /// Socket回调函数
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void IO_Completed(object sender, SocketAsyncEventArgs e)
        {
            switch (e.LastOperation)
            {
                case SocketAsyncOperation.Accept:
                    ProcessAccept(e);
                    break;
                default:
                    throw new ArgumentException("The last operation completed on the socket was not a receive or send");
            }
        }

        #endregion

        public Form1()
        {
            InitializeComponent();
        }

        /// <summary>
        ///  预览功能
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnPreview_Click(object sender, System.EventArgs e)
        {
            if (txtDvrIP.Text != "" && txtDvrPort.Text != "" && txtUserName.Text != "" && txtDvrPwd.Text != "")
            {
                IPEndPoint IP = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 1212);
                Server(IP, 500, 1);
            }
            else
            {
                MessageBox.Show("设备信息要先输入~！");
            }
        }

        /// <summary>
        /// 向屏幕输出显示状态信息（这里使用了委托机制）
        /// </summary>
        /// <param name="str"></param>
        public delegate void AddInfoDelegate(string str);
        /// <summary>
        /// 输出到屏幕
        /// </summary>
        /// <param name="str"></param>
        public void AddInfo(string str)
        {
            if (listBox1.InvokeRequired == true)
            {
                AddInfoDelegate d = new AddInfoDelegate(AddInfo);
                this.Invoke(d, str);
            }
            else
            {
                listBox1.Items.Add(str);
                listBox1.TopIndex = listBox1.Items.Count - 1;
                listBox1.ClearSelected();
            }
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }
    }
}