【正文】 = 4。 = new (96, 35)。 = new ()。 private timer1。 } // Find the appropriate encoder // 查找合適的編碼器 private ImageCodecInfo GetEncoderInfo(String mimeType) { int j。 if (b) { m_PacketCount++。 19 // Empty the stream //清空流 (0)。 } ()。 serv = new TcpServer(TCPLISTENPORT, ()[3])。 } /// summary /// Stop this service. /// 停止服務(wù) /// The Run() Method tests for this thread state each second /// 每秒都為這個(gè)進(jìn)程啟動(dòng)方法測試 /// /summary protected override void OnStop() { 16 // Set exit condition //設(shè)置退出狀態(tài) bShutDown = true。 = WebCamService。 } 13 } } } // Remove a connection from the list of active connections private void RemoveConnection(SockWrapper s) { try { ( )。 lock (this) { if (!m_bShuttingDown) { // Wrap the client and add it to the array SockWrapper s = new SockWrapper(client)。 private void _TcpServer(int nPortListen, IPAddress ip) { try 10 { // Initialize member vars m_aryClients = new ArrayList(5)。 t = new TcpClient((), )。 if USING_NET11 IPHostEntry ipEntry = ( strHostName )。 客戶端連接是指由客戶端的 socket 提出連接請求，要連接的目標(biāo)是服務(wù)器端的 socket。 IP 數(shù)據(jù)包是不可靠的，因?yàn)?IP 并沒有做任何事情來確認(rèn)數(shù)據(jù)包是按順序發(fā)送的或者沒有被破壞。 DirectShow 為多媒體流的捕捉和回放以及二次開發(fā)提供了強(qiáng)有力的支持。 本系統(tǒng)采用 DirectShow 網(wǎng) 絡(luò)組播技術(shù)實(shí)現(xiàn)了視頻捕獲、視頻壓縮、網(wǎng)絡(luò)傳輸、視頻解碼和實(shí)時(shí)回放，減小了網(wǎng)絡(luò)帶寬占用，高效的傳輸視頻數(shù)據(jù)，獨(dú)立于硬件。監(jiān)控服務(wù)器通過 Inter/Intra 輪詢網(wǎng)絡(luò)攝像機(jī)獲取視頻。用戶為了傳輸一個(gè)文件請求一個(gè)和其它計(jì)算機(jī)的連接，連接 建立后，就開始傳輸文件。 面向連接的 c/s 時(shí)序圖如圖 41 所示 服務(wù)器 客戶端 客戶端 . . . 5 圖 41 程序時(shí)序圖 系統(tǒng)由服務(wù)器終端采集傳輸系統(tǒng)和客戶端接收系統(tǒng)兩部分組，系統(tǒng)構(gòu)架如圖 42 所示 圖 42 系統(tǒng)架構(gòu) 程序設(shè)計(jì)分析 Accept() Recv() Send() Close() Listen() Bind() Socket() 服務(wù)器 發(fā)送數(shù)據(jù) 確認(rèn)發(fā)送數(shù)據(jù) 請求建立連接 Recv() Close() Send() Connect() Socket() 客戶 攝像頭 采集卡 服務(wù)器服務(wù)程序 網(wǎng)絡(luò)傳輸模塊 網(wǎng)絡(luò)接收模塊 客戶端程序 解碼 顯示 視頻流 控制指令 視頻流 控制指令 6 任務(wù)目標(biāo) 服務(wù)器端程序目標(biāo)：服務(wù)器服務(wù)器端服務(wù)程序進(jìn)行數(shù)據(jù)采集（捕捉攝像頭捕獲數(shù)據(jù)），提供IP 端口實(shí)現(xiàn)數(shù)據(jù)流的傳輸。 endregion // Return an array of the ip addresses assigned to this pc public static IPAddress [] GetAddresses() { IPAddress [] aryLocalAddr = null。 ()。 public event TcpConnected Disconnected。 if (bSend) (b, iLength, )。 ( , 0, , , receiveData, s )。 } WebCamService 類 : namespace WebCamService { public class WebCamService : ServiceBase { region Required Service Related Methods private ponents = null。 endregion /// summary /// Set things in motion so your service can do its work. /// 為了服務(wù)器可以工作而設(shè)置的選項(xiàng) /// /summary protected override void OnStart(string[] args) { ThreadStart starter = new ThreadStart(Run)。 try { // Set up member vars ConnectionReady = new ManualResetEvent(false)。 } catch(Exception ex) { try { (({0}: Failed on startup {1}, (), ex))。 // Send the length as a fixed length string //作為固定的字符串長度發(fā)送長度 = 0。 20 m_PacketCount = 0。 ()。 23 private txtPort。 = new ()。 = 。 = new (19, 236)。 = new (10, 374)。 = Start。 (()()).BeginInit()。 public Form1() { // // Required for Windows Form Designer support // InitializeComponent()。 j 。 } public void RemovePacket() { lock (this) { if (m_PacketCount 0) { m_PacketCount。 } catch(Exception ex) { try { (())。 IntPtr ip = 。 += new TcpReceive(Receive)。 // zero based index of video capture device to use const int FRAMERATE = 15。 } endregion [STAThread] public static void Main(string[] args) { = Main thread。 } catch {} // Fire the Disconnected event if (Disconnected != null) Disconnected(this, ref )。 // Set up an async wait for packets from the client AsyncCallback receiveData = new AsyncCallback( OnReceivedData )。 // Create the listener socket in this machine39。 m_sockListener = null。 // Ver